event

Documentation

Index

• type BatchEvents
• type Offset
• type OutputEventContext
  • func (c *OutputEventContext) Get(eventName string) (*protocol.Event, error)
  • func (c *OutputEventContext) Put(event *protocol.Event)
• type Type

Types

type BatchEvents

type BatchEvents []*protocol.Event

BatchEvents is used by Forwarder to forward.

type Offset

type Offset string

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

type OutputEventContext

type OutputEventContext struct {
	Context map[string]*protocol.Event
	Offset  Offset
}

OutputEventContext is a container to store the output context.

func (*OutputEventContext) Get

func (c *OutputEventContext) Get(eventName string) (*protocol.Event, 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 *protocol.Event)

Put puts the incoming event into the context.

type Type

type Type int32