model

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: May 25, 2025 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_record_proto protoreflect.FileDescriptor

Functions

func EncodeRecords

func EncodeRecords(rs []*Record, buf *bytes.Buffer) error

EncodeRecords encodes a list of Record instances into a buffer using the protocol buffer delimited format.

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

func DecodeRecords(buf *bytes.Buffer) ([]*Record, error)

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) Descriptor() ([]byte, []int)

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetArgs

func (x *Record) GetArgs() []string

func (*Record) GetCommandId

func (x *Record) GetCommandId() int64

func (*Record) GetLsn

func (x *Record) GetLsn() int64

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

Jump to

Keyboard shortcuts

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