pulsar

Documentation

Index

• Variables
• func NewPulsarID(id pulsar.MessageID) message.MessageID
• func UnmarshalMessageID(data string) (message.MessageID, error)
• type MessageIdData
  • func (*MessageIdData) Descriptor() ([]byte, []int)
  • func (x *MessageIdData) GetBatchIndex() int32
  • func (x *MessageIdData) GetEntryId() uint64
  • func (x *MessageIdData) GetLedgerId() uint64
  • func (x *MessageIdData) GetPartition() int32
  • func (*MessageIdData) ProtoMessage()
  • func (x *MessageIdData) ProtoReflect() protoreflect.Message
  • func (x *MessageIdData) Reset()
  • func (x *MessageIdData) String() string

Variables

var File_message_id_data_proto protoreflect.FileDescriptor

Functions

func NewPulsarID

func NewPulsarID(id pulsar.MessageID) message.MessageID

NewPulsarID creates a new pulsarID TODO: remove in future.

func UnmarshalMessageID

func UnmarshalMessageID(data string) (message.MessageID, error)

Types

type MessageIdData

type MessageIdData struct {
	LedgerId   *uint64 `protobuf:"varint,1,req,name=ledgerId" json:"ledgerId,omitempty"`
	EntryId    *uint64 `protobuf:"varint,2,req,name=entryId" json:"entryId,omitempty"`
	Partition  *int32  `protobuf:"varint,3,opt,name=partition" json:"partition,omitempty"`
	BatchIndex *int32  `protobuf:"varint,4,opt,name=batch_index,json=batchIndex" json:"batch_index,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageIdData) Descriptor

func (*MessageIdData) Descriptor() ([]byte, []int)

Deprecated: Use MessageIdData.ProtoReflect.Descriptor instead.

func (*MessageIdData) GetBatchIndex

func (x *MessageIdData) GetBatchIndex() int32

func (*MessageIdData) GetEntryId

func (x *MessageIdData) GetEntryId() uint64

func (*MessageIdData) GetLedgerId

func (x *MessageIdData) GetLedgerId() uint64

func (*MessageIdData) GetPartition

func (x *MessageIdData) GetPartition() int32

func (*MessageIdData) ProtoMessage

func (*MessageIdData) ProtoMessage()

func (*MessageIdData) ProtoReflect

func (x *MessageIdData) ProtoReflect() protoreflect.Message

func (*MessageIdData) Reset

func (x *MessageIdData) Reset()

func (*MessageIdData) String

func (x *MessageIdData) String() string