Documentation
¶
Index ¶
- Variables
- func EncodeRecords(rs []*Record, buf *bytes.Buffer) error
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetArgs() []string
- func (x *Record) GetCommandId() int64
- func (x *Record) GetLsn() int64
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (x *Record) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_record_proto protoreflect.FileDescriptor
Functions ¶
Types ¶
type Record ¶
type Record struct {
Lsn int64 `protobuf:"varint,1,opt,name=lsn,proto3" json:"lsn,omitempty"`
CommandId int64 `protobuf:"varint,2,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
// contains filtered or unexported fields
}
func DecodeRecords ¶
DecodeRecords reads and decodes a series of Record messages from the provided buffer using protobuf delimited encoding. It returns a slice of pointers to Record objects or an error if decoding fails.
func (*Record) Descriptor
deprecated
func (*Record) GetCommandId ¶
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.