common

Aug 27, 2019

Changes in this version

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

Aug 14, 2019

Changes in this version

+ const ArchivalDisabled

+ const ArchivalEnabled

+ const ArchivalPaused

Jul 30, 2019

Changes in this version

+ const EnforceDCRedirection

+ const FailureReasonSizeExceedsLimit

+ func MaxInt(a, b int) int

Jul 24, 2019

Changes in this version

+ const DefaultAdminOperationToken

+ const SystemGlobalDomainName

+ const SystemLocalDomainName

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

+ func GetArchivalScheme(URI string) (string, error)

+ func MaxInt64(a, b int64) int64

Jun 17, 2019

Changes in this version

+ const DefaultTransactionSizeLimit

+ const FailureReasonTransactionSizeExceedsLimit

+ func IsJustOrderByClause(clause string) bool

+ type VisibilityQueryValidator struct

+ func NewQueryValidator(validSearchAttributes dynamicconfig.MapPropertyFn) *VisibilityQueryValidator

+ func (qv *VisibilityQueryValidator) IsValidSearchAttributes(key string) bool

+ func (qv *VisibilityQueryValidator) ValidateCountRequestForQuery(countRequest *workflow.CountWorkflowExecutionsRequest) error

+ func (qv *VisibilityQueryValidator) ValidateListRequestForQuery(listRequest *workflow.ListWorkflowExecutionsRequest) error

May 14, 2019

Changes in this version

+ func MinInt64(a, b int64) int64

May 8, 2019

Changes in this version

+ const CriticalLongPollTimeout

+ const EncodingTypeEmpty

+ const MinLongPollTimeout

+ const SystemDomainID

+ const SystemDomainName

+ const SystemDomainRetentionDays

+ var ErrContextTimeoutNotSet = &workflow.BadRequestError

+ var ErrContextTimeoutTooShort = &workflow.BadRequestError

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

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

+ func Int16Ptr(v int16) *int16

+ func MinInt(a, b int) int

+ func TimeNowNanosPtr() *int64

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

Mar 8, 2019

Changes in this version

+ const EmptyEventTaskID

Feb 19, 2019

Changes in this version

+ const FirstBlobPageToken

+ const LastBlobNextPageToken

Feb 12, 2019

Changes in this version

+ const VisibilityAppName

+ func CreateBlobstoreClientRetryPolicy() backoff.RetryPolicy

+ func CreateKafkaOperationRetryPolicy() backoff.RetryPolicy

+ func CreatePublicClientRetryPolicy() backoff.RetryPolicy

+ func IsBlobstoreNonRetryableError(err error) bool

+ func IsBlobstoreTransientError(err error) bool

+ func IsKafkaTransientError(err error) bool

Jan 7, 2019

Changes in this version

+ const FailureReasonCancelDetailsExceedsLimit

+ const FailureReasonCompleteResultExceedsLimit

+ const FailureReasonDecisionBlobSizeExceedsLimit

+ const FailureReasonFailureDetailsExceedsLimit

+ const FailureReasonHeartbeatExceedsLimit

+ const GetHistoryMaxPageSize

+ const GetHistoryWarnSizeLimit

+ const TerminateReasonSizeExceedsLimit

+ var ErrBlobSizeExceedsLimit = &workflow.BadRequestError

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

+ func CheckEventBlobSizeLimit(actualSize, warnLimit, errorLimit int, domainID, workflowID, runID string, ...) error

+ func CreateAdminServiceRetryPolicy() backoff.RetryPolicy

+ func CreateMatchingServiceRetryPolicy() backoff.RetryPolicy

+ func ValidateCronSchedule(cronSchedule string) error

+ type ClientCache interface

+ GetClientForClientKey func(clientKey string) (interface{}, error)

+ GetClientForKey func(key string) (interface{}, error)

+ func NewClientCache(keyResolver keyResolver, clientProvider clientProvider) ClientCache

Oct 19, 2018

Changes in this version

+ const EncodingTypeThriftRW

+ const EncodingTypeUnknown

+ const NoRetryBackoff

+ func CreateHistoryStartWorkflowRequest(domainID string, startRequest *workflow.StartWorkflowExecutionRequest) *h.StartWorkflowExecutionRequest

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

+ func ValidateRetryPolicy(policy *workflow.RetryPolicy) error

+ type PriorityTokenBucket interface

+ GetToken func(priority, count int) (bool, time.Duration)

+ func NewFullPriorityTokenBucket(numOfPriority, rps int, timeSource TimeSource) PriorityTokenBucket

+ func NewPriorityTokenBucket(numOfPriority, rps int, timeSource TimeSource) PriorityTokenBucket

Jul 24, 2018

Changes in this version

+ const MaxTaskTimeout

+ func CreateMatchingRetryPolicy() backoff.RetryPolicy

+ func IsWhitelistServiceTransientError(err error) bool

+ func MinInt32(a, b int32) int32

+ type EventTimeSource struct

+ func NewEventTimeSource() *EventTimeSource

+ func (ts *EventTimeSource) Now() time.Time

+ func (ts *EventTimeSource) Update(now time.Time) *EventTimeSource

Jun 9, 2018

Changes in this version

+ const DaemonStatusInitialized

+ const DaemonStatusStarted

+ const DaemonStatusStopped

May 26, 2018

Changes in this version

+ const BufferedEventID

+ const TransientEventID

+ func CreateMatchingPollForDecisionTaskResponse(historyResponse *h.RecordDecisionTaskStartedResponse, ...) *m.PollForDecisionTaskResponse

+ func GenerateRandomString(n int) string

+ type FakeTimeSource struct

+ func NewFakeTimeSource() *FakeTimeSource

+ func (ts *FakeTimeSource) Now() time.Time

+ func (ts *FakeTimeSource) Update(now time.Time)

+ type Mutex interface

+ Lock func(context.Context) error

+ Unlock func()

+ func NewMutex() Mutex

+ type RealTimeSource struct

+ func (ts *RealTimeSource) Now() time.Time

Apr 16, 2018

Changes in this version

+ const EmptyVersion

+ func CreateFrontendServiceRetryPolicy() backoff.RetryPolicy

+ func IsServiceTransientError(err error) bool

Mar 12, 2018

Changes in this version

+ const WorkerServiceName

Jan 30, 2018

Changes in this version

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

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

Jan 12, 2018

Changes in this version

+ const ClientImplHeaderName

+ const EndEventID

+ const FeatureVersionHeaderName

+ const LibraryVersionHeaderName

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

+ type PProfInitializer interface

+ Start func() error

Dec 5, 2017

Changes in this version

+ type RWMutex interface

+ Lock func(context.Context) error

+ RLock func(context.Context) error

+ RUnlock func()

+ Unlock func()

+ func NewRWMutex() RWMutex

type TaskToken

+ ActivityID string

+ ScheduleAttempt int64

Sep 29, 2017

Changes in this version

+ func BoolDefault(v *bool) bool

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

+ func ChildPolicyPtr(t s.ChildPolicy) *s.ChildPolicy

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

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

+ func Int32Default(v *int32) int32

+ func Int64Default(v *int64) int64

+ func StringDefault(v *string) string

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

+ type QueryTaskToken struct

+ DomainID string

+ TaskID string

+ TaskList string

+ type RPCFactory interface

+ CreateDispatcher func() *yarpc.Dispatcher

+ CreateDispatcherForOutbound func(callerName, serviceName, hostName string) *yarpc.Dispatcher

type TaskTokenSerializer

+ DeserializeQueryTaskToken func(data []byte) (*QueryTaskToken, error)

+ SerializeQueryTaskToken func(token *QueryTaskToken) ([]byte, error)

Jun 30, 2017

Changes in this version

+ const EmptyEventID

+ const FirstEventID

+ const FrontendServiceName

+ const HistoryServiceName

+ const MatchingServiceName

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

+ func AddSecondsToBaseTime(baseTimeInNanoSec int64, durationInSeconds int64) int64

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

+ func BackgroundThriftContext() thrift.Context

+ func BoolPtr(v bool) *bool

+ func CQLTimestampToUnixNano(milliseconds int64) int64

+ func CreateCassandraKeyspace(s *gocql.Session, keyspace string, replicas int, overwrite bool) (err error)

+ func CreateHistoryServiceRetryPolicy() backoff.RetryPolicy

+ func CreatePersistanceRetryPolicy() backoff.RetryPolicy

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

+ func DropCassandraKeyspace(s *gocql.Session, keyspace string) (err error)

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

+ func Float64Ptr(v float64) *float64

+ func Int32Ptr(v int32) *int32

+ func Int64Ptr(v int64) *int64

+ func IntPtr(v int) *int

+ func IsPersistenceTransientError(err error) bool

+ func IsServiceNonRetryableError(err error) bool

+ func IsValidContext(ctx thrift.Context) error

+ func LoadCassandraSchema(dir string, fileNames []string, keyspace string, override bool) (err error)

+ func MergeDictoRight(src map[string]string, dest map[string]string)

+ func MergeDicts(dic1 map[string]string, dic2 map[string]string) (resultDict map[string]string)

+ func NewCassandraCluster(clusterHosts string, dc string) *gocql.ClusterConfig

+ func PrettyPrintHistory(history *workflow.History, logger bark.Logger)

+ 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 TaskListPtr(v s.TaskList) *s.TaskList

+ func Uint32Ptr(v uint32) *uint32

+ func Uint64Ptr(v uint64) *uint64

+ func UnixNanoToCQLTimestamp(timestamp int64) int64

+ func WorkflowIDToHistoryShard(workflowID string, numberOfShards int) int

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

+ type Daemon interface

+ Start func()

+ Stop func()

+ type EncodingType string

+ const EncodingTypeGob

+ const EncodingTypeJSON

+ type TaskToken struct

+ DomainID string

+ RunID string

+ ScheduleID int64

+ WorkflowID string

+ type TaskTokenSerializer interface

+ Deserialize func(data []byte) (*TaskToken, error)

+ Serialize func(token *TaskToken) ([]byte, error)

+ func NewJSONTaskTokenSerializer() TaskTokenSerializer

+ type TimeSource interface

+ Now func() time.Time

+ func NewRealTimeSource() TimeSource

+ type TokenBucket interface

+ Consume func(count int, timeout time.Duration) bool

+ TryConsume func(count int) (bool, time.Duration)

+ func NewTokenBucket(rps int, timeSource TimeSource) TokenBucket

+ type TokenBucketFactory interface

+ CreateTokenBucket func(rps int, timeSource TimeSource) TokenBucket

+ func NewTokenBucketFactory() TokenBucketFactory