123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552 |
- // Code generated by protoc-gen-gogo.
- // source: log_entry.proto
- // DO NOT EDIT!
- package protobuf
- import proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
- import json "encoding/json"
- import math "math"
- // discarding unused import gogoproto "code.google.com/p/gogoprotobuf/gogoproto/gogo.pb"
- import io "io"
- import code_google_com_p_gogoprotobuf_proto "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
- import fmt "fmt"
- import strings "strings"
- import reflect "reflect"
- import fmt1 "fmt"
- import strings1 "strings"
- import code_google_com_p_gogoprotobuf_proto1 "github.com/coreos/etcd/third_party/code.google.com/p/gogoprotobuf/proto"
- import sort "sort"
- import strconv "strconv"
- import reflect1 "reflect"
- import fmt2 "fmt"
- import bytes "bytes"
- // Reference proto, json, and math imports to suppress error if they are not otherwise used.
- var _ = proto.Marshal
- var _ = &json.SyntaxError{}
- var _ = math.Inf
- type LogEntry struct {
- Index *uint64 `protobuf:"varint,1,req" json:"Index,omitempty"`
- Term *uint64 `protobuf:"varint,2,req" json:"Term,omitempty"`
- CommandName *string `protobuf:"bytes,3,req" json:"CommandName,omitempty"`
- Command []byte `protobuf:"bytes,4,opt" json:"Command,omitempty"`
- XXX_unrecognized []byte `json:"-"`
- }
- func (m *LogEntry) Reset() { *m = LogEntry{} }
- func (*LogEntry) ProtoMessage() {}
- func (m *LogEntry) GetIndex() uint64 {
- if m != nil && m.Index != nil {
- return *m.Index
- }
- return 0
- }
- func (m *LogEntry) GetTerm() uint64 {
- if m != nil && m.Term != nil {
- return *m.Term
- }
- return 0
- }
- func (m *LogEntry) GetCommandName() string {
- if m != nil && m.CommandName != nil {
- return *m.CommandName
- }
- return ""
- }
- func (m *LogEntry) GetCommand() []byte {
- if m != nil {
- return m.Command
- }
- return nil
- }
- func init() {
- }
- func (m *LogEntry) Unmarshal(data []byte) error {
- l := len(data)
- index := 0
- for index < l {
- var wire uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- wire |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- fieldNum := int32(wire >> 3)
- wireType := int(wire & 0x7)
- switch fieldNum {
- case 1:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var v uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- v |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- m.Index = &v
- case 2:
- if wireType != 0 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var v uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- v |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- m.Term = &v
- case 3:
- if wireType != 2 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- stringLen |= (uint64(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- postIndex := index + int(stringLen)
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- s := string(data[index:postIndex])
- m.CommandName = &s
- index = postIndex
- case 4:
- if wireType != 2 {
- return code_google_com_p_gogoprotobuf_proto.ErrWrongType
- }
- var byteLen int
- for shift := uint(0); ; shift += 7 {
- if index >= l {
- return io.ErrUnexpectedEOF
- }
- b := data[index]
- index++
- byteLen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- postIndex := index + byteLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Command = append(m.Command, data[index:postIndex]...)
- index = postIndex
- default:
- var sizeOfWire int
- for {
- sizeOfWire++
- wire >>= 7
- if wire == 0 {
- break
- }
- }
- index -= sizeOfWire
- skippy, err := code_google_com_p_gogoprotobuf_proto.Skip(data[index:])
- if err != nil {
- return err
- }
- if (index + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- m.XXX_unrecognized = append(m.XXX_unrecognized, data[index:index+skippy]...)
- index += skippy
- }
- }
- return nil
- }
- func (this *LogEntry) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&LogEntry{`,
- `Index:` + valueToStringLogEntry(this.Index) + `,`,
- `Term:` + valueToStringLogEntry(this.Term) + `,`,
- `CommandName:` + valueToStringLogEntry(this.CommandName) + `,`,
- `Command:` + valueToStringLogEntry(this.Command) + `,`,
- `XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`,
- `}`,
- }, "")
- return s
- }
- func valueToStringLogEntry(v interface{}) string {
- rv := reflect.ValueOf(v)
- if rv.IsNil() {
- return "nil"
- }
- pv := reflect.Indirect(rv).Interface()
- return fmt.Sprintf("*%v", pv)
- }
- func (m *LogEntry) Size() (n int) {
- var l int
- _ = l
- if m.Index != nil {
- n += 1 + sovLogEntry(uint64(*m.Index))
- }
- if m.Term != nil {
- n += 1 + sovLogEntry(uint64(*m.Term))
- }
- if m.CommandName != nil {
- l = len(*m.CommandName)
- n += 1 + l + sovLogEntry(uint64(l))
- }
- if m.Command != nil {
- l = len(m.Command)
- n += 1 + l + sovLogEntry(uint64(l))
- }
- if m.XXX_unrecognized != nil {
- n += len(m.XXX_unrecognized)
- }
- return n
- }
- func sovLogEntry(x uint64) (n int) {
- for {
- n++
- x >>= 7
- if x == 0 {
- break
- }
- }
- return n
- }
- func sozLogEntry(x uint64) (n int) {
- return sovLogEntry(uint64((x << 1) ^ uint64((int64(x) >> 63))))
- }
- func NewPopulatedLogEntry(r randyLogEntry, easy bool) *LogEntry {
- this := &LogEntry{}
- v1 := uint64(r.Uint32())
- this.Index = &v1
- v2 := uint64(r.Uint32())
- this.Term = &v2
- v3 := randStringLogEntry(r)
- this.CommandName = &v3
- if r.Intn(10) != 0 {
- v4 := r.Intn(100)
- this.Command = make([]byte, v4)
- for i := 0; i < v4; i++ {
- this.Command[i] = byte(r.Intn(256))
- }
- }
- if !easy && r.Intn(10) != 0 {
- this.XXX_unrecognized = randUnrecognizedLogEntry(r, 5)
- }
- return this
- }
- type randyLogEntry interface {
- Float32() float32
- Float64() float64
- Int63() int64
- Int31() int32
- Uint32() uint32
- Intn(n int) int
- }
- func randUTF8RuneLogEntry(r randyLogEntry) rune {
- res := rune(r.Uint32() % 1112064)
- if 55296 <= res {
- res += 2047
- }
- return res
- }
- func randStringLogEntry(r randyLogEntry) string {
- v5 := r.Intn(100)
- tmps := make([]rune, v5)
- for i := 0; i < v5; i++ {
- tmps[i] = randUTF8RuneLogEntry(r)
- }
- return string(tmps)
- }
- func randUnrecognizedLogEntry(r randyLogEntry, maxFieldNumber int) (data []byte) {
- l := r.Intn(5)
- for i := 0; i < l; i++ {
- wire := r.Intn(4)
- if wire == 3 {
- wire = 5
- }
- fieldNumber := maxFieldNumber + r.Intn(100)
- data = randFieldLogEntry(data, r, fieldNumber, wire)
- }
- return data
- }
- func randFieldLogEntry(data []byte, r randyLogEntry, fieldNumber int, wire int) []byte {
- key := uint32(fieldNumber)<<3 | uint32(wire)
- switch wire {
- case 0:
- data = encodeVarintPopulateLogEntry(data, uint64(key))
- data = encodeVarintPopulateLogEntry(data, uint64(r.Int63()))
- case 1:
- data = encodeVarintPopulateLogEntry(data, uint64(key))
- data = append(data, byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)))
- case 2:
- data = encodeVarintPopulateLogEntry(data, uint64(key))
- ll := r.Intn(100)
- data = encodeVarintPopulateLogEntry(data, uint64(ll))
- for j := 0; j < ll; j++ {
- data = append(data, byte(r.Intn(256)))
- }
- default:
- data = encodeVarintPopulateLogEntry(data, uint64(key))
- data = append(data, byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)))
- }
- return data
- }
- func encodeVarintPopulateLogEntry(data []byte, v uint64) []byte {
- for v >= 1<<7 {
- data = append(data, uint8(uint64(v)&0x7f|0x80))
- v >>= 7
- }
- data = append(data, uint8(v))
- return data
- }
- func (m *LogEntry) Marshal() (data []byte, err error) {
- size := m.Size()
- data = make([]byte, size)
- n, err := m.MarshalTo(data)
- if err != nil {
- return nil, err
- }
- return data[:n], nil
- }
- func (m *LogEntry) MarshalTo(data []byte) (n int, err error) {
- var i int
- _ = i
- var l int
- _ = l
- if m.Index != nil {
- data[i] = 0x8
- i++
- i = encodeVarintLogEntry(data, i, uint64(*m.Index))
- }
- if m.Term != nil {
- data[i] = 0x10
- i++
- i = encodeVarintLogEntry(data, i, uint64(*m.Term))
- }
- if m.CommandName != nil {
- data[i] = 0x1a
- i++
- i = encodeVarintLogEntry(data, i, uint64(len(*m.CommandName)))
- i += copy(data[i:], *m.CommandName)
- }
- if m.Command != nil {
- data[i] = 0x22
- i++
- i = encodeVarintLogEntry(data, i, uint64(len(m.Command)))
- i += copy(data[i:], m.Command)
- }
- if m.XXX_unrecognized != nil {
- i += copy(data[i:], m.XXX_unrecognized)
- }
- return i, nil
- }
- func encodeFixed64LogEntry(data []byte, offset int, v uint64) int {
- data[offset] = uint8(v)
- data[offset+1] = uint8(v >> 8)
- data[offset+2] = uint8(v >> 16)
- data[offset+3] = uint8(v >> 24)
- data[offset+4] = uint8(v >> 32)
- data[offset+5] = uint8(v >> 40)
- data[offset+6] = uint8(v >> 48)
- data[offset+7] = uint8(v >> 56)
- return offset + 8
- }
- func encodeFixed32LogEntry(data []byte, offset int, v uint32) int {
- data[offset] = uint8(v)
- data[offset+1] = uint8(v >> 8)
- data[offset+2] = uint8(v >> 16)
- data[offset+3] = uint8(v >> 24)
- return offset + 4
- }
- func encodeVarintLogEntry(data []byte, offset int, v uint64) int {
- for v >= 1<<7 {
- data[offset] = uint8(v&0x7f | 0x80)
- v >>= 7
- offset++
- }
- data[offset] = uint8(v)
- return offset + 1
- }
- func (this *LogEntry) GoString() string {
- if this == nil {
- return "nil"
- }
- s := strings1.Join([]string{`&protobuf.LogEntry{` + `Index:` + valueToGoStringLogEntry(this.Index, "uint64"), `Term:` + valueToGoStringLogEntry(this.Term, "uint64"), `CommandName:` + valueToGoStringLogEntry(this.CommandName, "string"), `Command:` + valueToGoStringLogEntry(this.Command, "byte"), `XXX_unrecognized:` + fmt1.Sprintf("%#v", this.XXX_unrecognized) + `}`}, ", ")
- return s
- }
- func valueToGoStringLogEntry(v interface{}, typ string) string {
- rv := reflect1.ValueOf(v)
- if rv.IsNil() {
- return "nil"
- }
- pv := reflect1.Indirect(rv).Interface()
- return fmt1.Sprintf("func(v %v) *%v { return &v } ( %#v )", typ, typ, pv)
- }
- func extensionToGoStringLogEntry(e map[int32]code_google_com_p_gogoprotobuf_proto1.Extension) string {
- if e == nil {
- return "nil"
- }
- s := "map[int32]proto.Extension{"
- keys := make([]int, 0, len(e))
- for k := range e {
- keys = append(keys, int(k))
- }
- sort.Ints(keys)
- ss := []string{}
- for _, k := range keys {
- ss = append(ss, strconv.Itoa(k)+": "+e[int32(k)].GoString())
- }
- s += strings1.Join(ss, ",") + "}"
- return s
- }
- func (this *LogEntry) VerboseEqual(that interface{}) error {
- if that == nil {
- if this == nil {
- return nil
- }
- return fmt2.Errorf("that == nil && this != nil")
- }
- that1, ok := that.(*LogEntry)
- if !ok {
- return fmt2.Errorf("that is not of type *LogEntry")
- }
- if that1 == nil {
- if this == nil {
- return nil
- }
- return fmt2.Errorf("that is type *LogEntry but is nil && this != nil")
- } else if this == nil {
- return fmt2.Errorf("that is type *LogEntrybut is not nil && this == nil")
- }
- if this.Index != nil && that1.Index != nil {
- if *this.Index != *that1.Index {
- return fmt2.Errorf("Index this(%v) Not Equal that(%v)", *this.Index, *that1.Index)
- }
- } else if this.Index != nil {
- return fmt2.Errorf("this.Index == nil && that.Index != nil")
- } else if that1.Index != nil {
- return fmt2.Errorf("Index this(%v) Not Equal that(%v)", this.Index, that1.Index)
- }
- if this.Term != nil && that1.Term != nil {
- if *this.Term != *that1.Term {
- return fmt2.Errorf("Term this(%v) Not Equal that(%v)", *this.Term, *that1.Term)
- }
- } else if this.Term != nil {
- return fmt2.Errorf("this.Term == nil && that.Term != nil")
- } else if that1.Term != nil {
- return fmt2.Errorf("Term this(%v) Not Equal that(%v)", this.Term, that1.Term)
- }
- if this.CommandName != nil && that1.CommandName != nil {
- if *this.CommandName != *that1.CommandName {
- return fmt2.Errorf("CommandName this(%v) Not Equal that(%v)", *this.CommandName, *that1.CommandName)
- }
- } else if this.CommandName != nil {
- return fmt2.Errorf("this.CommandName == nil && that.CommandName != nil")
- } else if that1.CommandName != nil {
- return fmt2.Errorf("CommandName this(%v) Not Equal that(%v)", this.CommandName, that1.CommandName)
- }
- if !bytes.Equal(this.Command, that1.Command) {
- return fmt2.Errorf("Command this(%v) Not Equal that(%v)", this.Command, that1.Command)
- }
- if !bytes.Equal(this.XXX_unrecognized, that1.XXX_unrecognized) {
- return fmt2.Errorf("XXX_unrecognized this(%v) Not Equal that(%v)", this.XXX_unrecognized, that1.XXX_unrecognized)
- }
- return nil
- }
- func (this *LogEntry) Equal(that interface{}) bool {
- if that == nil {
- if this == nil {
- return true
- }
- return false
- }
- that1, ok := that.(*LogEntry)
- if !ok {
- return false
- }
- if that1 == nil {
- if this == nil {
- return true
- }
- return false
- } else if this == nil {
- return false
- }
- if this.Index != nil && that1.Index != nil {
- if *this.Index != *that1.Index {
- return false
- }
- } else if this.Index != nil {
- return false
- } else if that1.Index != nil {
- return false
- }
- if this.Term != nil && that1.Term != nil {
- if *this.Term != *that1.Term {
- return false
- }
- } else if this.Term != nil {
- return false
- } else if that1.Term != nil {
- return false
- }
- if this.CommandName != nil && that1.CommandName != nil {
- if *this.CommandName != *that1.CommandName {
- return false
- }
- } else if this.CommandName != nil {
- return false
- } else if that1.CommandName != nil {
- return false
- }
- if !bytes.Equal(this.Command, that1.Command) {
- return false
- }
- if !bytes.Equal(this.XXX_unrecognized, that1.XXX_unrecognized) {
- return false
- }
- return true
- }
|