model

Documentation

Index

• type EventInstantiationAttemptedTrace
  • func (e EventInstantiationAttemptedTrace) TraceInterface()
• type Model
  • func New(element *schema.Definitions, options ...Option) *Model
  • func (model *Model) ConsumeEvent(ev event.IEvent) (result event.ConsumptionResult, err error)
  • func (model *Model) FindProcessBy(f func(*process.Process) bool) (result *process.Process, found bool)
  • func (model *Model) NewEventDefinitionInstance(def schema.EventDefinitionInterface) (event.IDefinitionInstance, error)
  • func (model *Model) RegisterEventConsumer(ev event.IConsumer) (err error)
  • func (model *Model) Run(ctx context.Context) (err error)
• type Option
  • func WithContext(newCtx context.Context) Option
  • func WithEventDefinitionInstanceBuilder(builder event.IDefinitionInstanceBuilder) Option
  • func WithIdGenerator(builder id.IGeneratorBuilder) Option
  • func WithTracer(tracer tracing.ITracer) Option

Types

type EventInstantiationAttemptedTrace

type EventInstantiationAttemptedTrace struct {
	Event   event.IEvent
	Element schema.FlowNodeInterface
}

func (EventInstantiationAttemptedTrace) TraceInterface

func (e EventInstantiationAttemptedTrace) TraceInterface()

type Model

type Model struct {
	Element *schema.Definitions
	// contains filtered or unexported fields
}

func New

func New(element *schema.Definitions, options ...Option) *Model

func (*Model) ConsumeEvent

func (model *Model) ConsumeEvent(ev event.IEvent) (result event.ConsumptionResult, err error)

func (*Model) FindProcessBy

func (model *Model) FindProcessBy(f func(*process.Process) bool) (result *process.Process, found bool)

func (*Model) NewEventDefinitionInstance

func (model *Model) NewEventDefinitionInstance(def schema.EventDefinitionInterface) (event.IDefinitionInstance, error)

func (*Model) RegisterEventConsumer

func (model *Model) RegisterEventConsumer(ev event.IConsumer) (err error)

func (*Model) Run

func (model *Model) Run(ctx context.Context) (err error)

type Option

type Option func(context.Context, *Model) context.Context

func WithContext

func WithContext(newCtx context.Context) Option

WithContext will pass a given context to a new model instead of implicitly generated one

func WithEventDefinitionInstanceBuilder

func WithEventDefinitionInstanceBuilder(builder event.IDefinitionInstanceBuilder) Option

func WithIdGenerator

func WithIdGenerator(builder id.IGeneratorBuilder) Option

func WithTracer

func WithTracer(tracer tracing.ITracer) Option

WithTracer overrides model's tracer