client

Documentation

Index

• Variables
• type GCSBlobstore
  • func New(ctx context.Context, cfg *config.GCSCli) (*GCSBlobstore, error)
  • func (client *GCSBlobstore) Delete(dest string) error
  • func (client *GCSBlobstore) Exists(dest string) (exists bool, err error)
  • func (client *GCSBlobstore) Get(src string, dest io.Writer) error
  • func (client *GCSBlobstore) Put(src io.ReadSeeker, dest string) error

Variables

var ErrInvalidROWriteOperation = errors.New("the client operates in read only mode. Change 'credentials_source' parameter value ")

ErrInvalidROWriteOperation is returned when credentials associated with the client disallow an attempted write operation.

Types

type GCSBlobstore

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

GCSBlobstore encapsulates interaction with the GCS blobstore

func New

func New(ctx context.Context, cfg *config.GCSCli) (*GCSBlobstore, error)

New returns a GCSBlobstore configured to operate using the given config

non-nil error is returned on invalid Client or config. If the configuration is incompatible with the GCS bucket, a non-nil error is also returned.

func (*GCSBlobstore) Delete

func (client *GCSBlobstore) Delete(dest string) error

Delete removes a blob from from the GCS blobstore.

If the object does not exist, Delete returns a nil error.

func (*GCSBlobstore) Exists

func (client *GCSBlobstore) Exists(dest string) (exists bool, err error)

Exists checks if a blob exists in the GCS blobstore.

func (*GCSBlobstore) Get

func (client *GCSBlobstore) Get(src string, dest io.Writer) error

Get fetches a blob from the GCS blobstore. Destination will be overwritten if it already exists.

func (*GCSBlobstore) Put

func (client *GCSBlobstore) Put(src io.ReadSeeker, dest string) error