command

package

v0.0.0-...-54a44df Latest Latest Go to latest Published: Jun 14, 2018 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/t2y/go-pulsar

Links

Open Source Insights

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
type BatchMessage
- func UnmarshalBatchMessagePayload(numMessages int32, payloadBytes []byte) (batchMessage BatchMessage, err error)
type Frame
- func (f *Frame) HasPayload() (r bool)
- func (f *Frame) String() (s string)

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 CalculateChecksum(data []byte) (checksum []byte)

func HasChecksum ¶

func HasChecksum(frame []byte) (r bool)

func IsErrorOnProtocol ¶

func IsErrorOnProtocol(err error) (r bool)

func MakeBatchMessagePayload ¶

func MakeBatchMessagePayload(
	batchMessage BatchMessage,
) (data []byte, err error)

func MarshalMessage ¶

func MarshalMessage(msg proto.Message) (
	size int, 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 NewSizeFrame(size int) (frame []byte, err error)

func VerifyChecksum ¶

func VerifyChecksum(data []byte) (msgAndPayload []byte, err error)

Types ¶

type Base ¶

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

func NewBase ¶

func NewBase() (c *Base)

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) Marshal ¶

func (c *Base) Marshal() (data []byte, err error)

func (*Base) SetCommand ¶

func (c *Base) SetCommand(msg proto.Message) (err error)

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 (c *Base) SetTypeFromData() (err error)

func (*Base) Unmarshal ¶

func (c *Base) Unmarshal(buf []byte) (msg proto.Message, err error)

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)

type Frame ¶

type Frame struct {
	Cmddata  []byte
	Metadata []byte
	Payload  []byte
}

func (*Frame) HasPayload ¶

func (f *Frame) HasPayload() (r bool)

func (*Frame) String ¶

func (f *Frame) String() (s string)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL