storage

Nov 14, 2024

Changes in this version

+ func CheckDirectConnectivitySupported(ctx context.Context, bucket string, opts ...option.ClientOption) error

Oct 3, 2024

Changes in this version

+ func WithDisabledClientMetrics() option.ClientOption

type BucketAttrs

+ Updated time.Time

type ReaderObjectAttrs

+ CRC32C uint32

+ Decompressed bool

Jun 10, 2024

Changes in this version

type BucketAttrs

+ HierarchicalNamespace *HierarchicalNamespace

type BucketHandle

+ func (b *BucketHandle) BucketName() string

+ type HierarchicalNamespace struct

+ Enabled bool

May 13, 2024

Changes in this version

type BucketAttrs

+ SoftDeletePolicy *SoftDeletePolicy

type BucketAttrsToUpdate

+ SoftDeletePolicy *SoftDeletePolicy

type ObjectAttrs

+ HardDeleteTime time.Time

+ SoftDeleteTime time.Time

type ObjectHandle

+ func (o *ObjectHandle) Restore(ctx context.Context, opts *RestoreOptions) (*ObjectAttrs, error)

+ func (o *ObjectHandle) SoftDeleted() *ObjectHandle

type Query

+ SoftDeleted bool

+ type RestoreOptions struct

+ CopySourceACL bool

+ type SoftDeletePolicy struct

+ EffectiveTime time.Time

+ RetentionDuration time.Duration

Mar 29, 2024

Changes in this version

type Reader

+ func (r *Reader) WriteTo(w io.Writer) (int64, error)

Feb 29, 2024

Changes in this version

type Writer

+ ForceEmptyContentType bool

Jan 24, 2024

Changes in this version

type Query

+ IncludeFoldersAsPrefixes bool

type RetryOption

+ func WithMaxAttempts(maxAttempts int) RetryOption

Dec 14, 2023

Changes in this version

type BucketAttrs

+ ObjectRetentionMode string

type BucketHandle

+ func (b *BucketHandle) SetObjectRetention(enable bool) *BucketHandle

type ObjectAttrs

+ Retention *ObjectRetention

type ObjectAttrsToUpdate

+ Retention *ObjectRetention

type ObjectHandle

+ func (o *ObjectHandle) OverrideUnlockedRetention(override bool) *ObjectHandle

+ type ObjectRetention struct

+ Mode string

+ RetainUntil time.Time

Oct 31, 2023

Changes in this version

type Autoclass

+ TerminalStorageClass string

+ TerminalStorageClassUpdateTime time.Time

Sep 7, 2023

Changes in this version

type Client

+ func NewGRPCClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

Jun 28, 2023

Changes in this version

type PostPolicyV4Options

+ Hostname string

type Query

+ MatchGlob string

type SignedURLOptions

+ Hostname string

Mar 15, 2023

Changes in this version

+ func WithJSONReads() option.ClientOption

+ func WithXMLReads() option.ClientOption

Jan 19, 2023

Changes in this version

type ObjectAttrs

+ ComponentCount int64

Nov 7, 2022

Changes in this version

+ type Autoclass struct

+ Enabled bool

+ ToggleTime time.Time

type BucketAttrs

+ Autoclass *Autoclass

type BucketAttrsToUpdate

+ Autoclass *Autoclass

Aug 29, 2022

retracted

Changes in this version

+ func ShouldRetry(err error) bool

type LifecycleCondition

+ AllObjects bool

Jul 20, 2022

Changes in this version

type BucketAttrs

+ CustomPlacementConfig *CustomPlacementConfig

+ type CustomPlacementConfig struct

+ DataLocations []string

Jun 23, 2022

Changes in this version

+ const AbortIncompleteMPUAction

type LifecycleCondition

+ MatchesPrefix []string

+ MatchesSuffix []string

Apr 6, 2022

Changes in this version

type Query

+ IncludeTrailingDelimiter bool

Feb 17, 2022

Changes in this version

type Writer

+ ChunkRetryDeadline time.Duration

Jan 25, 2022

Changes in this version

type BucketAttrs

+ RPO RPO

type BucketAttrsToUpdate

+ RPO RPO

type BucketHandle

+ func (b *BucketHandle) GenerateSignedPostPolicyV4(object string, opts *PostPolicyV4Options) (*PostPolicyV4, error)

+ func (b *BucketHandle) Retryer(opts ...RetryOption) *BucketHandle

type Client

+ func (c *Client) SetRetry(opts ...RetryOption)

type ObjectHandle

+ func (o *ObjectHandle) Retryer(opts ...RetryOption) *ObjectHandle

type PostPolicyV4Options

+ SignRawBytes func(bytes []byte) (signature []byte, err error)

+ type RPO int

+ const RPOAsyncTurbo

+ const RPODefault

+ const RPOUnknown

+ func (rpo RPO) String() string

+ type RetryOption interface

+ func WithBackoff(backoff gax.Backoff) RetryOption

+ func WithErrorFunc(shouldRetry func(err error) bool) RetryOption

+ func WithPolicy(policy RetryPolicy) RetryOption

+ type RetryPolicy int

+ const RetryAlways

+ const RetryIdempotent

+ const RetryNever

Oct 11, 2021

Changes in this version

type BucketHandle

+ func (b *BucketHandle) SignedURL(object string, opts *SignedURLOptions) (string, error)

type PublicAccessPrevention

+ const PublicAccessPreventionInherited

Sep 29, 2021

Changes in this version

type BucketAttrs

+ ProjectNumber uint64

Jun 28, 2021

Changes in this version

type BucketAttrs

+ PublicAccessPrevention PublicAccessPrevention

type BucketAttrsToUpdate

+ PublicAccessPrevention PublicAccessPrevention

+ type PublicAccessPrevention int

+ const PublicAccessPreventionEnforced

+ const PublicAccessPreventionUnknown

+ const PublicAccessPreventionUnspecified

+ func (p PublicAccessPrevention) String() string

Feb 3, 2021

Changes in this version

type BucketAttrsToUpdate

+ StorageClass string

+ type Projection int

+ const ProjectionDefault

+ const ProjectionFull

+ const ProjectionNoACL

+ func (p Projection) String() string

type Query

+ Projection Projection

Aug 28, 2020

Changes in this version

type LifecycleCondition

+ CustomTimeBefore time.Time

+ DaysSinceCustomTime int64

+ DaysSinceNoncurrentTime int64

+ NoncurrentTimeBefore time.Time

type ObjectAttrs

+ CustomTime time.Time

type ObjectAttrsToUpdate

+ CustomTime time.Time

type Query

+ EndOffset string

+ StartOffset string

Jun 3, 2020

Changes in this version

type Composer

+ SendCRC32C bool

May 12, 2020

Changes in this version

+ type PolicyV4Fields struct

+ ACL string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentType string

+ Metadata map[string]string

+ RedirectToURLOnSuccess string

+ StatusCodeOnSuccess int

+ type PostPolicyV4 struct

+ Fields map[string]string

+ URL string

+ func GenerateSignedPostPolicyV4(bucket, object string, opts *PostPolicyV4Options) (*PostPolicyV4, error)

+ type PostPolicyV4Condition interface

+ func ConditionContentLengthRange(start, end uint64) PostPolicyV4Condition

+ func ConditionStartsWith(key, value string) PostPolicyV4Condition

+ type PostPolicyV4Options struct

+ Conditions []PostPolicyV4Condition

+ Expires time.Time

+ Fields *PolicyV4Fields

+ GoogleAccessID string

+ Insecure bool

+ PrivateKey []byte

+ SignBytes func(hashBytes []byte) (signature []byte, err error)

+ Style URLStyle

May 5, 2020

Changes in this version

type SignedURLOptions

+ Insecure bool

+ QueryParameters url.Values

+ Style URLStyle

+ type URLStyle interface

+ func BucketBoundHostname(hostname string) URLStyle

+ func PathStyle() URLStyle

+ func VirtualHostedStyle() URLStyle

Nov 19, 2019

Changes in this version

type Query

+ func (q *Query) SetAttrSelection(attrs []string) error

Nov 5, 2019

Changes in this version

type BucketAttrs

+ UniformBucketLevelAccess UniformBucketLevelAccess

type BucketAttrsToUpdate

+ UniformBucketLevelAccess *UniformBucketLevelAccess

+ type UniformBucketLevelAccess struct

+ Enabled bool

+ LockedTime time.Time

Oct 1, 2019

Changes in this version

type HMACKeyOption

+ func UserProjectForHMACKeys(userProjectID string) HMACKeyOption

Sep 16, 2019

Changes in this version

+ const DeleteAction

+ const JSONPayload

+ const NoPayload

+ const ObjectArchiveEvent

+ const ObjectDeleteEvent

+ const ObjectFinalizeEvent

+ const ObjectMetadataUpdateEvent

+ const ScopeFullControl

+ const ScopeReadOnly

+ const ScopeReadWrite

+ const SetStorageClassAction

+ var ErrBucketNotExist = errors.New("storage: bucket doesn't exist")

+ var ErrObjectNotExist = errors.New("storage: object doesn't exist")

+ func SignedURL(bucket, name string, opts *SignedURLOptions) (string, error)

+ type ACLEntity string

+ const AllAuthenticatedUsers

+ const AllUsers

+ type ACLHandle struct

+ func (a *ACLHandle) Delete(ctx context.Context, entity ACLEntity) (err error)

+ func (a *ACLHandle) List(ctx context.Context) (rules []ACLRule, err error)

+ func (a *ACLHandle) Set(ctx context.Context, entity ACLEntity, role ACLRole) (err error)

+ type ACLRole string

+ const RoleOwner

+ const RoleReader

+ const RoleWriter

+ type ACLRule struct

+ Domain string

+ Email string

+ Entity ACLEntity

+ EntityID string

+ ProjectTeam *ProjectTeam

+ Role ACLRole

+ type BucketAttrs struct

+ ACL []ACLRule

+ BucketPolicyOnly BucketPolicyOnly

+ CORS []CORS

+ Created time.Time

+ DefaultEventBasedHold bool

+ DefaultObjectACL []ACLRule

+ Encryption *BucketEncryption

+ Etag string

+ Labels map[string]string

+ Lifecycle Lifecycle

+ Location string

+ LocationType string

+ Logging *BucketLogging

+ MetaGeneration int64

+ Name string

+ PredefinedACL string

+ PredefinedDefaultObjectACL string

+ RequesterPays bool

+ RetentionPolicy *RetentionPolicy

+ StorageClass string

+ VersioningEnabled bool

+ Website *BucketWebsite

+ type BucketAttrsToUpdate struct

+ BucketPolicyOnly *BucketPolicyOnly

+ CORS []CORS

+ DefaultEventBasedHold optional.Bool

+ Encryption *BucketEncryption

+ Lifecycle *Lifecycle

+ Logging *BucketLogging

+ PredefinedACL string

+ PredefinedDefaultObjectACL string

+ RequesterPays optional.Bool

+ RetentionPolicy *RetentionPolicy

+ VersioningEnabled optional.Bool

+ Website *BucketWebsite

+ func (ua *BucketAttrsToUpdate) DeleteLabel(name string)

+ func (ua *BucketAttrsToUpdate) SetLabel(name, value string)

+ type BucketConditions struct

+ MetagenerationMatch int64

+ MetagenerationNotMatch int64

+ type BucketEncryption struct

+ DefaultKMSKeyName string

+ type BucketHandle struct

+ func (b *BucketHandle) ACL() *ACLHandle

+ func (b *BucketHandle) AddNotification(ctx context.Context, n *Notification) (ret *Notification, err error)

+ func (b *BucketHandle) Attrs(ctx context.Context) (attrs *BucketAttrs, err error)

+ func (b *BucketHandle) Create(ctx context.Context, projectID string, attrs *BucketAttrs) (err error)

+ func (b *BucketHandle) DefaultObjectACL() *ACLHandle

+ func (b *BucketHandle) Delete(ctx context.Context) (err error)

+ func (b *BucketHandle) DeleteNotification(ctx context.Context, id string) (err error)

+ func (b *BucketHandle) IAM() *iam.Handle

+ func (b *BucketHandle) If(conds BucketConditions) *BucketHandle

+ func (b *BucketHandle) LockRetentionPolicy(ctx context.Context) error

+ func (b *BucketHandle) Notifications(ctx context.Context) (n map[string]*Notification, err error)

+ func (b *BucketHandle) Object(name string) *ObjectHandle

+ func (b *BucketHandle) Objects(ctx context.Context, q *Query) *ObjectIterator

+ func (b *BucketHandle) Update(ctx context.Context, uattrs BucketAttrsToUpdate) (attrs *BucketAttrs, err error)

+ func (b *BucketHandle) UserProject(projectID string) *BucketHandle

+ type BucketIterator struct

+ Prefix string

+ func (it *BucketIterator) Next() (*BucketAttrs, error)

+ func (it *BucketIterator) PageInfo() *iterator.PageInfo

+ type BucketLogging struct

+ LogBucket string

+ LogObjectPrefix string

+ type BucketPolicyOnly struct

+ Enabled bool

+ LockedTime time.Time

+ type BucketWebsite struct

+ MainPageSuffix string

+ NotFoundPage string

+ type CORS struct

+ MaxAge time.Duration

+ Methods []string

+ Origins []string

+ ResponseHeaders []string

+ type Client struct

+ func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

+ func (c *Client) Bucket(name string) *BucketHandle

+ func (c *Client) Buckets(ctx context.Context, projectID string) *BucketIterator

+ func (c *Client) Close() error

+ func (c *Client) CreateHMACKey(ctx context.Context, projectID, serviceAccountEmail string) (*HMACKey, error)

+ func (c *Client) HMACKeyHandle(projectID, accessID string) *HMACKeyHandle

+ func (c *Client) ListHMACKeys(ctx context.Context, projectID string, opts ...HMACKeyOption) *HMACKeysIterator

+ func (c *Client) ServiceAccount(ctx context.Context, projectID string) (string, error)

+ type Composer struct

+ func (c *Composer) Run(ctx context.Context) (attrs *ObjectAttrs, err error)

+ type Conditions struct

+ DoesNotExist bool

+ GenerationMatch int64

+ GenerationNotMatch int64

+ MetagenerationMatch int64

+ MetagenerationNotMatch int64

+ type Copier struct

+ DestinationKMSKeyName string

+ ProgressFunc func(copiedBytes, totalBytes uint64)

+ RewriteToken string

+ func (c *Copier) Run(ctx context.Context) (attrs *ObjectAttrs, err error)

+ type HMACKey struct

+ AccessID string

+ CreatedTime time.Time

+ Etag string

+ ID string

+ ProjectID string

+ Secret string

+ ServiceAccountEmail string

+ State HMACState

+ UpdatedTime time.Time

+ type HMACKeyAttrsToUpdate struct

+ Etag string

+ State HMACState

+ type HMACKeyHandle struct

+ func (h *HMACKeyHandle) Update(ctx context.Context, au HMACKeyAttrsToUpdate) (*HMACKey, error)

+ func (hkh *HMACKeyHandle) Delete(ctx context.Context) error

+ func (hkh *HMACKeyHandle) Get(ctx context.Context) (*HMACKey, error)

+ type HMACKeyOption interface

+ func ForHMACKeyServiceAccountEmail(serviceAccountEmail string) HMACKeyOption

+ func HMACKeysForUserProject(userProjectID string) HMACKeyOption

+ func ShowDeletedHMACKeys() HMACKeyOption

+ type HMACKeysIterator struct

+ func (it *HMACKeysIterator) Next() (*HMACKey, error)

+ func (it *HMACKeysIterator) PageInfo() *iterator.PageInfo

+ type HMACState string

+ const Active

+ const Deleted

+ const Inactive

+ type Lifecycle struct

+ Rules []LifecycleRule

+ type LifecycleAction struct

+ StorageClass string

+ Type string

+ type LifecycleCondition struct

+ AgeInDays int64

+ CreatedBefore time.Time

+ Liveness Liveness

+ MatchesStorageClasses []string

+ NumNewerVersions int64

+ type LifecycleRule struct

+ Action LifecycleAction

+ Condition LifecycleCondition

+ type Liveness int

+ const Archived

+ const Live

+ const LiveAndArchived

+ type Notification struct

+ CustomAttributes map[string]string

+ EventTypes []string

+ ID string

+ ObjectNamePrefix string

+ PayloadFormat string

+ TopicID string

+ TopicProjectID string

+ type ObjectAttrs struct

+ ACL []ACLRule

+ Bucket string

+ CRC32C uint32

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ Created time.Time

+ CustomerKeySHA256 string

+ Deleted time.Time

+ Etag string

+ EventBasedHold bool

+ Generation int64

+ KMSKeyName string

+ MD5 []byte

+ MediaLink string

+ Metadata map[string]string

+ Metageneration int64

+ Name string

+ Owner string

+ PredefinedACL string

+ Prefix string

+ RetentionExpirationTime time.Time

+ Size int64

+ StorageClass string

+ TemporaryHold bool

+ Updated time.Time

+ type ObjectAttrsToUpdate struct

+ ACL []ACLRule

+ CacheControl optional.String

+ ContentDisposition optional.String

+ ContentEncoding optional.String

+ ContentLanguage optional.String

+ ContentType optional.String

+ EventBasedHold optional.Bool

+ Metadata map[string]string

+ PredefinedACL string

+ TemporaryHold optional.Bool

+ type ObjectHandle struct

+ func (dst *ObjectHandle) ComposerFrom(srcs ...*ObjectHandle) *Composer

+ func (dst *ObjectHandle) CopierFrom(src *ObjectHandle) *Copier

+ func (o *ObjectHandle) ACL() *ACLHandle

+ func (o *ObjectHandle) Attrs(ctx context.Context) (attrs *ObjectAttrs, err error)

+ func (o *ObjectHandle) BucketName() string

+ func (o *ObjectHandle) Delete(ctx context.Context) error

+ func (o *ObjectHandle) Generation(gen int64) *ObjectHandle

+ func (o *ObjectHandle) If(conds Conditions) *ObjectHandle

+ func (o *ObjectHandle) Key(encryptionKey []byte) *ObjectHandle

+ func (o *ObjectHandle) NewRangeReader(ctx context.Context, offset, length int64) (r *Reader, err error)

+ func (o *ObjectHandle) NewReader(ctx context.Context) (*Reader, error)

+ func (o *ObjectHandle) NewWriter(ctx context.Context) *Writer

+ func (o *ObjectHandle) ObjectName() string

+ func (o *ObjectHandle) ReadCompressed(compressed bool) *ObjectHandle

+ func (o *ObjectHandle) Update(ctx context.Context, uattrs ObjectAttrsToUpdate) (oa *ObjectAttrs, err error)

+ type ObjectIterator struct

+ func (it *ObjectIterator) Next() (*ObjectAttrs, error)

+ func (it *ObjectIterator) PageInfo() *iterator.PageInfo

+ type ProjectTeam struct

+ ProjectNumber string

+ Team string

+ type Query struct

+ Delimiter string

+ Prefix string

+ Versions bool

+ type Reader struct

+ Attrs ReaderObjectAttrs

+ func (r *Reader) CacheControl() string

+ func (r *Reader) Close() error

+ func (r *Reader) ContentEncoding() string

+ func (r *Reader) ContentType() string

+ func (r *Reader) LastModified() (time.Time, error)

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

+ func (r *Reader) Remain() int64

+ func (r *Reader) Size() int64

+ type ReaderObjectAttrs struct

+ CacheControl string

+ ContentEncoding string

+ ContentType string

+ Generation int64

+ LastModified time.Time

+ Metageneration int64

+ Size int64

+ StartOffset int64

+ type RetentionPolicy struct

+ EffectiveTime time.Time

+ IsLocked bool

+ RetentionPeriod time.Duration

+ type SignedURLOptions struct

+ ContentType string

+ Expires time.Time

+ GoogleAccessID string

+ Headers []string

+ MD5 string

+ Method string

+ PrivateKey []byte

+ Scheme SigningScheme

+ SignBytes func([]byte) ([]byte, error)

+ type SigningScheme int

+ const SigningSchemeDefault

+ const SigningSchemeV2

+ const SigningSchemeV4

+ type Writer struct

+ ChunkSize int

+ ProgressFunc func(int64)

+ SendCRC32C bool

+ func (w *Writer) Attrs() *ObjectAttrs

+ func (w *Writer) Close() error

+ func (w *Writer) CloseWithError(err error) error

+ func (w *Writer) Write(p []byte) (n int, err error)