migration

Documentation

Index

• Variables
• func ForceReplicationWorkflow(ctx workflow.Context, params ForceReplicationParams) error
• func ForceTaskQueueUserDataReplicationWorkflow(ctx workflow.Context, params TaskQueueUserDataReplicationParamsWithNamespace) error
• func NamespaceHandoverWorkflow(ctx workflow.Context, params NamespaceHandoverParams) (retErr error)
• func NewResult(params initParams) fxResult
• type ForceReplicationParams
• type ForceReplicationStatus
• type NamespaceHandoverParams
• type SkippedWorkflowExecution
• type TaskQueueUserDataReplicationParams
• type TaskQueueUserDataReplicationParamsWithNamespace
• type TaskQueueUserDataReplicationStatus

Variables

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

Functions

func ForceReplicationWorkflow

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

func ForceTaskQueueUserDataReplicationWorkflow

func ForceTaskQueueUserDataReplicationWorkflow(ctx workflow.Context, params TaskQueueUserDataReplicationParamsWithNamespace) 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 `validate:"required"`
	Query                   string `validate:"required"` // 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 for verifying workflow executions were replicated successfully on target cluster.
	EnableVerification      bool
	TargetClusterEndpoint   string `validate:"required"`
	VerifyIntervalInSeconds int    `validate:"gte=0"`
	RetentionBiasInSeconds  int    `validate:"gte=0"`

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

	// Carry over the replication status after continue-as-new.
	TaskQueueUserDataReplicationStatus TaskQueueUserDataReplicationStatus
}

type ForceReplicationStatus

type ForceReplicationStatus struct {
	LastCloseTime                      time.Time
	LastStartTime                      time.Time
	TaskQueueUserDataReplicationStatus TaskQueueUserDataReplicationStatus
	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
}

type SkippedWorkflowExecution

type SkippedWorkflowExecution struct {
	WorkflowExecution commonpb.WorkflowExecution
	Reason            string
}

type TaskQueueUserDataReplicationParams

type TaskQueueUserDataReplicationParams struct {
	// PageSize for the SeedReplicationQueueWithUserDataEntries activity
	PageSize int
	// RPS limits the number of task queue user data entries pages requested per second.
	RPS float64
}

type TaskQueueUserDataReplicationParamsWithNamespace

type TaskQueueUserDataReplicationParamsWithNamespace struct {
	TaskQueueUserDataReplicationParams
	// Namespace name
	Namespace string
}

TaskQueueUserDataReplicationParamsWithNamespace is used for child workflow / activity input

type TaskQueueUserDataReplicationStatus

type TaskQueueUserDataReplicationStatus struct {
	Done           bool
	FailureMessage string
}