Documentation ¶
Index ¶
- Constants
- Variables
- func CalculateChecksum(data []byte) (checksum []byte)
- func HasChecksum(frame []byte) (r bool)
- func IsErrorOnProtocol(err error) (r bool)
- func MakeBatchMessagePayload(batchMessage BatchMessage) (data []byte, err error)
- func MarshalMessage(msg proto.Message) (size int, data []byte, err error)
- func NewCommandError(cmdErr *pulsar_proto.CommandError) (err error)
- func NewMarshaledBase(msg proto.Message, meta *pulsar_proto.MessageMetadata, payload string, ...) (data []byte, err error)
- func NewMessageIdData(ledgerId, entryId *uint64, partition, batchIndex *int32) (data *pulsar_proto.MessageIdData)
- func NewSizeFrame(size int) (frame []byte, err error)
- func VerifyChecksum(data []byte) (msgAndPayload []byte, err error)
- type Base
- func (c *Base) GetRawCommand() (raw *pulsar_proto.BaseCommand)
- func (c *Base) GetType() (typ *pulsar_proto.BaseCommand_Type)
- func (c *Base) Marshal() (data []byte, err error)
- func (c *Base) SetCommand(msg proto.Message) (err error)
- func (c *Base) SetMetadata(meta *pulsar_proto.MessageMetadata, payload string)
- func (c *Base) SetMetadataWithBatchMessage(meta *pulsar_proto.MessageMetadata, batchMessage BatchMessage)
- func (c *Base) SetType(typ *pulsar_proto.BaseCommand_Type) (err error)
- func (c *Base) SetTypeFromData() (err error)
- func (c *Base) Unmarshal(buf []byte) (msg proto.Message, err error)
- func (c *Base) UnmarshalMeta(metaBytes []byte) (meta *pulsar_proto.MessageMetadata, err error)
- func (c *Base) UnmarshalPayload(meta *pulsar_proto.MessageMetadata, payloadBytes []byte) (payload string, batchMessage BatchMessage, err error)
- type BatchMessage
- type Frame
Constants ¶
View Source
const ( FrameSizeFieldSize = 4 FrameMagicNumberFieldSize = 2 FrameChecksumSize = 4 FrameMetadataFieldSize = 4 )
Variables ¶
View Source
var FrameMagicAndChecksumSize int
View Source
var FrameMagicNumber []byte
Functions ¶
func CalculateChecksum ¶
func HasChecksum ¶
func IsErrorOnProtocol ¶
func MakeBatchMessagePayload ¶
func MakeBatchMessagePayload( batchMessage BatchMessage, ) (data []byte, err error)
func NewCommandError ¶
func NewCommandError(cmdErr *pulsar_proto.CommandError) (err error)
func NewMarshaledBase ¶
func NewMarshaledBase( msg proto.Message, meta *pulsar_proto.MessageMetadata, payload string, batchMessage BatchMessage, ) (data []byte, err error)
func NewMessageIdData ¶
func NewMessageIdData( ledgerId, entryId *uint64, partition, batchIndex *int32, ) (data *pulsar_proto.MessageIdData)
func NewSizeFrame ¶
func VerifyChecksum ¶
Types ¶
type Base ¶
type Base struct {
// contains filtered or unexported fields
}
func NewBaseWithCommand ¶
func NewBaseWithCommand( msg proto.Message, meta *pulsar_proto.MessageMetadata, payload string, batchMessage BatchMessage, ) (c *Base)
func NewBaseWithType ¶
func NewBaseWithType(typ *pulsar_proto.BaseCommand_Type) (c *Base)
func (*Base) GetRawCommand ¶
func (c *Base) GetRawCommand() (raw *pulsar_proto.BaseCommand)
func (*Base) GetType ¶
func (c *Base) GetType() (typ *pulsar_proto.BaseCommand_Type)
func (*Base) SetMetadata ¶
func (c *Base) SetMetadata( meta *pulsar_proto.MessageMetadata, payload string, )
func (*Base) SetMetadataWithBatchMessage ¶
func (c *Base) SetMetadataWithBatchMessage( meta *pulsar_proto.MessageMetadata, batchMessage BatchMessage, )
func (*Base) SetType ¶
func (c *Base) SetType(typ *pulsar_proto.BaseCommand_Type) (err error)
func (*Base) SetTypeFromData ¶
func (*Base) UnmarshalMeta ¶
func (c *Base) UnmarshalMeta( metaBytes []byte, ) (meta *pulsar_proto.MessageMetadata, err error)
func (*Base) UnmarshalPayload ¶
func (c *Base) UnmarshalPayload( meta *pulsar_proto.MessageMetadata, payloadBytes []byte, ) (payload string, batchMessage BatchMessage, err error)
type BatchMessage ¶
type BatchMessage map[string]*pulsar_proto.SingleMessageMetadata
func UnmarshalBatchMessagePayload ¶
func UnmarshalBatchMessagePayload( numMessages int32, payloadBytes []byte, ) (batchMessage BatchMessage, err error)
Click to show internal directories.
Click to hide internal directories.