history

package

Go to main page

Versions in this module

v0

v0.19.0

Oct 27, 2024

Changes in this version

type ActivityScheduledAttributes

+ Attempt int

+ Queue core.Queue

type EventType

+ const EventType_TraceStarted

type ExecutionStartedAttributes

+ Queue core.Queue

+ WorkflowSpanID [8]byte

type SubWorkflowScheduledAttributes

+ SubWorkflowQueue core.Queue

+ WorkflowSpanID [8]byte

type TimerFiredAttributes

+ Name string

+ ScheduledAt time.Time

+ TraceContext tracing.Context

type TimerScheduledAttributes

+ Name string

+ type TraceStartedAttributes struct

+ SpanID payload.Payload

v0.18.5

Jan 21, 2024

v0.18.4

Jan 10, 2024

v0.18.3

Jan 8, 2024

v0.18.2

Dec 5, 2023

v0.18.1

Dec 5, 2023

v0.18.0

Nov 29, 2023

v0.17.0

Sep 28, 2023

Changes in this version

+ func DeserializeAttributes(eventType EventType, attributes []byte) (attr interface{}, err error)

+ func EventsByWorkflowInstance(events []WorkflowEvent) map[core.WorkflowInstance][]WorkflowEvent

+ func SerializeAttributes(attributes interface{}) ([]byte, error)

+ type ActivityCompletedAttributes struct

+ Result payload.Payload

+ type ActivityFailedAttributes struct

+ Error *workflowerrors.Error

+ type ActivityScheduledAttributes struct

+ Inputs []payload.Payload

+ Metadata *metadata.WorkflowMetadata

+ Name string

+ type Event struct

+ Attributes interface{}

+ ID string

+ ScheduleEventID int64

+ SequenceID int64

+ Timestamp time.Time

+ Type EventType

+ VisibleAt *time.Time

+ func NewHistoryEvent(sequenceID int64, timestamp time.Time, eventType EventType, ...) *Event

+ func NewPendingEvent(timestamp time.Time, eventType EventType, attributes interface{}, ...) *Event

+ func NewWorkflowCancellationEvent(timestamp time.Time) *Event

+ func (e *Event) UnmarshalJSON(data []byte) error

+ func (e Event) String() string

+ type EventType uint

+ const EventType_ActivityCompleted

+ const EventType_ActivityFailed

+ const EventType_ActivityScheduled

+ const EventType_SideEffectResult

+ const EventType_SignalReceived

+ const EventType_SubWorkflowCancellationRequested

+ const EventType_SubWorkflowCompleted

+ const EventType_SubWorkflowFailed

+ const EventType_SubWorkflowScheduled

+ const EventType_TimerCanceled

+ const EventType_TimerFired

+ const EventType_TimerScheduled

+ const EventType_WorkflowExecutionCanceled

+ const EventType_WorkflowExecutionContinuedAsNew

+ const EventType_WorkflowExecutionFinished

+ const EventType_WorkflowExecutionStarted

+ const EventType_WorkflowExecutionTerminated

+ const EventType_WorkflowTaskStarted

+ func (et EventType) String() string

+ type ExecutionCanceledAttributes struct

+ type ExecutionCompletedAttributes struct

+ Error *workflowerrors.Error

+ Result payload.Payload

+ type ExecutionContinuedAsNewAttributes struct

+ ContinuedExecutionID string

+ Result payload.Payload

+ type ExecutionStartedAttributes struct

+ Inputs []payload.Payload

+ Metadata *metadata.WorkflowMetadata

+ Name string

+ type HistoryEventOption func(e *Event)

+ func ScheduleEventID(scheduleEventID int64) HistoryEventOption

+ func VisibleAt(visibleAt time.Time) HistoryEventOption

+ type SideEffectResultAttributes struct

+ Result payload.Payload

+ type SignalReceivedAttributes struct

+ Arg payload.Payload

+ Name string

+ type SubWorkflowCancellationRequestedAttributes struct

+ SubWorkflowInstance *core.WorkflowInstance

+ type SubWorkflowCompletedAttributes struct

+ Result payload.Payload

+ type SubWorkflowFailedAttributes struct

+ Error *workflowerrors.Error

+ type SubWorkflowScheduledAttributes struct

+ Inputs []payload.Payload

+ Metadata *metadata.WorkflowMetadata

+ Name string

+ SubWorkflowInstance *core.WorkflowInstance

+ type TimerCanceledAttributes struct

+ type TimerFiredAttributes struct

+ At time.Time

+ type TimerScheduledAttributes struct

+ At time.Time

+ type WorkflowEvent struct

+ HistoryEvent *Event

+ WorkflowInstance *core.WorkflowInstance

+ type WorkflowTaskStartedAttributes struct

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