worker

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 15, 2025 License: Apache-2.0 Imports: 33 Imported by: 0

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

Constants

This section is empty.

Variables

View Source 
var ErrRetryDelayFunc = asynq.DefaultRetryDelayFunc

override in e2e test for short retry

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.