jsonata

Documentation

Index

• func Register()
• type Executor
  • func (c *Executor) Close() error
  • func (c *Executor) Configure(clientConfig *schemaregistry.Config, config map[string]string) error
  • func (c *Executor) Transform(ctx serde.RuleContext, msg interface{}) (interface{}, error)
  • func (c *Executor) Type() string

Functions

func Register

func Register()

Register registers the JSONata rule executor

Types

type Executor

type Executor struct {
	Config map[string]string
	// contains filtered or unexported fields
}

Executor is a JSONata rule executor

func (*Executor) Close

func (c *Executor) Close() error

Close closes the executor

func (*Executor) Configure

func (c *Executor) Configure(clientConfig *schemaregistry.Config, config map[string]string) error

Configure configures the executor

func (*Executor) Transform

func (c *Executor) Transform(ctx serde.RuleContext, msg interface{}) (interface{}, error)

Transform transforms the message using the rule

func (*Executor) Type

func (c *Executor) Type() string

Type returns the type of the executor