gcsstore

Sep 28, 2023

Changes in this version

+ const COMPOSE_RETRIES

+ const CONCURRENT_SIZE_REQUESTS

+ const MAX_OBJECT_COMPOSITION

+ type GCSAPI interface

+ ComposeObjects func(ctx context.Context, params GCSComposeParams) error

+ DeleteObject func(ctx context.Context, params GCSObjectParams) error

+ DeleteObjectsWithFilter func(ctx context.Context, params GCSFilterParams) error

+ FilterObjects func(ctx context.Context, params GCSFilterParams) ([]string, error)

+ GetObjectSize func(ctx context.Context, params GCSObjectParams) (int64, error)

+ ReadObject func(ctx context.Context, params GCSObjectParams) (GCSReader, error)

+ SetObjectMetadata func(ctx context.Context, params GCSObjectParams, metadata map[string]string) error

+ WriteObject func(ctx context.Context, params GCSObjectParams, r io.Reader) (int64, error)

+ type GCSComposeParams struct

+ Bucket string

+ Destination string

+ Sources []string

+ type GCSFilterParams struct

+ Bucket string

+ Prefix string

+ type GCSObjectParams struct

+ Bucket string

+ ID string

+ type GCSReader interface

+ Close func() error

+ ContentType func() string

+ Read func(p []byte) (int, error)

+ Remain func() int64

+ Size func() int64

+ type GCSService struct

+ Client *storage.Client

+ func NewGCSService(filename string) (*GCSService, error)

+ func (service *GCSService) ComposeFrom(ctx context.Context, objSrcs []*storage.ObjectHandle, ...) (uint32, error)

+ func (service *GCSService) ComposeObjects(ctx context.Context, params GCSComposeParams) error

+ func (service *GCSService) DeleteObject(ctx context.Context, params GCSObjectParams) error

+ func (service *GCSService) DeleteObjectsWithFilter(ctx context.Context, params GCSFilterParams) error

+ func (service *GCSService) FilterObjects(ctx context.Context, params GCSFilterParams) ([]string, error)

+ func (service *GCSService) GetObjectAttrs(ctx context.Context, params GCSObjectParams) (*storage.ObjectAttrs, error)

+ func (service *GCSService) GetObjectSize(ctx context.Context, params GCSObjectParams) (int64, error)

+ func (service *GCSService) ReadObject(ctx context.Context, params GCSObjectParams) (GCSReader, error)

+ func (service *GCSService) SetObjectMetadata(ctx context.Context, params GCSObjectParams, metadata map[string]string) error

+ func (service *GCSService) WriteObject(ctx context.Context, params GCSObjectParams, r io.Reader) (int64, error)

+ type GCSStore struct

+ Bucket string

+ ObjectPrefix string

+ Service GCSAPI

+ func New(bucket string, service GCSAPI) GCSStore

+ func (store GCSStore) AsTerminatableUpload(upload handler.Upload) handler.TerminatableUpload

+ func (store GCSStore) GetUpload(ctx context.Context, id string) (handler.Upload, error)

+ func (store GCSStore) NewUpload(ctx context.Context, info handler.FileInfo) (handler.Upload, error)

+ func (store GCSStore) UseIn(composer *handler.StoreComposer)