Documentation ¶
Index ¶
- type StorageACLHandle
- type StorageBucketHandle
- func (x *StorageBucketHandle) ACL() storagev1.StorageACLHandle
- func (x *StorageBucketHandle) AddNotification(ctx context.Context, notification *storage.Notification) (*storage.Notification, error)
- func (x *StorageBucketHandle) Attrs(ctx context.Context) (*storage.BucketAttrs, error)
- func (x *StorageBucketHandle) Create(ctx context.Context, projectID string, attr *storage.BucketAttrs) error
- func (x *StorageBucketHandle) DefaultObjectACL() storagev1.StorageACLHandle
- func (x *StorageBucketHandle) Delete(ctx context.Context) error
- func (x *StorageBucketHandle) DeleteNotification(ctx context.Context, id string) error
- func (x *StorageBucketHandle) If(cond storage.BucketConditions) storagev1.StorageBucketHandle
- func (x *StorageBucketHandle) LockRetentionPolicy(ctx context.Context) error
- func (x *StorageBucketHandle) Notifications(ctx context.Context) (map[string]*storage.Notification, error)
- func (x *StorageBucketHandle) Object(name string) storagev1.StorageObjectHandle
- func (x *StorageBucketHandle) Objects(ctx context.Context, query *storage.Query) storagev1.StorageObjectIterator
- func (x *StorageBucketHandle) Update(ctx context.Context, attr storage.BucketAttrsToUpdate) (*storage.BucketAttrs, error)
- func (x *StorageBucketHandle) UserProject(projectID string) storagev1.StorageBucketHandle
- type StorageBucketIterator
- type StorageComposer
- type StorageCopier
- func (x *StorageCopier) ObjectAttrs() *storage.ObjectAttrs
- func (x *StorageCopier) Run(ctx context.Context) (*storage.ObjectAttrs, error)
- func (x *StorageCopier) SetDestinationKMSKeyName(name string)
- func (x *StorageCopier) SetProgressFunc(fn func(uint64, uint64))
- func (x *StorageCopier) SetRewriteToken(token string)
- type StorageEventPubsubService
- type StorageObjectHandle
- func (x *StorageObjectHandle) ACL() storagev1.StorageACLHandle
- func (x *StorageObjectHandle) Attrs(ctx context.Context) (*storage.ObjectAttrs, error)
- func (x *StorageObjectHandle) ComposerFrom(handles ...storagev1.StorageObjectHandle) storagev1.StorageObjectComposer
- func (x *StorageObjectHandle) CopierFrom(handle storagev1.StorageObjectHandle) storagev1.StorageObjectCopier
- func (x *StorageObjectHandle) Delete(ctx context.Context) error
- func (x *StorageObjectHandle) Generation(gen int64) storagev1.StorageObjectHandle
- func (x *StorageObjectHandle) If(cond storage.Conditions) storagev1.StorageObjectHandle
- func (x *StorageObjectHandle) Key(data []byte) storagev1.StorageObjectHandle
- func (x *StorageObjectHandle) NewRangeReader(ctx context.Context, start int64, end int64) (storagev1.StorageObjectReader, error)
- func (x *StorageObjectHandle) NewReader(ctx context.Context) (storagev1.StorageObjectReader, error)
- func (x *StorageObjectHandle) NewWriter(ctx context.Context) storagev1.StorageObjectWriter
- func (x *StorageObjectHandle) ReadCompressed(compressed bool) storagev1.StorageObjectHandle
- func (x *StorageObjectHandle) Update(ctx context.Context, uattrs storage.ObjectAttrsToUpdate) (*storage.ObjectAttrs, error)
- type StorageObjectIterator
- type StoragePageInfo
- type StorageServiceClient
- type StorageWriter
- func (x *StorageWriter) Attrs() *storage.ObjectAttrs
- func (x *StorageWriter) Close() error
- func (x *StorageWriter) CloseWithError(err error) error
- func (x *StorageWriter) ObjectAttrs() *storage.ObjectAttrs
- func (x *StorageWriter) SetCRC32C(v uint32)
- func (x *StorageWriter) SetChunkSize(v int)
- func (x *StorageWriter) SetContentType(value string)
- func (x *StorageWriter) SetProgressFunc(fn func(int64))
- func (x *StorageWriter) Write(p []byte) (n int, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StorageACLHandle ¶
type StorageACLHandle struct {
// contains filtered or unexported fields
}
type StorageBucketHandle ¶
type StorageBucketHandle struct {
// contains filtered or unexported fields
}
func (*StorageBucketHandle) ACL ¶
func (x *StorageBucketHandle) ACL() storagev1.StorageACLHandle
ACL implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) AddNotification ¶
func (x *StorageBucketHandle) AddNotification(ctx context.Context, notification *storage.Notification) (*storage.Notification, error)
AddNotification implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) Attrs ¶
func (x *StorageBucketHandle) Attrs(ctx context.Context) (*storage.BucketAttrs, error)
Attrs implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) Create ¶
func (x *StorageBucketHandle) Create(ctx context.Context, projectID string, attr *storage.BucketAttrs) error
Create implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) DefaultObjectACL ¶
func (x *StorageBucketHandle) DefaultObjectACL() storagev1.StorageACLHandle
DefaultObjectACL implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) Delete ¶
func (x *StorageBucketHandle) Delete(ctx context.Context) error
Delete implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) DeleteNotification ¶
func (x *StorageBucketHandle) DeleteNotification(ctx context.Context, id string) error
DeleteNotification implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) If ¶
func (x *StorageBucketHandle) If(cond storage.BucketConditions) storagev1.StorageBucketHandle
If implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) LockRetentionPolicy ¶
func (x *StorageBucketHandle) LockRetentionPolicy(ctx context.Context) error
LockRetentionPolicy implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) Notifications ¶
func (x *StorageBucketHandle) Notifications(ctx context.Context) (map[string]*storage.Notification, error)
Notifications implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) Object ¶
func (x *StorageBucketHandle) Object(name string) storagev1.StorageObjectHandle
Object implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) Objects ¶
func (x *StorageBucketHandle) Objects(ctx context.Context, query *storage.Query) storagev1.StorageObjectIterator
Objects implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) Update ¶
func (x *StorageBucketHandle) Update(ctx context.Context, attr storage.BucketAttrsToUpdate) (*storage.BucketAttrs, error)
Update implements storagev1.StorageBucketHandle.
func (*StorageBucketHandle) UserProject ¶
func (x *StorageBucketHandle) UserProject(projectID string) storagev1.StorageBucketHandle
UserProject implements storagev1.StorageBucketHandle.
type StorageBucketIterator ¶
type StorageBucketIterator struct {
// contains filtered or unexported fields
}
func (*StorageBucketIterator) Next ¶
func (x *StorageBucketIterator) Next() (*storage.BucketAttrs, error)
Next implements storagev1.StorageBucketIterator.
func (*StorageBucketIterator) PageInfo ¶
func (x *StorageBucketIterator) PageInfo() storagev1.StoragePageInfo
PageInfo implements storagev1.StorageBucketIterator.
type StorageComposer ¶
type StorageComposer struct {
// contains filtered or unexported fields
}
func (*StorageComposer) ObjectAttrs ¶
func (x *StorageComposer) ObjectAttrs() *storage.ObjectAttrs
ObjectAttrs implements storagev1.StorageComposer.
func (*StorageComposer) Run ¶
func (x *StorageComposer) Run(ctx context.Context) (*storage.ObjectAttrs, error)
Run implements storagev1.StorageComposer.
type StorageCopier ¶
type StorageCopier struct {
// contains filtered or unexported fields
}
func (*StorageCopier) ObjectAttrs ¶
func (x *StorageCopier) ObjectAttrs() *storage.ObjectAttrs
ObjectAttrs implements storagev1.StorageCopier.
func (*StorageCopier) Run ¶
func (x *StorageCopier) Run(ctx context.Context) (*storage.ObjectAttrs, error)
Run implements storagev1.StorageCopier.
func (*StorageCopier) SetDestinationKMSKeyName ¶
func (x *StorageCopier) SetDestinationKMSKeyName(name string)
SetDestinationKMSKeyName implements storagev1.StorageCopier.
func (*StorageCopier) SetProgressFunc ¶
func (x *StorageCopier) SetProgressFunc(fn func(uint64, uint64))
SetProgressFunc implements storagev1.StorageCopier.
func (*StorageCopier) SetRewriteToken ¶
func (x *StorageCopier) SetRewriteToken(token string)
SetRewriteToken implements storagev1.StorageCopier.
type StorageEventPubsubService ¶
type StorageEventPubsubService struct { // StorageObjectEventHandler is a storage object event handler. StorageObjectEventHandler storagev1.StorageObjectEventHandler }
StorageEventPubsubService represents a storage pubsub service.
func (*StorageEventPubsubService) PushPubsubMessage ¶
func (x *StorageEventPubsubService) PushPubsubMessage(ctx context.Context, r *pubsubv1.PushPubsubMessageRequest) (*pubsubv1.PushPubsubMessageResponse, error)
PushPubsubMessage implements pubsubv1.PubsubService.
type StorageObjectHandle ¶
type StorageObjectHandle struct {
// contains filtered or unexported fields
}
func (*StorageObjectHandle) ACL ¶
func (x *StorageObjectHandle) ACL() storagev1.StorageACLHandle
ACL implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) Attrs ¶
func (x *StorageObjectHandle) Attrs(ctx context.Context) (*storage.ObjectAttrs, error)
Attrs implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) ComposerFrom ¶
func (x *StorageObjectHandle) ComposerFrom(handles ...storagev1.StorageObjectHandle) storagev1.StorageObjectComposer
ComposerFrom implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) CopierFrom ¶
func (x *StorageObjectHandle) CopierFrom(handle storagev1.StorageObjectHandle) storagev1.StorageObjectCopier
CopierFrom implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) Delete ¶
func (x *StorageObjectHandle) Delete(ctx context.Context) error
Delete implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) Generation ¶
func (x *StorageObjectHandle) Generation(gen int64) storagev1.StorageObjectHandle
Generation implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) If ¶
func (x *StorageObjectHandle) If(cond storage.Conditions) storagev1.StorageObjectHandle
If implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) Key ¶
func (x *StorageObjectHandle) Key(data []byte) storagev1.StorageObjectHandle
Key implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) NewRangeReader ¶
func (x *StorageObjectHandle) NewRangeReader(ctx context.Context, start int64, end int64) (storagev1.StorageObjectReader, error)
NewRangeReader implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) NewReader ¶
func (x *StorageObjectHandle) NewReader(ctx context.Context) (storagev1.StorageObjectReader, error)
NewReader implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) NewWriter ¶
func (x *StorageObjectHandle) NewWriter(ctx context.Context) storagev1.StorageObjectWriter
NewWriter implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) ReadCompressed ¶
func (x *StorageObjectHandle) ReadCompressed(compressed bool) storagev1.StorageObjectHandle
ReadCompressed implements storagev1.StorageObjectHandle.
func (*StorageObjectHandle) Update ¶
func (x *StorageObjectHandle) Update(ctx context.Context, uattrs storage.ObjectAttrsToUpdate) (*storage.ObjectAttrs, error)
Update implements storagev1.StorageObjectHandle.
type StorageObjectIterator ¶
type StorageObjectIterator struct {
// contains filtered or unexported fields
}
func (*StorageObjectIterator) Next ¶
func (x *StorageObjectIterator) Next() (*storage.ObjectAttrs, error)
Next implements storagev1.StorageObjectIterator.
func (*StorageObjectIterator) PageInfo ¶
func (x *StorageObjectIterator) PageInfo() storagev1.StoragePageInfo
PageInfo implements storagev1.StorageObjectIterator.
type StoragePageInfo ¶
type StoragePageInfo struct {
// contains filtered or unexported fields
}
StoragePageInfo represents a storage page info.
func (*StoragePageInfo) MaxSize ¶
func (x *StoragePageInfo) MaxSize() int
MaxSize implements storagev1.StoragePageInfo.
func (*StoragePageInfo) Remaining ¶
func (x *StoragePageInfo) Remaining() int
Remaining implements storagev1.StoragePageInfo.
func (*StoragePageInfo) Token ¶
func (x *StoragePageInfo) Token() string
Token implements storagev1.StoragePageInfo.
type StorageServiceClient ¶
type StorageServiceClient struct {
// contains filtered or unexported fields
}
StorageServiceClient represents a storage service client.
func NewStorageServiceClient ¶
func NewStorageServiceClient(ctx context.Context, options ...option.ClientOption) (*StorageServiceClient, error)
NewStorageServiceClient creates a new StorageServiceClient.
func (*StorageServiceClient) Bucket ¶
func (x *StorageServiceClient) Bucket(name string) storagev1.StorageBucketHandle
Bucket implements storagev1.StorageServiceClient.
func (*StorageServiceClient) Buckets ¶
func (x *StorageServiceClient) Buckets(ctx context.Context, projectID string) storagev1.StorageBucketIterator
Buckets implements storagev1.StorageServiceClient.
func (*StorageServiceClient) Close ¶
func (x *StorageServiceClient) Close() error
Close implements storagev1.StorageServiceClient.
type StorageWriter ¶
type StorageWriter struct {
// contains filtered or unexported fields
}
func (*StorageWriter) Attrs ¶
func (x *StorageWriter) Attrs() *storage.ObjectAttrs
Attrs implements storagev1.StorageWriter.
func (*StorageWriter) Close ¶
func (x *StorageWriter) Close() error
Close implements storagev1.StorageWriter.
func (*StorageWriter) CloseWithError ¶
func (x *StorageWriter) CloseWithError(err error) error
CloseWithError implements storagev1.StorageWriter.
func (*StorageWriter) ObjectAttrs ¶
func (x *StorageWriter) ObjectAttrs() *storage.ObjectAttrs
ObjectAttrs implements storagev1.StorageWriter.
func (*StorageWriter) SetCRC32C ¶
func (x *StorageWriter) SetCRC32C(v uint32)
SetCRC32C implements storagev1.StorageWriter.
func (*StorageWriter) SetChunkSize ¶
func (x *StorageWriter) SetChunkSize(v int)
SetChunkSize implements storagev1.StorageWriter.
func (*StorageWriter) SetContentType ¶
func (x *StorageWriter) SetContentType(value string)
SetContentType implements storagev1.StorageWriter.
func (*StorageWriter) SetProgressFunc ¶
func (x *StorageWriter) SetProgressFunc(fn func(int64))
SetProgressFunc implements storagev1.StorageWriter.