1
// Code generated by protoc-gen-go. DO NOT EDIT.
2
// versions:
3
// 	protoc-gen-go v1.36.11
4
// 	protoc        v7.34.0
5
// source: kv/aof/proto/mutation.proto
6
 
7
package proto
8
 
9
import (
10
	protocol "go.miragespace.co/specter/spec/protocol"
11
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
12
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
13
	reflect "reflect"
14
	sync "sync"
15
	unsafe "unsafe"
16
)
17
 
18
const (
19
	// Verify that this generated code is sufficiently up-to-date.
20
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
21
	// Verify that runtime/protoimpl is sufficiently up-to-date.
22
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
23
)
24
 
25
type MutationType int32
26
 
27
const (
28
	MutationType_UNKNOWN_TYPE  MutationType = 0
29
	MutationType_SIMPLE_PUT    MutationType = 1
30
	MutationType_SIMPLE_DELETE MutationType = 3
31
	MutationType_PREFIX_APPEND MutationType = 5
32
	MutationType_PREFIX_REMOVE MutationType = 7
33
	MutationType_IMPORT        MutationType = 20
34
	MutationType_REMOVE_KEYS   MutationType = 21
35
)
36
 
37
// Enum value maps for MutationType.
38
var (
39
	MutationType_name = map[int32]string{
40
		0:  "UNKNOWN_TYPE",
41
		1:  "SIMPLE_PUT",
42
		3:  "SIMPLE_DELETE",
43
		5:  "PREFIX_APPEND",
44
		7:  "PREFIX_REMOVE",
45
		20: "IMPORT",
46
		21: "REMOVE_KEYS",
47
	}
48
	MutationType_value = map[string]int32{
49
		"UNKNOWN_TYPE":  0,
50
		"SIMPLE_PUT":    1,
51
		"SIMPLE_DELETE": 3,
52
		"PREFIX_APPEND": 5,
53
		"PREFIX_REMOVE": 7,
54
		"IMPORT":        20,
55
		"REMOVE_KEYS":   21,
56
	}
57
)
58
 
59
func (x MutationType) Enum() *MutationType {
60
	p := new(MutationType)
61
	*p = x
62
	return p
63
}
64
 
65
func (x MutationType) String() string {
66
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
67
}
68
 
69
func (MutationType) Descriptor() protoreflect.EnumDescriptor {
70
	return file_kv_aof_proto_mutation_proto_enumTypes[0].Descriptor()
71
}
72
 
73
func (MutationType) Type() protoreflect.EnumType {
74
	return &file_kv_aof_proto_mutation_proto_enumTypes[0]
75
}
76
 
77
func (x MutationType) Number() protoreflect.EnumNumber {
78
	return protoreflect.EnumNumber(x)
79
}
80
 
81
// Deprecated: Use MutationType.Descriptor instead.
82
func (MutationType) EnumDescriptor() ([]byte, []int) {
83
	return file_kv_aof_proto_mutation_proto_rawDescGZIP(), []int{0}
84
}
85
 
86
type Mutation struct {
87
	state         protoimpl.MessageState `protogen:"open.v1"`
88
	Type          MutationType           `protobuf:"varint,1,opt,name=type,proto3,enum=proto.MutationType" json:"type,omitempty"`
89
	Key           []byte                 `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
90
	Value         []byte                 `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
91
	Keys          [][]byte               `protobuf:"bytes,10,rep,name=keys,proto3" json:"keys,omitempty"`
92
	Values        []*protocol.KVTransfer `protobuf:"bytes,20,rep,name=values,proto3" json:"values,omitempty"`
93
	unknownFields protoimpl.UnknownFields
94
	sizeCache     protoimpl.SizeCache
95
}
96
 
97
func (x *Mutation) Reset() {
98
	*x = Mutation{}
99
	mi := &file_kv_aof_proto_mutation_proto_msgTypes[0]
100
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
101
	ms.StoreMessageInfo(mi)
102
}
103
 
104
func (x *Mutation) String() string {
105
	return protoimpl.X.MessageStringOf(x)
106
}
107
 
108
func (*Mutation) ProtoMessage() {}
109
 
110
func (x *Mutation) ProtoReflect() protoreflect.Message {
111
	mi := &file_kv_aof_proto_mutation_proto_msgTypes[0]
112
	if x != nil {
113
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
114
		if ms.LoadMessageInfo() == nil {
115
			ms.StoreMessageInfo(mi)
116
		}
117
		return ms
118
	}
119
	return mi.MessageOf(x)
120
}
121
 
122
// Deprecated: Use Mutation.ProtoReflect.Descriptor instead.
123
func (*Mutation) Descriptor() ([]byte, []int) {
124
	return file_kv_aof_proto_mutation_proto_rawDescGZIP(), []int{0}
125
}
126
 
127
func (x *Mutation) GetType() MutationType {
128
	if x != nil {
129
		return x.Type
130
	}
131
	return MutationType_UNKNOWN_TYPE
132
}
133
 
134
func (x *Mutation) GetKey() []byte {
135
	if x != nil {
136
		return x.Key
137
	}
138
	return nil
139
}
140
 
141
func (x *Mutation) GetValue() []byte {
142
	if x != nil {
143
		return x.Value
144
	}
145
	return nil
146
}
147
 
148
func (x *Mutation) GetKeys() [][]byte {
149
	if x != nil {
150
		return x.Keys
151
	}
152
	return nil
153
}
154
 
155
func (x *Mutation) GetValues() []*protocol.KVTransfer {
156
	if x != nil {
157
		return x.Values
158
	}
159
	return nil
160
}
161
 
162
var File_kv_aof_proto_mutation_proto protoreflect.FileDescriptor
163
 
164
const file_kv_aof_proto_mutation_proto_rawDesc = "" +
165
	"\n" +
166
	"\x1bkv/aof/proto/mutation.proto\x12\x05proto\x1a\x13spec/proto/kv.proto\"\x9d\x01\n" +
167
	"\bMutation\x12'\n" +
168
	"\x04type\x18\x01 \x01(\x0e2\x13.proto.MutationTypeR\x04type\x12\x10\n" +
169
	"\x03key\x18\x02 \x01(\fR\x03key\x12\x14\n" +
170
	"\x05value\x18\x03 \x01(\fR\x05value\x12\x12\n" +
171
	"\x04keys\x18\n" +
172
	" \x03(\fR\x04keys\x12,\n" +
173
	"\x06values\x18\x14 \x03(\v2\x14.protocol.KVTransferR\x06values*\x86\x01\n" +
174
	"\fMutationType\x12\x10\n" +
175
	"\fUNKNOWN_TYPE\x10\x00\x12\x0e\n" +
176
	"\n" +
177
	"SIMPLE_PUT\x10\x01\x12\x11\n" +
178
	"\rSIMPLE_DELETE\x10\x03\x12\x11\n" +
179
	"\rPREFIX_APPEND\x10\x05\x12\x11\n" +
180
	"\rPREFIX_REMOVE\x10\a\x12\n" +
181
	"\n" +
182
	"\x06IMPORT\x10\x14\x12\x0f\n" +
183
	"\vREMOVE_KEYS\x10\x15B*H\x01Z&go.miragespace.co/specter/kv/aof/protob\x06proto3"
184
 
185
var (
186
	file_kv_aof_proto_mutation_proto_rawDescOnce sync.Once
187
	file_kv_aof_proto_mutation_proto_rawDescData []byte
188
)
189
 
190
func file_kv_aof_proto_mutation_proto_rawDescGZIP() []byte {
191
	file_kv_aof_proto_mutation_proto_rawDescOnce.Do(func() {
192
		file_kv_aof_proto_mutation_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_kv_aof_proto_mutation_proto_rawDesc), len(file_kv_aof_proto_mutation_proto_rawDesc)))
193
	})
194
	return file_kv_aof_proto_mutation_proto_rawDescData
195
}
196
 
197
var file_kv_aof_proto_mutation_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
198
var file_kv_aof_proto_mutation_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
199
var file_kv_aof_proto_mutation_proto_goTypes = []any{
200
	(MutationType)(0),           // 0: proto.MutationType
201
	(*Mutation)(nil),            // 1: proto.Mutation
202
	(*protocol.KVTransfer)(nil), // 2: protocol.KVTransfer
203
}
204
var file_kv_aof_proto_mutation_proto_depIdxs = []int32{
205
	0, // 0: proto.Mutation.type:type_name -> proto.MutationType
206
	2, // 1: proto.Mutation.values:type_name -> protocol.KVTransfer
207
	2, // [2:2] is the sub-list for method output_type
208
	2, // [2:2] is the sub-list for method input_type
209
	2, // [2:2] is the sub-list for extension type_name
210
	2, // [2:2] is the sub-list for extension extendee
211
	0, // [0:2] is the sub-list for field type_name
212
}
213
 
214
func init() { file_kv_aof_proto_mutation_proto_init() }
215
func file_kv_aof_proto_mutation_proto_init() {
216
	if File_kv_aof_proto_mutation_proto != nil {
217
		return
218
	}
219
	type x struct{}
220
	out := protoimpl.TypeBuilder{
221
		File: protoimpl.DescBuilder{
222
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
223
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_kv_aof_proto_mutation_proto_rawDesc), len(file_kv_aof_proto_mutation_proto_rawDesc)),
224
			NumEnums:      1,
225
			NumMessages:   1,
226
			NumExtensions: 0,
227
			NumServices:   0,
228
		},
229
		GoTypes:           file_kv_aof_proto_mutation_proto_goTypes,
230
		DependencyIndexes: file_kv_aof_proto_mutation_proto_depIdxs,
231
		EnumInfos:         file_kv_aof_proto_mutation_proto_enumTypes,
232
		MessageInfos:      file_kv_aof_proto_mutation_proto_msgTypes,
233
	}.Build()
234
	File_kv_aof_proto_mutation_proto = out.File
235
	file_kv_aof_proto_mutation_proto_goTypes = nil
236
	file_kv_aof_proto_mutation_proto_depIdxs = nil
237
}