storage

Documentation

Index

• Constants
• Variables
• type Config
• type Minio
  • func (m *Minio) PodEnvVars() map[string]string
  • func (m *Minio) Type() string
• type S3
  • func (s *S3) AccessData() map[string][]byte
  • func (s *S3) K8sSecretName() string
  • func (s *S3) PodEnvVars() map[string]string
  • func (s *S3) Type() string
  • func (s *S3) UploadFile(path string, file io.ReadSeeker) error
• type S3Client
• type Storage
  • func New(conf *Config) (Storage, error)
  • func NewFake() Storage

Constants

const (
	S3Type    storageType = "s3"
	MinioType storageType = "minio"
	FakeType  storageType = "fake"
)

Variables

var (
	ErrInvalidStorageType = errors.New("Invalid storage type")
)

Types

type Config

type Config struct {
	Type                storageType `envconfig:"type" default:"s3"`
	AwsKey              string      `envconfig:"aws_key"`
	AwsSecret           string      `envconfig:"aws_secret"`
	AwsRegion           string      `envconfig:"aws_region"`
	AwsBucket           string      `envconfig:"aws_bucket"`
	AwsEndpoint         string      `envconfig:"aws_endpoint" default:""`
	AwsDisableSSL       bool        `envconfig:"aws_disable_ssl" default:"false"`
	AwsS3ForcePathStyle bool        `envconfig:"aws_s3_force_path_style" default:"false"`
}

type Minio

type Minio struct {
	Storage
}

func (*Minio) PodEnvVars

func (m *Minio) PodEnvVars() map[string]string

func (*Minio) Type

func (m *Minio) Type() string

type S3

type S3 struct {
	Client           S3Client
	Key              string
	Secret           string
	Region           string
	Bucket           string
	Endpoint         string
	DisableSSL       bool
	S3ForcePathStyle bool
}

func (*S3) AccessData

func (s *S3) AccessData() map[string][]byte

func (*S3) K8sSecretName

func (s *S3) K8sSecretName() string

func (*S3) PodEnvVars

func (s *S3) PodEnvVars() map[string]string

func (*S3) Type

func (s *S3) Type() string

func (*S3) UploadFile

func (s *S3) UploadFile(path string, file io.ReadSeeker) error

type S3Client

type S3Client interface {
	PutObject(*s3.PutObjectInput) (*s3.PutObjectOutput, error)
}

type Storage

type Storage interface {
	K8sSecretName() string
	AccessData() map[string][]byte
	UploadFile(path string, file io.ReadSeeker) error
	Type() string
	PodEnvVars() map[string]string
}

func New

func New(conf *Config) (Storage, error)

func NewFake

func NewFake() Storage