controller

Documentation

Index

• type BucketSource
• type Controller
  • func NewController(db *storage.KVStore, bucketSources map[string]config.Bucket, ...) (*Controller, error)
  • func (c *Controller) Close() error
  • func (c *Controller) Get(ctx context.Context, bucket, key string) ([]byte, error)
  • func (c *Controller) SaveDir(ctx context.Context, dir, bucketName string) error
  • func (c *Controller) SyncJob(ctx context.Context) error
  • func (c *Controller) SyncSource(ctx context.Context, s BucketSource) error
• type DirSource
  • func (s *DirSource) GetBucket() string
  • func (s *DirSource) Sync(ctx context.Context) (string, string, error)
• type GitSource
  • func (s *GitSource) GetBucket() string
  • func (s *GitSource) Sync(ctx context.Context) (string, string, error)
  • func (s *GitSource) WithLogger(l *zap.Logger)
• type OptionFunc
  • func WithLogger(l *zap.Logger) OptionFunc

Types

type BucketSource

type BucketSource interface {
	// Sync returns (local dir path, bucketname , error)
	Sync(ctx context.Context) (string, string, error)
	GetBucket() string
}

type Controller

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

func NewController

func NewController(db *storage.KVStore, bucketSources map[string]config.Bucket, options ...OptionFunc) (*Controller, error)

func (*Controller) Close

func (c *Controller) Close() error

func (*Controller) Get

func (c *Controller) Get(ctx context.Context, bucket, key string) ([]byte, error)

func (*Controller) SaveDir

func (c *Controller) SaveDir(ctx context.Context, dir, bucketName string) error

func (*Controller) SyncJob

func (c *Controller) SyncJob(ctx context.Context) error

func (*Controller) SyncSource

func (c *Controller) SyncSource(ctx context.Context, s BucketSource) error

type DirSource

type DirSource struct {
	BucketName string
	Dir        string
	// contains filtered or unexported fields
}

func (*DirSource) GetBucket

func (s *DirSource) GetBucket() string

func (*DirSource) Sync

func (s *DirSource) Sync(ctx context.Context) (string, string, error)

type GitSource

type GitSource struct {
	BucketName string

	LocalDir        string
	GitRepo         string
	GitRelativePath string
	GitUsername     string
	GitPasswordEnv  string
	// contains filtered or unexported fields
}

func (*GitSource) GetBucket

func (s *GitSource) GetBucket() string

func (*GitSource) Sync

func (s *GitSource) Sync(ctx context.Context) (string, string, error)

func (*GitSource) WithLogger

func (s *GitSource) WithLogger(l *zap.Logger)

type OptionFunc

type OptionFunc func(c *Controller)

func WithLogger

func WithLogger(l *zap.Logger) OptionFunc