activecluster

type ChangeType string

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

type LookupResult struct {
	Region          string
	ClusterName     string
	FailoverVersion int64
}

type Manager interface {
	common.Daemon

	// LookupExternalEntity returns active cluster, cluster name and failover version of given external entity.
	// Only active-active global domains can have external entities.
	// For each entity type, there must be a corresponding watcher populating EntityActiveRegion table.
	// LookupExternalEntity will return the active cluster name and failover version by checking EntityActiveRegion table.
	LookupExternalEntity(ctx context.Context, entityType, entityKey string) (*LookupResult, error)

	// LookupExternalEntityOfNewWorkflow returns active cluster, cluster name and failover version of given new workflow.
	// Exactly same as LookupExternalEntity except it extracts entityType and entityKey from the start request.
	LookupExternalEntityOfNewWorkflow(ctx context.Context, req *types.HistoryStartWorkflowExecutionRequest) (*LookupResult, error)

	// LookupWorkflow returns active cluster, cluster name and failover version of given workflow.
	//  1. If domain is local:
	//     	Returns current cluster name and domain entry's failover version.
	//  2. If domain is active-passive global:
	//     	Returns domain entry's ActiveClusterName and domain entry's failover version.
	//  3. If domain is active-active global:
	//     	Returns corresponding active cluster name and failover version by checking workflow's activeness metadata and EntityActiveRegion lookup table.
	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.
	// For active-active global domains, it returns the cluster name based on cluster & region metadata and domain's activeactive config.
	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 MockManager struct {
	// contains filtered or unexported fields
}

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