event

type CancelEvent ¶

type CancelEvent struct{}

CancelEvent Cancellation event

func MakeCancelEvent() CancelEvent

func (ev CancelEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type CompensationEvent ¶

type CompensationEvent struct {
	// contains filtered or unexported fields
}

CompensationEvent Compensation event

func MakeCompensationEvent(activityRef string) CompensationEvent

func (ev *CompensationEvent) ActivityRef() *string

func (ev *CompensationEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type ConditionalEvent ¶

type ConditionalEvent struct {
	// contains filtered or unexported fields
}

ConditionalEvent represents an event that occurs when a certain timer is triggered.

func MakeConditionalEvent(instance IDefinitionInstance) ConditionalEvent

func (ev *ConditionalEvent) Instance() IDefinitionInstance

func (ev *ConditionalEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type ConsumptionResult ¶

type ConsumptionResult int

ConsumptionResult Result of event consumption

const (
	// Consumed Consumer has successfully consumed the event
	Consumed ConsumptionResult = iota
	// ConsumptionError Consumer had an unexpected error consuming the event
	//
	// The error is returned as a second value.
	ConsumptionError
	// PartiallyConsumed Consumer with multiple sub-consumers was able to
	// have at least some of the sub-consumers consume the event
	// but there were some errors (the errors are returned as
	// `multierror` list in the second value)
	PartiallyConsumed
	// DropEventConsumer Event consumer should no longer receive events
	//
	// This is a mechanism for "unsubscribing" from an event source
	DropEventConsumer
)

func ForwardEvent(ev IEvent, eventConsumers *[]IConsumer) (result ConsumptionResult, err error)

type EndEvent ¶

type EndEvent struct {
	Element *schema.EndEvent
}

EndEvent Process has ended

func MakeEndEvent(element *schema.EndEvent) EndEvent

func (ev EndEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type ErrorEvent ¶

type ErrorEvent struct {
	// contains filtered or unexported fields
}

ErrorEvent Error event

func MakeErrorEvent(errorRef string, items ...data.IItem) ErrorEvent

func (ev *ErrorEvent) ErrorRef() *string

func (ev *ErrorEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type EscalationEvent ¶

type EscalationEvent struct {
	// contains filtered or unexported fields
}

EscalationEvent Escalation event

func MakeEscalationEvent(escalationRef string, items ...data.IItem) EscalationEvent

func (ev *EscalationEvent) EscalationRef() *string

func (ev *EscalationEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type FanOut ¶

type FanOut struct {
	// contains filtered or unexported fields
}

FanOut is a straightforward Consumer + Source, forwards all consumed messages to all subscribers registered at it.

func NewFanOut() *FanOut

func (f *FanOut) ConsumeEvent(ev IEvent) (result ConsumptionResult, err error)

func (f *FanOut) RegisterEventConsumer(ev IConsumer) (err error)

type IConsumer ¶

type IConsumer interface {
	ConsumeEvent(IEvent) (ConsumptionResult, error)
}

IConsumer Process event consumer interface

type IDefinitionInstance ¶

type IDefinitionInstance interface {
	EventDefinition() schema.EventDefinitionInterface
}

IDefinitionInstance is a unifying interface for representing event definition within an execution context (useful for event definitions like timer, condition, etc.)

func WrapEventDefinition(def schema.EventDefinitionInterface) IDefinitionInstance

type IDefinitionInstanceBuilder ¶

type IDefinitionInstanceBuilder interface {
	NewEventDefinitionInstance(def schema.EventDefinitionInterface) (definitionInstance IDefinitionInstance, err error)
}

IDefinitionInstanceBuilder allows supplying custom instance builders that interact with the rest of the system and add context for further matching

func DefinitionInstanceBuildingChain(builders ...IDefinitionInstanceBuilder) IDefinitionInstanceBuilder

type IEvent ¶

type IEvent interface {
	MatchesEventInstance(IDefinitionInstance) bool
}

type ISource ¶

type ISource interface {
	RegisterEventConsumer(IConsumer) error
}

type LinkEvent ¶

type LinkEvent struct {
	// contains filtered or unexported fields
}

LinkEvent Link event

func MakeLinkEvent(sources []string, target *string) LinkEvent

func (ev *LinkEvent) MatchesEventInstance(instance IDefinitionInstance) bool

func (ev *LinkEvent) Sources() *[]string

func (ev *LinkEvent) Target() (result *string, present bool)

type MessageEvent ¶

type MessageEvent struct {
	// contains filtered or unexported fields
}

MessageEvent Message event

func MakeMessageEvent(messageRef string, operationRef *string, items ...data.IItem) MessageEvent

func NewMessageEvent(messageRef string, operationRef *string, items ...data.IItem) *MessageEvent

func (ev *MessageEvent) MatchesEventInstance(instance IDefinitionInstance) bool

func (ev *MessageEvent) MessageRef() *string

func (ev *MessageEvent) OperationRef() (result *string, present bool)

type NoneEvent ¶

type NoneEvent struct{}

NoneEvent None event

func MakeNoneEvent() NoneEvent

func (ev NoneEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type SignalEvent ¶

type SignalEvent struct {
	// contains filtered or unexported fields
}

SignalEvent Signal event

func MakeSignalEvent(signalRef string, items ...data.IItem) SignalEvent

func NewSignalEvent(signalRef string, items ...data.IItem) *SignalEvent

func (ev *SignalEvent) MatchesEventInstance(instance IDefinitionInstance) bool

func (ev *SignalEvent) SignalRef() *string

type TerminateEvent ¶

type TerminateEvent struct{}

TerminateEvent Termination event

func MakeTerminateEvent() TerminateEvent

func (ev TerminateEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type TimerEvent ¶

type TimerEvent struct {
	// contains filtered or unexported fields
}

TimerEvent represents an event that occurs when a certain timer is triggered.

func MakeTimerEvent(instance IDefinitionInstance) TimerEvent

func (ev TimerEvent) Instance() IDefinitionInstance

func (ev TimerEvent) MatchesEventInstance(instance IDefinitionInstance) bool

type VoidConsumer ¶

type VoidConsumer struct{}

VoidConsumer Process event consumer that does nothing and returns EventConsumed result

func (t VoidConsumer) ConsumeEvent(ev IEvent) (result ConsumptionResult, err error)

type VoidSource ¶

type VoidSource struct{}

func (t VoidSource) RegisterEventConsumer(consumer IConsumer) (err error)