Documentation
¶
Index ¶
- func DeserializeProto(bys []byte, msg proto.Message) error
- func PAppStatusErrorCode(input ybApi.AppStatusPB_ErrorCode) *ybApi.AppStatusPB_ErrorCode
- func PBool(a bool) *bool
- func PCDCErrorCode(input ybApi.CDCErrorPB_Code) *ybApi.CDCErrorPB_Code
- func PConsensusErrorCode(input ybApi.ConsensusErrorPB_Code) *ybApi.ConsensusErrorPB_Code
- func PInt32(a int32) *int32
- func PMasterErrorCode(input ybApi.MasterErrorPB_Code) *ybApi.MasterErrorPB_Code
- func PRemoteBootstrapErrorCode(input ybApi.RemoteBootstrapErrorPB_Code) *ybApi.RemoteBootstrapErrorPB_Code
- func PString(a string) *string
- func PTableServerErrorCode(input ybApi.TabletServerErrorPB_Code) *ybApi.TabletServerErrorPB_Code
- func PUint32(a uint32) *uint32
- func PUint64(a uint64) *uint64
- func PYQLDatabase(input ybApi.YQLDatabase) *ybApi.YQLDatabase
- func ReadInt(reader io.Reader) (int, error)
- func ReadUvarint32(r io.ByteReader) (uint64, error)
- func ReadVarint32(r io.ByteReader) (int64, error)
- func SerializeProto(msg proto.Message) ([]byte, error)
- func WriteMessages(b io.Writer, msgs ...protoreflect.ProtoMessage) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeserializeProto ¶
DeserializeProto deserializes proto message from bytes.
func PAppStatusErrorCode ¶
func PAppStatusErrorCode(input ybApi.AppStatusPB_ErrorCode) *ybApi.AppStatusPB_ErrorCode
PAppStatusErrorCode returns a pointer to the given input AppStatusErrorCode.
func PCDCErrorCode ¶
func PCDCErrorCode(input ybApi.CDCErrorPB_Code) *ybApi.CDCErrorPB_Code
PCDCErrorCode returns a pointer to the given input CDCErrorCode.
func PConsensusErrorCode ¶
func PConsensusErrorCode(input ybApi.ConsensusErrorPB_Code) *ybApi.ConsensusErrorPB_Code
PConsensusErrorCode returns a pointer to the given input ConsensusErrorCode.
func PMasterErrorCode ¶
func PMasterErrorCode(input ybApi.MasterErrorPB_Code) *ybApi.MasterErrorPB_Code
PMasterErrorCode returns a pointer to the given input MasterErrorCode.
func PRemoteBootstrapErrorCode ¶
func PRemoteBootstrapErrorCode(input ybApi.RemoteBootstrapErrorPB_Code) *ybApi.RemoteBootstrapErrorPB_Code
PRemoteBootstrapErrorCode returns a pointer to the given input RemoteBootstrapErrorCode.
func PTableServerErrorCode ¶
func PTableServerErrorCode(input ybApi.TabletServerErrorPB_Code) *ybApi.TabletServerErrorPB_Code
PTableServerErrorCode returns a pointer to the given input TableServerErrorCode.
func PYQLDatabase ¶
func PYQLDatabase(input ybApi.YQLDatabase) *ybApi.YQLDatabase
PYQLDatabase returns a pointer to the given input YQLDatabase.
func ReadUvarint32 ¶
func ReadUvarint32(r io.ByteReader) (uint64, error)
ReadUvarint32 reads an encoded unsigned 32-bit integer from r and returns it as a uint64.
func ReadVarint32 ¶
func ReadVarint32(r io.ByteReader) (int64, error)
ReadVarint32 reads an encoded signed integer from r and returns it as an int64.
func SerializeProto ¶
SerializeProto serializes proto message to bytes.
func WriteMessages ¶
func WriteMessages(b io.Writer, msgs ...protoreflect.ProtoMessage) error
WriteMessages writes a variable number of protobuf messages into a given writer. This code is essentially based on: https://github.com/yugabyte/yugabyte-db/blob/v2.7.2/java/yb-client/src/main/java/org/yb/client/YRpc.java#L274 In the Java code, the Message header is the requestHeader, the Message pb is the actual payload.
Types ¶
This section is empty.
Source Files
Directories