blobstoreclient

Documentation

Index

• func WriteTempFile(ctx context.Context, writer func(w io.Writer) error) (string, error)
• type BlobFile
  • func (f *BlobFile) Close() error
  • func (f *BlobFile) Open() io.ReadCloser
  • func (f *BlobFile) Path() string
• type BlobInfo
• type BlobStoreClient
  • func (c *BlobStoreClient) Download(ctx context.Context, blobHash []byte) (*BlobFile, error)
  • func (c *BlobStoreClient) Upload(ctx context.Context, r io.Reader) (*BlobInfo, error)
• type Client
  • func NewClient(ctx context.Context, options ClientOptions) (Client, error)
• type ClientOptions

Functions

func WriteTempFile

func WriteTempFile(ctx context.Context, writer func(w io.Writer) error) (string, error)

Types

type BlobFile

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

func (*BlobFile) Close

func (f *BlobFile) Close() error

func (*BlobFile) Open

func (f *BlobFile) Open() io.ReadCloser

func (*BlobFile) Path

func (f *BlobFile) Path() string

type BlobInfo

type BlobInfo struct {
	SHA256 []byte
	Length int64
}

type BlobStoreClient

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

func (*BlobStoreClient) Download

func (c *BlobStoreClient) Download(ctx context.Context, blobHash []byte) (*BlobFile, error)

func (*BlobStoreClient) Upload

func (c *BlobStoreClient) Upload(ctx context.Context, r io.Reader) (*BlobInfo, error)

type Client

type Client interface {
	Upload(ctx context.Context, r io.Reader) (*BlobInfo, error)
	Download(ctx context.Context, sha256 []byte) (*BlobFile, error)
}

func NewClient

func NewClient(ctx context.Context, options ClientOptions) (Client, error)

type ClientOptions

type ClientOptions struct {
	Host      string
	TLSConfig *tls.Config
}