engine

package

v0.2.5 Latest Latest Go to latest Published: Apr 22, 2023 License: MIT Imports: 4 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