wasm

Documentation

Index

• type Function
• type Module
  • func NewModule(ctx context.Context, r wz.Runtime, code wz.CompiledModule) (*Module, error)
  • func (m *Module) Close(ctx context.Context) error
  • func (m *Module) Predicate(_ context.Context) (*Predicate, error)
  • func (m *Module) Processor(_ context.Context) (*Processor, error)
• type ModuleOptionFn
• type Predicate
• type Processor
  • func (p *Processor) Process(ctx context.Context, message camel.Message) error
  • func (p *Processor) Test(ctx context.Context, message camel.Message) (bool, error)
• type Runtime
  • func NewRuntime(ctx context.Context) (*Runtime, error)
  • func (r *Runtime) Close(ctx context.Context) error
  • func (r *Runtime) Export(ctx context.Context, name string, fn interface{}) error
  • func (r *Runtime) Load(ctx context.Context, in io.ReadCloser) (*Module, error)

Types

type Function

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

type Module

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

func NewModule

func NewModule(ctx context.Context, r wz.Runtime, code wz.CompiledModule) (*Module, error)

func (*Module) Close

func (m *Module) Close(ctx context.Context) error

func (*Module) Predicate

func (m *Module) Predicate(_ context.Context) (*Predicate, error)

func (*Module) Processor

func (m *Module) Processor(_ context.Context) (*Processor, error)

type ModuleOptionFn

type ModuleOptionFn func(*Module)

type Predicate

type Predicate struct {
	Function
}

type Processor

type Processor struct {
	Function
}

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, message camel.Message) error

func (*Processor) Test

func (p *Processor) Test(ctx context.Context, message camel.Message) (bool, error)

type Runtime

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

func NewRuntime

func NewRuntime(ctx context.Context) (*Runtime, error)

func (*Runtime) Close

func (r *Runtime) Close(ctx context.Context) error

func (*Runtime) Export

func (r *Runtime) Export(ctx context.Context, name string, fn interface{}) error

func (*Runtime) Load

func (r *Runtime) Load(ctx context.Context, in io.ReadCloser) (*Module, error)