1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: physical/raft/types.proto 3 4package raft 5 6import ( 7 fmt "fmt" 8 proto "github.com/golang/protobuf/proto" 9 math "math" 10) 11 12// Reference imports to suppress errors if they are not otherwise used. 13var _ = proto.Marshal 14var _ = fmt.Errorf 15var _ = math.Inf 16 17// This is a compile-time assertion to ensure that this generated file 18// is compatible with the proto package it is being compiled against. 19// A compilation error at this line likely means your copy of the 20// proto package needs to be updated. 21const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 22 23type LogOperation struct { 24 // OpType is the Operation type 25 OpType uint32 `protobuf:"varint,1,opt,name=op_type,json=opType,proto3" json:"op_type,omitempty"` 26 // Flags is an opaque value, currently unused. Reserved. 27 Flags uint64 `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"` 28 // Key that is being affected 29 Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` 30 // Value is optional, corresponds to the key 31 Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` 32 XXX_NoUnkeyedLiteral struct{} `json:"-"` 33 XXX_unrecognized []byte `json:"-"` 34 XXX_sizecache int32 `json:"-"` 35} 36 37func (m *LogOperation) Reset() { *m = LogOperation{} } 38func (m *LogOperation) String() string { return proto.CompactTextString(m) } 39func (*LogOperation) ProtoMessage() {} 40func (*LogOperation) Descriptor() ([]byte, []int) { 41 return fileDescriptor_a8b3efb4def82ab3, []int{0} 42} 43 44func (m *LogOperation) XXX_Unmarshal(b []byte) error { 45 return xxx_messageInfo_LogOperation.Unmarshal(m, b) 46} 47func (m *LogOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 48 return xxx_messageInfo_LogOperation.Marshal(b, m, deterministic) 49} 50func (m *LogOperation) XXX_Merge(src proto.Message) { 51 xxx_messageInfo_LogOperation.Merge(m, src) 52} 53func (m *LogOperation) XXX_Size() int { 54 return xxx_messageInfo_LogOperation.Size(m) 55} 56func (m *LogOperation) XXX_DiscardUnknown() { 57 xxx_messageInfo_LogOperation.DiscardUnknown(m) 58} 59 60var xxx_messageInfo_LogOperation proto.InternalMessageInfo 61 62func (m *LogOperation) GetOpType() uint32 { 63 if m != nil { 64 return m.OpType 65 } 66 return 0 67} 68 69func (m *LogOperation) GetFlags() uint64 { 70 if m != nil { 71 return m.Flags 72 } 73 return 0 74} 75 76func (m *LogOperation) GetKey() string { 77 if m != nil { 78 return m.Key 79 } 80 return "" 81} 82 83func (m *LogOperation) GetValue() []byte { 84 if m != nil { 85 return m.Value 86 } 87 return nil 88} 89 90type LogData struct { 91 Operations []*LogOperation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"` 92 XXX_NoUnkeyedLiteral struct{} `json:"-"` 93 XXX_unrecognized []byte `json:"-"` 94 XXX_sizecache int32 `json:"-"` 95} 96 97func (m *LogData) Reset() { *m = LogData{} } 98func (m *LogData) String() string { return proto.CompactTextString(m) } 99func (*LogData) ProtoMessage() {} 100func (*LogData) Descriptor() ([]byte, []int) { 101 return fileDescriptor_a8b3efb4def82ab3, []int{1} 102} 103 104func (m *LogData) XXX_Unmarshal(b []byte) error { 105 return xxx_messageInfo_LogData.Unmarshal(m, b) 106} 107func (m *LogData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 108 return xxx_messageInfo_LogData.Marshal(b, m, deterministic) 109} 110func (m *LogData) XXX_Merge(src proto.Message) { 111 xxx_messageInfo_LogData.Merge(m, src) 112} 113func (m *LogData) XXX_Size() int { 114 return xxx_messageInfo_LogData.Size(m) 115} 116func (m *LogData) XXX_DiscardUnknown() { 117 xxx_messageInfo_LogData.DiscardUnknown(m) 118} 119 120var xxx_messageInfo_LogData proto.InternalMessageInfo 121 122func (m *LogData) GetOperations() []*LogOperation { 123 if m != nil { 124 return m.Operations 125 } 126 return nil 127} 128 129type IndexValue struct { 130 Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` 131 Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` 132 XXX_NoUnkeyedLiteral struct{} `json:"-"` 133 XXX_unrecognized []byte `json:"-"` 134 XXX_sizecache int32 `json:"-"` 135} 136 137func (m *IndexValue) Reset() { *m = IndexValue{} } 138func (m *IndexValue) String() string { return proto.CompactTextString(m) } 139func (*IndexValue) ProtoMessage() {} 140func (*IndexValue) Descriptor() ([]byte, []int) { 141 return fileDescriptor_a8b3efb4def82ab3, []int{2} 142} 143 144func (m *IndexValue) XXX_Unmarshal(b []byte) error { 145 return xxx_messageInfo_IndexValue.Unmarshal(m, b) 146} 147func (m *IndexValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 148 return xxx_messageInfo_IndexValue.Marshal(b, m, deterministic) 149} 150func (m *IndexValue) XXX_Merge(src proto.Message) { 151 xxx_messageInfo_IndexValue.Merge(m, src) 152} 153func (m *IndexValue) XXX_Size() int { 154 return xxx_messageInfo_IndexValue.Size(m) 155} 156func (m *IndexValue) XXX_DiscardUnknown() { 157 xxx_messageInfo_IndexValue.DiscardUnknown(m) 158} 159 160var xxx_messageInfo_IndexValue proto.InternalMessageInfo 161 162func (m *IndexValue) GetTerm() uint64 { 163 if m != nil { 164 return m.Term 165 } 166 return 0 167} 168 169func (m *IndexValue) GetIndex() uint64 { 170 if m != nil { 171 return m.Index 172 } 173 return 0 174} 175 176type Server struct { 177 Suffrage int32 `protobuf:"varint,1,opt,name=suffrage,proto3" json:"suffrage,omitempty"` 178 Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` 179 Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` 180 XXX_NoUnkeyedLiteral struct{} `json:"-"` 181 XXX_unrecognized []byte `json:"-"` 182 XXX_sizecache int32 `json:"-"` 183} 184 185func (m *Server) Reset() { *m = Server{} } 186func (m *Server) String() string { return proto.CompactTextString(m) } 187func (*Server) ProtoMessage() {} 188func (*Server) Descriptor() ([]byte, []int) { 189 return fileDescriptor_a8b3efb4def82ab3, []int{3} 190} 191 192func (m *Server) XXX_Unmarshal(b []byte) error { 193 return xxx_messageInfo_Server.Unmarshal(m, b) 194} 195func (m *Server) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 196 return xxx_messageInfo_Server.Marshal(b, m, deterministic) 197} 198func (m *Server) XXX_Merge(src proto.Message) { 199 xxx_messageInfo_Server.Merge(m, src) 200} 201func (m *Server) XXX_Size() int { 202 return xxx_messageInfo_Server.Size(m) 203} 204func (m *Server) XXX_DiscardUnknown() { 205 xxx_messageInfo_Server.DiscardUnknown(m) 206} 207 208var xxx_messageInfo_Server proto.InternalMessageInfo 209 210func (m *Server) GetSuffrage() int32 { 211 if m != nil { 212 return m.Suffrage 213 } 214 return 0 215} 216 217func (m *Server) GetId() string { 218 if m != nil { 219 return m.Id 220 } 221 return "" 222} 223 224func (m *Server) GetAddress() string { 225 if m != nil { 226 return m.Address 227 } 228 return "" 229} 230 231type ConfigurationValue struct { 232 Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` 233 Servers []*Server `protobuf:"bytes,2,rep,name=servers,proto3" json:"servers,omitempty"` 234 XXX_NoUnkeyedLiteral struct{} `json:"-"` 235 XXX_unrecognized []byte `json:"-"` 236 XXX_sizecache int32 `json:"-"` 237} 238 239func (m *ConfigurationValue) Reset() { *m = ConfigurationValue{} } 240func (m *ConfigurationValue) String() string { return proto.CompactTextString(m) } 241func (*ConfigurationValue) ProtoMessage() {} 242func (*ConfigurationValue) Descriptor() ([]byte, []int) { 243 return fileDescriptor_a8b3efb4def82ab3, []int{4} 244} 245 246func (m *ConfigurationValue) XXX_Unmarshal(b []byte) error { 247 return xxx_messageInfo_ConfigurationValue.Unmarshal(m, b) 248} 249func (m *ConfigurationValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 250 return xxx_messageInfo_ConfigurationValue.Marshal(b, m, deterministic) 251} 252func (m *ConfigurationValue) XXX_Merge(src proto.Message) { 253 xxx_messageInfo_ConfigurationValue.Merge(m, src) 254} 255func (m *ConfigurationValue) XXX_Size() int { 256 return xxx_messageInfo_ConfigurationValue.Size(m) 257} 258func (m *ConfigurationValue) XXX_DiscardUnknown() { 259 xxx_messageInfo_ConfigurationValue.DiscardUnknown(m) 260} 261 262var xxx_messageInfo_ConfigurationValue proto.InternalMessageInfo 263 264func (m *ConfigurationValue) GetIndex() uint64 { 265 if m != nil { 266 return m.Index 267 } 268 return 0 269} 270 271func (m *ConfigurationValue) GetServers() []*Server { 272 if m != nil { 273 return m.Servers 274 } 275 return nil 276} 277 278func init() { 279 proto.RegisterType((*LogOperation)(nil), "raft.LogOperation") 280 proto.RegisterType((*LogData)(nil), "raft.LogData") 281 proto.RegisterType((*IndexValue)(nil), "raft.IndexValue") 282 proto.RegisterType((*Server)(nil), "raft.Server") 283 proto.RegisterType((*ConfigurationValue)(nil), "raft.ConfigurationValue") 284} 285 286func init() { proto.RegisterFile("physical/raft/types.proto", fileDescriptor_a8b3efb4def82ab3) } 287 288var fileDescriptor_a8b3efb4def82ab3 = []byte{ 289 // 322 bytes of a gzipped FileDescriptorProto 290 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x54, 0x91, 0xc1, 0x4b, 0xc3, 0x30, 291 0x14, 0xc6, 0xc9, 0xd6, 0xad, 0xee, 0x39, 0x45, 0x1e, 0x82, 0xd5, 0x53, 0xe9, 0x41, 0x8a, 0x87, 292 0x16, 0x26, 0x78, 0xf3, 0xa2, 0x5e, 0x84, 0xa1, 0x10, 0xc5, 0x83, 0x17, 0xc9, 0xd6, 0xb4, 0x0d, 293 0x76, 0x4b, 0x48, 0xd2, 0x61, 0xff, 0x7b, 0x49, 0x63, 0xc7, 0xbc, 0xbd, 0xaf, 0xfd, 0x92, 0xef, 294 0xf7, 0xe5, 0xc1, 0xa5, 0xaa, 0x3b, 0x23, 0xd6, 0xac, 0xc9, 0x35, 0x2b, 0x6d, 0x6e, 0x3b, 0xc5, 295 0x4d, 0xa6, 0xb4, 0xb4, 0x12, 0x03, 0xf7, 0x25, 0xe1, 0x30, 0x5f, 0xca, 0xea, 0x55, 0x71, 0xcd, 296 0xac, 0x90, 0x5b, 0xbc, 0x80, 0x50, 0xaa, 0x2f, 0xe7, 0x8b, 0x48, 0x4c, 0xd2, 0x13, 0x3a, 0x95, 297 0xea, 0xbd, 0x53, 0x1c, 0xcf, 0x61, 0x52, 0x36, 0xac, 0x32, 0xd1, 0x28, 0x26, 0x69, 0x40, 0xbd, 298 0xc0, 0x33, 0x18, 0x7f, 0xf3, 0x2e, 0x1a, 0xc7, 0x24, 0x9d, 0x51, 0x37, 0x3a, 0xdf, 0x8e, 0x35, 299 0x2d, 0x8f, 0x82, 0x98, 0xa4, 0x73, 0xea, 0x45, 0x72, 0x0f, 0xe1, 0x52, 0x56, 0x4f, 0xcc, 0x32, 300 0x5c, 0x00, 0xc8, 0x21, 0xce, 0x44, 0x24, 0x1e, 0xa7, 0xc7, 0x0b, 0xcc, 0x1c, 0x4c, 0x76, 0x48, 301 0x42, 0x0f, 0x5c, 0xc9, 0x1d, 0xc0, 0xf3, 0xb6, 0xe0, 0x3f, 0x1f, 0xee, 0x32, 0x44, 0x08, 0x2c, 302 0xd7, 0x9b, 0x1e, 0x30, 0xa0, 0xfd, 0xec, 0x62, 0x85, 0x73, 0x0c, 0x78, 0xbd, 0x48, 0x5e, 0x60, 303 0xfa, 0xc6, 0xf5, 0x8e, 0x6b, 0xbc, 0x82, 0x23, 0xd3, 0x96, 0xa5, 0x66, 0x95, 0x2f, 0x36, 0xa1, 304 0x7b, 0x8d, 0xa7, 0x30, 0x12, 0x45, 0x7f, 0x70, 0x46, 0x47, 0xa2, 0xc0, 0x08, 0x42, 0x56, 0x14, 305 0x9a, 0x1b, 0xf3, 0x57, 0x6c, 0x90, 0x09, 0x05, 0x7c, 0x94, 0xdb, 0x52, 0x54, 0xad, 0x27, 0xf3, 306 0x3c, 0xfb, 0x6c, 0x72, 0x90, 0x8d, 0xd7, 0x10, 0x9a, 0x3e, 0xdb, 0x3d, 0x99, 0x2b, 0x39, 0xf7, 307 0x25, 0x3d, 0x10, 0x1d, 0x7e, 0x3e, 0xdc, 0x7c, 0xa6, 0x95, 0xb0, 0x75, 0xbb, 0xca, 0xd6, 0x72, 308 0x93, 0xd7, 0xcc, 0xd4, 0x62, 0x2d, 0xb5, 0xca, 0x77, 0xac, 0x6d, 0x6c, 0xfe, 0x6f, 0x7f, 0xab, 309 0x69, 0xbf, 0xba, 0xdb, 0xdf, 0x00, 0x00, 0x00, 0xff, 0xff, 0xff, 0x85, 0xad, 0xad, 0xd7, 0x01, 310 0x00, 0x00, 311} 312