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"`

	Api    *api.Config    `yaml:"api,omitempty"`
	RClone *rclone.Config `yaml:"rclone,omitempty"`
	Lock   *Lock          `yaml:"lock,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"`
}