event

Documentation

Index

• type BatchEvents
• type Offset
  • func (o *Offset) String() string
• type OutputEventContext
  • func (c *OutputEventContext) Get(eventName string) (*v1.SniffData, error)
  • func (c *OutputEventContext) Put(event *v1.SniffData)
• type Type

Types

type BatchEvents

type BatchEvents []*v1.SniffData

BatchEvents is used by Forwarder to forward.

type Offset

type Offset struct {
	Partition int
	Position  string
}

Offset is a generic form, which allows having different definitions in different Queues.

func (*Offset) String

func (o *Offset) String() string

type OutputEventContext

type OutputEventContext struct {
	Context map[string]*v1.SniffData
	Offset  *Offset
}

OutputEventContext is a container to store the output context.

func (*OutputEventContext) Get

func (c *OutputEventContext) Get(eventName string) (*v1.SniffData, error)

Get returns an event in the context. When the eventName does not exist, an error would be returned.

func (*OutputEventContext) Put

func (c *OutputEventContext) Put(event *v1.SniffData)

Put puts the incoming event into the context.

type Type

type Type int32