sysworkflow

package

Go to main page

Versions in this module

v0

v0.5.5

Mar 12, 2019

v0.5.4

Mar 8, 2019

Changes in this version

+ func StringPageToken(pageToken int) string

type ArchiveRequest

+ NextEventID int64

v0.5.3

Feb 19, 2019

Changes in this version

+ const SystemDomainName

+ func ArchivalDeleteHistoryActivity(ctx context.Context, request ArchiveRequest) error

+ func ArchivalUploadActivity(ctx context.Context, request ArchiveRequest) error

+ func ArchiveSystemWorkflow(ctx workflow.Context, carryoverRequests []ArchiveRequest) error

+ func NewReplayBarkLogger(logger bark.Logger, ctx workflow.Context, enableLogInReplay bool) bark.Logger

+ func NewReplayMetricsClient(client metrics.Client, ctx workflow.Context) metrics.Client

+ type ArchivalClientMock struct

+ func (_m *ArchivalClientMock) Archive(_a0 *ArchiveRequest) error

type ArchiveRequest

+ BranchToken []byte

+ CloseFailoverVersion int64

+ EventStoreVersion int32

+ LastFirstEventID int64

type Config

+ EnableArchivalCompression dynamicconfig.BoolPropertyFnWithDomainFilter

+ HistoryPageSize dynamicconfig.IntPropertyFnWithDomainFilter

+ TargetArchivalBlobSize dynamicconfig.IntPropertyFnWithDomainFilter

type HistoryBlobHeader

+ CloseFailoverVersion *int64

+ type HistoryBlobIterator interface

+ HasNext func() bool

+ Next func() (*HistoryBlob, error)

+ func NewHistoryBlobIterator(logger bark.Logger, metricsClient metrics.Client, request ArchiveRequest, ...) HistoryBlobIterator

+ type HistoryBlobIteratorMock struct

+ func (_m *HistoryBlobIteratorMock) HasNext() bool

+ func (_m *HistoryBlobIteratorMock) Next() (*HistoryBlob, error)

+ type SysWorkerContainer struct

+ Blobstore blobstore.Client

+ ClusterMetadata cluster.Metadata

+ Config *Config

+ DomainCache cache.DomainCache

+ HistoryBlobIterator HistoryBlobIterator

+ HistoryManager persistence.HistoryManager

+ HistoryV2Manager persistence.HistoryV2Manager

+ Logger bark.Logger

+ MetricsClient metrics.Client

+ PublicClient public.Client

v0.5.2

Feb 12, 2019

Changes in this version

+ const HistoryBlobKeyExt

+ func ConvertHeaderToTags(header *HistoryBlobHeader) (map[string]string, error)

+ func NewHistoryBlobKey(domainID, workflowID, runID, pageToken, failoverVersion string) (blob.Key, error)

type ArchiveRequest

+ LastWriteVersion int64

+ type HistoryBlob struct

+ Body *shared.History

+ Header *HistoryBlobHeader

+ type HistoryBlobHeader struct

+ CurrentPageToken *string

+ DomainID *string

+ DomainName *string

+ EventCount *int64

+ FirstEventID *int64

+ FirstFailoverVersion *string

+ LastEventID *int64

+ LastFailoverVersion *string

+ NextPageToken *string

+ RunID *string

+ UploadCluster *string

+ UploadDateTime *string

+ WorkflowID *string

v0.5.1

Jan 18, 2019

v0.5.0

Jan 7, 2019

Changes in this version

+ const ArchivalActivityFnName

+ const ArchivalFailureErr

+ const BackfillActivityFnName

+ const BackfillFailureErr

+ const BucketNameTag

+ const ChannelClosedUnexpectedlyError

+ const DecisionTaskList

+ const DecisionTaskStartToCloseTimeout

+ const Domain

+ const DomainIDTag

+ const HandledSignalCount

+ const RunIDTag

+ const SignalName

+ const SignalsUntilContinueAsNew

+ const SystemWorkflowFnName

+ const SystemWorkflowIDTag

+ const SystemWorkflowScope

+ const UnknownSignalTypeErr

+ const WorkflowIDPrefix

+ const WorkflowIDTag

+ const WorkflowStartToCloseTimeout

+ func ArchivalActivity(ctx context.Context, request ArchiveRequest) error

+ func BackfillActivity(_ context.Context, _ BackfillRequest) error

+ func HistoryBlobFilename(domainID string, workflowID string, runID string) string

+ func SystemWorkflow(ctx workflow.Context) error

+ type ArchivalClient interface

+ Archive func(*ArchiveRequest) error

+ Backfill func(*BackfillRequest) error

+ func NewArchivalClient(frontendClient frontend.Client, numSWFn dynamicconfig.IntPropertyFn) ArchivalClient

+ type ArchiveRequest struct

+ Bucket string

+ DomainID string

+ DomainName string

+ RunID string

+ WorkflowID string

+ type BackfillRequest struct

+ type Config struct

+ type RequestType int

+ type SysWorker struct

+ func NewSysWorker(frontendClient frontend.Client, scope tally.Scope, ...) *SysWorker

+ func (w *SysWorker) Start() error

+ func (w *SysWorker) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL