replication

Documentation

Index

• Variables
• func ForceReplicationWorkflow(ctx workflow.Context, params ForceReplicationParams) error
• func NamespaceHandoverWorkflow(ctx workflow.Context, params NamespaceHandoverParams) error
• func NewResult(params initParams) fxResult
• type ForceReplicationParams
• type NamespaceHandoverParams

Variables

var Module = fx.Options(
	fx.Provide(NewResult),
)

Functions

func ForceReplicationWorkflow

func ForceReplicationWorkflow(ctx workflow.Context, params ForceReplicationParams) error

func NamespaceHandoverWorkflow

func NamespaceHandoverWorkflow(ctx workflow.Context, params NamespaceHandoverParams) error

func NewResult

func NewResult(params initParams) fxResult

Types

type ForceReplicationParams

type ForceReplicationParams struct {
	Namespace               string
	SkipAfterTime           time.Time // skip workflows that are updated after this time
	ConcurrentActivityCount int32
	RemoteCluster           string // remote cluster name
}

type NamespaceHandoverParams

type NamespaceHandoverParams struct {
	Namespace     string
	RemoteCluster string

	// how far behind on replication is allowed for remote cluster before handover is initiated
	AllowedLaggingSeconds int
	// how long to wait for handover to complete before rollback
	HandoverTimeoutSeconds int
}