blob

Documentation

Index

• Variables
• type Config
• type FileSystemStore
  • func (c *FileSystemStore) Download(_ context.Context, filePath string) (io.ReadCloser, error)
  • func (c FileSystemStore) GetSignedURL(_ context.Context, _ string) (string, error)
  • func (c FileSystemStore) Upload(ctx context.Context, file io.Reader, filePath string) error
• type GCSStore
  • func (c *GCSStore) Download(_ context.Context, _ string) (io.ReadCloser, error)
  • func (c *GCSStore) GetSignedURL(ctx context.Context, filePath string) (string, error)
  • func (c *GCSStore) Upload(ctx context.Context, file io.Reader, filePath string) error
• type Provider
• type Store
  • func NewFileSystemStore(cfg Config) (Store, error)
  • func NewGCSStore(ctx context.Context, cfg Config) (Store, error)
  • func ProvideStore(ctx context.Context, config Config) (Store, error)

Variables

var (
	ErrNotFound     = errors.New("resource not found")
	ErrNotSupported = errors.New("not supported")
)

var WireSet = wire.NewSet(
	ProvideStore,
)

Types

type Config

type Config struct {
	Provider              Provider
	Bucket                string
	KeyPath               string
	TargetPrincipal       string
	ImpersonationLifetime time.Duration
}

type FileSystemStore

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

func (*FileSystemStore) Download

func (c *FileSystemStore) Download(_ context.Context, filePath string) (io.ReadCloser, error)

func (FileSystemStore) GetSignedURL

func (c FileSystemStore) GetSignedURL(_ context.Context, _ string) (string, error)

func (FileSystemStore) Upload

func (c FileSystemStore) Upload(ctx context.Context,
	file io.Reader,
	filePath string,
) error

type GCSStore

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

func (*GCSStore) Download

func (c *GCSStore) Download(_ context.Context, _ string) (io.ReadCloser, error)

func (*GCSStore) GetSignedURL

func (c *GCSStore) GetSignedURL(ctx context.Context, filePath string) (string, error)

func (*GCSStore) Upload

func (c *GCSStore) Upload(ctx context.Context, file io.Reader, filePath string) error

type Provider

type Provider string

const (
	ProviderGCS        Provider = "gcs"
	ProviderFileSystem Provider = "filesystem"
)

type Store

type Store interface {
	// Upload uploads a file to the blob store.
	Upload(ctx context.Context, file io.Reader, filePath string) error

	// GetSignedURL returns the URL for a file in the blob store.
	GetSignedURL(ctx context.Context, filePath string) (string, error)

	// Download returns a reader for a file in the blob store.
	Download(ctx context.Context, filePath string) (io.ReadCloser, error)
}

func NewFileSystemStore

func NewFileSystemStore(cfg Config) (Store, error)

func NewGCSStore

func NewGCSStore(ctx context.Context, cfg Config) (Store, error)

func ProvideStore

func ProvideStore(ctx context.Context, config Config) (Store, error)