common

package

Version: v0.22.0 Latest Latest Go to latest Published: Aug 20, 2021 License: MIT Imports: 23 Imported by: 51

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more

Repository

github.com/uber/cadence

Documentation ¶

Index ¶

Constants
Variables
func ActivityTypePtr(v s.ActivityType) *s.ActivityType
func AddSecondsToBaseTime(baseTimeInNanoSec int64, durationInSeconds int64) int64
func AggregateYarpcOptions(ctx context.Context, opts ...yarpc.CallOption) []yarpc.CallOption
func ArchivalStatusPtr(t s.ArchivalStatus) *s.ArchivalStatus
func AwaitWaitGroup(wg *sync.WaitGroup, timeout time.Duration) bool
func BoolDefault(v *bool) bool
func BoolPtr(v bool) *bool
func CancelExternalWorkflowExecutionFailedCausePtr(t s.CancelExternalWorkflowExecutionFailedCause) *s.CancelExternalWorkflowExecutionFailedCause
func CheckEventBlobSizeLimit(actualSize int, warnLimit int, errorLimit int, domainID string, ...) error
func ChildWorkflowExecutionFailedCausePtr(t s.ChildWorkflowExecutionFailedCause) *s.ChildWorkflowExecutionFailedCause
func ClientArchivalStatusPtr(t shared.ArchivalStatus) *shared.ArchivalStatus
func ConvertDynamicConfigMapPropertyToIntMap(dcValue map[string]interface{}) (map[int]int, error)
func ConvertIndexedValueTypeToThriftType(fieldType interface{}, logger log.Logger) workflow.IndexedValueType
func ConvertIntMapToDynamicConfigMapProperty(intMap map[int]int) map[string]interface{}
func CreateAdminServiceRetryPolicy() backoff.RetryPolicy
func CreateDlqPublishRetryPolicy() backoff.RetryPolicy
func CreateFrontendServiceRetryPolicy() backoff.RetryPolicy
func CreateHistoryServiceRetryPolicy() backoff.RetryPolicy
func CreateHistoryStartWorkflowRequest(domainID string, startRequest *types.StartWorkflowExecutionRequest, ...) *types.HistoryStartWorkflowExecutionRequest
func CreateMatchingPollForDecisionTaskResponse(historyResponse *types.RecordDecisionTaskStartedResponse, ...) *types.MatchingPollForDecisionTaskResponse
func CreateMatchingServiceRetryPolicy() backoff.RetryPolicy
func CreatePersistenceRetryPolicy() backoff.RetryPolicy
func CreatePersistenceRetryPolicyWithContext(ctx context.Context) backoff.RetryPolicy
func CreateReplicationServiceBusyRetryPolicy() backoff.RetryPolicy
func CreateTaskProcessingRetryPolicy() backoff.RetryPolicy
func DaysToDuration(d int32) time.Duration
func DecisionTaskFailedCausePtr(t s.DecisionTaskFailedCause) *s.DecisionTaskFailedCause
func DecisionTypePtr(t s.DecisionType) *s.DecisionType
func DeserializeSearchAttributeValue(value []byte, valueType workflow.IndexedValueType) (interface{}, error)
func DomainIDToHistoryShard(domainID string, numberOfShards int) int
func DurationPtr(v time.Duration) *time.Duration
func DurationToDays(d time.Duration) int32
func DurationToHours(d time.Duration) int64
func DurationToMicroseconds(d time.Duration) int64
func DurationToMilliseconds(d time.Duration) int64
func DurationToMinutes(d time.Duration) int64
func DurationToNanoseconds(d time.Duration) int64
func DurationToSeconds(d time.Duration) int64
func EventTypePtr(t s.EventType) *s.EventType
func Float64Ptr(v float64) *float64
func GenerateRandomString(n int) string
func GetDefaultAdvancedVisibilityWritingMode(isAdvancedVisConfigExist bool) string
func GetSizeOfHistoryEvent(event *types.HistoryEvent) uint64
func GetSizeOfMapStringToByteArray(input map[string][]byte) int
func HoursToDuration(d int64) time.Duration
func Int16Ptr(v int16) *int16
func Int32Default(v *int32) int32
func Int32Ptr(v int32) *int32
func Int64Default(v *int64) int64
func Int64Ptr(v int64) *int64
func IntPtr(v int) *int
func IsContextTimeoutError(err error) bool
func IsEntityNotExistsError(err error) bool
func IsJustOrderByClause(clause string) bool
func IsServiceBusyError(err error) bool
func IsServiceTransientError(err error) bool
func IsStickyTaskConditionError(err error) bool
func IsValidContext(ctx context.Context) error
func MaxDuration(a, b time.Duration) time.Duration
func MaxInt(a, b int) int
func MaxInt64(a, b int64) int64
func MicrosecondsToDuration(d int64) time.Duration
func MillisecondsToDuration(d int64) time.Duration
func MinDuration(a, b time.Duration) time.Duration
func MinInt(a, b int) int
func MinInt32(a, b int32) int32
func MinInt64(a, b int64) int64
func MinutesToDuration(d int64) time.Duration
func NanosecondsToDuration(d int64) time.Duration
func ParentClosePolicyPtr(t s.ParentClosePolicy) *s.ParentClosePolicy
func PrettyPrintHistory(history *types.History, logger log.Logger)
func QueryConsistencyLevelPtr(t s.QueryConsistencyLevel) *s.QueryConsistencyLevel
func QueryRejectConditionPtr(t s.QueryRejectCondition) *s.QueryRejectCondition
func QueryResultTypePtr(t s.QueryResultType) *s.QueryResultType
func QueryTaskCompletedTypePtr(t s.QueryTaskCompletedType) *s.QueryTaskCompletedType
func SecondsToDuration(d int64) time.Duration
func SignalExternalWorkflowExecutionFailedCausePtr(t s.SignalExternalWorkflowExecutionFailedCause) *s.SignalExternalWorkflowExecutionFailedCause
func SortInt64Slice(slice []int64)
func StringDefault(v *string) string
func StringPtr(v string) *string
func TDeserialize(msg thrift.TStruct, b []byte) (err error)
func TDeserializeString(msg thrift.TStruct, s string) (err error)
func TListDeserialize(msgType reflect.Type, b []byte) (msgs []thrift.TStruct, err error)
func TListSerialize(msgs []thrift.TStruct) (b []byte, err error)
func TSerialize(msg thrift.TStruct) (b []byte, err error)
func TSerializeString(msg thrift.TStruct) (s string, err error)
func TaskListKindPtr(t s.TaskListKind) *s.TaskListKind
func TaskListPtr(v s.TaskList) *s.TaskList
func TaskListTypePtr(t s.TaskListType) *s.TaskListType
func TimeNowNanosPtr() *int64
func TimePtr(v time.Time) *time.Time
func TimeoutTypePtr(t s.TimeoutType) *s.TimeoutType
func Uint32Ptr(v uint32) *uint32
func Uint64Ptr(v uint64) *uint64
func ValidIDLength(id string, scope metrics.Scope, warnLimit int, errorLimit int, ...) bool
func ValidateDomainUUID(domainUUID string) error
func ValidateLongPollContextTimeout(ctx context.Context, handlerName string, logger log.Logger) error
func ValidateLongPollContextTimeoutIsSet(ctx context.Context, handlerName string, logger log.Logger) (time.Time, error)
func ValidateRetryPolicy(policy *types.RetryPolicy) error
func WorkflowIDToHistoryShard(workflowID string, numberOfShards int) int
func WorkflowTypePtr(t s.WorkflowType) *s.WorkflowType
type ClientCache
- func NewClientCache(keyResolver keyResolver, clientProvider clientProvider) ClientCache
type Daemon
type EncodingType
type PProfInitializer
type QueryTaskToken
type RPCFactory
type TaskToken
type TaskTokenSerializer
- func NewJSONTaskTokenSerializer() TaskTokenSerializer
type TaskType

Constants ¶

View Source

const (
	// FirstEventID is the id of the first event in the history
	FirstEventID int64 = 1
	// EmptyEventID is the id of the empty event
	EmptyEventID int64 = -23
	// EmptyVersion is used as the default value for failover version when no value is provided
	EmptyVersion int64 = -24
	// 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 = -1234
	// 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
	// EmptyMessageID is the default start message ID for replication level
	EmptyMessageID = -1
	// InitialPreviousFailoverVersion is the initial previous failover version
	InitialPreviousFailoverVersion int64 = -1
)

View Source

const (
	// FrontendServiceName is the name of the frontend service
	FrontendServiceName = "cadence-frontend"
	// HistoryServiceName is the name of the history service
	HistoryServiceName = "cadence-history"
	// MatchingServiceName is the name of the matching service
	MatchingServiceName = "cadence-matching"
	// WorkerServiceName is the name of the worker service
	WorkerServiceName = "cadence-worker"
)

View Source

const (
	// GetHistoryMaxPageSize is the max page size for get history
	GetHistoryMaxPageSize = 1000
	// ReadDLQMessagesPageSize is the max page size for read DLQ messages
	ReadDLQMessagesPageSize = 1000
)

View Source

const (
	// SystemGlobalDomainName is global domain name for cadence system workflows running globally
	SystemGlobalDomainName = "cadence-system-global"
	// SystemDomainID is domain id for all cadence system workflows
	SystemDomainID = "32049b68-7872-4094-8e63-d0dd59896a83"
	// SystemLocalDomainName is domain name for cadence system workflows running in local cluster
	SystemLocalDomainName = "cadence-system"
	// SystemDomainRetentionDays is retention config for all cadence system workflows
	SystemDomainRetentionDays = 7
	// DefaultAdminOperationToken is the default dynamic config value for AdminOperationToken
	DefaultAdminOperationToken = "CadenceTeamONLY"
	// BatcherDomainID is domain id for batcher local domain
	BatcherDomainID = "3116607e-419b-4783-85fc-47726a4c3fe9"
	// BatcherLocalDomainName is domain name for batcher workflows running in local cluster
	// Batcher cannot use SystemLocalDomain because auth
	BatcherLocalDomainName = "cadence-batcher"
	// ShadowerDomainID is domain id for workflow shadower local domain
	ShadowerDomainID = "59c51119-1b41-4a28-986d-d6e377716f82"
	// ShadowerLocalDomainName
	ShadowerLocalDomainName = shadower.LocalDomainName
)

This was flagged by salus as potentially hardcoded credentials. This is a false positive by the scanner and should be disregarded. #nosec

View Source

const (
	// MinLongPollTimeout is the minimum context timeout for long poll API, below which
	// the request won't be processed
	MinLongPollTimeout = time.Second * 2
	// CriticalLongPollTimeout is a threshold for the context timeout passed into long poll API,
	// below which a warning will be logged
	CriticalLongPollTimeout = time.Second * 20
)

View Source

const (
	// DefaultIDLengthWarnLimit is the warning length for various ID types
	DefaultIDLengthWarnLimit = 128
	// DefaultIDLengthErrorLimit is the maximum length allowed for various ID types
	DefaultIDLengthErrorLimit = 1000
)

View Source

const (
	// ArchivalEnabled is the status for enabling archival
	ArchivalEnabled = "enabled"
	// ArchivalDisabled is the status for disabling archival
	ArchivalDisabled = "disabled"
	// ArchivalPaused is the status for pausing archival
	ArchivalPaused = "paused"
)

View Source

const (
	// AdvancedVisibilityWritingModeOff means do not write to advanced visibility store
	AdvancedVisibilityWritingModeOff = "off"
	// AdvancedVisibilityWritingModeOn means only write to advanced visibility store
	AdvancedVisibilityWritingModeOn = "on"
	// AdvancedVisibilityWritingModeDual means write to both normal visibility and advanced visibility store
	AdvancedVisibilityWritingModeDual = "dual"
)

enum for dynamic config AdvancedVisibilityWritingMode

View Source

const (
	// DomainDataKeyForManagedFailover is key of DomainData for managed failover
	DomainDataKeyForManagedFailover = "IsManagedByCadence"
	// DomainDataKeyForPreferredCluster is the key of DomainData for domain rebalance
	DomainDataKeyForPreferredCluster = "PreferredCluster"
)

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 (
	// LibraryVersionHeaderName refers to the name of the
	// tchannel / http header that contains the client
	// library version
	LibraryVersionHeaderName = "cadence-client-library-version"

	// 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.
	// This can be used for client capibility check, on
	// Cadence server, for backward compatibility
	FeatureVersionHeaderName = "cadence-client-feature-version"

	// Header name to pass the feature flags from customer to client or server
	ClientFeatureFlagsHeaderName = "cadence-client-feature-flags"

	// ClientImplHeaderName refers to the name of the
	// header that contains the client implementation
	ClientImplHeaderName = "cadence-client-name"
	// EnforceDCRedirection refers to a boolean string of whether
	// to enforce DCRedirection(auto-forwarding)
	// Will be removed in the future: https://github.com/uber/cadence/issues/2304
	EnforceDCRedirection = "cadence-enforce-dc-redirection"
)

View Source

const (

	// FailureReasonCompleteResultExceedsLimit is failureReason for complete result exceeds limit
	FailureReasonCompleteResultExceedsLimit = "COMPLETE_RESULT_EXCEEDS_LIMIT"
	// FailureReasonFailureDetailsExceedsLimit is failureReason for failure details exceeds limit
	FailureReasonFailureDetailsExceedsLimit = "FAILURE_DETAILS_EXCEEDS_LIMIT"
	// FailureReasonCancelDetailsExceedsLimit is failureReason for cancel details exceeds limit
	FailureReasonCancelDetailsExceedsLimit = "CANCEL_DETAILS_EXCEEDS_LIMIT"
	// FailureReasonHeartbeatExceedsLimit is failureReason for heartbeat exceeds limit
	FailureReasonHeartbeatExceedsLimit = "HEARTBEAT_EXCEEDS_LIMIT"
	// FailureReasonDecisionBlobSizeExceedsLimit is the failureReason for decision blob exceeds size limit
	FailureReasonDecisionBlobSizeExceedsLimit = "DECISION_BLOB_SIZE_EXCEEDS_LIMIT"
	// FailureReasonSizeExceedsLimit is reason to fail workflow when history size or count exceed limit
	FailureReasonSizeExceedsLimit = "HISTORY_EXCEEDS_LIMIT"
	// FailureReasonTransactionSizeExceedsLimit is the failureReason for when transaction cannot be committed because it exceeds size limit
	FailureReasonTransactionSizeExceedsLimit = "TRANSACTION_SIZE_EXCEEDS_LIMIT"
)

View Source

const (
	// DefaultTransactionSizeLimit is the largest allowed transaction size to persistence
	DefaultTransactionSizeLimit = 14 * 1024 * 1024
)

View Source

const (
	// EmptyUUID is the placeholder for UUID when it's empty
	EmptyUUID = "emptyUuid"
)

View Source

const MaxTaskTimeout = 31622400

MaxTaskTimeout is maximum task timeout allowed. 366 days in seconds

View Source

const MemoKeyForOperator = "operator"

MemoKeyForOperator is the memo key for operator

View Source

const ReservedTaskListPrefix = "/__cadence_sys/"

ReservedTaskListPrefix is the required naming prefix for any task list partition other than partition 0

View Source

const StickyTaskConditionFailedErrorMsg = "StickyTaskConditionFailedError"

StickyTaskConditionFailedErrorMsg error msg for sticky task ConditionFailedError

View Source

const (
	// VisibilityAppName is used to find kafka topics and ES indexName for visibility
	VisibilityAppName = "visibility"
)

Variables ¶

View Source

var (
	// ErrBlobSizeExceedsLimit is error for event blob size exceeds limit
	ErrBlobSizeExceedsLimit = &types.BadRequestError{Message: "Blob data size exceeds limit."}
	// ErrContextTimeoutTooShort is error for setting a very short context timeout when calling a long poll API
	ErrContextTimeoutTooShort = &types.BadRequestError{Message: "Context timeout is too short."}
	// ErrContextTimeoutNotSet is error for not setting a context timeout when calling a long poll API
	ErrContextTimeoutNotSet = &types.BadRequestError{Message: "Context timeout is not set."}
)

Functions ¶

func ActivityTypePtr ¶

func ActivityTypePtr(v s.ActivityType) *s.ActivityType

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

func AddSecondsToBaseTime ¶

func AddSecondsToBaseTime(baseTimeInNanoSec int64, durationInSeconds int64) int64

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

func AggregateYarpcOptions ¶ added in v0.3.5

func AggregateYarpcOptions(ctx context.Context, opts ...yarpc.CallOption) []yarpc.CallOption

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

func ArchivalStatusPtr ¶ added in v0.5.0

func ArchivalStatusPtr(t s.ArchivalStatus) *s.ArchivalStatus

ArchivalStatusPtr makes a copy and returns the pointer to an ArchivalStatus.

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 BoolDefault ¶ added in v0.3.2

func BoolDefault(v *bool) bool

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

func BoolPtr ¶

func BoolPtr(v bool) *bool

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

func CancelExternalWorkflowExecutionFailedCausePtr ¶ added in v0.3.2

func CancelExternalWorkflowExecutionFailedCausePtr(t s.CancelExternalWorkflowExecutionFailedCause) *s.CancelExternalWorkflowExecutionFailedCause

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

func CheckEventBlobSizeLimit ¶ added in v0.5.0

func CheckEventBlobSizeLimit(
	actualSize int,
	warnLimit int,
	errorLimit int,
	domainID string,
	workflowID string,
	runID string,
	scope metrics.Scope,
	logger log.Logger,
	blobSizeViolationOperationTag tag.Tag,
) 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 ChildWorkflowExecutionFailedCausePtr ¶ added in v0.3.2

func ChildWorkflowExecutionFailedCausePtr(t s.ChildWorkflowExecutionFailedCause) *s.ChildWorkflowExecutionFailedCause

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

func ClientArchivalStatusPtr ¶ added in v0.5.7

func ClientArchivalStatusPtr(t shared.ArchivalStatus) *shared.ArchivalStatus

ClientArchivalStatusPtr makes a copy and returns the pointer to a client ArchivalStatus.

func ConvertDynamicConfigMapPropertyToIntMap ¶ added in v0.13.0

func ConvertDynamicConfigMapPropertyToIntMap(
	dcValue map[string]interface{},
) (map[int]int, error)

ConvertDynamicConfigMapPropertyToIntMap convert a map property from dynamic config to a map whose type for both key and value are int

func ConvertIndexedValueTypeToThriftType ¶ added in v0.6.0

func ConvertIndexedValueTypeToThriftType(fieldType interface{}, logger log.Logger) workflow.IndexedValueType

ConvertIndexedValueTypeToThriftType takes fieldType as interface{} and convert to IndexedValueType. Because different implementation of dynamic config client may lead to different types

func ConvertIntMapToDynamicConfigMapProperty ¶ added in v0.13.0

func ConvertIntMapToDynamicConfigMapProperty(
	intMap map[int]int,
) map[string]interface{}

ConvertIntMapToDynamicConfigMapProperty converts a map whose key value type are both int to a map value that is compatible with dynamic config's map property

func CreateAdminServiceRetryPolicy ¶ added in v0.5.0

func CreateAdminServiceRetryPolicy() backoff.RetryPolicy

CreateAdminServiceRetryPolicy creates a retry policy for calls to matching service

func CreateDlqPublishRetryPolicy ¶ added in v0.18.0

func CreateDlqPublishRetryPolicy() backoff.RetryPolicy

CreateDlqPublishRetryPolicy creates a retry policy for kafka operation

func CreateFrontendServiceRetryPolicy ¶ added in v0.3.11

func CreateFrontendServiceRetryPolicy() backoff.RetryPolicy

CreateFrontendServiceRetryPolicy creates a retry policy for calls to frontend service

func CreateHistoryServiceRetryPolicy ¶

func CreateHistoryServiceRetryPolicy() backoff.RetryPolicy

CreateHistoryServiceRetryPolicy creates a retry policy for calls to history service

func CreateHistoryStartWorkflowRequest ¶ added in v0.4.0

func CreateHistoryStartWorkflowRequest(
	domainID string,
	startRequest *types.StartWorkflowExecutionRequest,
	now time.Time,
) *types.HistoryStartWorkflowExecutionRequest

CreateHistoryStartWorkflowRequest create a start workflow request for history

func CreateMatchingPollForDecisionTaskResponse ¶ added in v0.3.12

func CreateMatchingPollForDecisionTaskResponse(historyResponse *types.RecordDecisionTaskStartedResponse, workflowExecution *types.WorkflowExecution, token []byte) *types.MatchingPollForDecisionTaskResponse

CreateMatchingPollForDecisionTaskResponse create response for matching's PollForDecisionTask

func CreateMatchingServiceRetryPolicy ¶ added in v0.5.0

func CreateMatchingServiceRetryPolicy() backoff.RetryPolicy

CreateMatchingServiceRetryPolicy creates a retry policy for calls to matching service

func CreatePersistenceRetryPolicy ¶ added in v0.13.0

func CreatePersistenceRetryPolicy() backoff.RetryPolicy

CreatePersistenceRetryPolicy creates a retry policy for persistence layer operations

func CreatePersistenceRetryPolicyWithContext ¶ added in v0.22.0

func CreatePersistenceRetryPolicyWithContext(ctx context.Context) backoff.RetryPolicy

CreatePersistenceRetryPolicyWithContext create a retry policy for persistence layer operations which has an expiration interval computed based on the context's deadline

func CreateReplicationServiceBusyRetryPolicy ¶ added in v0.14.0

func CreateReplicationServiceBusyRetryPolicy() backoff.RetryPolicy

CreateReplicationServiceBusyRetryPolicy creates a retry policy to handle replication service busy

func CreateTaskProcessingRetryPolicy ¶ added in v0.13.0

func CreateTaskProcessingRetryPolicy() backoff.RetryPolicy

CreateTaskProcessingRetryPolicy creates a retry policy for task processing

func DaysToDuration ¶ added in v0.17.0

func DaysToDuration(d int32) time.Duration

DaysToDuration converts number of 24 hour days to time.Duration

func DecisionTaskFailedCausePtr ¶ added in v0.3.2

func DecisionTaskFailedCausePtr(t s.DecisionTaskFailedCause) *s.DecisionTaskFailedCause

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

func DecisionTypePtr ¶

func DecisionTypePtr(t s.DecisionType) *s.DecisionType

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

func DeserializeSearchAttributeValue ¶ added in v0.12.0

func DeserializeSearchAttributeValue(value []byte, valueType workflow.IndexedValueType) (interface{}, error)

DeserializeSearchAttributeValue takes json encoded search attribute value and it's type as input, then unmarshal the value into a concrete type and return the value

func DomainIDToHistoryShard ¶ added in v0.14.0

func DomainIDToHistoryShard(domainID string, numberOfShards int) int

DomainIDToHistoryShard is used to map a domainID to a shardID

func DurationPtr ¶ added in v0.18.0

func DurationPtr(v time.Duration) *time.Duration

DurationPtr makes a copy and returns the pointer to a duration

func DurationToDays ¶ added in v0.17.0

func DurationToDays(d time.Duration) int32

DurationToDays converts time.Duration to number of 24 hour days

func DurationToHours ¶ added in v0.17.0

func DurationToHours(d time.Duration) int64

DurationToHours converts time.Duration to number of hours

func DurationToMicroseconds ¶ added in v0.17.0

func DurationToMicroseconds(d time.Duration) int64

DurationToMicroseconds converts time.Duration to number of microseconds

func DurationToMilliseconds ¶ added in v0.17.0

func DurationToMilliseconds(d time.Duration) int64

DurationToMilliseconds converts time.Duration to number of milliseconds

func DurationToMinutes ¶ added in v0.17.0

func DurationToMinutes(d time.Duration) int64

DurationToMinutes converts time.Duration to number of minutes

func DurationToNanoseconds ¶ added in v0.17.0

func DurationToNanoseconds(d time.Duration) int64

DurationToNanoseconds converts time.Duration to number of nanoseconds

func DurationToSeconds ¶ added in v0.17.0

func DurationToSeconds(d time.Duration) int64

DurationToSeconds converts time.Duration to number of seconds

func EventTypePtr ¶

func EventTypePtr(t s.EventType) *s.EventType

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

func Float64Ptr ¶

func Float64Ptr(v float64) *float64

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

func GenerateRandomString ¶ added in v0.3.12

func GenerateRandomString(n int) string

GenerateRandomString is used for generate test string

func GetDefaultAdvancedVisibilityWritingMode ¶ added in v0.9.0

func GetDefaultAdvancedVisibilityWritingMode(isAdvancedVisConfigExist bool) string

GetDefaultAdvancedVisibilityWritingMode get default advancedVisibilityWritingMode based on whether related config exists in static config file.

func GetSizeOfHistoryEvent ¶ added in v0.14.0

func GetSizeOfHistoryEvent(event *types.HistoryEvent) uint64

GetSizeOfHistoryEvent returns approximate size in bytes of the history event taking into account byte arrays only now

func GetSizeOfMapStringToByteArray ¶ added in v0.5.7

func GetSizeOfMapStringToByteArray(input map[string][]byte) int

GetSizeOfMapStringToByteArray get size of map[string][]byte

func HoursToDuration ¶ added in v0.17.0

func HoursToDuration(d int64) time.Duration

HoursToDuration converts number of hours to time.Duration

func Int16Ptr ¶ added in v0.5.7

func Int16Ptr(v int16) *int16

Int16Ptr makes a copy and returns the pointer to an int16.

func Int32Default ¶ added in v0.3.2

func Int32Default(v *int32) int32

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

func Int32Ptr ¶

func Int32Ptr(v int32) *int32

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

func Int64Default ¶ added in v0.3.2

func Int64Default(v *int64) int64

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

func Int64Ptr ¶

func Int64Ptr(v int64) *int64

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

func IntPtr ¶

func IntPtr(v int) *int

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

func IsContextTimeoutError ¶ added in v0.14.0

func IsContextTimeoutError(err error) bool

IsContextTimeoutError checks if the error is context timeout error

func IsEntityNotExistsError ¶ added in v0.21.2

func IsEntityNotExistsError(err error) bool

IsEntityNotExistsError checks if the error is an entity not exists error.

func IsJustOrderByClause ¶ added in v0.5.9

func IsJustOrderByClause(clause string) bool

IsJustOrderByClause return true is query start with order by

func IsServiceBusyError ¶ added in v0.14.0

func IsServiceBusyError(err error) bool

IsServiceBusyError checks if the error is a service busy error.

func IsServiceTransientError ¶ added in v0.3.11

func IsServiceTransientError(err error) bool

IsServiceTransientError checks if the error is a transient error.

func IsStickyTaskConditionError ¶ added in v0.14.0

func IsStickyTaskConditionError(err error) bool

IsStickyTaskConditionError is error from matching engine

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 MaxDuration ¶ added in v0.12.0

func MaxDuration(a, b time.Duration) time.Duration

MaxDuration returns the greater of two given time durations

func MaxInt ¶ added in v0.7.0

func MaxInt(a, b int) int

MaxInt returns the greater one of two given integers

func MaxInt64 ¶ added in v0.6.0

func MaxInt64(a, b int64) int64

MaxInt64 returns the greater of two given int64

func MicrosecondsToDuration ¶ added in v0.17.0

func MicrosecondsToDuration(d int64) time.Duration

MicrosecondsToDuration converts number of microseconds to time.Duration

func MillisecondsToDuration ¶ added in v0.17.0

func MillisecondsToDuration(d int64) time.Duration

MillisecondsToDuration converts number of milliseconds to time.Duration

func MinDuration ¶ added in v0.12.0

func MinDuration(a, b time.Duration) time.Duration

MinDuration returns the smaller of two given time duration

func MinInt ¶ added in v0.5.7

func MinInt(a, b int) int

MinInt returns the smaller of two given integers

func MinInt32 ¶ added in v0.3.14

func MinInt32(a, b int32) int32

MinInt32 return smaller one of two inputs int32

func MinInt64 ¶ added in v0.5.8

func MinInt64(a, b int64) int64

MinInt64 returns the smaller of two given int64

func MinutesToDuration ¶ added in v0.17.0

func MinutesToDuration(d int64) time.Duration

MinutesToDuration converts number of minutes to time.Duration

func NanosecondsToDuration ¶ added in v0.17.0

func NanosecondsToDuration(d int64) time.Duration

NanosecondsToDuration converts number of nanoseconds to time.Duration

func ParentClosePolicyPtr ¶ added in v0.9.0

func ParentClosePolicyPtr(t s.ParentClosePolicy) *s.ParentClosePolicy

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

func PrettyPrintHistory ¶

func PrettyPrintHistory(history *types.History, logger log.Logger)

PrettyPrintHistory prints history in human readable format

func QueryConsistencyLevelPtr ¶ added in v0.11.0

func QueryConsistencyLevelPtr(t s.QueryConsistencyLevel) *s.QueryConsistencyLevel

QueryConsistencyLevelPtr makes a copy and returns the pointer to a QueryConsistencyLevel

func QueryRejectConditionPtr ¶ added in v0.11.0

func QueryRejectConditionPtr(t s.QueryRejectCondition) *s.QueryRejectCondition

QueryRejectConditionPtr makes a copy and returns the pointer to a QueryRejectCondition

func QueryResultTypePtr ¶ added in v0.11.0

func QueryResultTypePtr(t s.QueryResultType) *s.QueryResultType

QueryResultTypePtr makes a copy and returns the pointer to a QueryResultType

func QueryTaskCompletedTypePtr ¶ added in v0.10.1

func QueryTaskCompletedTypePtr(t s.QueryTaskCompletedType) *s.QueryTaskCompletedType

QueryTaskCompletedTypePtr makes a copy and returns the pointer to a QueryTaskCompletedType

func SecondsToDuration ¶ added in v0.17.0

func SecondsToDuration(d int64) time.Duration

SecondsToDuration converts number of seconds to time.Duration

func SignalExternalWorkflowExecutionFailedCausePtr ¶ added in v0.3.6

func SignalExternalWorkflowExecutionFailedCausePtr(t s.SignalExternalWorkflowExecutionFailedCause) *s.SignalExternalWorkflowExecutionFailedCause

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

func SortInt64Slice ¶ added in v0.12.0

func SortInt64Slice(slice []int64)

SortInt64Slice sorts the given int64 slice. Sort is not guaranteed to be stable.

func StringDefault ¶ added in v0.3.2

func StringDefault(v *string) string

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

func StringPtr ¶

func StringPtr(v string) *string

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

func TDeserialize ¶

func TDeserialize(msg thrift.TStruct, b []byte) (err error)

TDeserialize is used to deserialize []byte to thrift TStruct

func TDeserializeString ¶

func TDeserializeString(msg thrift.TStruct, s string) (err error)

TDeserializeString is used to deserialize string to thrift TStruct

func TListDeserialize ¶

func TListDeserialize(msgType reflect.Type, b []byte) (msgs []thrift.TStruct, err error)

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

func TListSerialize ¶

func TListSerialize(msgs []thrift.TStruct) (b []byte, err error)

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

func TSerialize ¶

func TSerialize(msg thrift.TStruct) (b []byte, err error)

TSerialize is used to serialize thrift TStruct to []byte

func TSerializeString ¶

func TSerializeString(msg thrift.TStruct) (s string, err error)

TSerializeString is used to serialize thrift TStruct to string

func TaskListKindPtr ¶ added in v0.3.6

func TaskListKindPtr(t s.TaskListKind) *s.TaskListKind

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

func TaskListPtr ¶

func TaskListPtr(v s.TaskList) *s.TaskList

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

func TaskListTypePtr ¶ added in v0.4.0

func TaskListTypePtr(t s.TaskListType) *s.TaskListType

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

func TimeNowNanosPtr ¶ added in v0.5.7

func TimeNowNanosPtr() *int64

TimeNowNanosPtr returns an int64 ptr to current time in unix nanos

func TimePtr ¶ added in v0.17.0

func TimePtr(v time.Time) *time.Time

TimePtr makes a copy and returns the pointer to a time

func TimeoutTypePtr ¶ added in v0.3.2

func TimeoutTypePtr(t s.TimeoutType) *s.TimeoutType

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

func Uint32Ptr ¶

func Uint32Ptr(v uint32) *uint32

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

func Uint64Ptr ¶

func Uint64Ptr(v uint64) *uint64

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

func ValidIDLength ¶ added in v0.21.2

func ValidIDLength(
	id string,
	scope metrics.Scope,
	warnLimit int,
	errorLimit int,
	metricsCounter int,
) bool

ValidIDLength checks if id is valid according to its length

func ValidateDomainUUID ¶ added in v0.20.0

func ValidateDomainUUID(
	domainUUID string,
) error

ValidateDomainUUID checks if the given domainID string is a valid UUID

func ValidateLongPollContextTimeout ¶ added in v0.5.7

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

ValidateLongPollContextTimeout check 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 return ErrContextTimeoutNotSet or ErrContextTimeoutTooShort accordingly. If the timeout is only below a normal value, it just logs an info and return nil.

func ValidateLongPollContextTimeoutIsSet ¶ added in v0.8.6

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 ValidateRetryPolicy ¶ added in v0.4.0

func ValidateRetryPolicy(policy *types.RetryPolicy) error

ValidateRetryPolicy validates a retry policy

func WorkflowIDToHistoryShard ¶

func WorkflowIDToHistoryShard(workflowID string, numberOfShards int) int

WorkflowIDToHistoryShard is used to map a workflowID to a shardID

func WorkflowTypePtr ¶

func WorkflowTypePtr(t s.WorkflowType) *s.WorkflowType

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

Types ¶

type ClientCache ¶ added in v0.5.0

type ClientCache interface {
	GetClientForKey(key string) (interface{}, error)
	GetClientForClientKey(clientKey string) (interface{}, error)
	GetHostNameForKey(key string) (string, error)
}

ClientCache store initialized clients

func NewClientCache ¶ added in v0.5.0

func NewClientCache(
	keyResolver keyResolver,
	clientProvider clientProvider,
) ClientCache

NewClientCache creates a new client cache based on membership

type Daemon ¶

type Daemon interface {
	Start()
	Stop()
}

Daemon is the base interfaces implemented by background tasks within Cadence

type EncodingType ¶

type EncodingType string

EncodingType is an enum that represents various data encoding types

const (
	EncodingTypeJSON     EncodingType = "json"
	EncodingTypeThriftRW EncodingType = "thriftrw"
	EncodingTypeGob      EncodingType = "gob"
	EncodingTypeUnknown  EncodingType = "unknow"
	EncodingTypeEmpty    EncodingType = ""
	EncodingTypeProto    EncodingType = "proto3"
)

Data encoding types

type PProfInitializer ¶ added in v0.3.5

type PProfInitializer interface {
	Start() error
}

PProfInitializer initialize the pprof based on config

type QueryTaskToken ¶ added in v0.3.2

type QueryTaskToken struct {
	DomainID string `json:"domainId"`
	TaskList string `json:"taskList"`
	TaskID   string `json:"taskId"`
}

QueryTaskToken identifies a query task

type RPCFactory ¶ added in v0.3.2

type RPCFactory interface {
	GetDispatcher() *yarpc.Dispatcher
	CreateDispatcherForOutbound(callerName, serviceName, hostName string) (*yarpc.Dispatcher, error)
	CreateGRPCDispatcherForOutbound(callerName, serviceName, hostName string) (*yarpc.Dispatcher, error)
	ReplaceGRPCPort(serviceName, hostAddress string) (string, error)
}

RPCFactory Creates a dispatcher that knows how to transport requests.

type TaskToken ¶

type TaskToken struct {
	DomainID        string `json:"domainId"`
	WorkflowID      string `json:"workflowId"`
	WorkflowType    string `json:"workflowType"`
	RunID           string `json:"runId"`
	ScheduleID      int64  `json:"scheduleId"`
	ScheduleAttempt int64  `json:"scheduleAttempt"`
	ActivityID      string `json:"activityId"`
	ActivityType    string `json:"activityType"`
}

TaskToken identifies a task

type TaskTokenSerializer ¶

type TaskTokenSerializer interface {
	Serialize(token *TaskToken) ([]byte, error)
	Deserialize(data []byte) (*TaskToken, error)
	SerializeQueryTaskToken(token *QueryTaskToken) ([]byte, error)
	DeserializeQueryTaskToken(data []byte) (*QueryTaskToken, error)
}

TaskTokenSerializer serializes task tokens

func NewJSONTaskTokenSerializer ¶

func NewJSONTaskTokenSerializer() TaskTokenSerializer

NewJSONTaskTokenSerializer creates a new instance of TaskTokenSerializer

type TaskType ¶ added in v0.12.0

type TaskType int

TaskType is the enum for representing different task types

const (
	// TaskTypeTransfer is the task type for transfer task
	TaskTypeTransfer TaskType = iota + 2 // starting from 2 here to be consistent with the row type define for cassandra
	// TaskTypeTimer is the task type for timer task
	TaskTypeTimer
	// TaskTypeReplication is the task type for replication task
	TaskTypeReplication
)

Source Files ¶

View all

Directories ¶

Path	Synopsis
archiver 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
gcloud/connector/mocks
provider
s3store Package s3store is a generated GoMock package.	Package s3store is a generated GoMock package.
s3store/mocks
authorization Package authorization is a generated GoMock package.	Package authorization is a generated GoMock package.
backoff
blobstore
filestore
cache Package cache is a generated GoMock package.	Package cache is a generated GoMock package.
checksum
client Package mock_client is a generated GoMock package.	Package mock_client is a generated GoMock package.
clock
cluster Package cluster is a generated GoMock package.	Package cluster is a generated GoMock package.
codec
gob
collection
config
definition
domain Package domain is a generated GoMock package.	Package domain is a generated GoMock package.
dynamicconfig Package dynamicconfig is a generated GoMock package.	Package dynamicconfig is a generated GoMock package.
elasticsearch
esql
mocks
validator
errors
future
locks
log
loggerimpl
tag
membership Package membership is a generated GoMock package.	Package membership is a generated GoMock package.
messaging
kafka
mocks
metrics
mocks
tally/prometheus
tally/statsd
mocks
ndc Package ndc is a generated GoMock package.	Package ndc is a generated GoMock package.
pagination Package pagination is a generated GoMock package.	Package pagination is a generated GoMock package.
persistence
cassandra
client Package client is a generated GoMock package.	Package client is a generated GoMock package.
elasticsearch
nosql/nosqlplugin
nosql/nosqlplugin/cassandra
nosql/nosqlplugin/cassandra/gocql Package gocql is a generated GoMock package.	Package gocql is a generated GoMock package.
nosql/nosqlplugin/cassandra/gocql/public
nosql/nosqlplugin/cassandra/tests
nosql/nosqlplugin/dynamodb
persistence-tests
persistence-utils
serialization
sql
sql/sqlplugin
sql/sqlplugin/mysql
sql/sqlplugin/postgres
quotas
reconciliation
entity
fetcher
invariant Package invariant is a generated GoMock package.	Package invariant is a generated GoMock package.
store Package store is a generated GoMock package.	Package store is a generated GoMock package.
resource
config
service
task Package task is a generated GoMock package.	Package task is a generated GoMock package.
testing
tokenbucket
types
mapper/proto
mapper/thrift
util

?	: This menu
/	: Search site
f or F	: Jump to
t or T	: Toggle theme	light dark auto
y or Y	: Canonical URL