blobstore

Jun 17, 2019

Changes in this version

+ var ErrConstructKey = &shared.BadRequestError

May 8, 2019

Changes in this version

type Client

+ BucketExists func(ctx context.Context, bucket string) (bool, error)

+ GetRetryPolicy func() backoff.RetryPolicy

+ GetTags func(ctx context.Context, bucket string, key blob.Key) (map[string]string, error)

+ IsRetryableError func(err error) bool

Feb 12, 2019

Changes in this version

+ var ErrBlobDeserialization = &shared.BadRequestError

+ var ErrBlobSerialization = &shared.BadRequestError

type Client

+ func NewMetricClient(client Client, metricsClient metrics.Client) Client

+ func NewRetryableClient(client Client, policy backoff.RetryPolicy, isRetryable backoff.IsRetryable) Client

+ Delete func(ctx context.Context, bucket string, key blob.Key) (bool, error)

+ Download func(ctx context.Context, bucket string, key blob.Key) (*blob.Blob, error)

+ Exists func(ctx context.Context, bucket string, key blob.Key) (bool, error)

+ ListByPrefix func(ctx context.Context, bucket string, prefix string) ([]blob.Key, error)

+ Upload func(ctx context.Context, bucket string, key blob.Key, blob *blob.Blob) error

Jan 7, 2019

Changes in this version

+ var ErrBlobNotExists = errors.New("requested blob does not exist")

+ var ErrBucketNotExists = errors.New("requested bucket does not exist")

+ type Blob struct

+ Body io.Reader

+ CompressionType CompressionType

+ Tags map[string]string

+ type BucketMetadataResponse struct

+ Owner string

+ RetentionDays int

+ type Client interface

+ BucketMetadata func(ctx context.Context, bucket string) (*BucketMetadataResponse, error)

+ DownloadBlob func(ctx context.Context, bucket string, filename string) (*Blob, error)

+ UploadBlob func(ctx context.Context, bucket string, filename string, blob *Blob) error

+ type CompressionType int

+ const NoCompression