processors

Documentation

Index

• Variables
• func ReifySteps(ctx context.Context, steps []Step) ([]camel.Verticle, error)
• type DefaultStepsVerticle
  • func NewDefaultStepsVerticle() DefaultStepsVerticle
  • func (v *DefaultStepsVerticle) Receive(ac actor.Context)
• type DefaultVerticle
  • func NewDefaultVerticle() DefaultVerticle
  • func (v *DefaultVerticle) Context() camel.Context
  • func (v *DefaultVerticle) Dispatch(ac actor.Context, msg camel.Message) bool
  • func (v *DefaultVerticle) ID() string
  • func (v *DefaultVerticle) SetContext(ctx camel.Context)
• type Reifyable
• type Step
  • func NewStep(r Reifyable) Step
  • func (s *Step) Reify(ctx context.Context) (camel.Verticle, error)
  • func (s *Step) UnmarshalYAML(node *yaml.Node) error
• type StepsDone
• type TypeFactory

Variables

var Types = make(map[string]TypeFactory)

Functions

func ReifySteps

func ReifySteps(ctx context.Context, steps []Step) ([]camel.Verticle, error)

Types

type DefaultStepsVerticle

type DefaultStepsVerticle struct {
	DefaultVerticle `yaml:",inline"`

	Steps []Step `yaml:"steps,omitempty"`
}

func NewDefaultStepsVerticle

func NewDefaultStepsVerticle() DefaultStepsVerticle

func (*DefaultStepsVerticle) Receive

func (v *DefaultStepsVerticle) Receive(ac actor.Context)

type DefaultVerticle

type DefaultVerticle struct {
	camel.Identifiable

	Identity string `yaml:"id"`
	// contains filtered or unexported fields
}

func NewDefaultVerticle

func NewDefaultVerticle() DefaultVerticle

func (*DefaultVerticle) Context

func (v *DefaultVerticle) Context() camel.Context

func (*DefaultVerticle) Dispatch

func (v *DefaultVerticle) Dispatch(ac actor.Context, msg camel.Message) bool

Dispatch send messages to the child steps, returns true if the dispatch is completed.

func (*DefaultVerticle) ID

func (v *DefaultVerticle) ID() string

func (*DefaultVerticle) SetContext

func (v *DefaultVerticle) SetContext(ctx camel.Context)

type Reifyable

type Reifyable interface {
	Reify(context.Context) (camel.Verticle, error)
}

type Step

type Step struct {
	Reifyable
	// contains filtered or unexported fields
}

func NewStep

func NewStep(r Reifyable) Step

func (*Step) Reify

func (s *Step) Reify(ctx context.Context) (camel.Verticle, error)

func (*Step) UnmarshalYAML

func (s *Step) UnmarshalYAML(node *yaml.Node) error

type StepsDone

type StepsDone struct {
	M camel.Message
}

StepsDone is a marker type to help break out.

type TypeFactory

type TypeFactory func() interface{}