Versions in this module Expand all Collapse all v1 v1.1.1 Feb 23, 2020 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)
Go to main page