usp_s3

Documentation

Index

• type S3Adapter
  • func NewS3Adapter(ctx context.Context, conf S3Config) (*S3Adapter, chan struct{}, error)
  • func (a *S3Adapter) Close() error
• type S3Config
  • func (c *S3Config) Validate() error

Types

type S3Adapter

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

func NewS3Adapter

func NewS3Adapter(ctx context.Context, conf S3Config) (*S3Adapter, chan struct{}, error)

func (*S3Adapter) Close

func (a *S3Adapter) Close() error

type S3Config

type S3Config struct {
	ClientOptions uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	BucketName    string                  `json:"bucket_name" yaml:"bucket_name"`
	AccessKey     string                  `json:"access_key" yaml:"access_key"`
	SecretKey     string                  `json:"secret_key,omitempty" yaml:"secret_key,omitempty"`
	IsOneTimeLoad bool                    `json:"single_load" yaml:"single_load"`
	Prefix        string                  `json:"prefix" yaml:"prefix"`
	ParallelFetch int                     `json:"parallel_fetch" yaml:"parallel_fetch"`
	Region        string                  `json:"region" yaml:"region"`
}

func (*S3Config) Validate

func (c *S3Config) Validate() error