process

Documentation

Index

• type Option
  • func WithContext(newCtx context.Context) Option
  • func WithEventDefinitionInstanceBuilder(builder event.IDefinitionInstanceBuilder) Option
  • func WithEventEgress(source event.ISource) Option
  • func WithEventIngress(consumer event.IConsumer) Option
  • func WithIdGenerator(builder id.IGeneratorBuilder) Option
  • func WithTracer(tracer tracing.ITracer) Option
• type Process
  • func Make(element *schema.Process, definitions *schema.Definitions, options ...Option) Process
  • func New(element *schema.Process, definitions *schema.Definitions, options ...Option) *Process
  • func (process *Process) Instantiate(options ...instance.Option) (inst *instance.Instance, err error)
• type Trace
  • func (t Trace) TraceInterface()
  • func (t Trace) Unwrap() tracing.ITrace

Types

type Option

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

func WithContext

func WithContext(newCtx context.Context) Option

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

func WithEventDefinitionInstanceBuilder

func WithEventDefinitionInstanceBuilder(builder event.IDefinitionInstanceBuilder) Option

func WithEventEgress

func WithEventEgress(source event.ISource) Option

func WithEventIngress

func WithEventIngress(consumer event.IConsumer) Option

func WithIdGenerator

func WithIdGenerator(builder id.IGeneratorBuilder) Option

func WithTracer

func WithTracer(tracer tracing.ITracer) Option

WithTracer overrides process's tracer

type Process

type Process struct {
	Element     *schema.Process
	Definitions *schema.Definitions

	EventIngress event.IConsumer
	EventEgress  event.ISource

	Tracer tracing.ITracer
	// contains filtered or unexported fields
}

func Make

func Make(element *schema.Process, definitions *schema.Definitions, options ...Option) Process

func New

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

func (*Process) Instantiate

func (process *Process) Instantiate(options ...instance.Option) (inst *instance.Instance, err error)

type Trace

type Trace struct {
	Process *schema.Process
	Trace   tracing.ITrace
}

Trace wraps any trace within a given process

func (Trace) TraceInterface

func (t Trace) TraceInterface()

func (Trace) Unwrap

func (t Trace) Unwrap() tracing.ITrace