worker

Jul 24, 2019

Changes in this version

type Config

+ BatcherCfg *batcher.Config

+ EnableBatcher dynamicconfig.BoolPropertyFn

May 8, 2019

Changes in this version

type Config

+ ArchiverConfig *archiver.Config

+ ScannerCfg *scanner.Config

+ ThrottledLogRPS dynamicconfig.IntPropertyFn

Feb 12, 2019

Changes in this version

type Config

+ IndexerCfg *indexer.Config

Jan 7, 2019

Changes in this version

+ const FrontendRetryLimit

+ const PollingDelay

type Config

+ ReplicationCfg *replicator.Config

+ SysWorkflowCfg *sysworkflow.Config

Jul 24, 2018

Changes in this version

+ var ErrDeserializeReplicationTask = &shared.BadRequestError

type Config

+ PersistenceMaxQPS dynamicconfig.FloatPropertyFn

+ ReplicationTaskMaxRetry int

+ ReplicatorBufferRetryCount int

Mar 12, 2018

Changes in this version

+ var ErrEmptyDomainReplicationTask = errors.New("empty domain replication task")

+ var ErrEmptyReplicationTask = errors.New("empty replication task")

+ var ErrInvalidDomainConfig = errors.New("invalid domain config attribute")

+ var ErrInvalidDomainConfigVersion = errors.New("invalid domain config version attribute")

+ var ErrInvalidDomainFailoverVersion = errors.New("invalid domain failover version attribute")

+ var ErrInvalidDomainID = errors.New("invalid domain ID attribute")

+ var ErrInvalidDomainInfo = errors.New("invalid domain info attribute")

+ var ErrInvalidDomainOperation = errors.New("invalid domain operation attribute")

+ var ErrInvalidDomainReplicationConfig = errors.New("invalid domain replication config attribute")

+ var ErrInvalidDomainStatus = errors.New("invalid domain status attribute")

+ var ErrUnknownReplicationTask = errors.New("unknown replication task")

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

+ type Config struct

+ ReplicatorConcurrency int

+ func NewConfig() *Config

+ type DomainReplicator interface

+ HandleReceivingTask func(task *replicator.DomainTaskAttributes) error

+ func NewDomainReplicator(metadataManager persistence.MetadataManager, logger bark.Logger) DomainReplicator

+ type Replicator struct

+ func NewReplicator(clusterMetadata cluster.Metadata, metadataManager persistence.MetadataManager, ...) *Replicator

+ func (r *Replicator) Start() error

+ func (r *Replicator) Stop()

+ type Service struct

+ func (s *Service) Start()

+ func (s *Service) Stop()