migration

type CatchUpOutput struct{}

type CatchUpParams struct {
	Namespace      string
	CatchupCluster string
	TargetCluster  string
}

type ExecutionInfo struct {
	BusinessID  string `json:"business_id,omitempty"`
	RunID       string `json:"run_id,omitempty"`
	ArchetypeID uint32 `json:"archetype_id,omitempty"`
}

type ForceReplicationOutput struct {
}

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
	GetParentInfoRPS        float64 // RPS for getting parent child info
	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
	TargetClusterName       string
	VerifyIntervalInSeconds int `validate:"gte=0"`

	// Used by query handler to indicate overall progress of replication
	LastCloseTime                      time.Time
	LastStartTime                      time.Time
	ContinuedAsNewCount                int
	TaskQueueUserDataReplicationParams TaskQueueUserDataReplicationParams
	ReplicatedWorkflowCount            int64
	TotalForceReplicateWorkflowCount   int64
	ReplicatedWorkflowCountPerSecond   float64

	// Used to calculate QPS
	QPSQueue QPSQueue
	// Queue size is determined by Multiplier * Concurrency
	EstimationMultiplier int

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

type ForceReplicationStatus struct {
	LastCloseTime                      time.Time
	LastStartTime                      time.Time
	TaskQueueUserDataReplicationStatus TaskQueueUserDataReplicationStatus
	ContinuedAsNewCount                int
	TotalWorkflowCount                 int64
	ReplicatedWorkflowCount            int64
	ReplicatedWorkflowCountPerSecond   float64
	PageTokenForRestart                []byte
}

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 QPSData struct {
	Count     int64
	Timestamp time.Time
}

type QPSQueue struct {
	MaxSize int
	Data    []QPSData
}

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 struct {
	TaskQueueUserDataReplicationParams
	// Namespace name
	Namespace string
}

type TaskQueueUserDataReplicationStatus struct {
	Done           bool
	FailureMessage string
}

type WorkflowVerifier func(
	ctx context.Context,
	request *verifyReplicationTasksRequest,
	remoteAdminClient adminservice.AdminServiceClient,
	localAdminClient adminservice.AdminServiceClient,
	ns *namespace.Namespace,
	execution *ExecutionInfo,
	mu *adminservice.DescribeMutableStateResponse,
) (verifyResult, error)