natssource

Documentation

Index

• func NewConnection(cfg config.Connection) (res itf.EventConnection, err error)
• type NatsEventCache
  • func (s *NatsEventCache) Close() (err error)
  • func (s *NatsEventCache) Del(key string) (err error)
  • func (s *NatsEventCache) Get(key string) (res any, err error)
  • func (s *NatsEventCache) Set(key string, value any) (err error)
• type NatsEventConnection
  • func (c *NatsEventConnection) Close() (err error)
  • func (c *NatsEventConnection) NewCache(cfg config.Cache) (res itf.EventCache, err error)
  • func (c *NatsEventConnection) NewInput(cfg config.Input) (res itf.EventInput, err error)
  • func (c *NatsEventConnection) NewOutput(cfg config.Output) (res itf.EventOutput, err error)
• type NatsEventInput
  • func (s *NatsEventInput) Close() (err error)
  • func (s *NatsEventInput) Receive() (res <-chan itf.EventMessage, err error)
• type NatsEventMessage
  • func (m NatsEventMessage) Ack() error
  • func (m NatsEventMessage) Data() ([]byte, error)
  • func (m NatsEventMessage) DataString() (string, error)
  • func (m NatsEventMessage) Metadata(key string) (res []string, err error)
  • func (m NatsEventMessage) Nak() error
  • func (m NatsEventMessage) ReplyTo() (string, error)
  • func (m NatsEventMessage) Time() (time.Time, error)
  • func (m NatsEventMessage) Topic() (string, error)
• type NatsEventOutput
  • func (s *NatsEventOutput) Close() (err error)
  • func (s *NatsEventOutput) Ingest(c <-chan itf.RunnerResult) (err error)

Functions

func NewConnection

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

Types

type NatsEventCache

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

func (*NatsEventCache) Close

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

func (*NatsEventCache) Del

func (s *NatsEventCache) Del(key string) (err error)

func (*NatsEventCache) Get

func (s *NatsEventCache) Get(key string) (res any, err error)

func (*NatsEventCache) Set

func (s *NatsEventCache) Set(key string, value any) (err error)

type NatsEventConnection

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

func (*NatsEventConnection) Close

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

func (*NatsEventConnection) NewCache

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

func (*NatsEventConnection) NewInput

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

func (*NatsEventConnection) NewOutput

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

type NatsEventInput

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

func (*NatsEventInput) Close

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

func (*NatsEventInput) Receive

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

type NatsEventMessage

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

func (NatsEventMessage) Ack

func (m NatsEventMessage) Ack() error

func (NatsEventMessage) Data

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

func (NatsEventMessage) DataString

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

func (NatsEventMessage) Metadata

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

func (NatsEventMessage) Nak

func (m NatsEventMessage) Nak() error

func (NatsEventMessage) ReplyTo

func (m NatsEventMessage) ReplyTo() (string, error)

func (NatsEventMessage) Time

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

func (NatsEventMessage) Topic

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

type NatsEventOutput

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

func (*NatsEventOutput) Close

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

func (*NatsEventOutput) Ingest

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