gcs

Documentation

Index

• type Storage
  • func NewStorage(opts StorageOptions) (*Storage, error)
  • func (s *Storage) CreateObjectExclusively(ctx context.Context, name string, objectMetadata storage.ObjectMetadata, ...) error
  • func (s *Storage) DeleteObject(ctx context.Context, name string) error
  • func (s *Storage) GetObject(ctx context.Context, name string) (io.ReadCloser, error)
  • func (s *Storage) GetObjectMetadata(ctx context.Context, name string) (storage.ObjectMetadata, error)
  • func (s *Storage) ListObjects(ctx context.Context, opts storage.ObjectListOptions) (*storage.ObjectList, error)
• type StorageOptions

Types

type Storage

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

func NewStorage

func NewStorage(opts StorageOptions) (*Storage, error)

func (*Storage) CreateObjectExclusively

func (s *Storage) CreateObjectExclusively(ctx context.Context,
	name string, objectMetadata storage.ObjectMetadata,
	data io.ReadSeeker) error

func (*Storage) DeleteObject

func (s *Storage) DeleteObject(ctx context.Context, name string) error

func (*Storage) GetObject

func (s *Storage) GetObject(ctx context.Context, name string) (io.ReadCloser, error)

func (*Storage) GetObjectMetadata

func (s *Storage) GetObjectMetadata(ctx context.Context, name string) (storage.ObjectMetadata, error)

func (*Storage) ListObjects

func (s *Storage) ListObjects(ctx context.Context, opts storage.ObjectListOptions) (*storage.ObjectList, error)

type StorageOptions

type StorageOptions struct {
	Bucket    string
	GCSClient *gcs.Client
	// HTTPClient is asumed to add Authorization headers on requests
	HTTPClient *http.Client
}