engine

package

v0.1.0 Latest Latest Go to latest Published: Oct 22, 2022 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ChannelEngine struct {
	OnError func(msg *message.Entry, err error)
	// contains filtered or unexported fields
}

func NewChannelEngine() *ChannelEngine

func (e *ChannelEngine) Init() error

func (e *ChannelEngine) Send(entry *message.Entry)

func (e *ChannelEngine) Start() error

func (e *ChannelEngine) Stop() (err error)

type IEngine interface {
	Init() error
	Start() error
	Stop() error
	Send(event *message.Entry)
}

func NewEngine(typ config.EngineType) IEngine

type RingBufferEngine struct {
	OnError func(msg *message.Entry, err error)
	// contains filtered or unexported fields
}

func NewRingBufferEngine() *RingBufferEngine

func (e *RingBufferEngine) Init() (err error)

func (e *RingBufferEngine) Send(msg *message.Entry)

func (e *RingBufferEngine) Start() error

func (e *RingBufferEngine) Stop() (err error)