Documentation ¶
Index ¶
- type BufferedEventFilter
- type EventFactory
- func (b *EventFactory) CreateActivityTaskCancelRequestedEvent(workflowTaskCompletedEventID int64, scheduledEventID int64) *historypb.HistoryEvent
- func (b *EventFactory) CreateActivityTaskCanceledEvent(scheduledEventID int64, startedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateActivityTaskCompletedEvent(scheduledEventID int64, startedEventID int64, identity string, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateActivityTaskFailedEvent(scheduledEventID int64, startedEventID int64, failure *failurepb.Failure, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateActivityTaskScheduledEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateActivityTaskStartedEvent(scheduledEventID int64, attempt int32, requestID string, identity string, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateActivityTaskTimedOutEvent(scheduledEventID int64, startedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateChildWorkflowExecutionCanceledEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateChildWorkflowExecutionCompletedEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateChildWorkflowExecutionFailedEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateChildWorkflowExecutionStartedEvent(initiatedID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateChildWorkflowExecutionTerminatedEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateChildWorkflowExecutionTimedOutEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateCompletedWorkflowEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b EventFactory) CreateContinuedAsNewEvent(workflowTaskCompletedEventID int64, newRunID string, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateExternalWorkflowExecutionCancelRequested(initiatedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateExternalWorkflowExecutionSignaled(initiatedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateFailWorkflowEvent(workflowTaskCompletedEventID int64, retryState enumspb.RetryState, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateMarkerRecordedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateRequestCancelExternalWorkflowExecutionFailedEvent(workflowTaskCompletedEventID int64, initiatedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateRequestCancelExternalWorkflowExecutionInitiatedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateSignalExternalWorkflowExecutionFailedEvent(workflowTaskCompletedEventID int64, initiatedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateSignalExternalWorkflowExecutionInitiatedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateStartChildWorkflowExecutionFailedEvent(workflowTaskCompletedEventID int64, initiatedID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateStartChildWorkflowExecutionInitiatedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateTimeoutWorkflowEvent(retryState enumspb.RetryState, newExecutionRunID string) *historypb.HistoryEvent
- func (b *EventFactory) CreateTimerCanceledEvent(workflowTaskCompletedEventID int64, startedEventID int64, timerID string, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateTimerFiredEvent(startedEventID int64, timerID string) *historypb.HistoryEvent
- func (b *EventFactory) CreateTimerStartedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateUpsertWorkflowSearchAttributesEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowExecutionCancelRequestedEvent(request *historyservice.RequestCancelWorkflowExecutionRequest) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowExecutionCanceledEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowExecutionSignaledEvent(signalName string, input *commonpb.Payloads, identity string, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowExecutionStartedEvent(startTime time.Time, request *historyservice.StartWorkflowExecutionRequest, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowExecutionTerminatedEvent(reason string, details *commonpb.Payloads, identity string) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowExecutionUpdateAcceptedEvent(protocolInstanceID string, acceptedRequestMessageId string, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowExecutionUpdateCompletedEvent(acceptedEventID int64, updResp *updatepb.Response) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowPropertiesModifiedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowTaskCompletedEvent(scheduledEventID int64, startedEventID int64, identity string, checksum string, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowTaskFailedEvent(scheduledEventID int64, startedEventID int64, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowTaskScheduledEvent(taskQueue *taskqueuepb.TaskQueue, startToCloseTimeout *durationpb.Duration, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowTaskStartedEvent(scheduledEventID int64, requestID string, identity string, startTime time.Time, ...) *historypb.HistoryEvent
- func (b *EventFactory) CreateWorkflowTaskTimedOutEvent(scheduledEventID int64, startedEventID int64, timeoutType enumspb.TimeoutType) *historypb.HistoryEvent
- type EventStore
- func (b *EventStore) AllocateEventID() int64
- func (b *EventStore) Finish(flushBufferEvent bool) (*HistoryMutation, error)
- func (b *EventStore) FlushAndCreateNewBatch()
- func (b *EventStore) FlushBufferToCurrentBatch() map[int64]int64
- func (b *EventStore) GetAndRemoveTimerFireEvent(timerID string) *historypb.HistoryEvent
- func (b *EventStore) HasActivityFinishEvent(scheduledEventID int64) bool
- func (b *EventStore) HasAnyBufferedEvent(predicate BufferedEventFilter) bool
- func (b *EventStore) HasBufferEvents() bool
- func (b *EventStore) IsDirty() bool
- func (b *EventStore) NextEventID() int64
- func (b *EventStore) NumBufferedEvents() int
- func (b *EventStore) SizeInBytesOfBufferedEvents() int
- type HistoryBuilder
- func (b *HistoryBuilder) AddActivityTaskCancelRequestedEvent(workflowTaskCompletedEventID int64, scheduledEventID int64) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddActivityTaskCanceledEvent(scheduledEventID int64, startedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddActivityTaskCompletedEvent(scheduledEventID int64, startedEventID int64, identity string, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddActivityTaskFailedEvent(scheduledEventID int64, startedEventID int64, failure *failurepb.Failure, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddActivityTaskScheduledEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddActivityTaskStartedEvent(scheduledEventID int64, attempt int32, requestID string, identity string, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddActivityTaskTimedOutEvent(scheduledEventID, startedEventID int64, timeoutFailure *failurepb.Failure, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddChildWorkflowExecutionCanceledEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddChildWorkflowExecutionCompletedEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddChildWorkflowExecutionFailedEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddChildWorkflowExecutionStartedEvent(initiatedID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddChildWorkflowExecutionTerminatedEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddChildWorkflowExecutionTimedOutEvent(initiatedID int64, startedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddCompletedWorkflowEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddContinuedAsNewEvent(workflowTaskCompletedEventID int64, newRunID string, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddExternalWorkflowExecutionCancelRequested(initiatedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddExternalWorkflowExecutionSignaled(initiatedEventID int64, targetNamespace namespace.Name, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddFailWorkflowEvent(workflowTaskCompletedEventID int64, retryState enumspb.RetryState, ...) (*historypb.HistoryEvent, int64)
- func (b *HistoryBuilder) AddMarkerRecordedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddRequestCancelExternalWorkflowExecutionFailedEvent(workflowTaskCompletedEventID int64, initiatedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddSignalExternalWorkflowExecutionFailedEvent(workflowTaskCompletedEventID int64, initiatedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddSignalExternalWorkflowExecutionInitiatedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddStartChildWorkflowExecutionFailedEvent(workflowTaskCompletedEventID int64, initiatedID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddStartChildWorkflowExecutionInitiatedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddTimeoutWorkflowEvent(retryState enumspb.RetryState, newExecutionRunID string) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddTimerCanceledEvent(workflowTaskCompletedEventID int64, startedEventID int64, timerID string, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddTimerFiredEvent(startedEventID int64, timerID string) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddTimerStartedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddUpsertWorkflowSearchAttributesEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowExecutionCancelRequestedEvent(request *historyservice.RequestCancelWorkflowExecutionRequest) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowExecutionCanceledEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowExecutionSignaledEvent(signalName string, input *commonpb.Payloads, identity string, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowExecutionStartedEvent(startTime time.Time, request *historyservice.StartWorkflowExecutionRequest, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowExecutionTerminatedEvent(reason string, details *commonpb.Payloads, identity string) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowExecutionUpdateAcceptedEvent(protocolInstanceID string, acceptedRequestMessageId string, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowExecutionUpdateCompletedEvent(acceptedEventID int64, updResp *updatepb.Response) (*historypb.HistoryEvent, int64)
- func (b *HistoryBuilder) AddWorkflowPropertiesModifiedEvent(workflowTaskCompletedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowTaskCompletedEvent(scheduledEventID int64, startedEventID int64, identity string, checksum string, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowTaskFailedEvent(scheduledEventID int64, startedEventID int64, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowTaskScheduledEvent(taskQueue *taskqueuepb.TaskQueue, startToCloseTimeout *durationpb.Duration, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowTaskStartedEvent(scheduledEventID int64, requestID string, identity string, startTime time.Time, ...) *historypb.HistoryEvent
- func (b *HistoryBuilder) AddWorkflowTaskTimedOutEvent(scheduledEventID int64, startedEventID int64, timeoutType enumspb.TimeoutType) *historypb.HistoryEvent
- func (b *HistoryBuilder) IsDirty() bool
- type HistoryBuilderState
- type HistoryMutation
- type TaskIDGenerator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BufferedEventFilter ¶
type BufferedEventFilter func(*historypb.HistoryEvent) bool
type EventFactory ¶
type EventFactory struct {
// contains filtered or unexported fields
}
func (*EventFactory) CreateActivityTaskCancelRequestedEvent ¶
func (b *EventFactory) CreateActivityTaskCancelRequestedEvent( workflowTaskCompletedEventID int64, scheduledEventID int64, ) *historypb.HistoryEvent
func (*EventFactory) CreateActivityTaskCanceledEvent ¶
func (b *EventFactory) CreateActivityTaskCanceledEvent( scheduledEventID int64, startedEventID int64, latestCancelRequestedEventID int64, details *commonpb.Payloads, identity string, ) *historypb.HistoryEvent
func (*EventFactory) CreateActivityTaskCompletedEvent ¶
func (b *EventFactory) CreateActivityTaskCompletedEvent( scheduledEventID int64, startedEventID int64, identity string, result *commonpb.Payloads, ) *historypb.HistoryEvent
func (*EventFactory) CreateActivityTaskFailedEvent ¶
func (b *EventFactory) CreateActivityTaskFailedEvent( scheduledEventID int64, startedEventID int64, failure *failurepb.Failure, retryState enumspb.RetryState, identity string, ) *historypb.HistoryEvent
func (*EventFactory) CreateActivityTaskScheduledEvent ¶
func (b *EventFactory) CreateActivityTaskScheduledEvent( workflowTaskCompletedEventID int64, command *commandpb.ScheduleActivityTaskCommandAttributes, ) *historypb.HistoryEvent
func (*EventFactory) CreateActivityTaskStartedEvent ¶
func (b *EventFactory) CreateActivityTaskStartedEvent( scheduledEventID int64, attempt int32, requestID string, identity string, lastFailure *failurepb.Failure, ) *historypb.HistoryEvent
func (*EventFactory) CreateActivityTaskTimedOutEvent ¶
func (b *EventFactory) CreateActivityTaskTimedOutEvent( scheduledEventID int64, startedEventID int64, timeoutFailure *failurepb.Failure, retryState enumspb.RetryState, ) *historypb.HistoryEvent
func (*EventFactory) CreateChildWorkflowExecutionCanceledEvent ¶
func (b *EventFactory) CreateChildWorkflowExecutionCanceledEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, details *commonpb.Payloads, ) *historypb.HistoryEvent
func (*EventFactory) CreateChildWorkflowExecutionCompletedEvent ¶
func (b *EventFactory) CreateChildWorkflowExecutionCompletedEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, result *commonpb.Payloads, ) *historypb.HistoryEvent
func (*EventFactory) CreateChildWorkflowExecutionFailedEvent ¶
func (b *EventFactory) CreateChildWorkflowExecutionFailedEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, failure *failurepb.Failure, retryState enumspb.RetryState, ) *historypb.HistoryEvent
func (*EventFactory) CreateChildWorkflowExecutionStartedEvent ¶
func (b *EventFactory) CreateChildWorkflowExecutionStartedEvent( initiatedID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, header *commonpb.Header, ) *historypb.HistoryEvent
func (*EventFactory) CreateChildWorkflowExecutionTerminatedEvent ¶
func (b *EventFactory) CreateChildWorkflowExecutionTerminatedEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, ) *historypb.HistoryEvent
func (*EventFactory) CreateChildWorkflowExecutionTimedOutEvent ¶
func (b *EventFactory) CreateChildWorkflowExecutionTimedOutEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, retryState enumspb.RetryState, ) *historypb.HistoryEvent
func (*EventFactory) CreateCompletedWorkflowEvent ¶
func (b *EventFactory) CreateCompletedWorkflowEvent( workflowTaskCompletedEventID int64, command *commandpb.CompleteWorkflowExecutionCommandAttributes, newExecutionRunID string, ) *historypb.HistoryEvent
func (EventFactory) CreateContinuedAsNewEvent ¶
func (b EventFactory) CreateContinuedAsNewEvent( workflowTaskCompletedEventID int64, newRunID string, command *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes, ) *historypb.HistoryEvent
func (*EventFactory) CreateExternalWorkflowExecutionCancelRequested ¶
func (b *EventFactory) CreateExternalWorkflowExecutionCancelRequested( initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, runID string, ) *historypb.HistoryEvent
func (*EventFactory) CreateExternalWorkflowExecutionSignaled ¶
func (*EventFactory) CreateFailWorkflowEvent ¶
func (b *EventFactory) CreateFailWorkflowEvent( workflowTaskCompletedEventID int64, retryState enumspb.RetryState, command *commandpb.FailWorkflowExecutionCommandAttributes, newExecutionRunID string, ) *historypb.HistoryEvent
func (*EventFactory) CreateMarkerRecordedEvent ¶
func (b *EventFactory) CreateMarkerRecordedEvent( workflowTaskCompletedEventID int64, command *commandpb.RecordMarkerCommandAttributes, ) *historypb.HistoryEvent
func (*EventFactory) CreateRequestCancelExternalWorkflowExecutionFailedEvent ¶
func (b *EventFactory) CreateRequestCancelExternalWorkflowExecutionFailedEvent( workflowTaskCompletedEventID int64, initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, runID string, cause enumspb.CancelExternalWorkflowExecutionFailedCause, ) *historypb.HistoryEvent
func (*EventFactory) CreateRequestCancelExternalWorkflowExecutionInitiatedEvent ¶
func (b *EventFactory) CreateRequestCancelExternalWorkflowExecutionInitiatedEvent( workflowTaskCompletedEventID int64, command *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes, targetNamespaceID namespace.ID, ) *historypb.HistoryEvent
func (*EventFactory) CreateSignalExternalWorkflowExecutionFailedEvent ¶
func (b *EventFactory) CreateSignalExternalWorkflowExecutionFailedEvent( workflowTaskCompletedEventID int64, initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, runID string, control string, cause enumspb.SignalExternalWorkflowExecutionFailedCause, ) *historypb.HistoryEvent
func (*EventFactory) CreateSignalExternalWorkflowExecutionInitiatedEvent ¶
func (b *EventFactory) CreateSignalExternalWorkflowExecutionInitiatedEvent( workflowTaskCompletedEventID int64, command *commandpb.SignalExternalWorkflowExecutionCommandAttributes, targetNamespaceID namespace.ID, ) *historypb.HistoryEvent
func (*EventFactory) CreateStartChildWorkflowExecutionFailedEvent ¶
func (b *EventFactory) CreateStartChildWorkflowExecutionFailedEvent( workflowTaskCompletedEventID int64, initiatedID int64, cause enumspb.StartChildWorkflowExecutionFailedCause, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, workflowType *commonpb.WorkflowType, control string, ) *historypb.HistoryEvent
func (*EventFactory) CreateStartChildWorkflowExecutionInitiatedEvent ¶
func (b *EventFactory) CreateStartChildWorkflowExecutionInitiatedEvent( workflowTaskCompletedEventID int64, command *commandpb.StartChildWorkflowExecutionCommandAttributes, targetNamespaceID namespace.ID, ) *historypb.HistoryEvent
func (*EventFactory) CreateTimeoutWorkflowEvent ¶
func (b *EventFactory) CreateTimeoutWorkflowEvent( retryState enumspb.RetryState, newExecutionRunID string, ) *historypb.HistoryEvent
func (*EventFactory) CreateTimerCanceledEvent ¶
func (b *EventFactory) CreateTimerCanceledEvent( workflowTaskCompletedEventID int64, startedEventID int64, timerID string, identity string, ) *historypb.HistoryEvent
func (*EventFactory) CreateTimerFiredEvent ¶
func (b *EventFactory) CreateTimerFiredEvent(startedEventID int64, timerID string) *historypb.HistoryEvent
func (*EventFactory) CreateTimerStartedEvent ¶
func (b *EventFactory) CreateTimerStartedEvent( workflowTaskCompletedEventID int64, command *commandpb.StartTimerCommandAttributes, ) *historypb.HistoryEvent
func (*EventFactory) CreateUpsertWorkflowSearchAttributesEvent ¶
func (b *EventFactory) CreateUpsertWorkflowSearchAttributesEvent( workflowTaskCompletedEventID int64, command *commandpb.UpsertWorkflowSearchAttributesCommandAttributes, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowExecutionCancelRequestedEvent ¶
func (b *EventFactory) CreateWorkflowExecutionCancelRequestedEvent(request *historyservice.RequestCancelWorkflowExecutionRequest) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowExecutionCanceledEvent ¶
func (b *EventFactory) CreateWorkflowExecutionCanceledEvent( workflowTaskCompletedEventID int64, command *commandpb.CancelWorkflowExecutionCommandAttributes, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowExecutionSignaledEvent ¶
func (b *EventFactory) CreateWorkflowExecutionSignaledEvent( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, skipGenerateWorkflowTask bool, externalWorkflowExecution *commonpb.WorkflowExecution, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowExecutionStartedEvent ¶
func (b *EventFactory) CreateWorkflowExecutionStartedEvent( startTime time.Time, request *historyservice.StartWorkflowExecutionRequest, resetPoints *workflowpb.ResetPoints, prevRunID string, firstRunID string, originalRunID string, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowExecutionTerminatedEvent ¶
func (b *EventFactory) CreateWorkflowExecutionTerminatedEvent( reason string, details *commonpb.Payloads, identity string, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowExecutionUpdateAcceptedEvent ¶
func (b *EventFactory) CreateWorkflowExecutionUpdateAcceptedEvent( protocolInstanceID string, acceptedRequestMessageId string, acceptedRequestSequencingEventId int64, acceptedRequest *updatepb.Request, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowExecutionUpdateCompletedEvent ¶
func (b *EventFactory) CreateWorkflowExecutionUpdateCompletedEvent( acceptedEventID int64, updResp *updatepb.Response, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowPropertiesModifiedEvent ¶
func (b *EventFactory) CreateWorkflowPropertiesModifiedEvent( workflowTaskCompletedEventID int64, command *commandpb.ModifyWorkflowPropertiesCommandAttributes, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowTaskCompletedEvent ¶
func (b *EventFactory) CreateWorkflowTaskCompletedEvent( scheduledEventID int64, startedEventID int64, identity string, checksum string, workerVersionStamp *commonpb.WorkerVersionStamp, sdkMetadata *sdkpb.WorkflowTaskCompletedMetadata, meteringMetadata *commonpb.MeteringMetadata, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowTaskFailedEvent ¶
func (b *EventFactory) CreateWorkflowTaskFailedEvent( scheduledEventID int64, startedEventID int64, cause enumspb.WorkflowTaskFailedCause, failure *failurepb.Failure, identity string, baseRunID string, newRunID string, forkEventVersion int64, checksum string, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowTaskScheduledEvent ¶
func (b *EventFactory) CreateWorkflowTaskScheduledEvent( taskQueue *taskqueuepb.TaskQueue, startToCloseTimeout *durationpb.Duration, attempt int32, scheduleTime time.Time, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowTaskStartedEvent ¶
func (b *EventFactory) CreateWorkflowTaskStartedEvent( scheduledEventID int64, requestID string, identity string, startTime time.Time, suggestContinueAsNew bool, historySizeBytes int64, ) *historypb.HistoryEvent
func (*EventFactory) CreateWorkflowTaskTimedOutEvent ¶
func (b *EventFactory) CreateWorkflowTaskTimedOutEvent( scheduledEventID int64, startedEventID int64, timeoutType enumspb.TimeoutType, ) *historypb.HistoryEvent
type EventStore ¶
type EventStore struct {
// contains filtered or unexported fields
}
func (*EventStore) AllocateEventID ¶
func (b *EventStore) AllocateEventID() int64
func (*EventStore) Finish ¶
func (b *EventStore) Finish( flushBufferEvent bool, ) (*HistoryMutation, error)
func (*EventStore) FlushAndCreateNewBatch ¶
func (b *EventStore) FlushAndCreateNewBatch()
func (*EventStore) FlushBufferToCurrentBatch ¶
func (b *EventStore) FlushBufferToCurrentBatch() map[int64]int64
func (*EventStore) GetAndRemoveTimerFireEvent ¶
func (b *EventStore) GetAndRemoveTimerFireEvent( timerID string, ) *historypb.HistoryEvent
func (*EventStore) HasActivityFinishEvent ¶
func (b *EventStore) HasActivityFinishEvent( scheduledEventID int64, ) bool
func (*EventStore) HasAnyBufferedEvent ¶
func (b *EventStore) HasAnyBufferedEvent(predicate BufferedEventFilter) bool
HasAnyBufferedEvent returns true if there is at least one buffered event that matches the provided filter.
func (*EventStore) HasBufferEvents ¶
func (b *EventStore) HasBufferEvents() bool
func (*EventStore) IsDirty ¶
func (b *EventStore) IsDirty() bool
func (*EventStore) NextEventID ¶
func (b *EventStore) NextEventID() int64
func (*EventStore) NumBufferedEvents ¶
func (b *EventStore) NumBufferedEvents() int
func (*EventStore) SizeInBytesOfBufferedEvents ¶
func (b *EventStore) SizeInBytesOfBufferedEvents() int
type HistoryBuilder ¶
type HistoryBuilder struct { EventStore EventFactory }
func New ¶
func New( timeSource clock.TimeSource, taskIDGenerator TaskIDGenerator, version int64, nextEventID int64, dbBufferBatch []*historypb.HistoryEvent, metricsHandler metrics.Handler, ) *HistoryBuilder
func NewImmutable ¶
func NewImmutable(histories ...[]*historypb.HistoryEvent) *HistoryBuilder
func (*HistoryBuilder) AddActivityTaskCancelRequestedEvent ¶
func (b *HistoryBuilder) AddActivityTaskCancelRequestedEvent( workflowTaskCompletedEventID int64, scheduledEventID int64, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddActivityTaskCanceledEvent ¶
func (b *HistoryBuilder) AddActivityTaskCanceledEvent( scheduledEventID int64, startedEventID int64, latestCancelRequestedEventID int64, details *commonpb.Payloads, identity string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddActivityTaskCompletedEvent ¶
func (b *HistoryBuilder) AddActivityTaskCompletedEvent( scheduledEventID int64, startedEventID int64, identity string, result *commonpb.Payloads, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddActivityTaskFailedEvent ¶
func (b *HistoryBuilder) AddActivityTaskFailedEvent( scheduledEventID int64, startedEventID int64, failure *failurepb.Failure, retryState enumspb.RetryState, identity string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddActivityTaskScheduledEvent ¶
func (b *HistoryBuilder) AddActivityTaskScheduledEvent( workflowTaskCompletedEventID int64, command *commandpb.ScheduleActivityTaskCommandAttributes, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddActivityTaskStartedEvent ¶
func (b *HistoryBuilder) AddActivityTaskStartedEvent( scheduledEventID int64, attempt int32, requestID string, identity string, lastFailure *failurepb.Failure, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddActivityTaskTimedOutEvent ¶
func (b *HistoryBuilder) AddActivityTaskTimedOutEvent( scheduledEventID, startedEventID int64, timeoutFailure *failurepb.Failure, retryState enumspb.RetryState, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddChildWorkflowExecutionCanceledEvent ¶
func (b *HistoryBuilder) AddChildWorkflowExecutionCanceledEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, details *commonpb.Payloads, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddChildWorkflowExecutionCompletedEvent ¶
func (b *HistoryBuilder) AddChildWorkflowExecutionCompletedEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, result *commonpb.Payloads, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddChildWorkflowExecutionFailedEvent ¶
func (b *HistoryBuilder) AddChildWorkflowExecutionFailedEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, failure *failurepb.Failure, retryState enumspb.RetryState, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddChildWorkflowExecutionStartedEvent ¶
func (b *HistoryBuilder) AddChildWorkflowExecutionStartedEvent( initiatedID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, header *commonpb.Header, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddChildWorkflowExecutionTerminatedEvent ¶
func (b *HistoryBuilder) AddChildWorkflowExecutionTerminatedEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddChildWorkflowExecutionTimedOutEvent ¶
func (b *HistoryBuilder) AddChildWorkflowExecutionTimedOutEvent( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.WorkflowExecution, workflowType *commonpb.WorkflowType, retryState enumspb.RetryState, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddCompletedWorkflowEvent ¶
func (b *HistoryBuilder) AddCompletedWorkflowEvent( workflowTaskCompletedEventID int64, command *commandpb.CompleteWorkflowExecutionCommandAttributes, newExecutionRunID string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddContinuedAsNewEvent ¶
func (b *HistoryBuilder) AddContinuedAsNewEvent( workflowTaskCompletedEventID int64, newRunID string, command *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddExternalWorkflowExecutionCancelRequested ¶
func (b *HistoryBuilder) AddExternalWorkflowExecutionCancelRequested( initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, runID string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddExternalWorkflowExecutionSignaled ¶
func (*HistoryBuilder) AddFailWorkflowEvent ¶
func (b *HistoryBuilder) AddFailWorkflowEvent( workflowTaskCompletedEventID int64, retryState enumspb.RetryState, command *commandpb.FailWorkflowExecutionCommandAttributes, newExecutionRunID string, ) (*historypb.HistoryEvent, int64)
func (*HistoryBuilder) AddMarkerRecordedEvent ¶
func (b *HistoryBuilder) AddMarkerRecordedEvent( workflowTaskCompletedEventID int64, command *commandpb.RecordMarkerCommandAttributes, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddRequestCancelExternalWorkflowExecutionFailedEvent ¶
func (b *HistoryBuilder) AddRequestCancelExternalWorkflowExecutionFailedEvent( workflowTaskCompletedEventID int64, initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, runID string, cause enumspb.CancelExternalWorkflowExecutionFailedCause, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent ¶
func (b *HistoryBuilder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent( workflowTaskCompletedEventID int64, command *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes, targetNamespaceID namespace.ID, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddSignalExternalWorkflowExecutionFailedEvent ¶
func (b *HistoryBuilder) AddSignalExternalWorkflowExecutionFailedEvent( workflowTaskCompletedEventID int64, initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, runID string, control string, cause enumspb.SignalExternalWorkflowExecutionFailedCause, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddSignalExternalWorkflowExecutionInitiatedEvent ¶
func (b *HistoryBuilder) AddSignalExternalWorkflowExecutionInitiatedEvent( workflowTaskCompletedEventID int64, command *commandpb.SignalExternalWorkflowExecutionCommandAttributes, targetNamespaceID namespace.ID, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddStartChildWorkflowExecutionFailedEvent ¶
func (b *HistoryBuilder) AddStartChildWorkflowExecutionFailedEvent( workflowTaskCompletedEventID int64, initiatedID int64, cause enumspb.StartChildWorkflowExecutionFailedCause, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID string, workflowType *commonpb.WorkflowType, control string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddStartChildWorkflowExecutionInitiatedEvent ¶
func (b *HistoryBuilder) AddStartChildWorkflowExecutionInitiatedEvent( workflowTaskCompletedEventID int64, command *commandpb.StartChildWorkflowExecutionCommandAttributes, targetNamespaceID namespace.ID, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddTimeoutWorkflowEvent ¶
func (b *HistoryBuilder) AddTimeoutWorkflowEvent( retryState enumspb.RetryState, newExecutionRunID string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddTimerCanceledEvent ¶
func (b *HistoryBuilder) AddTimerCanceledEvent( workflowTaskCompletedEventID int64, startedEventID int64, timerID string, identity string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddTimerFiredEvent ¶
func (b *HistoryBuilder) AddTimerFiredEvent( startedEventID int64, timerID string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddTimerStartedEvent ¶
func (b *HistoryBuilder) AddTimerStartedEvent( workflowTaskCompletedEventID int64, command *commandpb.StartTimerCommandAttributes, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddUpsertWorkflowSearchAttributesEvent ¶
func (b *HistoryBuilder) AddUpsertWorkflowSearchAttributesEvent( workflowTaskCompletedEventID int64, command *commandpb.UpsertWorkflowSearchAttributesCommandAttributes, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowExecutionCancelRequestedEvent ¶
func (b *HistoryBuilder) AddWorkflowExecutionCancelRequestedEvent( request *historyservice.RequestCancelWorkflowExecutionRequest, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowExecutionCanceledEvent ¶
func (b *HistoryBuilder) AddWorkflowExecutionCanceledEvent( workflowTaskCompletedEventID int64, command *commandpb.CancelWorkflowExecutionCommandAttributes, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowExecutionSignaledEvent ¶
func (b *HistoryBuilder) AddWorkflowExecutionSignaledEvent( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, skipGenerateWorkflowTask bool, externalWorkflowExecution *commonpb.WorkflowExecution, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowExecutionStartedEvent ¶
func (b *HistoryBuilder) AddWorkflowExecutionStartedEvent( startTime time.Time, request *historyservice.StartWorkflowExecutionRequest, resetPoints *workflowpb.ResetPoints, prevRunID string, firstInChainRunID string, originalRunID string, ) *historypb.HistoryEvent
AddWorkflowExecutionStartedEvent firstInChainRunID is the very first runID along the chain of ContinueAsNew and Reset originalRunID is the runID when the WorkflowExecutionStarted event is written
func (*HistoryBuilder) AddWorkflowExecutionTerminatedEvent ¶
func (b *HistoryBuilder) AddWorkflowExecutionTerminatedEvent( reason string, details *commonpb.Payloads, identity string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowExecutionUpdateAcceptedEvent ¶
func (b *HistoryBuilder) AddWorkflowExecutionUpdateAcceptedEvent( protocolInstanceID string, acceptedRequestMessageId string, acceptedRequestSequencingEventId int64, acceptedRequest *updatepb.Request, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowExecutionUpdateCompletedEvent ¶
func (b *HistoryBuilder) AddWorkflowExecutionUpdateCompletedEvent( acceptedEventID int64, updResp *updatepb.Response, ) (*historypb.HistoryEvent, int64)
func (*HistoryBuilder) AddWorkflowPropertiesModifiedEvent ¶
func (b *HistoryBuilder) AddWorkflowPropertiesModifiedEvent( workflowTaskCompletedEventID int64, command *commandpb.ModifyWorkflowPropertiesCommandAttributes, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowTaskCompletedEvent ¶
func (b *HistoryBuilder) AddWorkflowTaskCompletedEvent( scheduledEventID int64, startedEventID int64, identity string, checksum string, workerVersionStamp *commonpb.WorkerVersionStamp, sdkMetadata *sdkpb.WorkflowTaskCompletedMetadata, meteringMetadata *commonpb.MeteringMetadata, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowTaskFailedEvent ¶
func (b *HistoryBuilder) AddWorkflowTaskFailedEvent( scheduledEventID int64, startedEventID int64, cause enumspb.WorkflowTaskFailedCause, failure *failurepb.Failure, identity string, baseRunID string, newRunID string, forkEventVersion int64, checksum string, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowTaskScheduledEvent ¶
func (b *HistoryBuilder) AddWorkflowTaskScheduledEvent( taskQueue *taskqueuepb.TaskQueue, startToCloseTimeout *durationpb.Duration, attempt int32, scheduleTime time.Time, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowTaskStartedEvent ¶
func (b *HistoryBuilder) AddWorkflowTaskStartedEvent( scheduledEventID int64, requestID string, identity string, startTime time.Time, suggestContinueAsNew bool, historySizeBytes int64, ) *historypb.HistoryEvent
func (*HistoryBuilder) AddWorkflowTaskTimedOutEvent ¶
func (b *HistoryBuilder) AddWorkflowTaskTimedOutEvent( scheduledEventID int64, startedEventID int64, timeoutType enumspb.TimeoutType, ) *historypb.HistoryEvent
func (*HistoryBuilder) IsDirty ¶
func (b *HistoryBuilder) IsDirty() bool
type HistoryBuilderState ¶
type HistoryBuilderState int
const ( HistoryBuilderStateMutable HistoryBuilderState = iota HistoryBuilderStateImmutable HistoryBuilderStateSealed )
type HistoryMutation ¶
type HistoryMutation struct { // events to be persisted to events table DBEventsBatches [][]*historypb.HistoryEvent // events to be buffer in execution table DBBufferBatch []*historypb.HistoryEvent // whether to clear buffer events on DB DBClearBuffer bool // accumulated buffered events, equal to all buffer events from execution table MemBufferBatch []*historypb.HistoryEvent // scheduled to started event ID mapping for flushed buffered event ScheduledIDToStartedID map[int64]int64 }
type TaskIDGenerator ¶
Click to show internal directories.
Click to hide internal directories.