worker

README

Chorus worker

Processes replication tasks from Asynq work queue. Hosts management GRPC api on port :9670 and the same management api but in REST format on port :9671.

Worker using rclone to copy object content and additionally sync tags and ACLs.

Usage

Set s3 storage and redis credentials to config and run.

Documentation

Index

• func Start(ctx context.Context, app dom.AppInfo, conf *Config) error
• type Config
  • func GetConfig(src ...config.Src) (*Config, error)
  • func (c *Config) Validate() error
• type Lock

Functions

func Start

func Start(ctx context.Context, app dom.AppInfo, conf *Config) error

Types

type Config

type Config struct {
	config.Common `yaml:",inline,omitempty" mapstructure:",squash"`
	Storage       *s3.StorageConfig `yaml:"storage,omitempty"`

	Concurrency     int           `yaml:"concurrency"`
	ShutdownTimeout time.Duration `yaml:"shutdownTimeout"`

	Api    *api.Config     `yaml:"api,omitempty"`
	RClone *rclone.Config  `yaml:"rclone,omitempty"`
	Lock   *Lock           `yaml:"lock,omitempty"`
	Worker *handler.Config `yaml:"worker,omitempty"`
}

func GetConfig

func GetConfig(src ...config.Src) (*Config, error)

func (*Config) Validate

func (c *Config) Validate() error

type Lock

type Lock struct {
	Overlap time.Duration `yaml:"overlap"`
}