codec

package
v1.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrBadWireType = errors.New("proto: bad wiretype")

ErrBadWireType is returned when decoding a wire-type from a buffer that is not valid.

View Source
var ErrOverflow = errors.New("proto: integer overflow")

ErrOverflow is returned when an integer is too large to be represented.

Functions

This section is empty.

Types

type Buffer

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

Buffer is a reader and a writer that wraps a slice of bytes and also provides API for decoding and encoding the protobuf binary format.

Its operation is similar to that of a bytes.Buffer: writing pushes data to the end of the buffer while reading pops data from the head of the buffer. So the same buffer can be used to both read and write.

func NewBuffer

func NewBuffer(buf []byte) *Buffer

NewBuffer creates a new buffer with the given slice of bytes as the buffer's initial contents.

func (*Buffer) Bytes

func (cb *Buffer) Bytes() []byte

Bytes returns the slice of bytes remaining in the buffer. Note that this does not perform a copy: if the contents of the returned slice are modified, the modifications will be visible to subsequent reads via the buffer.

func (*Buffer) DecodeFixed32

func (cb *Buffer) DecodeFixed32() (x uint64, err error)

DecodeFixed32 reads a 32-bit integer from the Buffer. This is the format for the fixed32, sfixed32, and float protocol buffer types.

func (*Buffer) DecodeFixed64

func (cb *Buffer) DecodeFixed64() (x uint64, err error)

DecodeFixed64 reads a 64-bit integer from the Buffer. This is the format for the fixed64, sfixed64, and double protocol buffer types.

func (*Buffer) DecodeRawBytes

func (cb *Buffer) DecodeRawBytes(alloc bool) (buf []byte, err error)

DecodeRawBytes reads a count-delimited byte buffer from the Buffer. This is the format used for the bytes protocol buffer type and for embedded messages.

func (*Buffer) DecodeTagAndWireType

func (cb *Buffer) DecodeTagAndWireType() (tag int32, wireType int8, err error)

DecodeTagAndWireType decodes a field tag and wire type from input. This reads a varint and then extracts the two fields from the varint value read.

func (*Buffer) DecodeVarint

func (cb *Buffer) DecodeVarint() (uint64, error)

DecodeVarint reads a varint-encoded integer from the Buffer. This is the format for the int32, int64, uint32, uint64, bool, and enum protocol buffer types.

func (*Buffer) EOF

func (cb *Buffer) EOF() bool

EOF returns true if there are no more bytes remaining to read.

func (*Buffer) EncodeDelimitedMessage

func (cb *Buffer) EncodeDelimitedMessage(pm proto.Message) error

EncodeDelimitedMessage writes the given message to the buffer with a varint-encoded length prefix (the delimiter).

func (*Buffer) EncodeFixed32

func (cb *Buffer) EncodeFixed32(x uint64) error

EncodeFixed32 writes a 32-bit integer to the Buffer. This is the format for the fixed32, sfixed32, and float protocol buffer types.

func (*Buffer) EncodeFixed64

func (cb *Buffer) EncodeFixed64(x uint64) error

EncodeFixed64 writes a 64-bit integer to the Buffer. This is the format for the fixed64, sfixed64, and double protocol buffer types.

func (*Buffer) EncodeMessage

func (cb *Buffer) EncodeMessage(pm proto.Message) error

EncodeMessage writes the given message to the buffer.

func (*Buffer) EncodeRawBytes

func (cb *Buffer) EncodeRawBytes(b []byte) error

EncodeRawBytes writes a count-delimited byte buffer to the Buffer. This is the format used for the bytes protocol buffer type and for embedded messages.

func (*Buffer) EncodeTagAndWireType

func (cb *Buffer) EncodeTagAndWireType(tag int32, wireType int8) error

EncodeTagAndWireType encodes the given field tag and wire type to the buffer. This combines the two values and then writes them as a varint.

func (*Buffer) EncodeVarint

func (cb *Buffer) EncodeVarint(x uint64) error

EncodeVarint writes a varint-encoded integer to the Buffer. This is the format for the int32, int64, uint32, uint64, bool, and enum protocol buffer types.

func (*Buffer) IsDeterministic

func (cb *Buffer) IsDeterministic() bool

IsDeterministic returns whether or not this buffer is configured to encode messages deterministically.

func (*Buffer) Len

func (cb *Buffer) Len() int

Len returns the remaining number of bytes in the buffer.

func (*Buffer) Read

func (cb *Buffer) Read(dest []byte) (int, error)

Read implements the io.Reader interface. If there are no bytes remaining in the buffer, it will return 0, io.EOF. Otherwise, it reads max(len(dest), cb.Len()) bytes from input and copies them into dest. It returns the number of bytes copied and a nil error in this case.

func (*Buffer) ReadGroup

func (cb *Buffer) ReadGroup(alloc bool) ([]byte, error)

ReadGroup reads the input until a "group end" tag is found and returns the data up to that point. Subsequent reads from the buffer will read data after the group end tag. If alloc is true, the data is copied to a new slice before being returned. Otherwise, the returned slice is a view into the buffer's underlying byte slice.

This function correctly handles nested groups: if a "group start" tag is found, then that group's end tag will be included in the returned data.

func (*Buffer) Reset

func (cb *Buffer) Reset()

Reset resets this buffer back to empty. Any subsequent writes/encodes to the buffer will allocate a new backing slice of bytes.

func (*Buffer) SetDeterministic

func (cb *Buffer) SetDeterministic(deterministic bool)

SetDeterministic sets this buffer to encode messages deterministically. This is useful for tests. But the overhead is non-zero, so it should not likely be used outside of tests. When true, map fields in a message must have their keys sorted before serialization to ensure deterministic output. Otherwise, values in a map field will be serialized in map iteration order.

func (*Buffer) Skip

func (cb *Buffer) Skip(count int) error

Skip attempts to skip the given number of bytes in the input. If the input has fewer bytes than the given count, io.ErrUnexpectedEOF is returned and the buffer is unchanged. Otherwise, the given number of bytes are skipped and nil is returned.

func (*Buffer) SkipField

func (cb *Buffer) SkipField(wireType int8) error

SkipField attempts to skip the value of a field with the given wire type. When consuming a protobuf-encoded stream, it can be called immediately after DecodeTagAndWireType to discard the subsequent data for the field.

func (*Buffer) SkipGroup

func (cb *Buffer) SkipGroup() error

SkipGroup is like ReadGroup, except that it discards the data and just advances the buffer to point to the input right *after* the "group end" tag.

func (*Buffer) String

func (cb *Buffer) String() string

String returns the remaining bytes in the buffer as a string.

func (*Buffer) Write

func (cb *Buffer) Write(data []byte) (int, error)

Write implements the io.Writer interface. It always returns len(data), nil.

Jump to

Keyboard shortcuts

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