Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrEmptyDomainReplicationTask is the error to indicate empty replication task ErrEmptyDomainReplicationTask = errors.New("empty domain replication task") // ErrInvalidDomainOperation is the error to indicate empty domain operation attribute ErrInvalidDomainOperation = errors.New("invalid domain operation attribute") // ErrInvalidDomainID is the error to indicate empty rID attribute ErrInvalidDomainID = errors.New("invalid domain ID attribute") // ErrInvalidDomainInfo is the error to indicate empty info attribute ErrInvalidDomainInfo = errors.New("invalid domain info attribute") // ErrInvalidDomainConfig is the error to indicate empty config attribute ErrInvalidDomainConfig = errors.New("invalid domain config attribute") // ErrInvalidDomainReplicationConfig is the error to indicate empty replication config attribute ErrInvalidDomainReplicationConfig = errors.New("invalid domain replication config attribute") // ErrInvalidDomainConfigVersion is the error to indicate empty config version attribute ErrInvalidDomainConfigVersion = errors.New("invalid domain config version attribute") // ErrInvalidDomainFailoverVersion is the error to indicate empty failover version attribute ErrInvalidDomainFailoverVersion = errors.New("invalid domain failover version attribute") // ErrInvalidDomainStatus is the error to indicate invalid domain status ErrInvalidDomainStatus = errors.New("invalid domain status attribute") )
View Source
var ( // ErrEmptyReplicationTask is the error to indicate empty replication task ErrEmptyReplicationTask = errors.New("empty replication task") // ErrUnknownReplicationTask is the error to indicate unknown replication task type ErrUnknownReplicationTask = errors.New("unknown replication task") )
Functions ¶
func NewService ¶
func NewService(params *service.BootstrapParams) common.Daemon
NewService builds a new cadence-worker service
Types ¶
type Config ¶
type Config struct { // Replicator settings ReplicatorConcurrency int }
Config contains all the service config for worker
type DomainReplicator ¶
type DomainReplicator interface {
HandleReceivingTask(task *replicator.DomainTaskAttributes) error
}
DomainReplicator is the interface which can replicate the domain
func NewDomainReplicator ¶
func NewDomainReplicator(metadataManager persistence.MetadataManager, logger bark.Logger) DomainReplicator
NewDomainReplicator create a new instance odf domain replicator
type Replicator ¶
type Replicator struct {
// contains filtered or unexported fields
}
Replicator is the processor for replication tasks
func NewReplicator ¶
func NewReplicator(clusterMetadata cluster.Metadata, metadataManager persistence.MetadataManager, config *Config, client messaging.Client, logger bark.Logger, metricsClient metrics.Client) *Replicator
NewReplicator creates a new replicator for processing replication tasks
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service represents the cadence-worker service. This service host all background processing which needs to happen for a Cadence cluster. This service runs the replicator which is responsible for applying replication tasks generated by remote clusters.
Click to show internal directories.
Click to hide internal directories.