event

Documentation

Index

• func PutEvent(e *ProcessorEvent)
• type ProcessorEvent
  • func GetEvent() (e *ProcessorEvent)
  • func (e *ProcessorEvent) Bytes() []byte
  • func (e *ProcessorEvent) String() string
  • func (e *ProcessorEvent) Write(b []byte)

Functions

func PutEvent

func PutEvent(e *ProcessorEvent)

PutEvent put event back to pool

Types

type ProcessorEvent

type ProcessorEvent struct {
	Source       string
	Destination  string
	LogId        string
	AppId        []byte
	Level        []byte
	Time         time.Time
	Body         []byte
	Priority     string
	Length       int
	TimeRangeKey string
	Fields       map[string]interface{}
	ParsedFields map[string]string
	Tags         []string
}

event between input and processor

func GetEvent

func GetEvent() (e *ProcessorEvent)

GetEvent get event from pool.

func (*ProcessorEvent) Bytes

func (e *ProcessorEvent) Bytes() []byte

func (*ProcessorEvent) String

func (e *ProcessorEvent) String() string

func (*ProcessorEvent) Write

func (e *ProcessorEvent) Write(b []byte)