migration

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
	Query                   string // query to list workflows for replication
	ConcurrentActivityCount int
	RpsPerActivity          int    // RPS per each activity
	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
}

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
}