model

Documentation

Index

• type BatchUpdate
  • func (b *BatchUpdate) GetMessageIDs() []pulsar.MessageID
• type Event

Types

type BatchUpdate

type BatchUpdate struct {
	MessageIds []pulsar.MessageID
	Events     []*Event
}

BatchUpdate represents an Event Row along with information about the originating pulsar message

func (*BatchUpdate) GetMessageIDs

func (b *BatchUpdate) GetMessageIDs() []pulsar.MessageID

type Event

type Event struct {
	Queue  string
	Jobset string
	Event  []byte
}