migration

Documentation

Index

• Variables
• func ForceReplicationWorkflow(ctx workflow.Context, params ForceReplicationParams) error
• func NamespaceHandoverWorkflow(ctx workflow.Context, params NamespaceHandoverParams) (retErr error)
• func NewResult(params initParams) fxResult
• type ForceReplicationParams
• type ForceReplicationStatus
• 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) (retErr error)

func NewResult

func NewResult(params initParams) fxResult

Types

type ForceReplicationParams

type ForceReplicationParams struct {
	Namespace               string
	Query                   string // query to list workflows for replication
	ConcurrentActivityCount int
	OverallRps              float64 // RPS for enqueuing of replication tasks
	ListWorkflowsPageSize   int     // PageSize of ListWorkflow, will paginate through results.
	PageCountPerExecution   int     // number of pages to be processed before continue as new, max is 1000.
	NextPageToken           []byte  // used by continue as new

	// Used by query handler to indicate overall progress of replication
	LastCloseTime       time.Time
	LastStartTime       time.Time
	ContinuedAsNewCount int
}

type ForceReplicationStatus

type ForceReplicationStatus struct {
	LastCloseTime       time.Time
	LastStartTime       time.Time
	ContinuedAsNewCount int
}

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
	AllowedLaggingTasks   int64

	// how long to wait for handover to complete before rollback
	HandoverTimeoutSeconds int
}