Back to

Package worker

Latest Go to latest

The latest major version is .

Published: Aug 27, 2019 | License: MIT | Module:


func NewService

func NewService(params *service.BootstrapParams) common.Daemon

NewService builds a new cadence-worker service

type Config

type Config struct {
	ReplicationCfg  *replicator.Config
	ArchiverConfig  *archiver.Config
	IndexerCfg      *indexer.Config
	ScannerCfg      *scanner.Config
	BatcherCfg      *batcher.Config
	ThrottledLogRPS dynamicconfig.IntPropertyFn
	EnableBatcher   dynamicconfig.BoolPropertyFn

Config contains all the service config for worker

func NewConfig

func NewConfig(params *service.BootstrapParams) *Config

NewConfig builds the new Config for cadence-worker service

type Service

type Service struct {
	// contains filtered or unexported fields

Service represents the cadence-worker service. This service hosts all background processing needed for cadence cluster: 1. Replicator: Handles applying replication tasks generated by remote clusters. 2. Indexer: Handles uploading of visibility records to elastic search. 3. Archiver: Handles archival of workflow histories.

func (*Service) Start

func (s *Service) Start()

Start is called to start the service

func (*Service) Stop

func (s *Service) Stop()

Stop is called to stop the service

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier