store

package
v1.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 5, 2026 License: MIT Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const KeySlotPrefix = "keys/"

KeySlotPrefix is the object key prefix for encryption key slot objects. These objects are stored unencrypted (they contain already-wrapped keys) so they can be read without the encryption key — avoiding a chicken-and-egg problem during key loading.

Variables

View Source 
var ErrQuotaExceeded = errors.New("storage quota exceeded during backup")

Functions

func AddRecoverySlot 

func AddRecoverySlot(s ObjectStore, masterKey []byte) (mnemonic string, err error)

AddRecoverySlot generates a recovery key, wraps the given master key with it, stores the recovery slot, and returns the BIP39 24-word mnemonic.

func ChangePasswordSlot added in v1.6.0 

func ChangePasswordSlot(s ObjectStore, masterKey []byte, newPassword string) error

ChangePasswordSlot replaces (or creates) the password key slot for the repository. masterKey is the unwrapped master key; newPassword is the new password to wrap it with. The old password slot (keys/password-default) is overwritten.

func ExtractMasterKey 

func ExtractMasterKey(slots []KeySlot, platformKey []byte, password string) ([]byte, error)

ExtractMasterKey unwraps and returns the raw master key from whichever credential matches. Unlike the OpenWith* functions that return a derived encryption key, this returns the master key itself — needed when adding new key slots to an existing repo.

func ExtractMasterKeyWithKMS added in v1.4.6 

func ExtractMasterKeyWithKMS(ctx context.Context, slots []KeySlot, decrypter crypto.KMSDecrypter, platformKey []byte, password string) ([]byte, error)

ExtractMasterKeyWithKMS is like ExtractMasterKey but also supports kms-platform slots via a crypto.KMSDecrypter.

func GetConcurrencyHint added in v1.4.3 

func GetConcurrencyHint(s ObjectStore, defaultConcurrency int) int

GetConcurrencyHint walks the store wrapper chain and returns the first ConcurrencyHint it finds, defaulting to defaultConcurrency if none exists.

func HasKeySlots 

func HasKeySlots(s ObjectStore) bool

HasKeySlots reports whether the store contains any encryption key slots.

func InitEncryptionKey 

func InitEncryptionKey(s ObjectStore, platformKey []byte, password string) ([]byte, error)

InitEncryptionKey initializes encryption for a new repository. It generates a master key and creates key slots for whatever credentials are provided. At least one of platformKey or password must be non-empty. Returns the derived encryption key.

func InitKMSEncryptionKey added in v1.7.0 

func InitKMSEncryptionKey(ctx context.Context, s ObjectStore, encrypter crypto.KMSEncrypter, keyARN string, platformKey []byte, password string) ([]byte, error)

InitKMSEncryptionKey initializes encryption for a new repository using KMS. It generates a master key, wraps it with KMS, and optionally creates additional password/platform slots. Returns the derived encryption key.

func OpenWithKMS added in v1.4.6 

func OpenWithKMS(ctx context.Context, slots []KeySlot, decrypter crypto.KMSDecrypter) ([]byte, error)

OpenWithKMS finds a kms-platform slot, unwraps the master key using the given KMS decrypter, and returns the derived encryption key.

func OpenWithPassword 

func OpenWithPassword(slots []KeySlot, password string) ([]byte, error)

OpenWithPassword finds a password slot, derives the wrapping key using Argon2id, unwraps the master key, and returns the derived encryption key.

func OpenWithPlatformKey 

func OpenWithPlatformKey(slots []KeySlot, platformKey []byte) ([]byte, error)

OpenWithPlatformKey finds a platform slot, unwraps the master key using the given platform key, and returns the derived encryption key.

func OpenWithRecoveryKey 

func OpenWithRecoveryKey(slots []KeySlot, recoveryKey []byte) ([]byte, error)

OpenWithRecoveryKey finds a recovery slot, unwraps the master key using the given raw recovery key, and returns the derived encryption key.

func SlotTypes 

func SlotTypes(slots []KeySlot) string

SlotTypes returns the slot types present among the given slots.

func WriteKMSSlot added in v1.7.0 

func WriteKMSSlot(ctx context.Context, s ObjectStore, masterKey []byte, encrypter crypto.KMSEncrypter, keyARN string) error

WriteKMSSlot wraps the master key using a KMS encrypter and writes a kms-platform slot to the store.

Types

type B2Option added in v1.8.0 

type B2Option func(*b2Options)

B2Option configures a B2 store.

func WithClient added in v1.8.0 

func WithClient(client *b2.Client) B2Option

WithClient provides a pre-configured B2 client, skipping internal client creation. When set, WithCredentials is ignored.

func WithCredentials added in v1.8.0 

func WithCredentials(keyID, appKey string) B2Option

WithCredentials sets the Backblaze application key ID and key used to authenticate. Ignored when WithClient is provided.

func WithPrefix added in v1.8.0 

func WithPrefix(prefix string) B2Option

WithPrefix sets a key prefix prepended to every object key. Use this to isolate multiple repositories within a single bucket (e.g. "prod/" and "staging/").

type B2Store 

type B2Store struct {
	// contains filtered or unexported fields
}

B2Store implements ObjectStore for Backblaze B2.

func NewB2Store 

func NewB2Store(bucketName string, opts ...B2Option) (*B2Store, error)

NewB2Store creates a B2Store for the given bucket. Either WithCredentials or WithClient must be provided.

func (*B2Store) Delete 

func (s *B2Store) Delete(ctx context.Context, key string) error

func (*B2Store) DeletePrefix 

func (s *B2Store) DeletePrefix(ctx context.Context, prefix string) error

DeletePrefix deletes all objects under the given prefix.

func (*B2Store) Exists 

func (s *B2Store) Exists(ctx context.Context, key string) (bool, error)

func (*B2Store) Flush added in v1.4.3 

func (s *B2Store) Flush(ctx context.Context) error

func (*B2Store) Get 

func (s *B2Store) Get(ctx context.Context, key string) ([]byte, error)

func (*B2Store) List 

func (s *B2Store) List(ctx context.Context, prefix string) ([]string, error)

func (*B2Store) NewWriter 

func (s *B2Store) NewWriter(ctx context.Context, key string) io.WriteCloser

NewWriter returns a streaming writer to the given key in B2. The caller must Close the writer to finalize the upload.

func (*B2Store) Put 

func (s *B2Store) Put(ctx context.Context, key string, data []byte) error

func (*B2Store) SignedURL 

func (s *B2Store) SignedURL(ctx context.Context, key string, validFor time.Duration) (string, error)

SignedURL returns a time-limited download URL for the given key.

func (*B2Store) Size 

func (s *B2Store) Size(ctx context.Context, key string) (int64, error)

func (*B2Store) TotalSize 

func (s *B2Store) TotalSize(ctx context.Context) (int64, error)

type CompressedStore added in v1.1.0 

type CompressedStore struct {
	// contains filtered or unexported fields
}

CompressedStore wraps an ObjectStore and transparently zstd-compresses on write and decompresses (zstd or gzip) on read. Uncompressed data is returned as-is.

func NewCompressedStore added in v1.1.0 

func NewCompressedStore(inner ObjectStore) *CompressedStore

func (*CompressedStore) Delete added in v1.1.0 

func (s *CompressedStore) Delete(ctx context.Context, key string) error

func (*CompressedStore) Exists added in v1.1.0 

func (s *CompressedStore) Exists(ctx context.Context, key string) (bool, error)

func (*CompressedStore) Flush added in v1.4.3 

func (s *CompressedStore) Flush(ctx context.Context) error

func (*CompressedStore) Get added in v1.1.0 

func (s *CompressedStore) Get(ctx context.Context, key string) ([]byte, error)

func (*CompressedStore) List added in v1.1.0 

func (s *CompressedStore) List(ctx context.Context, prefix string) ([]string, error)

func (*CompressedStore) Put added in v1.1.0 

func (s *CompressedStore) Put(ctx context.Context, key string, data []byte) error

func (*CompressedStore) Size added in v1.1.0 

func (s *CompressedStore) Size(ctx context.Context, key string) (int64, error)

func (*CompressedStore) TotalSize added in v1.1.0 

func (s *CompressedStore) TotalSize(ctx context.Context) (int64, error)

func (*CompressedStore) Unwrap added in v1.4.3 

func (s *CompressedStore) Unwrap() ObjectStore

type ConcurrencyHinter added in v1.4.3 

type ConcurrencyHinter interface {
	ConcurrencyHint() int
}

ConcurrencyHinter is an optional interface that ObjectStore implementations can implement to indicate the optimal number of concurrent operations. Remote stores (S3) benefit from high concurrency; local stores do not.

type DebugStore added in v1.2.0 

type DebugStore struct {
	// contains filtered or unexported fields
}

DebugStore wraps an ObjectStore and logs every operation with timing information. Output goes to the provided writer, which should be a ui.SafeLogWriter so lines coexist with progress bars.

func NewDebugStore added in v1.2.0 

func NewDebugStore(inner ObjectStore, w io.Writer) *DebugStore

func (*DebugStore) Delete added in v1.2.0 

func (s *DebugStore) Delete(ctx context.Context, key string) error

func (*DebugStore) Exists added in v1.2.0 

func (s *DebugStore) Exists(ctx context.Context, key string) (bool, error)

func (*DebugStore) Flush added in v1.4.3 

func (s *DebugStore) Flush(ctx context.Context) error

func (*DebugStore) Get added in v1.2.0 

func (s *DebugStore) Get(ctx context.Context, key string) ([]byte, error)

func (*DebugStore) List added in v1.2.0 

func (s *DebugStore) List(ctx context.Context, prefix string) ([]string, error)

func (*DebugStore) Put added in v1.2.0 

func (s *DebugStore) Put(ctx context.Context, key string, data []byte) error

func (*DebugStore) Size added in v1.2.0 

func (s *DebugStore) Size(ctx context.Context, key string) (int64, error)

func (*DebugStore) TotalSize added in v1.2.0 

func (s *DebugStore) TotalSize(ctx context.Context) (int64, error)

func (*DebugStore) Unwrap added in v1.4.3 

func (s *DebugStore) Unwrap() ObjectStore

type EncryptedStore 

type EncryptedStore struct {
	ObjectStore
	// contains filtered or unexported fields
}

EncryptedStore wraps an ObjectStore and transparently encrypts data on Put and decrypts on Get using AES-256-GCM. Unencrypted (legacy) data is returned as-is on Get, enabling gradual migration.

Objects under the "keys/" prefix are passed through unencrypted because they hold the wrapped master key needed to derive the encryption key.

func NewEncryptedStore 

func NewEncryptedStore(inner ObjectStore, key []byte) *EncryptedStore

NewEncryptedStore creates an EncryptedStore that encrypts all Put operations and decrypts Get operations. The key must be 32 bytes (AES-256).

func (*EncryptedStore) Get 

func (s *EncryptedStore) Get(ctx context.Context, key string) ([]byte, error)

func (*EncryptedStore) Put 

func (s *EncryptedStore) Put(ctx context.Context, key string, data []byte) error

func (*EncryptedStore) Unwrap added in v1.4.3 

func (s *EncryptedStore) Unwrap() ObjectStore

type KDFParams 

type KDFParams struct {
	Algorithm string `json:"algorithm"`
	Salt      string `json:"salt"` // base64-encoded
	Time      uint32 `json:"time"`
	Memory    uint32 `json:"memory"`
	Threads   uint8  `json:"threads"`
}

KDFParams holds the parameters for password-based key derivation.

type KeyCacheStore added in v1.1.0 

type KeyCacheStore struct {
	// contains filtered or unexported fields
}

KeyCacheStore wraps an ObjectStore and caches key existence from List calls, so that Exists returns immediately for known keys. Thread-safe.

func NewKeyCacheStore added in v1.1.0 

func NewKeyCacheStore(inner ObjectStore) *KeyCacheStore

func (*KeyCacheStore) Delete added in v1.1.0 

func (s *KeyCacheStore) Delete(ctx context.Context, key string) error

func (*KeyCacheStore) Exists added in v1.1.0 

func (s *KeyCacheStore) Exists(ctx context.Context, key string) (bool, error)

func (*KeyCacheStore) Flush added in v1.4.3 

func (s *KeyCacheStore) Flush(ctx context.Context) error

func (*KeyCacheStore) Get added in v1.1.0 

func (s *KeyCacheStore) Get(ctx context.Context, key string) ([]byte, error)

func (*KeyCacheStore) List added in v1.1.0 

func (s *KeyCacheStore) List(ctx context.Context, prefix string) ([]string, error)

func (*KeyCacheStore) PreloadKeys added in v1.1.0 

func (s *KeyCacheStore) PreloadKeys(ctx context.Context, prefixes ...string) error

func (*KeyCacheStore) Put added in v1.1.0 

func (s *KeyCacheStore) Put(ctx context.Context, key string, data []byte) error

func (*KeyCacheStore) Size added in v1.1.0 

func (s *KeyCacheStore) Size(ctx context.Context, key string) (int64, error)

func (*KeyCacheStore) TotalSize added in v1.1.0 

func (s *KeyCacheStore) TotalSize(ctx context.Context) (int64, error)

func (*KeyCacheStore) Unwrap added in v1.4.3 

func (s *KeyCacheStore) Unwrap() ObjectStore

type KeySlot 

type KeySlot struct {
	SlotType   string     `json:"slot_type"`
	WrappedKey string     `json:"wrapped_key"`
	Label      string     `json:"label"`
	KDFParams  *KDFParams `json:"kdf_params,omitempty"`
}

KeySlot is the JSON representation of an encryption key slot stored in B2.

func LoadKeySlots 

func LoadKeySlots(s ObjectStore) ([]KeySlot, error)

LoadKeySlots reads all key slot objects from the store.

type LocalStore 

type LocalStore struct {
	BasePath string
	// contains filtered or unexported fields
}

LocalStore implements ObjectStore for the local filesystem.

func NewLocalStore 

func NewLocalStore(basePath string) (*LocalStore, error)

func (*LocalStore) Delete 

func (s *LocalStore) Delete(_ context.Context, key string) error

func (*LocalStore) Exists 

func (s *LocalStore) Exists(_ context.Context, key string) (bool, error)

func (*LocalStore) Flush added in v1.4.3 

func (s *LocalStore) Flush(ctx context.Context) error

func (*LocalStore) Get 

func (s *LocalStore) Get(_ context.Context, key string) ([]byte, error)

func (*LocalStore) List 

func (s *LocalStore) List(_ context.Context, prefix string) ([]string, error)

List returns all keys matching the given prefix. When a prefix is provided the walk is scoped to just that subdirectory for efficiency.

func (*LocalStore) Put 

func (s *LocalStore) Put(_ context.Context, key string, data []byte) error

func (*LocalStore) Size 

func (s *LocalStore) Size(_ context.Context, key string) (int64, error)

func (*LocalStore) TotalSize 

func (s *LocalStore) TotalSize(_ context.Context) (int64, error)

type MeteredStore 

type MeteredStore struct {
	ObjectStore
	// contains filtered or unexported fields
}

MeteredStore wraps an ObjectStore and tracks bytes written/deleted.

func NewMeteredStore 

func NewMeteredStore(s ObjectStore) *MeteredStore

func (*MeteredStore) BytesWritten 

func (m *MeteredStore) BytesWritten() int64

func (*MeteredStore) Delete 

func (m *MeteredStore) Delete(ctx context.Context, key string) error

func (*MeteredStore) DeleteReturnSize 

func (m *MeteredStore) DeleteReturnSize(ctx context.Context, key string) (int64, error)

func (*MeteredStore) Put 

func (m *MeteredStore) Put(ctx context.Context, key string, data []byte) error

func (*MeteredStore) Reset 

func (m *MeteredStore) Reset()

func (*MeteredStore) Unwrap added in v1.4.3 

func (m *MeteredStore) Unwrap() ObjectStore

type ObjectStore 

type ObjectStore interface {
	Put(ctx context.Context, key string, data []byte) error
	Get(ctx context.Context, key string) ([]byte, error)
	Exists(ctx context.Context, key string) (bool, error)
	Delete(ctx context.Context, key string) error
	List(ctx context.Context, prefix string) ([]string, error)
	Size(ctx context.Context, key string) (int64, error)
	TotalSize(ctx context.Context) (int64, error)
	Flush(ctx context.Context) error
}

ObjectStore is the interface for content-addressable object storage. Keys are slash-separated paths like "chunk/<hash>" or "snapshot/<hash>".

type PackEntry added in v1.4.3 

type PackEntry struct {
	PackRef string `json:"p"`
	Offset  int64  `json:"o"`
	Length  int64  `json:"l"`
}

PackEntry represents the location of a small object within a packfile.

type PackStore added in v1.4.3 

type PackStore struct {
	ObjectStore
	// contains filtered or unexported fields
}

PackStore wraps an ObjectStore to aggregate small objects into larger "packfiles". It uses a stateless JSON catalog ("index/packs") to keep track of which pack contains which object.

func NewPackStore added in v1.4.3 

func NewPackStore(inner ObjectStore) (*PackStore, error)

NewPackStore initializes a new MicroPackStore over an existing ObjectStore.

func (*PackStore) Delete added in v1.4.3 

func (s *PackStore) Delete(ctx context.Context, key string) error

Delete removes an object. For packed objects, it just removes it from the catalog. The actual packfile is not currently garbage collected.

func (*PackStore) Exists added in v1.4.3 

func (s *PackStore) Exists(ctx context.Context, key string) (bool, error)

Exists checks the un-flushed buffer, the catalog, or falls back to inner.

func (*PackStore) Flush added in v1.4.3 

func (s *PackStore) Flush(ctx context.Context) error

Flush ensures any pending small objects are written to a packfile, and uploads the latest JSON catalog.

func (*PackStore) Get added in v1.4.3 

func (s *PackStore) Get(ctx context.Context, key string) ([]byte, error)

Get retrieves an object from the active buffer, a cached pack, or downloads the pack.

func (*PackStore) List added in v1.4.3 

func (s *PackStore) List(ctx context.Context, prefix string) ([]string, error)

List returns all keys matching the prefix, merging results from the inner store with the keys currently buffered or indexed in packfiles.

func (*PackStore) Put added in v1.4.3 

func (s *PackStore) Put(ctx context.Context, key string, data []byte) error

Put stores data either in the active packbuffer or directly to the inner store.

func (*PackStore) Repack added in v1.4.4 

func (s *PackStore) Repack(ctx context.Context, maxWastedRatio float64) (int64, int, error)

Repack analyzes the packfiles and repacks those that have too much wasted space. Wasted space occurs when objects within a packfile are logically deleted (removed from catalog). maxWastedRatio is the threshold (0.0 to 1.0) above which a pack is repacked. For example, 0.3 means a pack is repacked if it is more than 30% empty. Returns the number of bytes reclaimed, number of packs deleted, and error.

func (*PackStore) Size added in v1.4.3 

func (s *PackStore) Size(ctx context.Context, key string) (int64, error)

func (*PackStore) TotalSize added in v1.4.3 

func (s *PackStore) TotalSize(ctx context.Context) (int64, error)

type QuotaStore 

type QuotaStore struct {
	ObjectStore
	// contains filtered or unexported fields
}

QuotaStore wraps an ObjectStore and cancels the backup context when cumulative bytes written exceed the remaining budget.

func NewQuotaStore 

func NewQuotaStore(inner ObjectStore, budget int64, cancel context.CancelCauseFunc) *QuotaStore

func (*QuotaStore) Put 

func (q *QuotaStore) Put(ctx context.Context, key string, data []byte) error

func (*QuotaStore) Unwrap added in v1.4.3 

func (q *QuotaStore) Unwrap() ObjectStore

func (*QuotaStore) Written 

func (q *QuotaStore) Written() int64

Written returns the total bytes successfully written through this store.

type S3Option added in v1.8.0 

type S3Option func(*s3Options)

S3Option configures an S3 store.

func WithS3Client added in v1.8.0 

func WithS3Client(client *s3.Client) S3Option

WithS3Client provides a pre-configured S3 client, skipping internal client creation. When set, credential, region, and endpoint options are ignored.

func WithS3Credentials added in v1.8.0 

func WithS3Credentials(accessKey, secretKey string) S3Option

WithS3Credentials sets static AWS credentials. When omitted the SDK default credential chain is used (env vars, shared config, IAM role, etc.).

func WithS3Endpoint added in v1.8.0 

func WithS3Endpoint(endpoint string) S3Option

WithS3Endpoint sets a custom S3-compatible endpoint URL (e.g. MinIO, Cloudflare R2). Path-style addressing is automatically enabled when an endpoint is set.

func WithS3Prefix added in v1.8.0 

func WithS3Prefix(prefix string) S3Option

WithS3Prefix sets a key prefix prepended to every object key. Use this to isolate multiple repositories within a single bucket.

func WithS3Region added in v1.8.0 

func WithS3Region(region string) S3Option

WithS3Region sets the AWS region for the bucket (e.g. "us-east-1").

type S3Store added in v1.3.0 

type S3Store struct {
	// contains filtered or unexported fields
}

S3Store implements ObjectStore for Amazon S3 and compatible services.

func NewS3Store added in v1.3.0 

func NewS3Store(ctx context.Context, bucketName string, opts ...S3Option) (*S3Store, error)

func (*S3Store) ConcurrencyHint added in v1.4.3 

func (s *S3Store) ConcurrencyHint() int

ConcurrencyHint implements ConcurrencyHinter. S3 benefits from highly parallel uploads since each PUT is a separate HTTP round-trip.

func (*S3Store) Delete added in v1.3.0 

func (s *S3Store) Delete(ctx context.Context, key string) error

func (*S3Store) Exists added in v1.3.0 

func (s *S3Store) Exists(ctx context.Context, key string) (bool, error)

func (*S3Store) Flush added in v1.4.3 

func (s *S3Store) Flush(ctx context.Context) error

func (*S3Store) Get added in v1.3.0 

func (s *S3Store) Get(ctx context.Context, key string) ([]byte, error)

func (*S3Store) List added in v1.3.0 

func (s *S3Store) List(ctx context.Context, prefix string) ([]string, error)

func (*S3Store) Put added in v1.3.0 

func (s *S3Store) Put(ctx context.Context, key string, data []byte) error

func (*S3Store) Size added in v1.3.0 

func (s *S3Store) Size(ctx context.Context, key string) (int64, error)

func (*S3Store) TotalSize added in v1.3.0 

func (s *S3Store) TotalSize(ctx context.Context) (int64, error)

type SFTPStore added in v1.4.0 

type SFTPStore struct {
	// contains filtered or unexported fields
}

SFTPStore implements ObjectStore backed by an SFTP server.

func NewSFTPStore added in v1.4.0 

func NewSFTPStore(host string, opts ...SFTPStoreOption) (*SFTPStore, error)

NewSFTPStore creates an SFTP-backed store for the given host. Either WithSFTPClient or authentication options must be provided. The base path directory is created if it does not exist.

func (*SFTPStore) Close added in v1.4.0 

func (s *SFTPStore) Close() error

Close releases the underlying SFTP and SSH connections.

func (*SFTPStore) Delete added in v1.4.0 

func (s *SFTPStore) Delete(_ context.Context, key string) error

func (*SFTPStore) Exists added in v1.4.0 

func (s *SFTPStore) Exists(_ context.Context, key string) (bool, error)

func (*SFTPStore) Flush added in v1.4.3 

func (s *SFTPStore) Flush(ctx context.Context) error

func (*SFTPStore) Get added in v1.4.0 

func (s *SFTPStore) Get(_ context.Context, key string) ([]byte, error)

func (*SFTPStore) List added in v1.4.0 

func (s *SFTPStore) List(_ context.Context, prefix string) ([]string, error)

func (*SFTPStore) Put added in v1.4.0 

func (s *SFTPStore) Put(_ context.Context, key string, data []byte) error

func (*SFTPStore) Size added in v1.4.0 

func (s *SFTPStore) Size(_ context.Context, key string) (int64, error)

func (*SFTPStore) TotalSize added in v1.4.0 

func (s *SFTPStore) TotalSize(_ context.Context) (int64, error)

type SFTPStoreOption added in v1.8.0 

type SFTPStoreOption func(*sftpStoreOptions)

SFTPStoreOption configures an SFTP store.

func WithSFTPBasePath added in v1.8.0 

func WithSFTPBasePath(basePath string) SFTPStoreOption

WithSFTPBasePath sets the root directory on the SFTP server.

func WithSFTPClient added in v1.8.0 

func WithSFTPClient(client *sftp.Client) SFTPStoreOption

WithSFTPClient provides a pre-configured SFTP client, skipping internal connection setup. When set, server and auth options are ignored.

func WithSFTPKey added in v1.8.0 

func WithSFTPKey(keyPath string) SFTPStoreOption

WithSFTPKey sets the path to a PEM-encoded private key for authentication.

func WithSFTPPassword added in v1.8.0 

func WithSFTPPassword(password string) SFTPStoreOption

WithSFTPPassword sets password authentication.

func WithSFTPPort added in v1.8.0 

func WithSFTPPort(port string) SFTPStoreOption

WithSFTPPort sets the SSH port. Defaults to "22" when empty.

func WithSFTPUser added in v1.8.0 

func WithSFTPUser(user string) SFTPStoreOption

WithSFTPUser sets the SSH user for authentication.

type Unwrapper added in v1.4.3 

type Unwrapper interface {
	Unwrap() ObjectStore
}

Unwrapper is an optional interface for wrapper stores (CompressedStore, EncryptedStore, etc.) to expose their inner store for introspection.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.