backend

type Batch ¶

type Batch interface {
	Pick(*Message) (bool, error)
	Flush() error
}

NewBatch must return these interface

type BatchList ¶

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

func NewBatch() (*BatchList, error)

func (bl *BatchList) Flush() error

func (bl *BatchList) Pick(m *Message, isNotDecoded bool) error

type InitFunction ¶

type InitFunction func() error

Plugin must implement Init() function with the following type

type Message ¶

type Message struct {
	Date     time.Time
	Facility int
	Severity int
	Hostname string
	Process  string
	Pid      int
	Data     string
}

this struct is the representation of syslog message.

type NewBatchFunction ¶

type NewBatchFunction func() (Batch, error)

Plugin must implement NewBatch() function with the following type

type TransactionOps ¶

type TransactionOps interface {
	Append(...interface{}) error
	Flush() error
}

func NewTransaction(table string, columns ...string) (TransactionOps, error)