constants

Documentation

Index

• Variables

Variables

var (
	ErrDomainNotSet            = &types.BadRequestError{Message: "Domain not set on request."}
	ErrWorkflowExecutionNotSet = &types.BadRequestError{Message: "WorkflowExecution not set on request."}
	ErrTaskListNotSet          = &types.BadRequestError{Message: "Tasklist not set."}
	ErrRunIDNotValid           = &types.BadRequestError{Message: "RunID is not valid UUID."}
	ErrWorkflowIDNotSet        = &types.BadRequestError{Message: "WorkflowId is not set on request."}
	ErrSourceClusterNotSet     = &types.BadRequestError{Message: "Source Cluster not set on request."}
	ErrTimestampNotSet         = &types.BadRequestError{Message: "Timestamp not set on request."}
	ErrInvalidTaskType         = &types.BadRequestError{Message: "Invalid task type"}
	ErrHistoryHostThrottle     = &types.ServiceBusyError{Message: "History host rps exceeded"}
	ErrShuttingDown            = &types.InternalServiceError{Message: "Shutting down"}
)

var (
	// TestVersion is the workflow version for test
	TestVersion = cluster.TestCurrentClusterInitialFailoverVersion + (cluster.TestFailoverVersionIncrement * 5)
	// TestDomainID is the domainID for test
	TestDomainID = "deadbeef-0123-4567-890a-bcdef0123456"
	// TestDomainName is the domainName for test
	TestDomainName = "some random domain name"
	// TestRateLimitedDomainName is the domain name for testing task processing rate limits
	TestRateLimitedDomainName = "rate-limited-domain-0123-4567-890a-bcdef0123456"
	// TestRateLimitedDomainID is the domain ID for testing task processing rate limits
	TestRateLimitedDomainID = "rate-limited-domain"
	// TestUnknownDomainID is the domain ID for testing unknown domains
	TestUnknownDomainID = "unknown-domain-id"
	// TestWorkflowID is the workflowID for test
	TestWorkflowID = "random-workflow-id"
	// TestRunID is the workflow runID for test
	TestRunID = "0d00698f-08e1-4d36-a3e2-3bf109f5d2d6"
	// TestRequestID is the request ID for test
	TestRequestID = "143b22cd-dfac-4d59-9398-893f89d89df6"

	// TestClusterMetadata is the cluster metadata for test
	TestClusterMetadata = cluster.GetTestClusterMetadata(true)

	// TestLocalDomainEntry is the local domain cache entry for test
	TestLocalDomainEntry = cache.NewLocalDomainCacheEntryForTest(
		&persistence.DomainInfo{ID: TestDomainID, Name: TestDomainName},
		&persistence.DomainConfig{Retention: 1},
		cluster.TestCurrentClusterName,
	)

	// TestGlobalDomainEntry is the global domain cache entry for test
	TestGlobalDomainEntry = cache.NewGlobalDomainCacheEntryForTest(
		&persistence.DomainInfo{ID: TestDomainID, Name: TestDomainName},
		&persistence.DomainConfig{
			Retention:                1,
			VisibilityArchivalStatus: types.ArchivalStatusEnabled,
			VisibilityArchivalURI:    "test:///visibility/archival",
		},
		&persistence.DomainReplicationConfig{
			ActiveClusterName: cluster.TestCurrentClusterName,
			Clusters: []*persistence.ClusterReplicationConfig{
				{ClusterName: cluster.TestCurrentClusterName},
				{ClusterName: cluster.TestAlternativeClusterName},
			},
		},
		TestVersion,
	)

	// TestRateLimitedDomainEntry is the global domain cache entry for test
	TestRateLimitedDomainEntry = cache.NewGlobalDomainCacheEntryForTest(
		&persistence.DomainInfo{ID: TestRateLimitedDomainID, Name: TestRateLimitedDomainName},
		&persistence.DomainConfig{
			Retention:                1,
			VisibilityArchivalStatus: types.ArchivalStatusEnabled,
			VisibilityArchivalURI:    "test:///visibility/archival",
		},
		&persistence.DomainReplicationConfig{
			ActiveClusterName: cluster.TestCurrentClusterName,
			Clusters: []*persistence.ClusterReplicationConfig{
				{ClusterName: cluster.TestCurrentClusterName},
				{ClusterName: cluster.TestAlternativeClusterName},
			},
		},
		TestVersion,
	)

	// TestGlobalParentDomainEntry is the global parent domain cache entry for test
	TestGlobalParentDomainEntry = cache.NewGlobalDomainCacheEntryForTest(
		&persistence.DomainInfo{ID: TestDomainID, Name: TestDomainName},
		&persistence.DomainConfig{Retention: 1},
		&persistence.DomainReplicationConfig{
			ActiveClusterName: cluster.TestCurrentClusterName,
			Clusters: []*persistence.ClusterReplicationConfig{
				{ClusterName: cluster.TestCurrentClusterName},
				{ClusterName: cluster.TestAlternativeClusterName},
			},
		},
		TestVersion,
	)

	// TestGlobalTargetDomainEntry is the global target domain cache entry for test
	TestGlobalTargetDomainEntry = cache.NewGlobalDomainCacheEntryForTest(
		&persistence.DomainInfo{ID: TestDomainID, Name: TestDomainName},
		&persistence.DomainConfig{Retention: 1},
		&persistence.DomainReplicationConfig{
			ActiveClusterName: cluster.TestCurrentClusterName,
			Clusters: []*persistence.ClusterReplicationConfig{
				{ClusterName: cluster.TestCurrentClusterName},
				{ClusterName: cluster.TestAlternativeClusterName},
			},
		},
		TestVersion,
	)

	// TestGlobalChildDomainEntry is the global child domain cache entry for test
	TestGlobalChildDomainEntry = cache.NewGlobalDomainCacheEntryForTest(
		&persistence.DomainInfo{ID: TestDomainID, Name: TestDomainName},
		&persistence.DomainConfig{Retention: 1},
		&persistence.DomainReplicationConfig{
			ActiveClusterName: cluster.TestCurrentClusterName,
			Clusters: []*persistence.ClusterReplicationConfig{
				{ClusterName: cluster.TestCurrentClusterName},
				{ClusterName: cluster.TestAlternativeClusterName},
			},
		},
		TestVersion,
	)

	// TestGlobalStandbyDomainEntry is the global standby domain cache entry for test
	TestGlobalStandbyDomainEntry = cache.NewGlobalDomainCacheEntryForTest(
		&persistence.DomainInfo{ID: TestDomainID, Name: TestDomainName},
		&persistence.DomainConfig{
			Retention:                1,
			VisibilityArchivalStatus: types.ArchivalStatusEnabled,
			VisibilityArchivalURI:    "test:///visibility/archival",
		},
		&persistence.DomainReplicationConfig{
			ActiveClusterName: cluster.TestAlternativeClusterName,
			Clusters: []*persistence.ClusterReplicationConfig{
				{ClusterName: cluster.TestCurrentClusterName},
				{ClusterName: cluster.TestAlternativeClusterName},
			},
		},
		TestVersion,
	)
)