es5runner

Documentation

Index

• func NewRunner(c config.Runner) (res itf.RunnerManager, err error)
• type CacheWrapper
  • func (c *CacheWrapper) Del(key string)
  • func (c *CacheWrapper) Get(key string) any
  • func (c *CacheWrapper) Set(key string, data any)
• type Config
• type ES5Runner
  • func (r *ES5Runner) Ingest(c <-chan itf.EventMessage) (res <-chan itf.RunnerResult, err error)
  • func (r *ES5Runner) Stop() error
• type ES5RunnerManager
  • func (r *ES5RunnerManager) New(cache itf.EventCache, plugins itf.EventPlugins) (res itf.Runner, err error)
  • func (r *ES5RunnerManager) StopAll() error
• type ES5RunnerResult
  • func (r *ES5RunnerResult) Ack() error
  • func (r *ES5RunnerResult) AddMetadata(name string, value string)
  • func (r *ES5RunnerResult) Config() (res map[string]string, err error)
  • func (r *ES5RunnerResult) Data() (any, error)
  • func (r *ES5RunnerResult) Destination() (string, error)
  • func (r *ES5RunnerResult) HasResult() bool
  • func (r *ES5RunnerResult) Message() itf.EventMessage
  • func (r *ES5RunnerResult) Metadata() (res map[string][]string, err error)
  • func (r *ES5RunnerResult) Nak() error
  • func (r *ES5RunnerResult) SetConfig(name string, value string)
  • func (r *ES5RunnerResult) SetData(data any)
  • func (r *ES5RunnerResult) SetMetadata(name string, value string)
• type PluginWrapper
  • func (p *PluginWrapper) Command(name string, data any) (res any, e error)
• type PluginsWrapper
  • func (p *PluginsWrapper) Get(key string) (res *PluginWrapper)

Functions

func NewRunner

func NewRunner(c config.Runner) (res itf.RunnerManager, err error)

Types

type CacheWrapper

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

func (*CacheWrapper) Del

func (c *CacheWrapper) Del(key string)

func (*CacheWrapper) Get

func (c *CacheWrapper) Get(key string) any

func (*CacheWrapper) Set

func (c *CacheWrapper) Set(key string, data any)

type Config

type Config struct {
	Name        string `validate:"required"`
	Program     string `validate:"required"`
	ProgramPath string `validate:"required"`
}

type ES5Runner

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

func (*ES5Runner) Ingest

func (r *ES5Runner) Ingest(c <-chan itf.EventMessage) (res <-chan itf.RunnerResult, err error)

func (*ES5Runner) Stop

func (r *ES5Runner) Stop() error

type ES5RunnerManager

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

func (*ES5RunnerManager) New

func (r *ES5RunnerManager) New(cache itf.EventCache, plugins itf.EventPlugins) (res itf.Runner, err error)

func (*ES5RunnerManager) StopAll

func (r *ES5RunnerManager) StopAll() error

type ES5RunnerResult

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

func (*ES5RunnerResult) Ack

func (r *ES5RunnerResult) Ack() error

func (*ES5RunnerResult) AddMetadata

func (r *ES5RunnerResult) AddMetadata(name string, value string)

func (*ES5RunnerResult) Config

func (r *ES5RunnerResult) Config() (res map[string]string, err error)

func (*ES5RunnerResult) Data

func (r *ES5RunnerResult) Data() (any, error)

func (*ES5RunnerResult) Destination

func (r *ES5RunnerResult) Destination() (string, error)

func (*ES5RunnerResult) HasResult

func (r *ES5RunnerResult) HasResult() bool

func (*ES5RunnerResult) Message

func (r *ES5RunnerResult) Message() itf.EventMessage

func (*ES5RunnerResult) Metadata

func (r *ES5RunnerResult) Metadata() (res map[string][]string, err error)

func (*ES5RunnerResult) Nak

func (r *ES5RunnerResult) Nak() error

func (*ES5RunnerResult) SetConfig

func (r *ES5RunnerResult) SetConfig(name string, value string)

func (*ES5RunnerResult) SetData

func (r *ES5RunnerResult) SetData(data any)

func (*ES5RunnerResult) SetMetadata

func (r *ES5RunnerResult) SetMetadata(name string, value string)

type PluginWrapper

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

func (*PluginWrapper) Command

func (p *PluginWrapper) Command(name string, data any) (res any, e error)

type PluginsWrapper

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

func (*PluginsWrapper) Get

func (p *PluginsWrapper) Get(key string) (res *PluginWrapper)