proto

package

v0.0.0-...-16f22ad Latest Latest Go to latest Published: Sep 4, 2025 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zllovesuki/specter

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	LogVersion_name = map[int32]string{
		0: "UNKNOWN_VERSION",
		1: "V1",
	}
	LogVersion_value = map[string]int32{
		"UNKNOWN_VERSION": 0,
		"V1":              1,
	}
)

Enum value maps for LogVersion.

View Source

var (
	MutationType_name = map[int32]string{
		0:  "UNKNOWN_TYPE",
		1:  "SIMPLE_PUT",
		3:  "SIMPLE_DELETE",
		5:  "PREFIX_APPEND",
		7:  "PREFIX_REMOVE",
		20: "IMPORT",
		21: "REMOVE_KEYS",
	}
	MutationType_value = map[string]int32{
		"UNKNOWN_TYPE":  0,
		"SIMPLE_PUT":    1,
		"SIMPLE_DELETE": 3,
		"PREFIX_APPEND": 5,
		"PREFIX_REMOVE": 7,
		"IMPORT":        20,
		"REMOVE_KEYS":   21,
	}
)

Enum value maps for MutationType.

View Source

var File_kv_aof_proto_log_proto protoreflect.FileDescriptor

View Source

var File_kv_aof_proto_mutation_proto protoreflect.FileDescriptor

Functions ¶

This section is empty.

Types ¶

type LogEntry ¶

type LogEntry struct {
	Version  LogVersion `protobuf:"varint,1,opt,name=version,proto3,enum=proto.LogVersion" json:"version,omitempty"`
	Data     []byte     `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Checksum uint64     `protobuf:"varint,5,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func LogEntryFromVTPool ¶

func LogEntryFromVTPool() *LogEntry

func (*LogEntry) Descriptor deprecated

func (*LogEntry) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetChecksum ¶

func (x *LogEntry) GetChecksum() uint64

func (*LogEntry) GetData ¶

func (x *LogEntry) GetData() []byte

func (*LogEntry) GetVersion ¶

func (x *LogEntry) GetVersion() LogVersion

func (*LogEntry) MarshalToSizedBufferVT ¶

func (m *LogEntry) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogEntry) MarshalToVT ¶

func (m *LogEntry) MarshalToVT(dAtA []byte) (int, error)

func (*LogEntry) MarshalVT ¶

func (m *LogEntry) MarshalVT() (dAtA []byte, err error)

func (*LogEntry) ProtoMessage ¶

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect ¶

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

func (*LogEntry) Reset ¶

func (x *LogEntry) Reset()

func (*LogEntry) ResetVT ¶

func (m *LogEntry) ResetVT()

func (*LogEntry) ReturnToVTPool ¶

func (m *LogEntry) ReturnToVTPool()

func (*LogEntry) SizeVT ¶

func (m *LogEntry) SizeVT() (n int)

func (*LogEntry) String ¶

func (x *LogEntry) String() string

func (*LogEntry) UnmarshalVT ¶

func (m *LogEntry) UnmarshalVT(dAtA []byte) error

type LogVersion ¶

type LogVersion int32

const (
	LogVersion_UNKNOWN_VERSION LogVersion = 0
	// uncompressed
	LogVersion_V1 LogVersion = 1
)

func (LogVersion) Descriptor ¶

func (LogVersion) Descriptor() protoreflect.EnumDescriptor

func (LogVersion) Enum ¶

func (x LogVersion) Enum() *LogVersion

func (LogVersion) EnumDescriptor deprecated

func (LogVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogVersion.Descriptor instead.

func (LogVersion) Number ¶

func (x LogVersion) Number() protoreflect.EnumNumber

func (LogVersion) String ¶

func (x LogVersion) String() string

func (LogVersion) Type ¶

func (LogVersion) Type() protoreflect.EnumType

type Mutation ¶

type Mutation struct {
	Type   MutationType           `protobuf:"varint,1,opt,name=type,proto3,enum=proto.MutationType" json:"type,omitempty"`
	Key    []byte                 `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value  []byte                 `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Keys   [][]byte               `protobuf:"bytes,10,rep,name=keys,proto3" json:"keys,omitempty"`
	Values []*protocol.KVTransfer `protobuf:"bytes,20,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func MutationFromVTPool ¶

func MutationFromVTPool() *Mutation

func (*Mutation) Descriptor deprecated

func (*Mutation) Descriptor() ([]byte, []int)

Deprecated: Use Mutation.ProtoReflect.Descriptor instead.

func (*Mutation) GetKey ¶

func (x *Mutation) GetKey() []byte

func (*Mutation) GetKeys ¶

func (x *Mutation) GetKeys() [][]byte

func (*Mutation) GetType ¶

func (x *Mutation) GetType() MutationType

func (*Mutation) GetValue ¶

func (x *Mutation) GetValue() []byte

func (*Mutation) GetValues ¶

func (x *Mutation) GetValues() []*protocol.KVTransfer

func (*Mutation) MarshalToSizedBufferVT ¶

func (m *Mutation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Mutation) MarshalToVT ¶

func (m *Mutation) MarshalToVT(dAtA []byte) (int, error)

func (*Mutation) MarshalVT ¶

func (m *Mutation) MarshalVT() (dAtA []byte, err error)

func (*Mutation) ProtoMessage ¶

func (*Mutation) ProtoMessage()

func (*Mutation) ProtoReflect ¶

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

func (*Mutation) Reset ¶

func (x *Mutation) Reset()

func (*Mutation) ResetVT ¶

func (m *Mutation) ResetVT()

func (*Mutation) ReturnToVTPool ¶

func (m *Mutation) ReturnToVTPool()

func (*Mutation) SizeVT ¶

func (m *Mutation) SizeVT() (n int)

func (*Mutation) String ¶

func (x *Mutation) String() string

func (*Mutation) UnmarshalVT ¶

func (m *Mutation) UnmarshalVT(dAtA []byte) error

type MutationType ¶

type MutationType int32

const (
	MutationType_UNKNOWN_TYPE  MutationType = 0
	MutationType_SIMPLE_PUT    MutationType = 1
	MutationType_SIMPLE_DELETE MutationType = 3
	MutationType_PREFIX_APPEND MutationType = 5
	MutationType_PREFIX_REMOVE MutationType = 7
	MutationType_IMPORT        MutationType = 20
	MutationType_REMOVE_KEYS   MutationType = 21
)

func (MutationType) Descriptor ¶

func (MutationType) Descriptor() protoreflect.EnumDescriptor

func (MutationType) Enum ¶

func (x MutationType) Enum() *MutationType

func (MutationType) EnumDescriptor deprecated

func (MutationType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MutationType.Descriptor instead.

func (MutationType) Number ¶

func (x MutationType) Number() protoreflect.EnumNumber

func (MutationType) String ¶

func (x MutationType) String() string

func (MutationType) Type ¶

func (MutationType) Type() protoreflect.EnumType

Source Files ¶

View all Source files

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