gcp

Documentation

Index

• type Backend
  • func NewBackend(client *storage.Client) *Backend
  • func (b *Backend) CreateReader(ctx context.Context, uploadBucket string, uploadLocation string) (io.ReadCloser, error)
  • func (b *Backend) CreateWriter(ctx context.Context, uploadBucket string, uploadLocation string) (io.WriteCloser, error)
  • func (b *Backend) DeleteFile(ctx context.Context, bucket string, location string) error
  • func (b *Backend) GetDeploymentId(ctx context.Context) string
  • func (b *Backend) GetNodeId(ctx context.Context) string
  • func (b *Backend) ListFilesPrefix(ctx context.Context, bucket string, prefix string) ([]string, error)
  • func (b *Backend) ReadFile(ctx context.Context, readBucket string, readLocation string) ([]byte, error)
  • func (b *Backend) UploadFile(ctx context.Context, data []byte, uploadBucket string, uploadLocation string) error
  • func (b *Backend) WriteLeaderFile(ctx context.Context, metadataBucket string, fileContents []byte) error

Types

type Backend

type Backend struct {
	GcsClient *storage.Client
}

This should satify interface for FirehoseBackend

func NewBackend

func NewBackend(client *storage.Client) *Backend

NewBackend creates a Firehose on GCP The provider metadata produced by this Backend will have concrete type: gcp.Metadata

func (*Backend) CreateReader

func (b *Backend) CreateReader(ctx context.Context, uploadBucket string, uploadLocation string) (io.ReadCloser, error)

func (*Backend) CreateWriter

func (b *Backend) CreateWriter(ctx context.Context, uploadBucket string, uploadLocation string) (io.WriteCloser, error)

func (*Backend) DeleteFile

func (b *Backend) DeleteFile(ctx context.Context, bucket string, location string) error

func (*Backend) GetDeploymentId

func (b *Backend) GetDeploymentId(ctx context.Context) string

func (*Backend) GetNodeId

func (b *Backend) GetNodeId(ctx context.Context) string

func (*Backend) ListFilesPrefix

func (b *Backend) ListFilesPrefix(ctx context.Context, bucket string, prefix string) ([]string, error)

func (*Backend) ReadFile

func (b *Backend) ReadFile(ctx context.Context, readBucket string, readLocation string) ([]byte, error)

func (*Backend) UploadFile

func (b *Backend) UploadFile(ctx context.Context, data []byte, uploadBucket string, uploadLocation string) error

func (*Backend) WriteLeaderFile

func (b *Backend) WriteLeaderFile(ctx context.Context, metadataBucket string, fileContents []byte) error