logevent

Documentation

Index

• type FileTransport
  • func NewFileTransport(c *config.Config, log logger.Logger) *FileTransport
  • func (self *FileTransport) Close() error
  • func (self *FileTransport) Consume(operationUUID string) (<-chan *Message, error)
  • func (self *FileTransport) WriteLexemes(operationUUID string, lexemes []*Message) error
• type Message
  • func (self *Message) Event() loxer.Event
  • func (self *Message) OperationUUID() string
• type RedisTransport
  • func NewRedisTransport(redsi *redis.Client, log logger.Logger) *RedisTransport
  • func (self *RedisTransport) Close() error
  • func (self *RedisTransport) Consume(operationUUID string) (<-chan *Message, error)
  • func (self *RedisTransport) EOF(operationUUID string) error
  • func (self *RedisTransport) Expire(operationUUID string) error
  • func (self *RedisTransport) Publish(operationUUID string, fd int, time int64, event loxer.Event) error
• type Sink
• type Source

Types

type FileTransport

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

func NewFileTransport

func NewFileTransport(c *config.Config, log logger.Logger) *FileTransport

func (*FileTransport) Close

func (self *FileTransport) Close() error

func (*FileTransport) Consume

func (self *FileTransport) Consume(operationUUID string) (<-chan *Message, error)

func (*FileTransport) WriteLexemes

func (self *FileTransport) WriteLexemes(operationUUID string, lexemes []*Message) error

type Message

type Message struct {
	O  string
	FD int
	T  int64
	E  loxer.SerializedEvent
}

func (*Message) Event

func (self *Message) Event() loxer.Event

func (*Message) OperationUUID

func (self *Message) OperationUUID() string

type RedisTransport

type RedisTransport struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRedisTransport

func NewRedisTransport(redsi *redis.Client, log logger.Logger) *RedisTransport

func (*RedisTransport) Close

func (self *RedisTransport) Close() error

func (*RedisTransport) Consume

func (self *RedisTransport) Consume(operationUUID string) (<-chan *Message, error)

func (*RedisTransport) EOF

func (self *RedisTransport) EOF(operationUUID string) error

synthesize an EofEvent, signalling running consumers to close the connecion

func (*RedisTransport) Expire

func (self *RedisTransport) Expire(operationUUID string) error

func (*RedisTransport) Publish

func (self *RedisTransport) Publish(operationUUID string, fd int, time int64, event loxer.Event) error

type Sink

type Sink interface {
	Publish(operationUUID string, fd int, time int64, event loxer.Event) error
	Close() error
}

type Source

type Source interface {
	Consume(operationUUID string) (<-chan *Message, error)
	Close() error
}