syncer

Documentation

Index

• Variables
• type LocalSyncer
  • func (s *LocalSyncer) Persistent(ctx context.Context, key string, data io.Reader) (string, error)
  • func (s *LocalSyncer) PickOne(ctx context.Context) (string, error)
• type Option
• type S3Syncer
  • func (s *S3Syncer) Persistent(ctx context.Context, key string, data io.Reader) (string, error)
  • func (s *S3Syncer) PickOne(ctx context.Context) (string, error)
• type Synchronizer
  • func NewLocalSyncer(dir string) (Synchronizer, error)
  • func NewS3Syncer(opt *Option) (Synchronizer, error)

Variables

var (
	ErrorIsNotDirectory = errors.New("the input dir is not a directory")
	ErrorEmptyDirectory = errors.New("the dir is empty")
)

var (
	ErrorNilOption = errors.New("the option is not set")
)

Types

type LocalSyncer

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

func (*LocalSyncer) Persistent

func (s *LocalSyncer) Persistent(ctx context.Context, key string, data io.Reader) (string, error)

func (*LocalSyncer) PickOne

func (s *LocalSyncer) PickOne(ctx context.Context) (string, error)

type Option

type Option struct {
	Endpoint     string
	AccessID     string
	AccessSecret string
	BucketName   string
	Region       string
}

type S3Syncer

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

func (*S3Syncer) Persistent

func (s *S3Syncer) Persistent(ctx context.Context, key string, data io.Reader) (string, error)

func (*S3Syncer) PickOne

func (s *S3Syncer) PickOne(ctx context.Context) (string, error)

type Synchronizer

type Synchronizer interface {
	// Persistent - save data
	Persistent(ctx context.Context, key string, data io.Reader) (location string, err error)

	// PickOne - randomly pick one
	PickOne(ctx context.Context) (location string, err error)
}

Synchronizer - sync remote data into local

func NewLocalSyncer

func NewLocalSyncer(dir string) (Synchronizer, error)

func NewS3Syncer

func NewS3Syncer(opt *Option) (Synchronizer, error)