process

Documentation

Index

• Constants
• type OptionFn
  • func WithRef(ref string) OptionFn
• type Process
  • func New(opts ...OptionFn) *Process
  • func (p *Process) Receive(ac actor.Context)
  • func (p *Process) Reify(ctx context.Context) (camel.Verticle, error)

Constants

const TAG = "process"

Types

type OptionFn

type OptionFn func(*Process)

func WithRef

func WithRef(ref string) OptionFn

type Process

type Process struct {
	processors.DefaultVerticle `yaml:",inline"`

	Ref string `yaml:"ref"`
	// contains filtered or unexported fields
}

func New

func New(opts ...OptionFn) *Process

func (*Process) Receive

func (p *Process) Receive(ac actor.Context)

func (*Process) Reify

func (p *Process) Reify(ctx context.Context) (camel.Verticle, error)