blobio

Documentation

Index

• func Pull(logger lager.Logger, ctx context.Context, bucket BucketConfig, ...) error
• func Push(logger lager.Logger, ctx context.Context, bucket BucketConfig, ...) error
• type BlobReaderWriter
  • func (brw *BlobReaderWriter) InputBlobReader(logger lager.Logger, ctx context.Context) (*blob.Reader, error)
  • func (brw *BlobReaderWriter) OutputBlobWriter(logger lager.Logger, ctx context.Context) (*blob.Writer, error)
• type BlobstoreIO
  • func NewBlobReaderWriter(bucketURL string, bucketKey string) BlobstoreIO
• type BucketConfig

Functions

func Pull

func Pull(logger lager.Logger, ctx context.Context, bucket BucketConfig, sourceKey, destinationPath string) error

func Push

func Push(logger lager.Logger, ctx context.Context, bucket BucketConfig, sourcePath, destinationKey string) error

Types

type BlobReaderWriter

type BlobReaderWriter struct {
	BucketURL string
	BucketKey string
}

func (*BlobReaderWriter) InputBlobReader

func (brw *BlobReaderWriter) InputBlobReader(logger lager.Logger, ctx context.Context) (*blob.Reader, error)

func (*BlobReaderWriter) OutputBlobWriter

func (brw *BlobReaderWriter) OutputBlobWriter(logger lager.Logger, ctx context.Context) (*blob.Writer, error)

type BlobstoreIO

type BlobstoreIO interface {
	InputBlobReader(lager.Logger, context.Context) (*blob.Reader, error)
	OutputBlobWriter(lager.Logger, context.Context) (*blob.Writer, error)
}

func NewBlobReaderWriter

func NewBlobReaderWriter(bucketURL string, bucketKey string) BlobstoreIO

type BucketConfig

type BucketConfig struct {
	URL string
}