object

type AttrSet ¶

type AttrSet struct {
	// contains filtered or unexported fields
}

AttrSet used to set optional GCS object attributes in upload, write, and update operations

func (a AttrSet) CacheControl(cacheControl string) AttrSet

func (a AttrSet) GetCacheControl() *string

type AttrSetter ¶

type AttrSetter func(AttrSet) AttrSet

AttrSetter used to set optional GCS object attributes in upload, write, and update operations

type Attrs ¶

type Attrs interface {
	Attrs() *storage.ObjectAttrs
	SyncOperation
}

Attrs reads the attributes of an object in a GCS bucket

func NewAttrs() Attrs

type Delete ¶

type Delete interface {
	SyncOperation
}

func NewDelete() Delete

type Download ¶

type Download interface {
	SyncOperation
}

func NewDownload(toFile string) Download

type Exists ¶

type Exists interface {
	Exists() bool
	SyncOperation
}

func NewExists() Exists

type Object ¶

type Object struct {
	Ctx    context.Context
	Handle *storage.ObjectHandle
}

type Read ¶

type Read interface {
	Content() []byte
	SyncOperation
}

Read reads the content of an object in a GCS bucket

func NewRead() Read

type SyncOperation ¶ added in v1.0.8

type SyncOperation interface {
	// Handler performs the call, given object and logger references
	Handler(object Object, logger zerolog.Logger) error
	// Kind returns the a description of the kind of this operation (eg. "delete", "upload")
	Kind() string
}

SyncOperation is an interface for synchronous operations on GCS bucket objects

type Update ¶

type Update interface {
	SyncOperation
}

Update updates attributes of an object in a GCS bucket

func NewUpdate(attrs AttrSet) Update

type Upload ¶

type Upload interface {
	SyncOperation
}

func NewUpload(fromFile string, attrs AttrSet) Upload

type Write ¶

type Write interface {
	SyncOperation
}

func NewWrite(content []byte, attrs AttrSet) Write

func NewWriteFromStream(reader io.Reader, attrs AttrSet) Write