blobio

package
v0.0.0-...-cd088ab Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 24, 2022 License: BSD-2-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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
}

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL