common

package
v1.32.1-x.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 17, 2026 License: MIT Imports: 36 Imported by: 0

Documentation

Overview

Package common is a generated GoMock package.

Index

Constants

View Source 
const (
	// FirstEventID is the id of the first event in the history
	FirstEventID int64 = 1
	// LastEventID is the id of the last possible event in the history
	LastEventID int64 = math.MaxInt64
	// EmptyEventID is the id of the empty event
	EmptyEventID int64 = 0
	// EmptyVersion is used as the default value for failover version when no value is provided
	EmptyVersion int64 = 0
	// EndEventID is the id of the end event, here we use the int64 max
	EndEventID int64 = 1<<63 - 1
	// BufferedEventID is the id of the buffered event
	BufferedEventID int64 = -123
	// EmptyEventTaskID is uninitialized id of the task id within event
	EmptyEventTaskID int64 = 0
	// TransientEventID is the id of the transient event
	TransientEventID int64 = -124
	// FirstBlobPageToken is the page token identifying the first blob for each history archival
	FirstBlobPageToken = 1
	// LastBlobNextPageToken is the next page token on the last blob for each history archival
	LastBlobNextPageToken = -1
	// EndMessageID is the id of the end message, here we use the int64 max
	EndMessageID int64 = 1<<63 - 1
)
View Source 
const (
	// DefaultLongPollTimeout is the default context timeout for a long poll request.
	DefaultLongPollTimeout = time.Second * 60
	// DefaultLongPollBuffer is the buffer used to adjust a long poll request timeout.
	// Specifically, long poll requests are timed out at a time which leaves at least the buffer's duration
	// remaining before the caller's deadline, if permitted by the caller's deadline.
	DefaultLongPollBuffer = time.Second
	// MinLongPollTimeout is the minimum context timeout for a long poll request, below which
	// the request won't be processed.
	MinLongPollTimeout = time.Second * 2
	// CriticalLongPollTimeout is a threshold for the context timeout passed into a long poll request,
	// below which a warning will be logged
	CriticalLongPollTimeout = time.Second * 10
)
View Source 
const (
	// Limit for schedule notes field
	ScheduleNotesSizeLimit = 1000

	ScheduledTaskMinPrecision = time.Millisecond
)
View Source 
const (

	// DaemonStatusInitialized coroutine pool initialized
	DaemonStatusInitialized int32 = 0
	// DaemonStatusStarted coroutine pool started
	DaemonStatusStarted int32 = 1
	// DaemonStatusStopped coroutine pool stopped
	DaemonStatusStopped int32 = 2
)
View Source 
const (

	// FailureReasonActivityTimeout is failureReason for when an activity times out, with %v as the timeout type.
	FailureReasonActivityTimeout = "activity %v timeout"
	// FailureReasonActivityRetryScheduleToCloseTimeout is failureReason for when an activity retry cannot be scheduled before its schedule-to-close timeout.
	FailureReasonActivityRetryScheduleToCloseTimeout = "Not enough time to schedule next retry before activity ScheduleToClose timeout, giving up retrying"
	// FailureReasonCompleteResultExceedsLimit is failureReason for complete result exceeds limit
	FailureReasonCompleteResultExceedsLimit = "Complete result exceeds size limit."
	// FailureReasonFailureDetailsExceedsLimit is failureReason for failure details exceeds limit
	FailureReasonFailureExceedsLimit = "Failure exceeds size limit."
	// FailureReasonCancelDetailsExceedsLimit is failureReason for cancel details exceeds limit
	FailureReasonCancelDetailsExceedsLimit = "Cancel details exceed size limit."
	// FailureReasonHeartbeatExceedsLimit is failureReason for heartbeat exceeds limit
	FailureReasonHeartbeatExceedsLimit = "Heartbeat details exceed size limit."
	// FailureReasonHistorySizeExceedsLimit is reason to fail workflow when history size exceeds limit
	FailureReasonHistorySizeExceedsLimit = "Workflow history size exceeds limit."
	// FailureReasonHistorySizeExceedsLimit is reason to fail workflow when history count exceeds limit
	FailureReasonHistoryCountExceedsLimit = "Workflow history count exceeds limit."
	// FailureReasonMutableStateSizeExceedsLimit is reason to fail workflow when mutable state size exceeds limit
	FailureReasonMutableStateSizeExceedsLimit = "Workflow mutable state size exceeds limit."
	// FailureReasonTransactionSizeExceedsLimit is the failureReason for when transaction cannot be committed because it exceeds size limit
	FailureReasonTransactionSizeExceedsLimit = "Transaction size exceeds limit."
	// FailureReasonWorkflowTerminationDueToVersionConflict is the failureReason for when workflow is terminated due to version conflict
	FailureReasonWorkflowTerminationDueToVersionConflict = "Terminate Workflow Due To Version Conflict."
)
View Source 
const (
	// DefaultOperatorRPSRatio is the default percentage of rate limit that should be used for operator priority requests
	DefaultOperatorRPSRatio float64 = 0.2
)
View Source 
const (
	// DefaultQueueReaderID is the default readerID when loading history tasks
	DefaultQueueReaderID int64 = 0
)

Variables

View Source 
var (
	// ErrBlobSizeExceedsLimit is error for event blob size exceeds limit
	ErrBlobSizeExceedsLimit = serviceerror.NewInvalidArgument("Blob data size exceeds limit.")
	// ErrMemoSizeExceedsLimit is error for memo size exceeds limit
	ErrMemoSizeExceedsLimit = serviceerror.NewInvalidArgument("Memo size exceeds limit.")
	// ErrContextTimeoutTooShort is error for setting a very short context timeout when calling a long poll API
	ErrContextTimeoutTooShort = serviceerror.NewFailedPrecondition("Context timeout is too short.")
	// ErrContextTimeoutNotSet is error for not setting a context timeout when calling a long poll API
	ErrContextTimeoutNotSet = serviceerror.NewInvalidArgument("Context timeout is not set.")
)
View Source 
var (
	// ErrNamespaceHandover is error indicating namespace is in handover state and cannot process request.
	ErrNamespaceHandover = serviceerror.NewUnavailablef("Namespace replication in %s state.", enumspb.REPLICATION_STATE_HANDOVER)
)

Functions

func AwaitWaitGroup 

func AwaitWaitGroup(wg *sync.WaitGroup, timeout time.Duration) bool

AwaitWaitGroup calls Wait on the given wait Returns true if the Wait() call succeeded before the timeout Returns false if the Wait() did not return before the timeout

func BlockWithTimeout 

func BlockWithTimeout(fn func(), timeout time.Duration) bool

BlockWithTimeout invokes fn and waits for it to complete until the timeout. Returns true if the call completed before the timeout, otherwise returns false. fn is expected to be a blocking call and will continue to occupy a goroutine until it finally completes.

func CheckEventBlobSizeLimit 

func CheckEventBlobSizeLimit(
	actualSize int,
	warnLimit int,
	errorLimit int,
	namespace string,
	workflowID string,
	runID string,
	metricsHandler metrics.Handler,
	logger log.Logger,
	operation string,
) error

CheckEventBlobSizeLimit checks if a blob data exceeds limits. It logs a warning if it exceeds warnLimit, and return ErrBlobSizeExceedsLimit if it exceeds errorLimit.

func CloneProto 

func CloneProto[T proto.Message](v T) T

CloneProto is a generic typed version of proto.Clone from proto.

func CloneProtoMap 

func CloneProtoMap[K comparable, T proto.Message](src map[K]T) map[K]T

func CreateCompleteTaskRetryPolicy 

func CreateCompleteTaskRetryPolicy() backoff.RetryPolicy

CreateCompleteTaskRetryPolicy creates a retry policy for completing background tasks

func CreateDependencyTaskNotCompletedReschedulePolicy 

func CreateDependencyTaskNotCompletedReschedulePolicy() backoff.RetryPolicy

CreateDependencyTaskNotCompletedReschedulePolicy creates a retry policy for rescheduling task with ErrDependencyTaskNotCompleted

func CreateFrontendClientRetryPolicy 

func CreateFrontendClientRetryPolicy() backoff.RetryPolicy

CreateFrontendClientRetryPolicy creates a retry policy for calls to frontend service

func CreateFrontendHandlerRetryPolicy 

func CreateFrontendHandlerRetryPolicy() backoff.RetryPolicy

CreateFrontendHandlerRetryPolicy creates a retry policy for calls to frontend service

func CreateHistoryClientRetryPolicy 

func CreateHistoryClientRetryPolicy(retryUnboundedOnSystemResourceExhausted func() bool) backoff.RetryPolicy

CreateHistoryClientRetryPolicy creates a retry policy for calls to history service. When retryUnboundedOnSystemResourceExhausted returns true, system-scoped ResourceExhausted errors retry past the historyClientRetryMaxAttempts cap, bounded only by the policy's default 1-minute expiration interval and the caller's context. Other errors (and all errors when the flag is off) follow the standard cap.

func CreateHistoryHandlerRetryPolicy 

func CreateHistoryHandlerRetryPolicy() backoff.RetryPolicy

CreateHistoryHandlerRetryPolicy creates a retry policy for calls to history service

func CreateHistoryStartWorkflowRequest 

func CreateHistoryStartWorkflowRequest(
	namespaceID string,
	startRequest *workflowservice.StartWorkflowExecutionRequest,
	parentExecutionInfo *workflowspb.ParentExecutionInfo,
	rootExecutionInfo *workflowspb.RootExecutionInfo,
	now time.Time,
) *historyservice.StartWorkflowExecutionRequest

CreateHistoryStartWorkflowRequest create a start workflow request for history. Assumes startRequest is valid. See frontend workflow_handler for detailed validation logic.

func CreateMatchingClientLongPollRetryPolicy 

func CreateMatchingClientLongPollRetryPolicy() backoff.RetryPolicy

CreateMatchingClientLongPollRetryPolicy creates a retry policy for poll calls to matching service

func CreateMatchingClientRetryPolicy 

func CreateMatchingClientRetryPolicy(retryUnboundedOnSystemResourceExhausted func() bool) backoff.RetryPolicy

CreateMatchingClientRetryPolicy creates a retry policy for calls to matching service. When retryUnboundedOnSystemResourceExhausted returns true, system-scoped ResourceExhausted errors retry past the matchingClientRetryMaxAttempts cap, bounded only by the policy's default 1-minute expiration interval and the caller's context. Other errors (and all errors when the flag is off) follow the standard cap.

func CreateMatchingHandlerRetryPolicy 

func CreateMatchingHandlerRetryPolicy() backoff.RetryPolicy

CreateMatchingHandlerRetryPolicy creates a retry policy for calls to matching service

func CreateMatchingPollWorkflowTaskQueueResponse 

func CreateMatchingPollWorkflowTaskQueueResponse(historyResponse *historyservice.RecordWorkflowTaskStartedResponse, workflowExecution *commonpb.WorkflowExecution, token []byte) *matchingservice.PollWorkflowTaskQueueResponseWithRawHistory

CreateMatchingPollWorkflowTaskQueueResponse create response for matching's PollWorkflowTaskQueue

func CreatePersistenceClientRetryPolicy 

func CreatePersistenceClientRetryPolicy() backoff.RetryPolicy

CreatePersistenceClientRetryPolicy creates a retry policy for calls to persistence

func CreateReadTaskRetryPolicy 

func CreateReadTaskRetryPolicy() backoff.RetryPolicy

CreateReadTaskRetryPolicy creates a retry policy for loading background tasks

func CreateSdkClientFactoryRetryPolicy 

func CreateSdkClientFactoryRetryPolicy() backoff.RetryPolicy

CreateSdkClientFactoryRetryPolicy creates a retry policy to handle SdkClientFactory NewClient when frontend service is not ready

func CreateTaskNotReadyReschedulePolicy 

func CreateTaskNotReadyReschedulePolicy() backoff.RetryPolicy

CreateTaskNotReadyReschedulePolicy creates a retry policy for rescheduling task with ErrTaskRetry

func CreateTaskReschedulePolicy 

func CreateTaskReschedulePolicy() backoff.RetryPolicy

CreateTaskReschedulePolicy creates a retry policy for rescheduling task with errors not equal to ErrTaskRetry

func CreateTaskResourceExhaustedReschedulePolicy 

func CreateTaskResourceExhaustedReschedulePolicy() backoff.RetryPolicy

CreateTaskResourceExhaustedReschedulePolicy creates a retry policy for rescheduling task with resource exhausted error

func DiscardUnknownProto 

func DiscardUnknownProto(m proto.Message) error

DiscardUnknownProto discards unknown fields in a proto message.

func ErrorHash 

func ErrorHash(err error) string

func GenerateRandomString 

func GenerateRandomString(n int) string

GenerateRandomString is used for generate test string

func GetPayloadsMapSize 

func GetPayloadsMapSize(data map[string]*commonpb.Payloads) int

func IsContextCanceledErr 

func IsContextCanceledErr(err error) bool

IsContextCanceledErr checks if the error is context.Canceled or serviceerror.Canceled error

func IsContextDeadlineExceededErr 

func IsContextDeadlineExceededErr(err error) bool

IsContextDeadlineExceededErr checks if the error is context.DeadlineExceeded or serviceerror.DeadlineExceeded error

func IsInternalError 

func IsInternalError(err error) bool

IsInternalError checks if the error is an internal error.

func IsNamespaceHandoverError 

func IsNamespaceHandoverError(err error) bool

func IsNotFoundError 

func IsNotFoundError(err error) bool

IsNotFoundError checks if the error is a not found error.

func IsPersistenceTransientError 

func IsPersistenceTransientError(err error) bool

IsPersistenceTransientError checks if the error is a transient persistence error

func IsResourceExhausted 

func IsResourceExhausted(err error) bool

IsResourceExhausted checks if the error is a service busy error.

func IsRetryableRPCError 

func IsRetryableRPCError(err error) bool

IsRetryableRPCError checks if the error is a retryable gRPC error.

func IsServiceClientTransientError 

func IsServiceClientTransientError(err error) bool

IsServiceClientTransientError checks if the error is a transient error.

func IsServiceHandlerRetryableError 

func IsServiceHandlerRetryableError(err error) bool

func IsServiceTransientError 

func IsServiceTransientError(err error) bool

IsServiceTransientError checks if the error is a retryable error.

func IsStickyWorkerUnavailable 

func IsStickyWorkerUnavailable(err error) bool

func IsValidContext 

func IsValidContext(ctx context.Context) error

IsValidContext checks that the thrift context is not expired on cancelled. Returns nil if the context is still valid. Otherwise, returns the result of ctx.Err()

func MapShardID 

func MapShardID(
	sourceShardCount int32,
	targetShardCount int32,
	sourceShardID int32,
) []int32

func MergeProtoExcludingFields 

func MergeProtoExcludingFields(target, source proto.Message, doNotSyncFunc func(v any) []any) error

MergeProtoExcludingFields merges fields from source into target, excluding specific fields. The fields to exclude are specified as pointers to fields in the target struct.

func PrettyPrint 

func PrettyPrint[T proto.Message](msgs []T, header ...string)

func ValidateLongPollContextTimeout 

func ValidateLongPollContextTimeout(
	ctx context.Context,
	handlerName string,
	logger log.Logger,
) error

ValidateLongPollContextTimeout checks if the context timeout for a long poll handler is too short or below a normal value. If the timeout is not set or too short, it logs an error, and returns ErrContextTimeoutNotSet or ErrContextTimeoutTooShort accordingly. If the timeout is only below a normal value, it just logs an info and returns nil.

func ValidateLongPollContextTimeoutIsSet 

func ValidateLongPollContextTimeoutIsSet(
	ctx context.Context,
	handlerName string,
	logger log.Logger,
) (time.Time, error)

ValidateLongPollContextTimeoutIsSet checks if the context timeout is set for long poll requests.

func VerifyShardIDMapping 

func VerifyShardIDMapping(
	thisShardCount int32,
	thatShardCount int32,
	thisShardID int32,
	thatShardID int32,
) error

func WorkflowIDToHistoryShard 

func WorkflowIDToHistoryShard(
	namespaceID string,
	workflowID string,
	numberOfShards int32,
) int32

WorkflowIDToHistoryShard is used to map namespaceID-workflowID pair to a shardID. TODO: rename to BusinessIDToHistoryShard.

Types

type ClientCache 

type ClientCache interface {
	Lookup(key string, index int) (string, error) // pass through to keyResolver
	GetClientForKey(key string, index int) (any, error)
	GetClientForClientKey(clientKey string) (any, error)
	GetAllClients() ([]any, error)
	// Evict removes the cached entry for the given key and runs its
	// release fn.
	Evict(clientKey string)
	// EvictAll removes every cached entry and runs each one's release fn.
	// Used to deterministically release cached gRPC connections on shutdown.
	EvictAll()
}

ClientCache store initialized clients

func NewClientCache 

func NewClientCache(
	keyResolver keyResolver,
	clientProvider clientProvider,
	logger log.Logger,
) ClientCache

NewClientCache creates a new client cache based on membership

type FrontendHTTPClient 

type FrontendHTTPClient struct {
	http.Client
	// Address is the host:port pair of this HTTP client.
	Address string
	// Scheme is the URL scheme of this HTTP client.
	Scheme string
}

func (*FrontendHTTPClient) BaseURL 

func (c *FrontendHTTPClient) BaseURL() string

BaseURL is the scheme and address of this HTTP client.

type MockRPCFactory 

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

MockRPCFactory is a mock of RPCFactory interface.

func NewMockRPCFactory 

func NewMockRPCFactory(ctrl *gomock.Controller) *MockRPCFactory

NewMockRPCFactory creates a new mock instance.

func (*MockRPCFactory) CreateHistoryGRPCConnection 

func (m *MockRPCFactory) CreateHistoryGRPCConnection(rpcAddress string) *grpc.ClientConn

CreateHistoryGRPCConnection mocks base method.

func (*MockRPCFactory) CreateLocalFrontendGRPCConnection 

func (m *MockRPCFactory) CreateLocalFrontendGRPCConnection() *grpc.ClientConn

CreateLocalFrontendGRPCConnection mocks base method.

func (*MockRPCFactory) CreateLocalFrontendHTTPClient 

func (m *MockRPCFactory) CreateLocalFrontendHTTPClient() (*FrontendHTTPClient, error)

CreateLocalFrontendHTTPClient mocks base method.

func (*MockRPCFactory) CreateMatchingGRPCConnection 

func (m *MockRPCFactory) CreateMatchingGRPCConnection(rpcAddress string) *grpc.ClientConn

CreateMatchingGRPCConnection mocks base method.

func (*MockRPCFactory) CreateRemoteFrontendGRPCConnection 

func (m *MockRPCFactory) CreateRemoteFrontendGRPCConnection(rpcAddress string) *grpc.ClientConn

CreateRemoteFrontendGRPCConnection mocks base method.

func (*MockRPCFactory) EXPECT 

func (m *MockRPCFactory) EXPECT() *MockRPCFactoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRPCFactory) GetFrontendGRPCServerOptions 

func (m *MockRPCFactory) GetFrontendGRPCServerOptions() ([]grpc.ServerOption, error)

GetFrontendGRPCServerOptions mocks base method.

func (*MockRPCFactory) GetGRPCListener 

func (m *MockRPCFactory) GetGRPCListener() net.Listener

GetGRPCListener mocks base method.

func (*MockRPCFactory) GetInternodeGRPCServerOptions 

func (m *MockRPCFactory) GetInternodeGRPCServerOptions() ([]grpc.ServerOption, error)

GetInternodeGRPCServerOptions mocks base method.

type MockRPCFactoryMockRecorder 

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

MockRPCFactoryMockRecorder is the mock recorder for MockRPCFactory.

func (*MockRPCFactoryMockRecorder) CreateHistoryGRPCConnection 

func (mr *MockRPCFactoryMockRecorder) CreateHistoryGRPCConnection(rpcAddress any) *gomock.Call

CreateHistoryGRPCConnection indicates an expected call of CreateHistoryGRPCConnection.

func (*MockRPCFactoryMockRecorder) CreateLocalFrontendGRPCConnection 

func (mr *MockRPCFactoryMockRecorder) CreateLocalFrontendGRPCConnection() *gomock.Call

CreateLocalFrontendGRPCConnection indicates an expected call of CreateLocalFrontendGRPCConnection.

func (*MockRPCFactoryMockRecorder) CreateLocalFrontendHTTPClient 

func (mr *MockRPCFactoryMockRecorder) CreateLocalFrontendHTTPClient() *gomock.Call

CreateLocalFrontendHTTPClient indicates an expected call of CreateLocalFrontendHTTPClient.

func (*MockRPCFactoryMockRecorder) CreateMatchingGRPCConnection 

func (mr *MockRPCFactoryMockRecorder) CreateMatchingGRPCConnection(rpcAddress any) *gomock.Call

CreateMatchingGRPCConnection indicates an expected call of CreateMatchingGRPCConnection.

func (*MockRPCFactoryMockRecorder) CreateRemoteFrontendGRPCConnection 

func (mr *MockRPCFactoryMockRecorder) CreateRemoteFrontendGRPCConnection(rpcAddress any) *gomock.Call

CreateRemoteFrontendGRPCConnection indicates an expected call of CreateRemoteFrontendGRPCConnection.

func (*MockRPCFactoryMockRecorder) GetFrontendGRPCServerOptions 

func (mr *MockRPCFactoryMockRecorder) GetFrontendGRPCServerOptions() *gomock.Call

GetFrontendGRPCServerOptions indicates an expected call of GetFrontendGRPCServerOptions.

func (*MockRPCFactoryMockRecorder) GetGRPCListener 

func (mr *MockRPCFactoryMockRecorder) GetGRPCListener() *gomock.Call

GetGRPCListener indicates an expected call of GetGRPCListener.

func (*MockRPCFactoryMockRecorder) GetInternodeGRPCServerOptions 

func (mr *MockRPCFactoryMockRecorder) GetInternodeGRPCServerOptions() *gomock.Call

GetInternodeGRPCServerOptions indicates an expected call of GetInternodeGRPCServerOptions.

type RPCFactory 

type RPCFactory interface {
	GetFrontendGRPCServerOptions() ([]grpc.ServerOption, error)
	GetInternodeGRPCServerOptions() ([]grpc.ServerOption, error)
	GetGRPCListener() net.Listener
	CreateRemoteFrontendGRPCConnection(rpcAddress string) *grpc.ClientConn
	CreateLocalFrontendGRPCConnection() *grpc.ClientConn
	CreateHistoryGRPCConnection(rpcAddress string) *grpc.ClientConn
	CreateMatchingGRPCConnection(rpcAddress string) *grpc.ClientConn
	CreateLocalFrontendHTTPClient() (*FrontendHTTPClient, error)
}

RPCFactory creates gRPC listeners and connections, and frontend HTTP clients.

Source Files

View all Source files

Directories

Path Synopsis
Package archiver is a generated GoMock package.
 Package archiver is a generated GoMock package.
filestore
Package filestore is a generated GoMock package.
 Package filestore is a generated GoMock package.
gcloud
Package gcloud is a generated GoMock package.
 Package gcloud is a generated GoMock package.
gcloud/connector
Package connector is a generated GoMock package.
 Package connector is a generated GoMock package.
provider
Package provider is a generated GoMock package.
 Package provider is a generated GoMock package.
s3store
Package s3store is a generated GoMock package.
 Package s3store is a generated GoMock package.
s3store/mocks
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.
Package authorization is a generated GoMock package.
 Package authorization is a generated GoMock package.
Package cache is a generated GoMock package.
 Package cache is a generated GoMock package.
Package clock provides extensions to the time package.
 Package clock provides extensions to the time package.
hybrid_logical_clock
Package cluster is a generated GoMock package.
 Package cluster is a generated GoMock package.
clustertest
Package dynamicconfig is a generated GoMock package.
 Package dynamicconfig is a generated GoMock package.
Package fastrand exposes an object Rand which can be used as a simple drop-in replacement for `[math/rand.Rand]` where performance or thread safety is required.
 Package fastrand exposes an object Rand which can be used as a simple drop-in replacement for `[math/rand.Rand]` where performance or thread safety is required.
Package goro provides utilities for spawning and subsequently managing the liftime(s) of one or more goroutines.
 Package goro provides utilities for spawning and subsequently managing the liftime(s) of one or more goroutines.
Package links provides validation helpers for temporal.api.common.v1.Link values.
 Package links provides validation helpers for temporal.api.common.v1.Link values.
log
Package log is a generated GoMock package.
 Package log is a generated GoMock package.
tag
Package membership is a generated GoMock package.
 Package membership is a generated GoMock package.
ringpop
Package ringpop provides a service-based membership monitor
 Package ringpop provides a service-based membership monitor
static
Package metrics is a generated GoMock package.
 Package metrics is a generated GoMock package.
metricstest
tally/statsd
Package namespace is a generated GoMock package.
 Package namespace is a generated GoMock package.
nsmanager
nsregistry
Package nsregistry provides a cached namespace registry that reduces load on persistence by maintaining an in-memory cache of namespace information.
 Package nsregistry provides a cached namespace registry that reduces load on persistence by maintaining an in-memory cache of namespace information.
nsreplication
Package nsreplication is a generated GoMock package.
 Package nsreplication is a generated GoMock package.
nexusrpc
Package nexusrpc provides client and server implementations of the Nexus HTTP API [HTTP API]: https://github.com/nexus-rpc/api
 Package nexusrpc provides client and server implementations of the Nexus HTTP API [HTTP API]: https://github.com/nexus-rpc/api
nexustest
Package persistence is a generated GoMock package.
 Package persistence is a generated GoMock package.
cassandra
client
faultinjection
mock
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.
nosql/nosqlplugin/cassandra/gocql
nosql/nosqlplugin/cassandra/translator
persistence-tests
persistencetest
schema
serialization
sql
sql/sqlplugin
Package sqlplugin is a generated GoMock package.
 Package sqlplugin is a generated GoMock package.
sql/sqlplugin/mysql
sql/sqlplugin/mysql/session
sql/sqlplugin/postgresql
sql/sqlplugin/postgresql/driver
sql/sqlplugin/postgresql/session
sql/sqlplugin/sqlite
sql/sqlplugin/tests
telemetry
tests
transitionhistory
versionhistory
visibility
Package visibility is a generated GoMock package.
 Package visibility is a generated GoMock package.
visibility/manager
Package manager is a generated GoMock package.
 Package manager is a generated GoMock package.
visibility/store
Package store is a generated GoMock package.
 Package store is a generated GoMock package.
visibility/store/elasticsearch
Package elasticsearch is a generated GoMock package.
 Package elasticsearch is a generated GoMock package.
visibility/store/elasticsearch/client
Package client is a generated GoMock package.
 Package client is a generated GoMock package.
visibility/store/query
Package query is inspired and partially copied from by github.com/cch123/elasticsql.
 Package query is inspired and partially copied from by github.com/cch123/elasticsql.
visibility/store/sql
timestamp
Package quotas is a generated GoMock package.
 Package quotas is a generated GoMock package.
calculator
quotastest
Package resolver is a generated GoMock package.
 Package resolver is a generated GoMock package.
Package routing provides utilities to define a number of Route instances, which can be...
 Package routing provides utilities to define a number of Route instances, which can be...
rpc
auth
auth/authtest
Package authtest provides shared test helpers for the auth package.
 Package authtest provides shared test helpers for the auth package.
encryption
interceptor
Package interceptor is a generated GoMock package.
 Package interceptor is a generated GoMock package.
interceptor/logtags
Package sdk is a generated GoMock package.
 Package sdk is a generated GoMock package.
Package searchattribute is a generated GoMock package.
 Package searchattribute is a generated GoMock package.
sadefs
softassert provides utilities for performing assertions.
 softassert provides utilities for performing assertions.
Package tasks is a generated GoMock package.
 Package tasks is a generated GoMock package.
await
Package await provides polling-based test assertions as a replacement for testify's Eventually, EventuallyWithT, and their formatted variants.
 Package await provides polling-based test assertions as a replacement for testify's Eventually, EventuallyWithT, and their formatted variants.
fakedata
Package fakedata provides utilities for generating random data for testing.
 Package fakedata provides utilities for generating random data for testing.
freeport
historyrequire
mockapi
mockapi/operatorservicemock/v1
Package operatorservicemock is a generated GoMock package.
 Package operatorservicemock is a generated GoMock package.
mockapi/workflowservicemock/v1
Package workflowservicemock is a generated GoMock package.
 Package workflowservicemock is a generated GoMock package.
mocksdk
Package mocksdk is a generated GoMock package.
 Package mocksdk is a generated GoMock package.
nettest
Package nettest provides an in-memory socket, Pipe.
 Package nettest provides an in-memory socket, Pipe.
objectleak
parallelsuite
protoassert
Assert wraps testify's require package with useful helpers
 Assert wraps testify's require package with useful helpers
protomock
Proto-type adapters for the mock library
 Proto-type adapters for the mock library
protorequire
protoutils
rpctest
runtime
taskpoller
temporalapi
testcontext
testhooks
testlogger
testtelemetry
testvars
updateutils
util contains small standalone utility functions.
 util contains small standalone utility functions.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.