eventid

Documentation

Index

• type EventId
  • func New(messageId pulsar.MessageID, sequenceId int32) *EventId
  • func (id *EventId) BatchIdx() int32
  • func (id *EventId) EntryID() int64
  • func (id *EventId) Equal(other *EventId) (bool, error)
  • func (id *EventId) Greater(other *EventId) (bool, error)
  • func (id *EventId) GreaterEqual(other *EventId) (bool, error)
  • func (id *EventId) LedgerID() int64
  • func (id *EventId) MessageId() pulsar.MessageID
  • func (id *EventId) PartitionIdx() int32
  • func (id *EventId) SequenceId() int32
  • func (id *EventId) Serialize() []byte

Types

type EventId

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

EventId identifies a particular event within an event sequence. Because event sequences and Pulsar messages map one-to-one, the event sequence is identified by a Pulsar message id. The specific event within that sequence is identified by the index of the event within the sequence.

This type satisfies the pulsar.MessageID interface.

func New

func New(messageId pulsar.MessageID, sequenceId int32) *EventId

func (*EventId) BatchIdx

func (id *EventId) BatchIdx() int32

func (*EventId) EntryID

func (id *EventId) EntryID() int64

func (*EventId) Equal

func (id *EventId) Equal(other *EventId) (bool, error)

func (*EventId) Greater

func (id *EventId) Greater(other *EventId) (bool, error)

Greater returns true if id occurred after other, or an error if the message ids are not comparable (i.e., if they are from different partitions).

func (*EventId) GreaterEqual

func (id *EventId) GreaterEqual(other *EventId) (bool, error)

func (*EventId) LedgerID

func (id *EventId) LedgerID() int64

func (*EventId) MessageId

func (id *EventId) MessageId() pulsar.MessageID

func (*EventId) PartitionIdx

func (id *EventId) PartitionIdx() int32

func (*EventId) SequenceId

func (id *EventId) SequenceId() int32

func (*EventId) Serialize

func (id *EventId) Serialize() []byte