activecluster

type ChangeType string

type ClusterNotFoundForRegionError struct {
	ClusterName string
	Region      string
}

type DomainIDToDomainFn func(id string) (*cache.DomainCacheEntry, error)

type ExternalEntity struct {
	Source          string
	Key             string
	Region          string
	FailoverVersion int64
}

type ExternalEntityProvider interface {
	SupportedSource() string
	ChangeEvents() <-chan ChangeType
	GetExternalEntity(ctx context.Context, entitySKey string) (*ExternalEntity, error)
}

type LookupResult struct {
	Region          string
	ClusterName     string
	FailoverVersion int64
}

type Manager interface {
	common.Daemon

	// FailoverVersionOfNewWorkflow returns failover version of given new workflow.
	//  1. If domain is local:
	//     	Returns domain entry's failover version.
	//  2. If domain is active-passive global:
	//     	Returns domain entry's failover version.
	//  3. If domain is active-active global:
	//     	3.1. if workflow is region sticky, returns failover version of current cluster.
	//     	3.2. if workflow has external entity, returns failover version of corresponding row in EntityActiveRegion lookup table.
	FailoverVersionOfNewWorkflow(ctx context.Context, req *types.HistoryStartWorkflowExecutionRequest) (int64, error)

	// LookupWorkflow returns active cluster, region and failover version of given workflow.
	// Returns the info from domain entry for local and active-passive domains
	//
	// Active-active domain logic:
	//  1. Get ActivenessMetadata record of the workflow
	//     1.a. If it's found, continue with step 2
	//     1.b. If it's not found, the domain is migrated from active-passive to active-active and workflow is created before migration.
	//     This case will fallback to active-passive logic and return domain's ActiveClusterName and FailoverVersion.
	//  2. Given ActivenessMetadata, return region and failover version
	//     2.a. If workflow is region sticky (origin=regionA), find active cluster in that region in domain's active cluster config and return its name and failover version.
	//     2.b. If workflow has external entity, locate the entity from EntityActiveRegion table and return that region and it's failover version.
	LookupWorkflow(ctx context.Context, domainID, wfID, rID string) (*LookupResult, error)

	// ClusterNameForFailoverVersion returns cluster name of given failover version.
	// For local domains, it returns current cluster name.
	// For active-passive global domains, it returns the cluster name based on cluster metadata that corresponds to the failover version.
	// For active-active global domains, it returns the cluster name based on cluster & region metadata that corresponds to the failover version.
	ClusterNameForFailoverVersion(failoverVersion int64, domainID string) (string, error)

	// RegisterChangeCallback registers a callback that will be called for change events such as entity map changes.
	RegisterChangeCallback(shardID int, callback func(ChangeType))

	// UnregisterChangeCallback unregisters a callback that will be called for change events.
	UnregisterChangeCallback(shardID int)
}

type ManagerOption func(*managerImpl)

type MockExternalEntityProvider struct {
	// contains filtered or unexported fields
}

type MockExternalEntityProviderMockRecorder struct {
	// contains filtered or unexported fields
}

type MockManager struct {
	// contains filtered or unexported fields
}

type MockManagerMockRecorder struct {
	// contains filtered or unexported fields
}

type RegionNotFoundForDomainError struct {
	Region   string
	DomainID string
}

type WorkflowActivenessMetadata struct {
	Type WorkflowActivenessType

	// Region is the origin region of the workflow.
	// It's set for region sticky workflows.
	Region string

	// EntityKey is the key of the external entity associated with the workflow.
	// It's set for workflows with external entity associations.
	EntityKey string

	// EntitySource is the source of the external entity.
	// It's set for workflows with external entity associations.
	EntitySource string
}

type WorkflowActivenessType string