ActivityTypePtr makes a copy and returns the pointer to a ActivityType.

AddSecondsToBaseTime - Gets the UnixNano with given duration and base time.

AggregateYarpcOptions aggregate the header information from context to existing yarpc call options.

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.

BoolDefault returns value if bool pointer is set otherwise default value of bool.

BoolPtr makes a copy and returns the pointer to a bool.

CancelExternalWorkflowExecutionFailedCausePtr makes a copy and returns the pointer to a CancelExternalWorkflowExecutionFailedCause.

ChildPolicyPtr makes a copy and returns the pointer to a ChildPolicy.

ChildWorkflowExecutionFailedCausePtr makes a copy and returns the pointer to a ChildWorkflowExecutionFailedCause.

CQLTimestampToUnixNano converts CQL timestamp to UnixNano.

CreateCassandraKeyspace creates the keyspace using this session for given replica count.

CreateFrontendServiceRetryPolicy creates a retry policy for calls to frontend service.

CreateHistoryServiceRetryPolicy creates a retry policy for calls to history service.

CreatePersistanceRetryPolicy creates a retry policy for persistence layer operations.

DecisionTaskFailedCausePtr makes a copy and returns the pointer to a DecisionTaskFailedCause.

DecisionTypePtr makes a copy and returns the pointer to a DecisionType.

DropCassandraKeyspace drops the given keyspace, if it exists.

EventTypePtr makes a copy and returns the pointer to a EventType.

Float64Ptr makes a copy and returns the pointer to an int64.

Int32Default returns value if int32 pointer is set otherwise default value of int32.

Int32Ptr makes a copy and returns the pointer to an int32.

Int64Default returns value if int64 pointer is set otherwise default value of int64.

Int64Ptr makes a copy and returns the pointer to an int64.

IntPtr makes a copy and returns the pointer to an int.

IsPersistenceTransientError checks if the error is a transient persistence error.

IsServiceNonRetryableError checks if the error is a non retryable error.

IsServiceTransientError checks if the error is a retryable error.

IsValidContext checks that the thrift context is not expired on cancelled.

LoadCassandraSchema loads the schema from the given .cql files on this keyspace.

MergeDictoRight copies the contents of src to dest.

MergeDicts creates a union of the two dicts.

NewCassandraCluster creates a cassandra cluster given comma separated list of clusterHosts.

NewJSONTaskTokenSerializer creates a new instance of TaskTokenSerializer.

NewRealTimeSource returns a time source that servers real wall clock time using CLOCK_REALTIME.

NewRWMutex creates a new RWMutex.

NewTokenBucket creates and returns a new token bucket rate limiter that repelenishes the bucket every 100 milliseconds.

NewTokenBucketFactory creates an instance of factory used for creating TokenBucket instances.

PrettyPrintHistory prints history in human readable format.

SignalExternalWorkflowExecutionFailedCausePtr makes a copy and returns the pointer to a SignalExternalWorkflowExecutionFailedCause.

StringDefault returns value if string pointer is set otherwise default value of string.

StringPtr makes a copy and returns the pointer to a string.

TaskListKindPtr makes a copy and returns the pointer to a TaskListKind.

TaskListPtr makes a copy and returns the pointer to a TaskList.

TDeserialize is used to deserialize []byte to thrift TStruct.

TDeserializeString is used to deserialize string to thrift TStruct.

TimeoutTypePtr makes a copy and returns the pointer to a TimeoutType.

TListDeserialize is used to deserialize []byte to list of thrift TStruct.

TListSerialize is used to serialize list of thrift TStruct to []byte.

TSerialize is used to serialize thrift TStruct to []byte.

TSerializeString is used to serialize thrift TStruct to string.

Uint32Ptr makes a copy and returns the pointer to a uint32.

Uint64Ptr makes a copy and returns the pointer to a uint64.

UnixNanoToCQLTimestamp converts UnixNano to CQL timestamp.

WorkflowIDToHistoryShard is used to map workflowID to a shardID.

WorkflowTypePtr makes a copy and returns the pointer to a WorkflowType.

ClientImplHeaderName refers to the name of the header that contains the client implementation.

EmptyEventID is the id of the empty event.

EmptyVersion is used as the default value for failover version when no value is provided.

Data encoding types.

Data encoding types.

EndEventID is the id of the end event, here we use the int64 max.

FeatureVersionHeaderName refers to the name of the tchannel / http header that contains the client feature version the feature version sent from client represents the feature set of the cadence client library support.

FirstEventID is the id of the first event in the history.

FrontendServiceName is the name of the frontend service.

HistoryServiceName is the name of the history service.

LibraryVersionHeaderName refers to the name of the tchannel / http header that contains the client library version.

MatchingServiceName is the name of the matching service.

WorkerServiceName is the name of the worker service.