pluginsource

Documentation

Index

• func NewConnection(cfg config.Connection, manager itf.EventPlugins) (res itf.EventConnection, err error)
• type PluginEventConnection
  • func (c *PluginEventConnection) Close() (err error)
  • func (c *PluginEventConnection) NewCache(cfg config.Cache) (res itf.EventCache, err error)
  • func (c *PluginEventConnection) NewInput(cfg config.Input) (res itf.EventInput, err error)
  • func (c *PluginEventConnection) NewOutput(cfg config.Output) (res itf.EventOutput, err error)
• type PluginEventInput
  • func (s *PluginEventInput) Close() (err error)
  • func (s *PluginEventInput) Receive() (res <-chan itf.EventMessage, err error)
• type PluginEventMessage
  • func (m PluginEventMessage) Ack() error
  • func (m PluginEventMessage) Data() ([]byte, error)
  • func (m PluginEventMessage) DataString() (string, error)
  • func (m PluginEventMessage) Metadata(key string) (res []string, err error)
  • func (m PluginEventMessage) Nak() error
  • func (m PluginEventMessage) ReplyTo() (res string, err error)
  • func (m PluginEventMessage) Time() (time.Time, error)
  • func (m PluginEventMessage) Topic() (string, error)
• type PluginEventOutput
  • func (s *PluginEventOutput) Close() (err error)
  • func (s *PluginEventOutput) Ingest(c <-chan itf.RunnerResult) (err error)

Functions

func NewConnection

func NewConnection(cfg config.Connection, manager itf.EventPlugins) (res itf.EventConnection, err error)

Types

type PluginEventConnection

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

func (*PluginEventConnection) Close

func (c *PluginEventConnection) Close() (err error)

func (*PluginEventConnection) NewCache

func (c *PluginEventConnection) NewCache(cfg config.Cache) (res itf.EventCache, err error)

func (*PluginEventConnection) NewInput

func (c *PluginEventConnection) NewInput(cfg config.Input) (res itf.EventInput, err error)

func (*PluginEventConnection) NewOutput

func (c *PluginEventConnection) NewOutput(cfg config.Output) (res itf.EventOutput, err error)

type PluginEventInput

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

func (*PluginEventInput) Close

func (s *PluginEventInput) Close() (err error)

func (*PluginEventInput) Receive

func (s *PluginEventInput) Receive() (res <-chan itf.EventMessage, err error)

type PluginEventMessage

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

func (PluginEventMessage) Ack

func (m PluginEventMessage) Ack() error

func (PluginEventMessage) Data

func (m PluginEventMessage) Data() ([]byte, error)

func (PluginEventMessage) DataString

func (m PluginEventMessage) DataString() (string, error)

func (PluginEventMessage) Metadata

func (m PluginEventMessage) Metadata(key string) (res []string, err error)

func (PluginEventMessage) Nak

func (m PluginEventMessage) Nak() error

func (PluginEventMessage) ReplyTo

func (m PluginEventMessage) ReplyTo() (res string, err error)

func (PluginEventMessage) Time

func (m PluginEventMessage) Time() (time.Time, error)

func (PluginEventMessage) Topic

func (m PluginEventMessage) Topic() (string, error)

type PluginEventOutput

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

func (*PluginEventOutput) Close

func (s *PluginEventOutput) Close() (err error)

func (*PluginEventOutput) Ingest

func (s *PluginEventOutput) Ingest(c <-chan itf.RunnerResult) (err error)