diff --git a/examples_test.go b/examples_test.go index 330a50f..5f78b38 100644 --- a/examples_test.go +++ b/examples_test.go @@ -21,6 +21,7 @@ import ( "encoding/json" "fmt" "log" + "strings" "time" "github.com/dgraph-io/dgo" @@ -37,7 +38,22 @@ func getDgraphClient() (*dgo.Dgraph, CancelFunc) { } dc := api.NewDgraphClient(conn) - return dgo.NewDgraphClient(dc), func() { + dg := dgo.NewDgraphClient(dc) + ctx := context.Background() + + for { + // keep retrying until we succeed or receive a non-retriable error + err = dg.Login(ctx, "groot", "password") + if err == nil || !strings.Contains(err.Error(), "Please retry") { + break + } + time.Sleep(time.Second) + } + if err != nil { + log.Fatalf("While trying to login %v", err.Error()) + } + + return dg, func() { if err := conn.Close(); err != nil { log.Printf("Error while closing connection:%v", err) } @@ -47,9 +63,7 @@ func getDgraphClient() (*dgo.Dgraph, CancelFunc) { func ExampleDgraph_Alter_dropAll() { dg, cancel := getDgraphClient() defer cancel() - op := api.Operation{ - DropAll: true, - } + op := api.Operation{DropAll: true} ctx := context.Background() if err := dg.Alter(ctx, &op); err != nil { log.Fatal(err) @@ -450,9 +464,7 @@ func ExampleTxn_Mutate_facets() { defer cancel() // Doing a dropAll isn't required by the user. We do it here so that we can verify that the // example runs as expected. - op := api.Operation{ - DropAll: true, - } + op := api.Operation{DropAll: true} ctx := context.Background() if err := dg.Alter(ctx, &op); err != nil { log.Fatal(err) @@ -957,15 +969,13 @@ func ExampleTxn_Mutate_deletePredicate() { log.Fatal(err) } - op = &api.Operation{ - DropAttr: "friend", - } + op = &api.Operation{DropAttr: "friend"} err = dg.Alter(ctx, op) if err != nil { log.Fatal(err) } - op.DropAttr = "married" + op = &api.Operation{DropAttr: "married"} err = dg.Alter(ctx, op) if err != nil { log.Fatal(err) diff --git a/protos/api.proto b/protos/api.proto index 8788622..66108ce 100644 --- a/protos/api.proto +++ b/protos/api.proto @@ -79,11 +79,17 @@ message Mutation { bool ignore_index_conflict = 15; // this field is not parsed and used by the server anymore. } - message Operation { string schema = 1; string drop_attr = 2; bool drop_all = 3; + + enum DropOp { + NONE = 0; + ALL = 1; + DATA = 2; + } + DropOp drop_op = 4; } // Worker services. diff --git a/protos/api/api.pb.go b/protos/api/api.pb.go index 7d509af..db4bf6f 100644 --- a/protos/api/api.pb.go +++ b/protos/api/api.pb.go @@ -3,19 +3,16 @@ package api -import proto "github.com/golang/protobuf/proto" -import fmt "fmt" -import math "math" - import ( - context "golang.org/x/net/context" + context "context" + encoding_binary "encoding/binary" + fmt "fmt" + proto "github.com/golang/protobuf/proto" grpc "google.golang.org/grpc" + io "io" + math "math" ) -import encoding_binary "encoding/binary" - -import io "io" - // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf @@ -27,6 +24,34 @@ var _ = math.Inf // proto package needs to be updated. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package +type Operation_DropOp int32 + +const ( + Operation_NONE Operation_DropOp = 0 + Operation_ALL Operation_DropOp = 1 + Operation_DATA Operation_DropOp = 2 +) + +var Operation_DropOp_name = map[int32]string{ + 0: "NONE", + 1: "ALL", + 2: "DATA", +} + +var Operation_DropOp_value = map[string]int32{ + "NONE": 0, + "ALL": 1, + "DATA": 2, +} + +func (x Operation_DropOp) String() string { + return proto.EnumName(Operation_DropOp_name, int32(x)) +} + +func (Operation_DropOp) EnumDescriptor() ([]byte, []int) { + return fileDescriptor_00212fb1f9d3bf1c, []int{4, 0} +} + type LinRead_Sequencing int32 const ( @@ -38,6 +63,7 @@ var LinRead_Sequencing_name = map[int32]string{ 0: "CLIENT_SIDE", 1: "SERVER_SIDE", } + var LinRead_Sequencing_value = map[string]int32{ "CLIENT_SIDE": 0, "SERVER_SIDE": 1, @@ -46,8 +72,9 @@ var LinRead_Sequencing_value = map[string]int32{ func (x LinRead_Sequencing) String() string { return proto.EnumName(LinRead_Sequencing_name, int32(x)) } + func (LinRead_Sequencing) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{9, 0} + return fileDescriptor_00212fb1f9d3bf1c, []int{9, 0} } type Facet_ValType int32 @@ -67,6 +94,7 @@ var Facet_ValType_name = map[int32]string{ 3: "BOOL", 4: "DATETIME", } + var Facet_ValType_value = map[string]int32{ "STRING": 0, "INT": 1, @@ -78,15 +106,16 @@ var Facet_ValType_value = map[string]int32{ func (x Facet_ValType) String() string { return proto.EnumName(Facet_ValType_name, int32(x)) } + func (Facet_ValType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{13, 0} + return fileDescriptor_00212fb1f9d3bf1c, []int{13, 0} } type Request struct { Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` - Vars map[string]string `protobuf:"bytes,2,rep,name=vars" json:"vars,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + Vars map[string]string `protobuf:"bytes,2,rep,name=vars,proto3" json:"vars,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` StartTs uint64 `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"` - LinRead *LinRead `protobuf:"bytes,14,opt,name=lin_read,json=linRead" json:"lin_read,omitempty"` + LinRead *LinRead `protobuf:"bytes,14,opt,name=lin_read,json=linRead,proto3" json:"lin_read,omitempty"` ReadOnly bool `protobuf:"varint,15,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"` BestEffort bool `protobuf:"varint,16,opt,name=best_effort,json=bestEffort,proto3" json:"best_effort,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` @@ -98,7 +127,7 @@ func (m *Request) Reset() { *m = Request{} } func (m *Request) String() string { return proto.CompactTextString(m) } func (*Request) ProtoMessage() {} func (*Request) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{0} + return fileDescriptor_00212fb1f9d3bf1c, []int{0} } func (m *Request) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -115,8 +144,8 @@ func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Request) XXX_Merge(src proto.Message) { - xxx_messageInfo_Request.Merge(dst, src) +func (m *Request) XXX_Merge(src proto.Message) { + xxx_messageInfo_Request.Merge(m, src) } func (m *Request) XXX_Size() int { return m.Size() @@ -171,9 +200,9 @@ func (m *Request) GetBestEffort() bool { type Response struct { Json []byte `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"` - Schema []*SchemaNode `protobuf:"bytes,2,rep,name=schema" json:"schema,omitempty"` // Deprecated: Do not use. - Txn *TxnContext `protobuf:"bytes,3,opt,name=txn" json:"txn,omitempty"` - Latency *Latency `protobuf:"bytes,12,opt,name=latency" json:"latency,omitempty"` + Schema []*SchemaNode `protobuf:"bytes,2,rep,name=schema,proto3" json:"schema,omitempty"` // Deprecated: Do not use. + Txn *TxnContext `protobuf:"bytes,3,opt,name=txn,proto3" json:"txn,omitempty"` + Latency *Latency `protobuf:"bytes,12,opt,name=latency,proto3" json:"latency,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -183,7 +212,7 @@ func (m *Response) Reset() { *m = Response{} } func (m *Response) String() string { return proto.CompactTextString(m) } func (*Response) ProtoMessage() {} func (*Response) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{1} + return fileDescriptor_00212fb1f9d3bf1c, []int{1} } func (m *Response) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -200,8 +229,8 @@ func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Response) XXX_Merge(src proto.Message) { - xxx_messageInfo_Response.Merge(dst, src) +func (m *Response) XXX_Merge(src proto.Message) { + xxx_messageInfo_Response.Merge(m, src) } func (m *Response) XXX_Size() int { return m.Size() @@ -242,9 +271,9 @@ func (m *Response) GetLatency() *Latency { } type Assigned struct { - Uids map[string]string `protobuf:"bytes,1,rep,name=uids" json:"uids,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` - Context *TxnContext `protobuf:"bytes,2,opt,name=context" json:"context,omitempty"` - Latency *Latency `protobuf:"bytes,12,opt,name=latency" json:"latency,omitempty"` + Uids map[string]string `protobuf:"bytes,1,rep,name=uids,proto3" json:"uids,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` + Context *TxnContext `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"` + Latency *Latency `protobuf:"bytes,12,opt,name=latency,proto3" json:"latency,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -254,7 +283,7 @@ func (m *Assigned) Reset() { *m = Assigned{} } func (m *Assigned) String() string { return proto.CompactTextString(m) } func (*Assigned) ProtoMessage() {} func (*Assigned) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{2} + return fileDescriptor_00212fb1f9d3bf1c, []int{2} } func (m *Assigned) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -271,8 +300,8 @@ func (m *Assigned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Assigned) XXX_Merge(src proto.Message) { - xxx_messageInfo_Assigned.Merge(dst, src) +func (m *Assigned) XXX_Merge(src proto.Message) { + xxx_messageInfo_Assigned.Merge(m, src) } func (m *Assigned) XXX_Size() int { return m.Size() @@ -309,8 +338,8 @@ type Mutation struct { DeleteJson []byte `protobuf:"bytes,2,opt,name=delete_json,json=deleteJson,proto3" json:"delete_json,omitempty"` SetNquads []byte `protobuf:"bytes,3,opt,name=set_nquads,json=setNquads,proto3" json:"set_nquads,omitempty"` DelNquads []byte `protobuf:"bytes,4,opt,name=del_nquads,json=delNquads,proto3" json:"del_nquads,omitempty"` - Set []*NQuad `protobuf:"bytes,10,rep,name=set" json:"set,omitempty"` - Del []*NQuad `protobuf:"bytes,11,rep,name=del" json:"del,omitempty"` + Set []*NQuad `protobuf:"bytes,10,rep,name=set,proto3" json:"set,omitempty"` + Del []*NQuad `protobuf:"bytes,11,rep,name=del,proto3" json:"del,omitempty"` StartTs uint64 `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"` CommitNow bool `protobuf:"varint,14,opt,name=commit_now,json=commitNow,proto3" json:"commit_now,omitempty"` IgnoreIndexConflict bool `protobuf:"varint,15,opt,name=ignore_index_conflict,json=ignoreIndexConflict,proto3" json:"ignore_index_conflict,omitempty"` @@ -323,7 +352,7 @@ func (m *Mutation) Reset() { *m = Mutation{} } func (m *Mutation) String() string { return proto.CompactTextString(m) } func (*Mutation) ProtoMessage() {} func (*Mutation) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{3} + return fileDescriptor_00212fb1f9d3bf1c, []int{3} } func (m *Mutation) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -340,8 +369,8 @@ func (m *Mutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Mutation) XXX_Merge(src proto.Message) { - xxx_messageInfo_Mutation.Merge(dst, src) +func (m *Mutation) XXX_Merge(src proto.Message) { + xxx_messageInfo_Mutation.Merge(m, src) } func (m *Mutation) XXX_Size() int { return m.Size() @@ -416,19 +445,20 @@ func (m *Mutation) GetIgnoreIndexConflict() bool { } type Operation struct { - Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` - DropAttr string `protobuf:"bytes,2,opt,name=drop_attr,json=dropAttr,proto3" json:"drop_attr,omitempty"` - DropAll bool `protobuf:"varint,3,opt,name=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` + DropAttr string `protobuf:"bytes,2,opt,name=drop_attr,json=dropAttr,proto3" json:"drop_attr,omitempty"` + DropAll bool `protobuf:"varint,3,opt,name=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"` + DropOp Operation_DropOp `protobuf:"varint,4,opt,name=drop_op,json=dropOp,proto3,enum=api.Operation_DropOp" json:"drop_op,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } func (m *Operation) Reset() { *m = Operation{} } func (m *Operation) String() string { return proto.CompactTextString(m) } func (*Operation) ProtoMessage() {} func (*Operation) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{4} + return fileDescriptor_00212fb1f9d3bf1c, []int{4} } func (m *Operation) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -445,8 +475,8 @@ func (m *Operation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Operation) XXX_Merge(src proto.Message) { - xxx_messageInfo_Operation.Merge(dst, src) +func (m *Operation) XXX_Merge(src proto.Message) { + xxx_messageInfo_Operation.Merge(m, src) } func (m *Operation) XXX_Size() int { return m.Size() @@ -478,6 +508,13 @@ func (m *Operation) GetDropAll() bool { return false } +func (m *Operation) GetDropOp() Operation_DropOp { + if m != nil { + return m.DropOp + } + return Operation_NONE +} + // Worker services. type Payload struct { Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"` @@ -490,7 +527,7 @@ func (m *Payload) Reset() { *m = Payload{} } func (m *Payload) String() string { return proto.CompactTextString(m) } func (*Payload) ProtoMessage() {} func (*Payload) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{5} + return fileDescriptor_00212fb1f9d3bf1c, []int{5} } func (m *Payload) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -507,8 +544,8 @@ func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Payload) XXX_Merge(src proto.Message) { - xxx_messageInfo_Payload.Merge(dst, src) +func (m *Payload) XXX_Merge(src proto.Message) { + xxx_messageInfo_Payload.Merge(m, src) } func (m *Payload) XXX_Size() int { return m.Size() @@ -530,9 +567,9 @@ type TxnContext struct { StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"` CommitTs uint64 `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"` Aborted bool `protobuf:"varint,3,opt,name=aborted,proto3" json:"aborted,omitempty"` - Keys []string `protobuf:"bytes,4,rep,name=keys" json:"keys,omitempty"` - Preds []string `protobuf:"bytes,5,rep,name=preds" json:"preds,omitempty"` - LinRead *LinRead `protobuf:"bytes,13,opt,name=lin_read,json=linRead" json:"lin_read,omitempty"` + Keys []string `protobuf:"bytes,4,rep,name=keys,proto3" json:"keys,omitempty"` + Preds []string `protobuf:"bytes,5,rep,name=preds,proto3" json:"preds,omitempty"` + LinRead *LinRead `protobuf:"bytes,13,opt,name=lin_read,json=linRead,proto3" json:"lin_read,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -542,7 +579,7 @@ func (m *TxnContext) Reset() { *m = TxnContext{} } func (m *TxnContext) String() string { return proto.CompactTextString(m) } func (*TxnContext) ProtoMessage() {} func (*TxnContext) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{6} + return fileDescriptor_00212fb1f9d3bf1c, []int{6} } func (m *TxnContext) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -559,8 +596,8 @@ func (m *TxnContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *TxnContext) XXX_Merge(src proto.Message) { - xxx_messageInfo_TxnContext.Merge(dst, src) +func (m *TxnContext) XXX_Merge(src proto.Message) { + xxx_messageInfo_TxnContext.Merge(m, src) } func (m *TxnContext) XXX_Size() int { return m.Size() @@ -623,7 +660,7 @@ func (m *Check) Reset() { *m = Check{} } func (m *Check) String() string { return proto.CompactTextString(m) } func (*Check) ProtoMessage() {} func (*Check) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{7} + return fileDescriptor_00212fb1f9d3bf1c, []int{7} } func (m *Check) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -640,8 +677,8 @@ func (m *Check) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Check) XXX_Merge(src proto.Message) { - xxx_messageInfo_Check.Merge(dst, src) +func (m *Check) XXX_Merge(src proto.Message) { + xxx_messageInfo_Check.Merge(m, src) } func (m *Check) XXX_Size() int { return m.Size() @@ -663,7 +700,7 @@ func (m *Version) Reset() { *m = Version{} } func (m *Version) String() string { return proto.CompactTextString(m) } func (*Version) ProtoMessage() {} func (*Version) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{8} + return fileDescriptor_00212fb1f9d3bf1c, []int{8} } func (m *Version) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -680,8 +717,8 @@ func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Version) XXX_Merge(src proto.Message) { - xxx_messageInfo_Version.Merge(dst, src) +func (m *Version) XXX_Merge(src proto.Message) { + xxx_messageInfo_Version.Merge(m, src) } func (m *Version) XXX_Size() int { return m.Size() @@ -700,7 +737,7 @@ func (m *Version) GetTag() string { } type LinRead struct { - Ids map[uint32]uint64 `protobuf:"bytes,1,rep,name=ids" json:"ids,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` + Ids map[uint32]uint64 `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` Sequencing LinRead_Sequencing `protobuf:"varint,2,opt,name=sequencing,proto3,enum=api.LinRead_Sequencing" json:"sequencing,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -711,7 +748,7 @@ func (m *LinRead) Reset() { *m = LinRead{} } func (m *LinRead) String() string { return proto.CompactTextString(m) } func (*LinRead) ProtoMessage() {} func (*LinRead) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{9} + return fileDescriptor_00212fb1f9d3bf1c, []int{9} } func (m *LinRead) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -728,8 +765,8 @@ func (m *LinRead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *LinRead) XXX_Merge(src proto.Message) { - xxx_messageInfo_LinRead.Merge(dst, src) +func (m *LinRead) XXX_Merge(src proto.Message) { + xxx_messageInfo_LinRead.Merge(m, src) } func (m *LinRead) XXX_Size() int { return m.Size() @@ -767,7 +804,7 @@ func (m *Latency) Reset() { *m = Latency{} } func (m *Latency) String() string { return proto.CompactTextString(m) } func (*Latency) ProtoMessage() {} func (*Latency) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{10} + return fileDescriptor_00212fb1f9d3bf1c, []int{10} } func (m *Latency) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -784,8 +821,8 @@ func (m *Latency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Latency) XXX_Merge(src proto.Message) { - xxx_messageInfo_Latency.Merge(dst, src) +func (m *Latency) XXX_Merge(src proto.Message) { + xxx_messageInfo_Latency.Merge(m, src) } func (m *Latency) XXX_Size() int { return m.Size() @@ -821,10 +858,10 @@ type NQuad struct { Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"` Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"` ObjectId string `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"` - ObjectValue *Value `protobuf:"bytes,4,opt,name=object_value,json=objectValue" json:"object_value,omitempty"` + ObjectValue *Value `protobuf:"bytes,4,opt,name=object_value,json=objectValue,proto3" json:"object_value,omitempty"` Label string `protobuf:"bytes,5,opt,name=label,proto3" json:"label,omitempty"` Lang string `protobuf:"bytes,6,opt,name=lang,proto3" json:"lang,omitempty"` - Facets []*Facet `protobuf:"bytes,7,rep,name=facets" json:"facets,omitempty"` + Facets []*Facet `protobuf:"bytes,7,rep,name=facets,proto3" json:"facets,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -834,7 +871,7 @@ func (m *NQuad) Reset() { *m = NQuad{} } func (m *NQuad) String() string { return proto.CompactTextString(m) } func (*NQuad) ProtoMessage() {} func (*NQuad) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{11} + return fileDescriptor_00212fb1f9d3bf1c, []int{11} } func (m *NQuad) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -851,8 +888,8 @@ func (m *NQuad) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *NQuad) XXX_Merge(src proto.Message) { - xxx_messageInfo_NQuad.Merge(dst, src) +func (m *NQuad) XXX_Merge(src proto.Message) { + xxx_messageInfo_NQuad.Merge(m, src) } func (m *NQuad) XXX_Size() int { return m.Size() @@ -935,7 +972,7 @@ func (m *Value) Reset() { *m = Value{} } func (m *Value) String() string { return proto.CompactTextString(m) } func (*Value) ProtoMessage() {} func (*Value) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{12} + return fileDescriptor_00212fb1f9d3bf1c, []int{12} } func (m *Value) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -952,8 +989,8 @@ func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Value) XXX_Merge(src proto.Message) { - xxx_messageInfo_Value.Merge(dst, src) +func (m *Value) XXX_Merge(src proto.Message) { + xxx_messageInfo_Value.Merge(m, src) } func (m *Value) XXX_Size() int { return m.Size() @@ -1305,7 +1342,7 @@ type Facet struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` ValType Facet_ValType `protobuf:"varint,3,opt,name=val_type,json=valType,proto3,enum=api.Facet_ValType" json:"val_type,omitempty"` - Tokens []string `protobuf:"bytes,4,rep,name=tokens" json:"tokens,omitempty"` + Tokens []string `protobuf:"bytes,4,rep,name=tokens,proto3" json:"tokens,omitempty"` Alias string `protobuf:"bytes,5,opt,name=alias,proto3" json:"alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` @@ -1316,7 +1353,7 @@ func (m *Facet) Reset() { *m = Facet{} } func (m *Facet) String() string { return proto.CompactTextString(m) } func (*Facet) ProtoMessage() {} func (*Facet) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{13} + return fileDescriptor_00212fb1f9d3bf1c, []int{13} } func (m *Facet) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1333,8 +1370,8 @@ func (m *Facet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Facet) XXX_Merge(src proto.Message) { - xxx_messageInfo_Facet.Merge(dst, src) +func (m *Facet) XXX_Merge(src proto.Message) { + xxx_messageInfo_Facet.Merge(m, src) } func (m *Facet) XXX_Size() int { return m.Size() @@ -1384,7 +1421,7 @@ type SchemaNode struct { Predicate string `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Index bool `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` - Tokenizer []string `protobuf:"bytes,4,rep,name=tokenizer" json:"tokenizer,omitempty"` + Tokenizer []string `protobuf:"bytes,4,rep,name=tokenizer,proto3" json:"tokenizer,omitempty"` Reverse bool `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"` Count bool `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"` List bool `protobuf:"varint,7,opt,name=list,proto3" json:"list,omitempty"` @@ -1399,7 +1436,7 @@ func (m *SchemaNode) Reset() { *m = SchemaNode{} } func (m *SchemaNode) String() string { return proto.CompactTextString(m) } func (*SchemaNode) ProtoMessage() {} func (*SchemaNode) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{14} + return fileDescriptor_00212fb1f9d3bf1c, []int{14} } func (m *SchemaNode) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1416,8 +1453,8 @@ func (m *SchemaNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *SchemaNode) XXX_Merge(src proto.Message) { - xxx_messageInfo_SchemaNode.Merge(dst, src) +func (m *SchemaNode) XXX_Merge(src proto.Message) { + xxx_messageInfo_SchemaNode.Merge(m, src) } func (m *SchemaNode) XXX_Size() int { return m.Size() @@ -1504,7 +1541,7 @@ func (m *LoginRequest) Reset() { *m = LoginRequest{} } func (m *LoginRequest) String() string { return proto.CompactTextString(m) } func (*LoginRequest) ProtoMessage() {} func (*LoginRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{15} + return fileDescriptor_00212fb1f9d3bf1c, []int{15} } func (m *LoginRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1521,8 +1558,8 @@ func (m *LoginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) return b[:n], nil } } -func (dst *LoginRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_LoginRequest.Merge(dst, src) +func (m *LoginRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_LoginRequest.Merge(m, src) } func (m *LoginRequest) XXX_Size() int { return m.Size() @@ -1566,7 +1603,7 @@ func (m *Jwt) Reset() { *m = Jwt{} } func (m *Jwt) String() string { return proto.CompactTextString(m) } func (*Jwt) ProtoMessage() {} func (*Jwt) Descriptor() ([]byte, []int) { - return fileDescriptor_api_716cfbe908c1685c, []int{16} + return fileDescriptor_00212fb1f9d3bf1c, []int{16} } func (m *Jwt) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1583,8 +1620,8 @@ func (m *Jwt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return b[:n], nil } } -func (dst *Jwt) XXX_Merge(src proto.Message) { - xxx_messageInfo_Jwt.Merge(dst, src) +func (m *Jwt) XXX_Merge(src proto.Message) { + xxx_messageInfo_Jwt.Merge(m, src) } func (m *Jwt) XXX_Size() int { return m.Size() @@ -1610,6 +1647,9 @@ func (m *Jwt) GetRefreshJwt() string { } func init() { + proto.RegisterEnum("api.Operation_DropOp", Operation_DropOp_name, Operation_DropOp_value) + proto.RegisterEnum("api.LinRead_Sequencing", LinRead_Sequencing_name, LinRead_Sequencing_value) + proto.RegisterEnum("api.Facet_ValType", Facet_ValType_name, Facet_ValType_value) proto.RegisterType((*Request)(nil), "api.Request") proto.RegisterMapType((map[string]string)(nil), "api.Request.VarsEntry") proto.RegisterType((*Response)(nil), "api.Response") @@ -1630,8 +1670,111 @@ func init() { proto.RegisterType((*SchemaNode)(nil), "api.SchemaNode") proto.RegisterType((*LoginRequest)(nil), "api.LoginRequest") proto.RegisterType((*Jwt)(nil), "api.Jwt") - proto.RegisterEnum("api.LinRead_Sequencing", LinRead_Sequencing_name, LinRead_Sequencing_value) - proto.RegisterEnum("api.Facet_ValType", Facet_ValType_name, Facet_ValType_value) +} + +func init() { proto.RegisterFile("api.proto", fileDescriptor_00212fb1f9d3bf1c) } + +var fileDescriptor_00212fb1f9d3bf1c = []byte{ + // 1569 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x57, 0xcd, 0x72, 0x24, 0x39, + 0x11, 0xee, 0xea, 0xbf, 0xaa, 0xca, 0x6e, 0x7b, 0x1a, 0xc1, 0x2c, 0xb5, 0xf6, 0xce, 0x8c, 0xb7, + 0x36, 0xd8, 0x31, 0x3b, 0xb1, 0x7d, 0xf0, 0x46, 0xb0, 0x04, 0xb7, 0xb6, 0xdd, 0x8b, 0x7b, 0xc2, + 0xdb, 0xde, 0x95, 0x1b, 0x5f, 0x3b, 0xe4, 0x2e, 0xb9, 0xa7, 0x66, 0x6a, 0x4a, 0x35, 0x92, 0xda, + 0x9e, 0xe6, 0x01, 0xb8, 0x73, 0x21, 0x78, 0x0a, 0x22, 0xe0, 0x15, 0xb8, 0x70, 0x83, 0x08, 0x4e, + 0xdc, 0xc0, 0xbc, 0x08, 0x91, 0x29, 0x95, 0x7f, 0x66, 0x27, 0x16, 0x38, 0x95, 0xf2, 0xfb, 0x52, + 0x52, 0x66, 0x2a, 0x33, 0xa5, 0x82, 0x58, 0x54, 0xf9, 0xb0, 0xd2, 0xca, 0x2a, 0xd6, 0x12, 0x55, + 0x9e, 0xfe, 0xa6, 0x09, 0x21, 0x97, 0x6f, 0x56, 0xd2, 0x58, 0xf6, 0x23, 0xe8, 0xbc, 0x59, 0x49, + 0xbd, 0x4e, 0x82, 0x9d, 0x60, 0x37, 0xe6, 0x4e, 0x60, 0x9f, 0x41, 0xfb, 0x52, 0x68, 0x93, 0x34, + 0x77, 0x5a, 0xbb, 0xbd, 0xbd, 0x0f, 0x86, 0xb8, 0x80, 0x9f, 0x31, 0x3c, 0x13, 0xda, 0x8c, 0x4b, + 0xab, 0xd7, 0x9c, 0x74, 0xd8, 0x87, 0x10, 0x19, 0x2b, 0xb4, 0x9d, 0x5b, 0x93, 0x6c, 0xec, 0x04, + 0xbb, 0x6d, 0x1e, 0x92, 0x3c, 0x33, 0xec, 0x29, 0x44, 0x45, 0x5e, 0xce, 0xb5, 0x14, 0x59, 0xb2, + 0xb9, 0x13, 0xec, 0xf6, 0xf6, 0xfa, 0xb4, 0xd4, 0x71, 0x5e, 0x72, 0x29, 0x32, 0x1e, 0x16, 0x6e, + 0xc0, 0xb6, 0x21, 0x46, 0xa5, 0xb9, 0x2a, 0x8b, 0x75, 0xf2, 0x60, 0x27, 0xd8, 0x8d, 0x78, 0x84, + 0xc0, 0x49, 0x59, 0xac, 0xd9, 0x13, 0xe8, 0x9d, 0x4b, 0x63, 0xe7, 0xf2, 0xe2, 0x42, 0x69, 0x9b, + 0x0c, 0x88, 0x06, 0x84, 0xc6, 0x84, 0x6c, 0x7d, 0x09, 0xf1, 0x8d, 0x51, 0x6c, 0x00, 0xad, 0x57, + 0xb2, 0x76, 0x07, 0x87, 0xe8, 0xe2, 0xa5, 0x28, 0x56, 0x32, 0x69, 0x3a, 0x17, 0x49, 0xf8, 0x45, + 0xf3, 0xe7, 0x41, 0xfa, 0xbb, 0x00, 0x22, 0x2e, 0x4d, 0xa5, 0x4a, 0x23, 0x19, 0x83, 0xf6, 0x4b, + 0xa3, 0x4a, 0x9a, 0xd9, 0xe7, 0x34, 0x66, 0xcf, 0xa0, 0x6b, 0x16, 0x2f, 0xe4, 0x6b, 0xe1, 0x23, + 0xf1, 0x80, 0xcc, 0x3f, 0x25, 0x68, 0xaa, 0x32, 0xb9, 0xdf, 0x4c, 0x02, 0xee, 0x55, 0xd8, 0xc7, + 0xd0, 0xb2, 0x6f, 0xcb, 0xa4, 0x45, 0x8e, 0x3a, 0xcd, 0xd9, 0xdb, 0xf2, 0x40, 0x95, 0x56, 0xbe, + 0xb5, 0x1c, 0x39, 0xf6, 0x29, 0x84, 0x85, 0xb0, 0xb2, 0x5c, 0xac, 0x93, 0xfe, 0xdd, 0x78, 0x38, + 0x8c, 0xd7, 0x64, 0xfa, 0xe7, 0x00, 0xa2, 0x91, 0x31, 0xf9, 0xb2, 0x94, 0x19, 0x7b, 0x06, 0xed, + 0x55, 0x9e, 0x99, 0x24, 0x20, 0x13, 0x7e, 0x4c, 0x33, 0x6a, 0x72, 0xf8, 0xab, 0x3c, 0xab, 0x4f, + 0x03, 0x95, 0xd8, 0x4f, 0x21, 0x5c, 0xb8, 0x1d, 0xc9, 0xdd, 0xf7, 0x18, 0x52, 0xf3, 0xff, 0xab, + 0x31, 0x18, 0xde, 0x9b, 0x5d, 0xfe, 0xaf, 0xf0, 0xfe, 0xa1, 0x09, 0xd1, 0xd7, 0x2b, 0x2b, 0x6c, + 0xae, 0x4a, 0x4a, 0x13, 0x69, 0xe7, 0x77, 0x42, 0x1c, 0x1a, 0x69, 0x9f, 0x63, 0x94, 0x9f, 0x40, + 0x2f, 0x93, 0x85, 0xb4, 0xd2, 0xb1, 0x4d, 0x62, 0xc1, 0x41, 0xa4, 0xf0, 0x08, 0x00, 0xe7, 0x96, + 0x6f, 0x56, 0x22, 0x33, 0x14, 0xe0, 0x3e, 0x8f, 0x8d, 0xb4, 0x53, 0x02, 0x90, 0xce, 0x64, 0x51, + 0xd3, 0x6d, 0x47, 0x67, 0xb2, 0xf0, 0xf4, 0x47, 0xd0, 0x32, 0xd2, 0x26, 0x40, 0xe1, 0x03, 0xf2, + 0x71, 0xfa, 0xed, 0x4a, 0x64, 0x1c, 0x61, 0x64, 0x33, 0x59, 0x24, 0xbd, 0xef, 0xb2, 0x99, 0x2c, + 0xbe, 0x2f, 0xb9, 0x1f, 0x01, 0x2c, 0xd4, 0xeb, 0xd7, 0xb9, 0x9d, 0x97, 0xea, 0x8a, 0xd2, 0x3b, + 0xe2, 0xb1, 0x43, 0xa6, 0xea, 0x8a, 0xed, 0xc1, 0xc3, 0x7c, 0x59, 0x2a, 0x2d, 0xe7, 0x79, 0x99, + 0xc9, 0xb7, 0xf3, 0x85, 0x2a, 0x2f, 0x8a, 0x7c, 0x61, 0x7d, 0x7a, 0xff, 0xd0, 0x91, 0x13, 0xe4, + 0x0e, 0x3c, 0x95, 0xfe, 0x29, 0x80, 0xf8, 0xa4, 0x92, 0xda, 0x45, 0xec, 0x83, 0x9b, 0xe4, 0x73, + 0xd1, 0xae, 0xf3, 0x6c, 0x1b, 0xe2, 0x4c, 0xab, 0x6a, 0x2e, 0xac, 0xd5, 0x3e, 0xe8, 0x11, 0x02, + 0x23, 0x6b, 0x35, 0x1a, 0xec, 0xc8, 0xa2, 0xa0, 0x40, 0x45, 0x3c, 0x24, 0xae, 0x28, 0xd8, 0x10, + 0x68, 0x38, 0x57, 0x15, 0xc5, 0x68, 0x73, 0xef, 0x21, 0x79, 0x7b, 0xb3, 0xe1, 0xf0, 0x50, 0xab, + 0xea, 0xa4, 0xe2, 0xdd, 0x8c, 0xbe, 0xe9, 0x4f, 0xa0, 0xeb, 0x10, 0x16, 0x41, 0x7b, 0x7a, 0x32, + 0x1d, 0x0f, 0x1a, 0x2c, 0x84, 0xd6, 0xe8, 0xf8, 0x78, 0x10, 0x20, 0x74, 0x38, 0x9a, 0x8d, 0x06, + 0xcd, 0xf4, 0x11, 0x84, 0xdf, 0x88, 0x75, 0xa1, 0x44, 0x86, 0x25, 0x74, 0x28, 0xac, 0xa8, 0x4b, + 0x08, 0xc7, 0xe9, 0x1f, 0x03, 0x80, 0xdb, 0xec, 0xbb, 0x17, 0xd0, 0xe0, 0x7e, 0x40, 0xb7, 0xc1, + 0x87, 0x0f, 0xb9, 0x26, 0x71, 0x91, 0x03, 0x66, 0x86, 0x25, 0x10, 0x8a, 0x73, 0xa5, 0xad, 0xcc, + 0x6a, 0xb7, 0xbc, 0x88, 0x9b, 0xbe, 0x92, 0x6b, 0x3c, 0xf7, 0xd6, 0x6e, 0xcc, 0x69, 0x8c, 0x39, + 0x59, 0x69, 0x99, 0x99, 0xa4, 0x43, 0xa0, 0x13, 0xee, 0xb5, 0xa3, 0x8d, 0xef, 0x69, 0x47, 0x69, + 0x08, 0x9d, 0x83, 0x17, 0x72, 0xf1, 0x2a, 0xdd, 0x86, 0xf0, 0x4c, 0x6a, 0x83, 0xa7, 0x31, 0x80, + 0x96, 0x15, 0xcb, 0x3a, 0xf1, 0xad, 0x58, 0xa6, 0x7f, 0x0f, 0x20, 0xf4, 0x53, 0xd9, 0x53, 0x68, + 0xdd, 0x96, 0xe8, 0xc3, 0xbb, 0xab, 0x0e, 0x27, 0x75, 0x81, 0xa2, 0x06, 0xfb, 0x12, 0x53, 0xf9, + 0xcd, 0x4a, 0x96, 0x8b, 0xbc, 0x5c, 0x92, 0x97, 0x9b, 0xbe, 0xa4, 0x6b, 0xfd, 0xd3, 0x1b, 0x9a, + 0xdf, 0x51, 0xdd, 0xfa, 0x19, 0x44, 0x93, 0xf7, 0x14, 0xe1, 0xc6, 0x7b, 0x8a, 0xb0, 0x7d, 0xb7, + 0x08, 0x87, 0x00, 0xb7, 0x2b, 0xb2, 0x07, 0xd0, 0x3b, 0x38, 0x9e, 0x8c, 0xa7, 0xb3, 0xf9, 0xe9, + 0xe4, 0x10, 0x0f, 0xf4, 0x01, 0xf4, 0x4e, 0xc7, 0xfc, 0x6c, 0xcc, 0x1d, 0x10, 0xa4, 0x25, 0x84, + 0xbe, 0x03, 0x60, 0x86, 0x57, 0x42, 0x9b, 0xbc, 0x5c, 0xce, 0xcb, 0xfa, 0xb4, 0x62, 0x8f, 0x4c, + 0x0d, 0xfb, 0x04, 0x36, 0x2a, 0xad, 0x16, 0xd2, 0xd4, 0x1a, 0x6e, 0xef, 0xfe, 0x2d, 0x38, 0x35, + 0x58, 0xdb, 0xb2, 0x5c, 0xa8, 0xcc, 0xab, 0xb4, 0x48, 0x05, 0x6a, 0x68, 0x6a, 0xd2, 0x7f, 0x04, + 0xd0, 0xa1, 0x82, 0xc3, 0x23, 0x36, 0xab, 0xf3, 0x97, 0x72, 0x61, 0x7d, 0x94, 0x6b, 0x91, 0x7d, + 0x04, 0x31, 0x9e, 0x60, 0xbe, 0x10, 0xb6, 0x6e, 0x33, 0xb7, 0x00, 0xe6, 0x8d, 0x22, 0xbd, 0x79, + 0xee, 0x92, 0x23, 0xe6, 0x91, 0x03, 0x26, 0x19, 0xfb, 0x1c, 0xfa, 0x9e, 0x74, 0xf1, 0x69, 0xd3, + 0xb9, 0xbb, 0x3a, 0x3f, 0x43, 0x84, 0xf7, 0x1c, 0x4f, 0x02, 0xc6, 0xb1, 0x10, 0xe7, 0xb2, 0x48, + 0x3a, 0xae, 0x99, 0x91, 0x80, 0x29, 0x56, 0x88, 0x72, 0x99, 0x74, 0x09, 0xa4, 0x31, 0x4b, 0xa1, + 0x7b, 0x21, 0x16, 0xd2, 0x9a, 0x24, 0xbc, 0xd3, 0x3a, 0xbe, 0x42, 0x88, 0x7b, 0x26, 0xfd, 0x57, + 0x13, 0x3a, 0x6e, 0xdd, 0x8f, 0xb1, 0xc5, 0x5d, 0x88, 0x55, 0x41, 0x76, 0x38, 0xff, 0x8e, 0x1a, + 0xd8, 0xe4, 0x08, 0x3c, 0x13, 0x05, 0x7b, 0x04, 0xf1, 0xf9, 0xda, 0x4a, 0x43, 0x0a, 0xd4, 0x03, + 0x8f, 0x1a, 0x3c, 0x22, 0x08, 0xe9, 0x0f, 0x21, 0xcc, 0x4b, 0x37, 0x1b, 0x7d, 0x6c, 0x1d, 0x35, + 0x78, 0x37, 0x2f, 0x69, 0xe6, 0x36, 0x44, 0xe7, 0x4a, 0x15, 0xc4, 0xa1, 0x7f, 0xd1, 0x51, 0x83, + 0x87, 0x88, 0xf8, 0x79, 0xc6, 0x6a, 0xe2, 0x3a, 0x7e, 0xd7, 0xae, 0xb1, 0x1a, 0xa9, 0x27, 0x00, + 0x99, 0x5a, 0x9d, 0x17, 0x92, 0x58, 0x74, 0x2e, 0x38, 0x6a, 0xf0, 0xd8, 0x61, 0x7e, 0xee, 0x52, + 0x2a, 0x62, 0x43, 0x6f, 0x50, 0x77, 0x29, 0x95, 0xdf, 0x33, 0x13, 0xd6, 0xcd, 0x8c, 0x3c, 0x17, + 0x22, 0x82, 0xe4, 0x27, 0xd0, 0xc7, 0xa1, 0xcd, 0x5f, 0x3b, 0x85, 0xd8, 0x2b, 0xf4, 0x6a, 0xd4, + 0x2b, 0x55, 0xc2, 0x98, 0x2b, 0xa5, 0x33, 0x52, 0x02, 0x6f, 0x5d, 0xaf, 0x46, 0xbd, 0x05, 0xab, + 0xdc, 0xf1, 0x3d, 0x4c, 0x1d, 0xb4, 0x60, 0x95, 0x23, 0xb5, 0xdf, 0x81, 0xd6, 0xa5, 0x28, 0xd2, + 0xbf, 0x06, 0xd0, 0xa1, 0xa8, 0xff, 0xb7, 0xab, 0xa9, 0xef, 0xab, 0x82, 0x7d, 0x0e, 0xd1, 0xa5, + 0x28, 0xe6, 0x76, 0x5d, 0x49, 0x0a, 0xe5, 0xe6, 0x1e, 0xbb, 0x3d, 0x3b, 0x4c, 0x8a, 0xd9, 0xba, + 0x92, 0x3c, 0xbc, 0x74, 0x03, 0x6c, 0xc3, 0x56, 0xbd, 0x92, 0x65, 0xdd, 0x61, 0xbc, 0x84, 0x8b, + 0x8b, 0x22, 0x17, 0xa6, 0x4e, 0x15, 0x12, 0xd2, 0x11, 0x84, 0x7e, 0x05, 0x06, 0xd0, 0x3d, 0x9d, + 0xf1, 0xc9, 0xf4, 0x97, 0xae, 0x6f, 0x4e, 0xa6, 0xb3, 0x41, 0xc0, 0x62, 0xe8, 0x7c, 0x75, 0x7c, + 0x32, 0x9a, 0x0d, 0x9a, 0xd8, 0x42, 0xf7, 0x4f, 0x4e, 0x8e, 0x07, 0x2d, 0xd6, 0x87, 0xe8, 0x70, + 0x34, 0x1b, 0xcf, 0x26, 0x5f, 0x8f, 0x07, 0xed, 0xf4, 0x3a, 0x00, 0xb8, 0x7d, 0x62, 0xdc, 0x4f, + 0xfe, 0xe0, 0xdd, 0xe4, 0x67, 0xd0, 0x26, 0x47, 0x5c, 0x55, 0xd0, 0x18, 0x2d, 0xa3, 0x3b, 0xc7, + 0x77, 0x4a, 0x27, 0xe0, 0x3a, 0x64, 0x79, 0xfe, 0x6b, 0xa9, 0xbd, 0x2b, 0xb7, 0x00, 0x16, 0x9f, + 0x96, 0x97, 0x52, 0x1b, 0x49, 0xfe, 0x44, 0xbc, 0x16, 0x71, 0xb5, 0x85, 0x5a, 0x95, 0x96, 0x12, + 0x24, 0xe2, 0x4e, 0xa0, 0x92, 0xc8, 0x8d, 0xa5, 0xbc, 0x88, 0x38, 0x8d, 0x31, 0x52, 0xab, 0xca, + 0x48, 0x6d, 0x29, 0x23, 0x22, 0xee, 0xa5, 0x9b, 0xf2, 0x89, 0xbd, 0xae, 0x28, 0x97, 0xe9, 0x12, + 0xfa, 0xc7, 0x6a, 0x89, 0x2d, 0xcf, 0xbd, 0x43, 0x71, 0xae, 0x91, 0x3a, 0xcf, 0xea, 0xcb, 0xce, + 0x49, 0x6c, 0x0b, 0xa2, 0x3a, 0x1f, 0xea, 0xbb, 0xae, 0x96, 0xb1, 0x01, 0x69, 0x79, 0xa1, 0xa5, + 0x79, 0x31, 0x27, 0x47, 0x7c, 0xf1, 0xf7, 0x3d, 0x38, 0x43, 0x2c, 0x1d, 0x43, 0xeb, 0xf9, 0x95, + 0xc5, 0x5e, 0x26, 0x16, 0xd8, 0x96, 0xe6, 0x2f, 0xaf, 0xea, 0xfe, 0x12, 0x3b, 0x04, 0xe9, 0x27, + 0xd0, 0xab, 0x97, 0x42, 0xde, 0xed, 0x04, 0x1e, 0x7a, 0x7e, 0x65, 0xf7, 0x7e, 0xdb, 0x84, 0xee, + 0xe1, 0x52, 0x8b, 0xea, 0x05, 0x7b, 0x06, 0x1d, 0x32, 0x9d, 0xfd, 0xc0, 0xf5, 0xed, 0x3b, 0x6e, + 0x6c, 0x6d, 0xf8, 0xa7, 0xb2, 0x7b, 0x53, 0xa6, 0x0d, 0xf6, 0x29, 0x74, 0xbe, 0xa5, 0x27, 0x75, + 0xff, 0xee, 0x23, 0xfa, 0xbb, 0x7a, 0xbb, 0xd0, 0xa5, 0xa7, 0x92, 0x64, 0x8e, 0xaa, 0xdf, 0x4d, + 0x5e, 0xb3, 0x7e, 0xef, 0xa5, 0x0d, 0xf6, 0x14, 0x3a, 0xa3, 0xc2, 0x4a, 0xcd, 0x36, 0xef, 0x5f, + 0xdf, 0x5b, 0x6e, 0x07, 0x7f, 0x17, 0xa7, 0x0d, 0xf6, 0x05, 0x6c, 0x1c, 0xd0, 0xf5, 0x79, 0xa2, + 0x47, 0x78, 0x57, 0xb2, 0x77, 0x9f, 0x82, 0x5b, 0xef, 0x02, 0x69, 0x83, 0x7d, 0x06, 0x7d, 0xba, + 0xfa, 0xea, 0x6b, 0xcf, 0xb5, 0x35, 0x82, 0xfc, 0x06, 0x9e, 0x49, 0x1b, 0xfb, 0xbb, 0x7f, 0xb9, + 0x7e, 0x1c, 0xfc, 0xed, 0xfa, 0x71, 0xf0, 0xcf, 0xeb, 0xc7, 0xc1, 0xef, 0xff, 0xfd, 0xb8, 0x01, + 0x71, 0xae, 0x86, 0x19, 0x45, 0x69, 0xbf, 0xe7, 0xa2, 0xf5, 0x0d, 0xfe, 0x76, 0x9c, 0x77, 0xe9, + 0xef, 0xe3, 0x8b, 0xff, 0x04, 0x00, 0x00, 0xff, 0xff, 0x90, 0x9f, 0x82, 0xc2, 0x8a, 0x0c, 0x00, + 0x00, } // Reference imports to suppress errors if they are not otherwise used. @@ -1918,9 +2061,9 @@ func (m *Request) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x72 i++ i = encodeVarintApi(dAtA, i, uint64(m.LinRead.Size())) - n1, err := m.LinRead.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + n1, err1 := m.LinRead.MarshalTo(dAtA[i:]) + if err1 != nil { + return 0, err1 } i += n1 } @@ -1989,9 +2132,9 @@ func (m *Response) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x1a i++ i = encodeVarintApi(dAtA, i, uint64(m.Txn.Size())) - n2, err := m.Txn.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + n2, err2 := m.Txn.MarshalTo(dAtA[i:]) + if err2 != nil { + return 0, err2 } i += n2 } @@ -1999,9 +2142,9 @@ func (m *Response) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x62 i++ i = encodeVarintApi(dAtA, i, uint64(m.Latency.Size())) - n3, err := m.Latency.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + n3, err3 := m.Latency.MarshalTo(dAtA[i:]) + if err3 != nil { + return 0, err3 } i += n3 } @@ -2047,9 +2190,9 @@ func (m *Assigned) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x12 i++ i = encodeVarintApi(dAtA, i, uint64(m.Context.Size())) - n4, err := m.Context.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + n4, err4 := m.Context.MarshalTo(dAtA[i:]) + if err4 != nil { + return 0, err4 } i += n4 } @@ -2057,9 +2200,9 @@ func (m *Assigned) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x62 i++ i = encodeVarintApi(dAtA, i, uint64(m.Latency.Size())) - n5, err := m.Latency.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + n5, err5 := m.Latency.MarshalTo(dAtA[i:]) + if err5 != nil { + return 0, err5 } i += n5 } @@ -2200,6 +2343,11 @@ func (m *Operation) MarshalTo(dAtA []byte) (int, error) { } i++ } + if m.DropOp != 0 { + dAtA[i] = 0x20 + i++ + i = encodeVarintApi(dAtA, i, uint64(m.DropOp)) + } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -2302,9 +2450,9 @@ func (m *TxnContext) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x6a i++ i = encodeVarintApi(dAtA, i, uint64(m.LinRead.Size())) - n6, err := m.LinRead.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + n6, err6 := m.LinRead.MarshalTo(dAtA[i:]) + if err6 != nil { + return 0, err6 } i += n6 } @@ -2476,9 +2624,9 @@ func (m *NQuad) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x22 i++ i = encodeVarintApi(dAtA, i, uint64(m.ObjectValue.Size())) - n7, err := m.ObjectValue.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + n7, err7 := m.ObjectValue.MarshalTo(dAtA[i:]) + if err7 != nil { + return 0, err7 } i += n7 } @@ -2528,9 +2676,9 @@ func (m *Value) MarshalTo(dAtA []byte) (int, error) { var l int _ = l if m.Val != nil { - nn8, err := m.Val.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + nn8, err8 := m.Val.MarshalTo(dAtA[i:]) + if err8 != nil { + return 0, err8 } i += nn8 } @@ -3047,6 +3195,9 @@ func (m *Operation) Size() (n int) { if m.DropAll { n += 2 } + if m.DropOp != 0 { + n += 1 + sovApi(uint64(m.DropOp)) + } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -3498,7 +3649,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3526,7 +3677,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3536,6 +3687,9 @@ func (m *Request) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -3555,7 +3709,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3564,6 +3718,9 @@ func (m *Request) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -3584,7 +3741,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3601,7 +3758,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLenmapkey |= (uint64(b) & 0x7F) << shift + stringLenmapkey |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3611,6 +3768,9 @@ func (m *Request) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postStringIndexmapkey := iNdEx + intStringLenmapkey + if postStringIndexmapkey < 0 { + return ErrInvalidLengthApi + } if postStringIndexmapkey > l { return io.ErrUnexpectedEOF } @@ -3627,7 +3787,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLenmapvalue |= (uint64(b) & 0x7F) << shift + stringLenmapvalue |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3637,6 +3797,9 @@ func (m *Request) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postStringIndexmapvalue := iNdEx + intStringLenmapvalue + if postStringIndexmapvalue < 0 { + return ErrInvalidLengthApi + } if postStringIndexmapvalue > l { return io.ErrUnexpectedEOF } @@ -3673,7 +3836,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.StartTs |= (uint64(b) & 0x7F) << shift + m.StartTs |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3692,7 +3855,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3701,6 +3864,9 @@ func (m *Request) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -3725,7 +3891,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3745,7 +3911,7 @@ func (m *Request) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3760,6 +3926,9 @@ func (m *Request) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -3788,7 +3957,7 @@ func (m *Response) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3816,7 +3985,7 @@ func (m *Response) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3825,6 +3994,9 @@ func (m *Response) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -3847,7 +4019,7 @@ func (m *Response) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3856,6 +4028,9 @@ func (m *Response) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -3878,7 +4053,7 @@ func (m *Response) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3887,6 +4062,9 @@ func (m *Response) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -3911,7 +4089,7 @@ func (m *Response) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -3920,6 +4098,9 @@ func (m *Response) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -3939,6 +4120,9 @@ func (m *Response) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -3967,7 +4151,7 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -3995,7 +4179,7 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4004,6 +4188,9 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4024,7 +4211,7 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4041,7 +4228,7 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLenmapkey |= (uint64(b) & 0x7F) << shift + stringLenmapkey |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4051,6 +4238,9 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postStringIndexmapkey := iNdEx + intStringLenmapkey + if postStringIndexmapkey < 0 { + return ErrInvalidLengthApi + } if postStringIndexmapkey > l { return io.ErrUnexpectedEOF } @@ -4067,7 +4257,7 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLenmapvalue |= (uint64(b) & 0x7F) << shift + stringLenmapvalue |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4077,6 +4267,9 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postStringIndexmapvalue := iNdEx + intStringLenmapvalue + if postStringIndexmapvalue < 0 { + return ErrInvalidLengthApi + } if postStringIndexmapvalue > l { return io.ErrUnexpectedEOF } @@ -4113,7 +4306,7 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4122,6 +4315,9 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4146,7 +4342,7 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4155,6 +4351,9 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4174,6 +4373,9 @@ func (m *Assigned) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -4202,7 +4404,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4230,7 +4432,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4239,6 +4441,9 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4261,7 +4466,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4270,6 +4475,9 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4292,7 +4500,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4301,6 +4509,9 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4323,7 +4534,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4332,6 +4543,9 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4354,7 +4568,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4363,6 +4577,9 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4385,7 +4602,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4394,6 +4611,9 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4416,7 +4636,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.StartTs |= (uint64(b) & 0x7F) << shift + m.StartTs |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4435,7 +4655,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4455,7 +4675,7 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4470,6 +4690,9 @@ func (m *Mutation) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -4498,7 +4721,7 @@ func (m *Operation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4526,7 +4749,7 @@ func (m *Operation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4536,6 +4759,9 @@ func (m *Operation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4555,7 +4781,7 @@ func (m *Operation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4565,6 +4791,9 @@ func (m *Operation) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4584,12 +4813,31 @@ func (m *Operation) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } } m.DropAll = bool(v != 0) + case 4: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field DropOp", wireType) + } + m.DropOp = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowApi + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.DropOp |= Operation_DropOp(b&0x7F) << shift + if b < 0x80 { + break + } + } default: iNdEx = preIndex skippy, err := skipApi(dAtA[iNdEx:]) @@ -4599,6 +4847,9 @@ func (m *Operation) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -4627,7 +4878,7 @@ func (m *Payload) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4655,7 +4906,7 @@ func (m *Payload) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4664,6 +4915,9 @@ func (m *Payload) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4681,6 +4935,9 @@ func (m *Payload) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -4709,7 +4966,7 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4737,7 +4994,7 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.StartTs |= (uint64(b) & 0x7F) << shift + m.StartTs |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4756,7 +5013,7 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.CommitTs |= (uint64(b) & 0x7F) << shift + m.CommitTs |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4775,7 +5032,7 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4795,7 +5052,7 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4805,6 +5062,9 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4824,7 +5084,7 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4834,6 +5094,9 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4853,7 +5116,7 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -4862,6 +5125,9 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -4881,6 +5147,9 @@ func (m *TxnContext) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -4909,7 +5178,7 @@ func (m *Check) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4932,6 +5201,9 @@ func (m *Check) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -4960,7 +5232,7 @@ func (m *Version) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4988,7 +5260,7 @@ func (m *Version) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -4998,6 +5270,9 @@ func (m *Version) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5012,6 +5287,9 @@ func (m *Version) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -5040,7 +5318,7 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5068,7 +5346,7 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5077,6 +5355,9 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5097,7 +5378,7 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5113,7 +5394,7 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - mapkey |= (uint32(b) & 0x7F) << shift + mapkey |= uint32(b&0x7F) << shift if b < 0x80 { break } @@ -5128,7 +5409,7 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - mapvalue |= (uint64(b) & 0x7F) << shift + mapvalue |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5164,7 +5445,7 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.Sequencing |= (LinRead_Sequencing(b) & 0x7F) << shift + m.Sequencing |= LinRead_Sequencing(b&0x7F) << shift if b < 0x80 { break } @@ -5178,6 +5459,9 @@ func (m *LinRead) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -5206,7 +5490,7 @@ func (m *Latency) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5234,7 +5518,7 @@ func (m *Latency) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.ParsingNs |= (uint64(b) & 0x7F) << shift + m.ParsingNs |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5253,7 +5537,7 @@ func (m *Latency) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.ProcessingNs |= (uint64(b) & 0x7F) << shift + m.ProcessingNs |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5272,7 +5556,7 @@ func (m *Latency) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.EncodingNs |= (uint64(b) & 0x7F) << shift + m.EncodingNs |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5286,6 +5570,9 @@ func (m *Latency) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -5314,7 +5601,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5342,7 +5629,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5352,6 +5639,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5371,7 +5661,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5381,6 +5671,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5400,7 +5693,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5410,6 +5703,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5429,7 +5725,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5438,6 +5734,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5462,7 +5761,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5472,6 +5771,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5491,7 +5793,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5501,6 +5803,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5520,7 +5825,7 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5529,6 +5834,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5546,6 +5854,9 @@ func (m *NQuad) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -5574,7 +5885,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5602,7 +5913,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5612,6 +5923,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5631,7 +5945,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5640,6 +5954,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5661,7 +5978,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int64(b) & 0x7F) << shift + v |= int64(b&0x7F) << shift if b < 0x80 { break } @@ -5681,7 +5998,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5702,7 +6019,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5712,6 +6029,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5742,7 +6062,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5751,6 +6071,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5772,7 +6095,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5781,6 +6104,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5802,7 +6128,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5811,6 +6137,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5832,7 +6161,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5842,6 +6171,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5861,7 +6193,7 @@ func (m *Value) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (uint64(b) & 0x7F) << shift + v |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5876,6 +6208,9 @@ func (m *Value) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -5904,7 +6239,7 @@ func (m *Facet) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5932,7 +6267,7 @@ func (m *Facet) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -5942,6 +6277,9 @@ func (m *Facet) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5961,7 +6299,7 @@ func (m *Facet) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -5970,6 +6308,9 @@ func (m *Facet) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -5992,7 +6333,7 @@ func (m *Facet) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.ValType |= (Facet_ValType(b) & 0x7F) << shift + m.ValType |= Facet_ValType(b&0x7F) << shift if b < 0x80 { break } @@ -6011,7 +6352,7 @@ func (m *Facet) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6021,6 +6362,9 @@ func (m *Facet) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6040,7 +6384,7 @@ func (m *Facet) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6050,6 +6394,9 @@ func (m *Facet) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6064,6 +6411,9 @@ func (m *Facet) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -6092,7 +6442,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6120,7 +6470,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6130,6 +6480,9 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6149,7 +6502,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6159,6 +6512,9 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6178,7 +6534,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -6198,7 +6554,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6208,6 +6564,9 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6227,7 +6586,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -6247,7 +6606,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -6267,7 +6626,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -6287,7 +6646,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -6307,7 +6666,7 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - v |= (int(b) & 0x7F) << shift + v |= int(b&0x7F) << shift if b < 0x80 { break } @@ -6322,6 +6681,9 @@ func (m *SchemaNode) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -6350,7 +6712,7 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6378,7 +6740,7 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6388,6 +6750,9 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6407,7 +6772,7 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6417,6 +6782,9 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6436,7 +6804,7 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6446,6 +6814,9 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6460,6 +6831,9 @@ func (m *LoginRequest) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -6488,7 +6862,7 @@ func (m *Jwt) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6516,7 +6890,7 @@ func (m *Jwt) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6526,6 +6900,9 @@ func (m *Jwt) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6545,7 +6922,7 @@ func (m *Jwt) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -6555,6 +6932,9 @@ func (m *Jwt) Unmarshal(dAtA []byte) error { return ErrInvalidLengthApi } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthApi + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -6569,6 +6949,9 @@ func (m *Jwt) Unmarshal(dAtA []byte) error { if skippy < 0 { return ErrInvalidLengthApi } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthApi + } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } @@ -6636,10 +7019,13 @@ func skipApi(dAtA []byte) (n int, err error) { break } } - iNdEx += length if length < 0 { return 0, ErrInvalidLengthApi } + iNdEx += length + if iNdEx < 0 { + return 0, ErrInvalidLengthApi + } return iNdEx, nil case 3: for { @@ -6668,6 +7054,9 @@ func skipApi(dAtA []byte) (n int, err error) { return 0, err } iNdEx = start + next + if iNdEx < 0 { + return 0, ErrInvalidLengthApi + } } return iNdEx, nil case 4: @@ -6686,104 +7075,3 @@ var ( ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") ) - -func init() { proto.RegisterFile("api.proto", fileDescriptor_api_716cfbe908c1685c) } - -var fileDescriptor_api_716cfbe908c1685c = []byte{ - // 1516 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x57, 0xcd, 0x72, 0x1b, 0x4f, - 0x11, 0xd7, 0xea, 0x6b, 0x77, 0x5b, 0xb2, 0x23, 0x06, 0x12, 0x36, 0x76, 0xfc, 0x91, 0x4d, 0x55, - 0x22, 0x92, 0x8a, 0x0f, 0x4e, 0x15, 0xa1, 0xb8, 0xf9, 0x43, 0xc1, 0x4a, 0x39, 0x72, 0x32, 0x16, - 0xbe, 0x70, 0x50, 0x8d, 0xb4, 0x63, 0x79, 0xe3, 0xf5, 0xae, 0xbc, 0x33, 0xb2, 0x2d, 0x1e, 0x80, - 0x3b, 0x17, 0x8a, 0xa7, 0xa0, 0x8a, 0x67, 0xe0, 0xc2, 0x0d, 0xaa, 0x38, 0x71, 0x03, 0xf3, 0x22, - 0x54, 0xf7, 0xcc, 0x5a, 0x72, 0x92, 0x0a, 0xfc, 0x6f, 0xd3, 0xbf, 0x5f, 0xcf, 0x47, 0xf7, 0xfe, - 0xba, 0x67, 0x16, 0x7c, 0x31, 0x89, 0xb7, 0x26, 0x79, 0xa6, 0x33, 0x56, 0x11, 0x93, 0x38, 0xfc, - 0x5d, 0x19, 0x5c, 0x2e, 0x2f, 0xa7, 0x52, 0x69, 0xf6, 0x13, 0xa8, 0x5d, 0x4e, 0x65, 0x3e, 0x0b, - 0x9c, 0x4d, 0xa7, 0xed, 0x73, 0x63, 0xb0, 0x97, 0x50, 0xbd, 0x12, 0xb9, 0x0a, 0xca, 0x9b, 0x95, - 0x76, 0x63, 0xfb, 0xd1, 0x16, 0x2e, 0x60, 0x67, 0x6c, 0x9d, 0x88, 0x5c, 0x75, 0x52, 0x9d, 0xcf, - 0x38, 0xf9, 0xb0, 0xc7, 0xe0, 0x29, 0x2d, 0x72, 0x3d, 0xd0, 0x2a, 0x58, 0xda, 0x74, 0xda, 0x55, - 0xee, 0x92, 0xdd, 0x57, 0xec, 0x05, 0x78, 0x49, 0x9c, 0x0e, 0x72, 0x29, 0xa2, 0x60, 0x79, 0xd3, - 0x69, 0x37, 0xb6, 0x9b, 0xb4, 0xd4, 0x61, 0x9c, 0x72, 0x29, 0x22, 0xee, 0x26, 0x66, 0xc0, 0x56, - 0xc1, 0x47, 0xa7, 0x41, 0x96, 0x26, 0xb3, 0xe0, 0xc1, 0xa6, 0xd3, 0xf6, 0xb8, 0x87, 0xc0, 0x51, - 0x9a, 0xcc, 0xd8, 0x06, 0x34, 0x86, 0x52, 0xe9, 0x81, 0x3c, 0x3d, 0xcd, 0x72, 0x1d, 0xb4, 0x88, - 0x06, 0x84, 0x3a, 0x84, 0xac, 0xbc, 0x05, 0xff, 0xee, 0x50, 0xac, 0x05, 0x95, 0x73, 0x59, 0x84, - 0x83, 0x43, 0x0c, 0xf1, 0x4a, 0x24, 0x53, 0x19, 0x94, 0x4d, 0x88, 0x64, 0xfc, 0xb2, 0xfc, 0x0b, - 0x27, 0xfc, 0x83, 0x03, 0x1e, 0x97, 0x6a, 0x92, 0xa5, 0x4a, 0x32, 0x06, 0xd5, 0xcf, 0x2a, 0x4b, - 0x69, 0x66, 0x93, 0xd3, 0x98, 0xbd, 0x82, 0xba, 0x1a, 0x9d, 0xc9, 0x0b, 0x61, 0x33, 0xf1, 0x80, - 0x8e, 0x7f, 0x4c, 0x50, 0x2f, 0x8b, 0xe4, 0x6e, 0x39, 0x70, 0xb8, 0x75, 0x61, 0x4f, 0xa1, 0xa2, - 0x6f, 0xd2, 0xa0, 0x42, 0x81, 0x1a, 0xcf, 0xfe, 0x4d, 0xba, 0x97, 0xa5, 0x5a, 0xde, 0x68, 0x8e, - 0x1c, 0x7b, 0x0e, 0x6e, 0x22, 0xb4, 0x4c, 0x47, 0xb3, 0xa0, 0xb9, 0x98, 0x0f, 0x83, 0xf1, 0x82, - 0x0c, 0xff, 0xe2, 0x80, 0xb7, 0xa3, 0x54, 0x3c, 0x4e, 0x65, 0xc4, 0x5e, 0x41, 0x75, 0x1a, 0x47, - 0x2a, 0x70, 0xe8, 0x08, 0x3f, 0xa5, 0x19, 0x05, 0xb9, 0xf5, 0xeb, 0x38, 0x2a, 0xbe, 0x06, 0x3a, - 0xb1, 0x9f, 0x81, 0x3b, 0x32, 0x3b, 0x52, 0xb8, 0xdf, 0x38, 0x48, 0xc1, 0xff, 0xbf, 0x87, 0xc1, - 0xf4, 0xde, 0xed, 0xf2, 0x83, 0xd2, 0xfb, 0xa7, 0x32, 0x78, 0x1f, 0xa6, 0x5a, 0xe8, 0x38, 0x4b, - 0x49, 0x26, 0x52, 0x0f, 0x16, 0x52, 0xec, 0x2a, 0xa9, 0xdf, 0x63, 0x96, 0x37, 0xa0, 0x11, 0xc9, - 0x44, 0x6a, 0x69, 0xd8, 0x32, 0xb1, 0x60, 0x20, 0x72, 0x58, 0x03, 0xc0, 0xb9, 0xe9, 0xe5, 0x54, - 0x44, 0x8a, 0x12, 0xdc, 0xe4, 0xbe, 0x92, 0xba, 0x47, 0x00, 0xd2, 0x91, 0x4c, 0x0a, 0xba, 0x6a, - 0xe8, 0x48, 0x26, 0x96, 0x7e, 0x02, 0x15, 0x25, 0x75, 0x00, 0x94, 0x3e, 0xa0, 0x18, 0x7b, 0x9f, - 0xa6, 0x22, 0xe2, 0x08, 0x23, 0x1b, 0xc9, 0x24, 0x68, 0x7c, 0xcd, 0x46, 0x32, 0xf9, 0x9e, 0xb8, - 0xd7, 0x00, 0x46, 0xd9, 0xc5, 0x45, 0xac, 0x07, 0x69, 0x76, 0x4d, 0xf2, 0xf6, 0xb8, 0x6f, 0x90, - 0x5e, 0x76, 0xcd, 0xb6, 0xe1, 0x61, 0x3c, 0x4e, 0xb3, 0x5c, 0x0e, 0xe2, 0x34, 0x92, 0x37, 0x83, - 0x51, 0x96, 0x9e, 0x26, 0xf1, 0x48, 0x5b, 0x79, 0xff, 0xd8, 0x90, 0x5d, 0xe4, 0xf6, 0x2c, 0x15, - 0xfe, 0x06, 0xfc, 0xa3, 0x89, 0xcc, 0x4d, 0xc2, 0x1e, 0xdd, 0x69, 0xcf, 0x24, 0xbb, 0x90, 0xd9, - 0x2a, 0xf8, 0x51, 0x9e, 0x4d, 0x06, 0x42, 0xeb, 0xdc, 0xe6, 0xdc, 0x43, 0x60, 0x47, 0xeb, 0x1c, - 0xcf, 0x6b, 0xc8, 0x24, 0xa1, 0x3c, 0x79, 0xdc, 0x25, 0x2e, 0x49, 0xc2, 0x35, 0x70, 0x3f, 0x8a, - 0x59, 0x92, 0x89, 0x08, 0xa5, 0xbe, 0x2f, 0xb4, 0x28, 0xa4, 0x8e, 0xe3, 0xf0, 0xcf, 0x0e, 0xc0, - 0x5c, 0x25, 0xf7, 0x02, 0x77, 0xee, 0x07, 0xbe, 0x0a, 0x36, 0x4c, 0xe4, 0xca, 0xc4, 0x79, 0x06, - 0xe8, 0x2b, 0x16, 0x80, 0x2b, 0x86, 0x59, 0xae, 0x65, 0x54, 0xec, 0x6f, 0x4d, 0xdc, 0xf4, 0x5c, - 0xce, 0xf0, 0xfb, 0x54, 0xda, 0x3e, 0xa7, 0x31, 0x6a, 0x67, 0x92, 0xcb, 0x48, 0x05, 0x35, 0x02, - 0x8d, 0x71, 0xaf, 0x6d, 0x2c, 0x7d, 0xa7, 0x6d, 0x84, 0x2e, 0xd4, 0xf6, 0xce, 0xe4, 0xe8, 0x3c, - 0x5c, 0x05, 0xf7, 0x44, 0xe6, 0x0a, 0xd3, 0xd6, 0x82, 0x8a, 0x16, 0xe3, 0x42, 0xa0, 0x5a, 0x8c, - 0xc3, 0x7f, 0x38, 0xe0, 0xda, 0xa9, 0xec, 0x05, 0x54, 0xe6, 0xa5, 0xf4, 0x70, 0x71, 0xd5, 0xad, - 0x6e, 0x51, 0x48, 0xe8, 0xc1, 0xde, 0xa2, 0xe4, 0x2e, 0xa7, 0x32, 0x1d, 0xc5, 0xe9, 0x98, 0xa2, - 0x5c, 0xb6, 0xa5, 0x57, 0xf8, 0x1f, 0xdf, 0xd1, 0x7c, 0xc1, 0x75, 0xe5, 0xe7, 0xe0, 0x75, 0xbf, - 0x51, 0x2c, 0x4b, 0xdf, 0x28, 0x96, 0xea, 0x62, 0xb1, 0x6c, 0x01, 0xcc, 0x57, 0x64, 0x0f, 0xa0, - 0xb1, 0x77, 0xd8, 0xed, 0xf4, 0xfa, 0x83, 0xe3, 0xee, 0x7e, 0xa7, 0x55, 0x42, 0xe0, 0xb8, 0xc3, - 0x4f, 0x3a, 0xdc, 0x00, 0x4e, 0x98, 0x82, 0x6b, 0x2b, 0x15, 0x95, 0x38, 0x11, 0xb9, 0x8a, 0xd3, - 0xf1, 0x20, 0x2d, 0xbe, 0x96, 0x6f, 0x91, 0x9e, 0x62, 0xcf, 0x60, 0x69, 0x92, 0x67, 0x23, 0xa9, - 0x0a, 0x0f, 0xb3, 0x77, 0x73, 0x0e, 0xf6, 0x14, 0xd6, 0xa0, 0x4c, 0x47, 0x59, 0x64, 0x5d, 0x2a, - 0xe4, 0x02, 0x05, 0xd4, 0x53, 0xe1, 0x3f, 0x1d, 0xa8, 0x51, 0x61, 0xe0, 0x27, 0x56, 0xd3, 0xe1, - 0x67, 0x39, 0xd2, 0x36, 0xcb, 0x85, 0xc9, 0x9e, 0x80, 0x8f, 0x5f, 0x30, 0x1e, 0x09, 0x5d, 0xb4, - 0x83, 0x39, 0x80, 0xba, 0xc9, 0xc8, 0x6f, 0x10, 0x1b, 0x71, 0xf8, 0xdc, 0x33, 0x40, 0x37, 0x62, - 0xaf, 0xa1, 0x69, 0x49, 0x93, 0x9f, 0x2a, 0x7d, 0x77, 0x53, 0x8f, 0x27, 0x88, 0xf0, 0x86, 0xe1, - 0xc9, 0xc0, 0x3c, 0x26, 0x62, 0x28, 0x93, 0xa0, 0x66, 0x9a, 0x0e, 0x19, 0x28, 0xb1, 0x44, 0xa4, - 0xe3, 0xa0, 0x4e, 0x20, 0x8d, 0x59, 0x08, 0xf5, 0x53, 0x31, 0x92, 0x5a, 0x05, 0xee, 0x42, 0x89, - 0xbf, 0x43, 0x88, 0x5b, 0x26, 0xfc, 0x77, 0x19, 0x6a, 0x66, 0xdd, 0xa7, 0xd8, 0x8a, 0x4e, 0xc5, - 0x34, 0xa1, 0x73, 0x98, 0xf8, 0x0e, 0x4a, 0xd8, 0x8c, 0x08, 0x3c, 0x11, 0x09, 0x5b, 0x03, 0x7f, - 0x38, 0xd3, 0x52, 0x91, 0x03, 0xf5, 0xaa, 0x83, 0x12, 0xf7, 0x08, 0x42, 0xfa, 0x31, 0xb8, 0x71, - 0x6a, 0x66, 0x63, 0x8c, 0x95, 0x83, 0x12, 0xaf, 0xc7, 0x29, 0xcd, 0x5c, 0x05, 0x6f, 0x98, 0x65, - 0x09, 0x71, 0x18, 0x9f, 0x77, 0x50, 0xe2, 0x2e, 0x22, 0x76, 0x9e, 0xd2, 0x39, 0x71, 0x35, 0xbb, - 0x6b, 0x5d, 0xe9, 0x1c, 0xa9, 0x0d, 0x80, 0x28, 0x9b, 0x0e, 0x13, 0x49, 0x2c, 0x06, 0xe7, 0x1c, - 0x94, 0xb8, 0x6f, 0x30, 0x3b, 0x77, 0x2c, 0x33, 0x62, 0x5d, 0x7b, 0xa0, 0xfa, 0x58, 0x66, 0x76, - 0xcf, 0x48, 0x68, 0x33, 0xd3, 0xb3, 0x9c, 0x8b, 0x08, 0x92, 0xcf, 0xa0, 0x89, 0x43, 0x1d, 0x5f, - 0x18, 0x07, 0xdf, 0x3a, 0x34, 0x0a, 0xd4, 0x3a, 0x4d, 0x84, 0x52, 0xd7, 0x59, 0x1e, 0x91, 0x13, - 0xd8, 0xd3, 0x35, 0x0a, 0xd4, 0x9e, 0x60, 0x1a, 0x1b, 0xbe, 0x81, 0xd2, 0xc1, 0x13, 0x4c, 0x63, - 0xa4, 0x76, 0x6b, 0x50, 0xb9, 0x12, 0x49, 0xf8, 0x37, 0x07, 0x6a, 0x94, 0xf5, 0xff, 0x75, 0x85, - 0x34, 0x6d, 0x55, 0xb0, 0xd7, 0xe0, 0x5d, 0x89, 0x64, 0xa0, 0x67, 0x13, 0x49, 0xa9, 0x5c, 0xde, - 0x66, 0xf3, 0x6f, 0x87, 0xa2, 0xe8, 0xcf, 0x26, 0x92, 0xbb, 0x57, 0x66, 0x80, 0xfd, 0x52, 0x67, - 0xe7, 0x32, 0x2d, 0x3a, 0x8c, 0xb5, 0x70, 0x71, 0x91, 0xc4, 0x42, 0x15, 0x52, 0x21, 0x23, 0xdc, - 0x01, 0xd7, 0xae, 0xc0, 0x00, 0xea, 0xc7, 0x7d, 0xde, 0xed, 0xfd, 0xaa, 0x55, 0x62, 0x2e, 0x54, - 0xba, 0xbd, 0x7e, 0xcb, 0x61, 0x3e, 0xd4, 0xde, 0x1d, 0x1e, 0xed, 0xf4, 0x5b, 0x65, 0xe6, 0x41, - 0x75, 0xf7, 0xe8, 0xe8, 0xb0, 0x55, 0x61, 0x4d, 0xf0, 0xf6, 0x77, 0xfa, 0x9d, 0x7e, 0xf7, 0x43, - 0xa7, 0x55, 0x0d, 0x6f, 0x1d, 0x80, 0xf9, 0x53, 0xe0, 0xbe, 0xf8, 0x9d, 0x2f, 0xc5, 0xcf, 0xa0, - 0x4a, 0x81, 0x98, 0xaa, 0xa0, 0x31, 0x9e, 0x8c, 0xee, 0x06, 0xdb, 0x29, 0x8d, 0x81, 0xeb, 0xd0, - 0xc9, 0xe3, 0xdf, 0xca, 0xdc, 0x86, 0x32, 0x07, 0xb0, 0xf8, 0x72, 0x79, 0x25, 0x73, 0x25, 0x29, - 0x1e, 0x8f, 0x17, 0x26, 0xae, 0x36, 0xca, 0xa6, 0xa9, 0x26, 0x81, 0x78, 0xdc, 0x18, 0x54, 0x12, - 0xb1, 0xd2, 0xa4, 0x0b, 0x8f, 0xd3, 0x18, 0x33, 0x35, 0x9d, 0x28, 0x99, 0x6b, 0x52, 0x84, 0xc7, - 0xad, 0x75, 0x57, 0x3e, 0xbe, 0xf5, 0x15, 0xe9, 0x38, 0x1c, 0x43, 0xf3, 0x30, 0x1b, 0x63, 0xcb, - 0x33, 0xef, 0x45, 0x9c, 0xab, 0x64, 0x1e, 0x47, 0xc5, 0xad, 0x64, 0x2c, 0xb6, 0x02, 0x5e, 0xa1, - 0x87, 0xe2, 0x52, 0x2a, 0x6c, 0x6c, 0x40, 0xb9, 0x3c, 0xcd, 0xa5, 0x3a, 0x1b, 0x50, 0x20, 0xb6, - 0xf8, 0x9b, 0x16, 0xec, 0x23, 0x16, 0x76, 0xa0, 0xf2, 0xfe, 0x5a, 0x63, 0x2f, 0x13, 0x23, 0x6c, - 0x4b, 0x83, 0xcf, 0xd7, 0x45, 0x7f, 0xf1, 0x0d, 0x82, 0xf4, 0x06, 0x34, 0x8a, 0xa5, 0x90, 0x37, - 0x3b, 0x81, 0x85, 0xde, 0x5f, 0xeb, 0xed, 0xdf, 0x97, 0xa1, 0xbe, 0x3f, 0xce, 0xc5, 0xe4, 0x8c, - 0xbd, 0x82, 0x1a, 0x1d, 0x9d, 0xfd, 0xc8, 0xf4, 0xed, 0x85, 0x30, 0x56, 0x96, 0xec, 0x93, 0xd6, - 0xbc, 0xfd, 0xc2, 0x12, 0x7b, 0x0e, 0xb5, 0x4f, 0xf4, 0xf4, 0x6d, 0x2e, 0x3e, 0x76, 0xbf, 0xf6, - 0x6b, 0x43, 0x9d, 0x9e, 0x34, 0x92, 0x19, 0xaa, 0x78, 0xdf, 0x58, 0xcf, 0xe2, 0x5d, 0x16, 0x96, - 0xd8, 0x0b, 0xa8, 0xed, 0x24, 0x5a, 0xe6, 0x6c, 0x99, 0x98, 0xbb, 0x8b, 0x7d, 0xc5, 0xec, 0x60, - 0xef, 0xe2, 0xb0, 0xc4, 0xde, 0xc0, 0xd2, 0x1e, 0x5d, 0x9f, 0x47, 0xf9, 0x0e, 0xde, 0x95, 0xec, - 0xcb, 0x27, 0xdb, 0xca, 0x97, 0x40, 0x58, 0x62, 0x2f, 0xa1, 0x49, 0x57, 0x5f, 0x71, 0xed, 0x99, - 0xb6, 0x46, 0x90, 0xdd, 0xc0, 0x32, 0x61, 0x69, 0xb7, 0xfd, 0xd7, 0xdb, 0x75, 0xe7, 0xef, 0xb7, - 0xeb, 0xce, 0xbf, 0x6e, 0xd7, 0x9d, 0x3f, 0xfe, 0x67, 0xbd, 0x04, 0x7e, 0x9c, 0x6d, 0x45, 0x94, - 0xa5, 0xdd, 0x86, 0xc9, 0xd6, 0x47, 0xfc, 0x3d, 0x18, 0xd6, 0xe9, 0x2f, 0xe1, 0xcd, 0x7f, 0x03, - 0x00, 0x00, 0xff, 0xff, 0x2b, 0x33, 0x32, 0x2d, 0x32, 0x0c, 0x00, 0x00, -}