s3

type Client ¶

type Client interface {
	Put(context.Context, string, string, []byte) error
	Get(context.Context, string, string, int) ([]byte, error)
}

Client is the narrow S3-compatible data-plane interface used by Store.

It intentionally contains neither credentials nor endpoint configuration; applications configure those at their composition root and pass the resulting MinIO client to New.

type Store ¶

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

Store is an immutable temporalpayload.BlobStore backed by one explicit S3 bucket.

func New(client *minio.Client, bucket string) (*Store, error)

func NewWithClient(client Client, bucket string) (*Store, error)

func (store *Store) Get(ctx context.Context, key temporalpayload.BlobKey, maxBytes int) ([]byte, error)

func (store *Store) Put(ctx context.Context, key temporalpayload.BlobKey, value []byte) error