Documentation ¶
Overview ¶
Package task is a generated protocol buffer package.
It is generated from these files:
task.proto
It has these top-level messages:
List Value Query Result Sort SortResult Num RaftContext Membership MembershipUpdate DirectedEdge Mutations RebuildIndex Proposal KV KC GroupKeys
Index ¶
- Variables
- type DirectedEdge
- func (*DirectedEdge) Descriptor() ([]byte, []int)
- func (m *DirectedEdge) GetAttr() string
- func (m *DirectedEdge) GetEntity() uint64
- func (m *DirectedEdge) GetLabel() string
- func (m *DirectedEdge) GetOp() DirectedEdge_Op
- func (m *DirectedEdge) GetValue() []byte
- func (m *DirectedEdge) GetValueId() uint64
- func (m *DirectedEdge) GetValueType() uint32
- func (m *DirectedEdge) Marshal() (dAtA []byte, err error)
- func (m *DirectedEdge) MarshalTo(dAtA []byte) (int, error)
- func (*DirectedEdge) ProtoMessage()
- func (m *DirectedEdge) Reset()
- func (m *DirectedEdge) Size() (n int)
- func (m *DirectedEdge) String() string
- func (m *DirectedEdge) Unmarshal(dAtA []byte) error
- type DirectedEdge_Op
- type GroupKeys
- func (*GroupKeys) Descriptor() ([]byte, []int)
- func (m *GroupKeys) GetGroupId() uint32
- func (m *GroupKeys) GetKeys() []*KC
- func (m *GroupKeys) Marshal() (dAtA []byte, err error)
- func (m *GroupKeys) MarshalTo(dAtA []byte) (int, error)
- func (*GroupKeys) ProtoMessage()
- func (m *GroupKeys) Reset()
- func (m *GroupKeys) Size() (n int)
- func (m *GroupKeys) String() string
- func (m *GroupKeys) Unmarshal(dAtA []byte) error
- type KC
- func (*KC) Descriptor() ([]byte, []int)
- func (m *KC) GetChecksum() []byte
- func (m *KC) GetKey() []byte
- func (m *KC) Marshal() (dAtA []byte, err error)
- func (m *KC) MarshalTo(dAtA []byte) (int, error)
- func (*KC) ProtoMessage()
- func (m *KC) Reset()
- func (m *KC) Size() (n int)
- func (m *KC) String() string
- func (m *KC) Unmarshal(dAtA []byte) error
- type KV
- func (*KV) Descriptor() ([]byte, []int)
- func (m *KV) GetKey() []byte
- func (m *KV) GetVal() []byte
- func (m *KV) Marshal() (dAtA []byte, err error)
- func (m *KV) MarshalTo(dAtA []byte) (int, error)
- func (*KV) ProtoMessage()
- func (m *KV) Reset()
- func (m *KV) Size() (n int)
- func (m *KV) String() string
- func (m *KV) Unmarshal(dAtA []byte) error
- type List
- func (*List) Descriptor() ([]byte, []int)
- func (m *List) GetUids() []uint64
- func (m *List) Marshal() (dAtA []byte, err error)
- func (m *List) MarshalTo(dAtA []byte) (int, error)
- func (*List) ProtoMessage()
- func (m *List) Reset()
- func (m *List) Size() (n int)
- func (m *List) String() string
- func (m *List) Unmarshal(dAtA []byte) error
- type Membership
- func (*Membership) Descriptor() ([]byte, []int)
- func (m *Membership) GetAddr() string
- func (m *Membership) GetAmDead() bool
- func (m *Membership) GetGroupId() uint32
- func (m *Membership) GetId() uint64
- func (m *Membership) GetLastUpdate() uint64
- func (m *Membership) GetLeader() bool
- func (m *Membership) Marshal() (dAtA []byte, err error)
- func (m *Membership) MarshalTo(dAtA []byte) (int, error)
- func (*Membership) ProtoMessage()
- func (m *Membership) Reset()
- func (m *Membership) Size() (n int)
- func (m *Membership) String() string
- func (m *Membership) Unmarshal(dAtA []byte) error
- type MembershipUpdate
- func (*MembershipUpdate) Descriptor() ([]byte, []int)
- func (m *MembershipUpdate) GetLastUpdate() uint64
- func (m *MembershipUpdate) GetMembers() []*Membership
- func (m *MembershipUpdate) GetRedirect() bool
- func (m *MembershipUpdate) GetRedirectAddr() string
- func (m *MembershipUpdate) Marshal() (dAtA []byte, err error)
- func (m *MembershipUpdate) MarshalTo(dAtA []byte) (int, error)
- func (*MembershipUpdate) ProtoMessage()
- func (m *MembershipUpdate) Reset()
- func (m *MembershipUpdate) Size() (n int)
- func (m *MembershipUpdate) String() string
- func (m *MembershipUpdate) Unmarshal(dAtA []byte) error
- type Mutations
- func (*Mutations) Descriptor() ([]byte, []int)
- func (m *Mutations) GetEdges() []*DirectedEdge
- func (m *Mutations) GetGroupId() uint32
- func (m *Mutations) Marshal() (dAtA []byte, err error)
- func (m *Mutations) MarshalTo(dAtA []byte) (int, error)
- func (*Mutations) ProtoMessage()
- func (m *Mutations) Reset()
- func (m *Mutations) Size() (n int)
- func (m *Mutations) String() string
- func (m *Mutations) Unmarshal(dAtA []byte) error
- type Num
- func (*Num) Descriptor() ([]byte, []int)
- func (m *Num) GetGroup() uint32
- func (m *Num) GetUids() []uint64
- func (m *Num) GetVal() int64
- func (m *Num) Marshal() (dAtA []byte, err error)
- func (m *Num) MarshalTo(dAtA []byte) (int, error)
- func (*Num) ProtoMessage()
- func (m *Num) Reset()
- func (m *Num) Size() (n int)
- func (m *Num) String() string
- func (m *Num) Unmarshal(dAtA []byte) error
- type Proposal
- func (*Proposal) Descriptor() ([]byte, []int)
- func (m *Proposal) GetId() uint32
- func (m *Proposal) GetMembership() *Membership
- func (m *Proposal) GetMutations() *Mutations
- func (m *Proposal) GetRebuildIndex() *RebuildIndex
- func (m *Proposal) Marshal() (dAtA []byte, err error)
- func (m *Proposal) MarshalTo(dAtA []byte) (int, error)
- func (*Proposal) ProtoMessage()
- func (m *Proposal) Reset()
- func (m *Proposal) Size() (n int)
- func (m *Proposal) String() string
- func (m *Proposal) Unmarshal(dAtA []byte) error
- type Query
- func (*Query) Descriptor() ([]byte, []int)
- func (m *Query) GetAfterUid() uint64
- func (m *Query) GetAttr() string
- func (m *Query) GetCount() int32
- func (m *Query) GetDoCount() bool
- func (m *Query) GetOffset() int32
- func (m *Query) GetReverse() bool
- func (m *Query) GetSrcFunc() []string
- func (m *Query) GetUids() []uint64
- func (m *Query) Marshal() (dAtA []byte, err error)
- func (m *Query) MarshalTo(dAtA []byte) (int, error)
- func (*Query) ProtoMessage()
- func (m *Query) Reset()
- func (m *Query) Size() (n int)
- func (m *Query) String() string
- func (m *Query) Unmarshal(dAtA []byte) error
- type RaftContext
- func (*RaftContext) Descriptor() ([]byte, []int)
- func (m *RaftContext) GetAddr() string
- func (m *RaftContext) GetGroup() uint32
- func (m *RaftContext) GetId() uint64
- func (m *RaftContext) Marshal() (dAtA []byte, err error)
- func (m *RaftContext) MarshalTo(dAtA []byte) (int, error)
- func (*RaftContext) ProtoMessage()
- func (m *RaftContext) Reset()
- func (m *RaftContext) Size() (n int)
- func (m *RaftContext) String() string
- func (m *RaftContext) Unmarshal(dAtA []byte) error
- type RebuildIndex
- func (*RebuildIndex) Descriptor() ([]byte, []int)
- func (m *RebuildIndex) GetAttr() string
- func (m *RebuildIndex) GetGroupId() uint32
- func (m *RebuildIndex) Marshal() (dAtA []byte, err error)
- func (m *RebuildIndex) MarshalTo(dAtA []byte) (int, error)
- func (*RebuildIndex) ProtoMessage()
- func (m *RebuildIndex) Reset()
- func (m *RebuildIndex) Size() (n int)
- func (m *RebuildIndex) String() string
- func (m *RebuildIndex) Unmarshal(dAtA []byte) error
- type Result
- func (*Result) Descriptor() ([]byte, []int)
- func (m *Result) GetCounts() []uint32
- func (m *Result) GetIntersectDest() bool
- func (m *Result) GetUidMatrix() []*List
- func (m *Result) GetValues() []*Value
- func (m *Result) Marshal() (dAtA []byte, err error)
- func (m *Result) MarshalTo(dAtA []byte) (int, error)
- func (*Result) ProtoMessage()
- func (m *Result) Reset()
- func (m *Result) Size() (n int)
- func (m *Result) String() string
- func (m *Result) Unmarshal(dAtA []byte) error
- type Sort
- func (*Sort) Descriptor() ([]byte, []int)
- func (m *Sort) GetAttr() string
- func (m *Sort) GetCount() int32
- func (m *Sort) GetDesc() bool
- func (m *Sort) GetOffset() int32
- func (m *Sort) GetUidMatrix() []*List
- func (m *Sort) Marshal() (dAtA []byte, err error)
- func (m *Sort) MarshalTo(dAtA []byte) (int, error)
- func (*Sort) ProtoMessage()
- func (m *Sort) Reset()
- func (m *Sort) Size() (n int)
- func (m *Sort) String() string
- func (m *Sort) Unmarshal(dAtA []byte) error
- type SortResult
- func (*SortResult) Descriptor() ([]byte, []int)
- func (m *SortResult) GetUidMatrix() []*List
- func (m *SortResult) Marshal() (dAtA []byte, err error)
- func (m *SortResult) MarshalTo(dAtA []byte) (int, error)
- func (*SortResult) ProtoMessage()
- func (m *SortResult) Reset()
- func (m *SortResult) Size() (n int)
- func (m *SortResult) String() string
- func (m *SortResult) Unmarshal(dAtA []byte) error
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetVal() []byte
- func (m *Value) GetValType() int32
- func (m *Value) Marshal() (dAtA []byte, err error)
- func (m *Value) MarshalTo(dAtA []byte) (int, error)
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) Size() (n int)
- func (m *Value) String() string
- func (m *Value) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTask = fmt.Errorf("proto: integer overflow") )
View Source
var DirectedEdge_Op_name = map[int32]string{
0: "SET",
1: "DEL",
}
View Source
var DirectedEdge_Op_value = map[string]int32{
"SET": 0,
"DEL": 1,
}
Functions ¶
This section is empty.
Types ¶
type DirectedEdge ¶ added in v0.7.0
type DirectedEdge struct { Entity uint64 `protobuf:"fixed64,1,opt,name=entity,proto3" json:"entity,omitempty"` Attr string `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` ValueType uint32 `protobuf:"varint,4,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"` ValueId uint64 `protobuf:"fixed64,5,opt,name=value_id,json=valueId,proto3" json:"value_id,omitempty"` Label string `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"` Op DirectedEdge_Op `protobuf:"varint,7,opt,name=op,proto3,enum=task.DirectedEdge_Op" json:"op,omitempty"` }
func (*DirectedEdge) Descriptor ¶ added in v0.7.0
func (*DirectedEdge) Descriptor() ([]byte, []int)
func (*DirectedEdge) GetAttr ¶ added in v0.7.2
func (m *DirectedEdge) GetAttr() string
func (*DirectedEdge) GetEntity ¶ added in v0.7.2
func (m *DirectedEdge) GetEntity() uint64
func (*DirectedEdge) GetLabel ¶ added in v0.7.2
func (m *DirectedEdge) GetLabel() string
func (*DirectedEdge) GetOp ¶ added in v0.7.2
func (m *DirectedEdge) GetOp() DirectedEdge_Op
func (*DirectedEdge) GetValue ¶ added in v0.7.2
func (m *DirectedEdge) GetValue() []byte
func (*DirectedEdge) GetValueId ¶ added in v0.7.2
func (m *DirectedEdge) GetValueId() uint64
func (*DirectedEdge) GetValueType ¶ added in v0.7.2
func (m *DirectedEdge) GetValueType() uint32
func (*DirectedEdge) Marshal ¶ added in v0.7.0
func (m *DirectedEdge) Marshal() (dAtA []byte, err error)
func (*DirectedEdge) MarshalTo ¶ added in v0.7.0
func (m *DirectedEdge) MarshalTo(dAtA []byte) (int, error)
func (*DirectedEdge) ProtoMessage ¶ added in v0.7.0
func (*DirectedEdge) ProtoMessage()
func (*DirectedEdge) Reset ¶ added in v0.7.0
func (m *DirectedEdge) Reset()
func (*DirectedEdge) Size ¶ added in v0.7.0
func (m *DirectedEdge) Size() (n int)
func (*DirectedEdge) String ¶ added in v0.7.0
func (m *DirectedEdge) String() string
func (*DirectedEdge) Unmarshal ¶ added in v0.7.0
func (m *DirectedEdge) Unmarshal(dAtA []byte) error
type DirectedEdge_Op ¶ added in v0.7.1
type DirectedEdge_Op int32
const ( DirectedEdge_SET DirectedEdge_Op = 0 DirectedEdge_DEL DirectedEdge_Op = 1 )
func (DirectedEdge_Op) EnumDescriptor ¶ added in v0.7.1
func (DirectedEdge_Op) EnumDescriptor() ([]byte, []int)
func (DirectedEdge_Op) String ¶ added in v0.7.1
func (x DirectedEdge_Op) String() string
type GroupKeys ¶ added in v0.7.0
type GroupKeys struct { GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` Keys []*KC `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"` }
func (*GroupKeys) Descriptor ¶ added in v0.7.0
func (*GroupKeys) GetGroupId ¶ added in v0.7.2
func (*GroupKeys) ProtoMessage ¶ added in v0.7.0
func (*GroupKeys) ProtoMessage()
type KC ¶ added in v0.7.0
type KC struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Checksum []byte `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"` }
func (*KC) Descriptor ¶ added in v0.7.0
func (*KC) GetChecksum ¶ added in v0.7.2
func (*KC) ProtoMessage ¶ added in v0.7.0
func (*KC) ProtoMessage()
type KV ¶ added in v0.4.4
type KV struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Val []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"` }
func (*KV) Descriptor ¶ added in v0.7.0
func (*KV) ProtoMessage ¶ added in v0.7.0
func (*KV) ProtoMessage()
type List ¶ added in v0.7.0
type List struct {
Uids []uint64 `protobuf:"fixed64,1,rep,packed,name=uids" json:"uids,omitempty"`
}
func (*List) Descriptor ¶ added in v0.7.0
func (*List) ProtoMessage ¶ added in v0.7.0
func (*List) ProtoMessage()
type Membership ¶ added in v0.7.0
type Membership struct { Id uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"` GroupId uint32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"` Leader bool `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"` AmDead bool `protobuf:"varint,5,opt,name=am_dead,json=amDead,proto3" json:"am_dead,omitempty"` LastUpdate uint64 `protobuf:"varint,6,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"` }
Membership stores information about RAFT group membership for a single RAFT node. Note that each server can be serving multiple RAFT groups. Each group would have one RAFT node per server serving that group.
func (*Membership) Descriptor ¶ added in v0.7.0
func (*Membership) Descriptor() ([]byte, []int)
func (*Membership) GetAddr ¶ added in v0.7.2
func (m *Membership) GetAddr() string
func (*Membership) GetAmDead ¶ added in v0.7.2
func (m *Membership) GetAmDead() bool
func (*Membership) GetGroupId ¶ added in v0.7.2
func (m *Membership) GetGroupId() uint32
func (*Membership) GetId ¶ added in v0.7.2
func (m *Membership) GetId() uint64
func (*Membership) GetLastUpdate ¶ added in v0.7.2
func (m *Membership) GetLastUpdate() uint64
func (*Membership) GetLeader ¶ added in v0.7.2
func (m *Membership) GetLeader() bool
func (*Membership) Marshal ¶ added in v0.7.0
func (m *Membership) Marshal() (dAtA []byte, err error)
func (*Membership) MarshalTo ¶ added in v0.7.0
func (m *Membership) MarshalTo(dAtA []byte) (int, error)
func (*Membership) ProtoMessage ¶ added in v0.7.0
func (*Membership) ProtoMessage()
func (*Membership) Reset ¶ added in v0.7.0
func (m *Membership) Reset()
func (*Membership) Size ¶ added in v0.7.0
func (m *Membership) Size() (n int)
func (*Membership) String ¶ added in v0.7.0
func (m *Membership) String() string
func (*Membership) Unmarshal ¶ added in v0.7.0
func (m *Membership) Unmarshal(dAtA []byte) error
type MembershipUpdate ¶ added in v0.7.0
type MembershipUpdate struct { Members []*Membership `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"` LastUpdate uint64 `protobuf:"varint,2,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"` Redirect bool `protobuf:"varint,3,opt,name=redirect,proto3" json:"redirect,omitempty"` RedirectAddr string `protobuf:"bytes,4,opt,name=redirect_addr,json=redirectAddr,proto3" json:"redirect_addr,omitempty"` }
MembershipUpdate is used to pack together the current membership state of all the nodes in the caller server; and the membership updates recorded by the callee server since the provided lastUpdate.
func (*MembershipUpdate) Descriptor ¶ added in v0.7.0
func (*MembershipUpdate) Descriptor() ([]byte, []int)
func (*MembershipUpdate) GetLastUpdate ¶ added in v0.7.2
func (m *MembershipUpdate) GetLastUpdate() uint64
func (*MembershipUpdate) GetMembers ¶ added in v0.7.0
func (m *MembershipUpdate) GetMembers() []*Membership
func (*MembershipUpdate) GetRedirect ¶ added in v0.7.2
func (m *MembershipUpdate) GetRedirect() bool
func (*MembershipUpdate) GetRedirectAddr ¶ added in v0.7.2
func (m *MembershipUpdate) GetRedirectAddr() string
func (*MembershipUpdate) Marshal ¶ added in v0.7.0
func (m *MembershipUpdate) Marshal() (dAtA []byte, err error)
func (*MembershipUpdate) MarshalTo ¶ added in v0.7.0
func (m *MembershipUpdate) MarshalTo(dAtA []byte) (int, error)
func (*MembershipUpdate) ProtoMessage ¶ added in v0.7.0
func (*MembershipUpdate) ProtoMessage()
func (*MembershipUpdate) Reset ¶ added in v0.7.0
func (m *MembershipUpdate) Reset()
func (*MembershipUpdate) Size ¶ added in v0.7.0
func (m *MembershipUpdate) Size() (n int)
func (*MembershipUpdate) String ¶ added in v0.7.0
func (m *MembershipUpdate) String() string
func (*MembershipUpdate) Unmarshal ¶ added in v0.7.0
func (m *MembershipUpdate) Unmarshal(dAtA []byte) error
type Mutations ¶ added in v0.7.0
type Mutations struct { GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` Edges []*DirectedEdge `protobuf:"bytes,2,rep,name=edges" json:"edges,omitempty"` }
func (*Mutations) Descriptor ¶ added in v0.7.0
func (*Mutations) GetEdges ¶ added in v0.7.1
func (m *Mutations) GetEdges() []*DirectedEdge
func (*Mutations) GetGroupId ¶ added in v0.7.2
func (*Mutations) ProtoMessage ¶ added in v0.7.0
func (*Mutations) ProtoMessage()
type Num ¶ added in v0.7.0
type Num struct { Group uint32 `protobuf:"varint,1,opt,name=group,proto3" json:"group,omitempty"` Val int64 `protobuf:"varint,2,opt,name=val,proto3" json:"val,omitempty"` Uids []uint64 `protobuf:"varint,3,rep,packed,name=uids" json:"uids,omitempty"` }
func (*Num) Descriptor ¶ added in v0.7.0
func (*Num) ProtoMessage ¶ added in v0.7.0
func (*Num) ProtoMessage()
type Proposal ¶ added in v0.7.0
type Proposal struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Mutations *Mutations `protobuf:"bytes,2,opt,name=mutations" json:"mutations,omitempty"` Membership *Membership `protobuf:"bytes,3,opt,name=membership" json:"membership,omitempty"` RebuildIndex *RebuildIndex `protobuf:"bytes,4,opt,name=rebuild_index,json=rebuildIndex" json:"rebuild_index,omitempty"` }
func (*Proposal) Descriptor ¶ added in v0.7.0
func (*Proposal) GetMembership ¶ added in v0.7.0
func (m *Proposal) GetMembership() *Membership
func (*Proposal) GetMutations ¶ added in v0.7.0
func (*Proposal) GetRebuildIndex ¶ added in v0.7.2
func (m *Proposal) GetRebuildIndex() *RebuildIndex
func (*Proposal) ProtoMessage ¶ added in v0.7.0
func (*Proposal) ProtoMessage()
type Query ¶
type Query struct { Attr string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"` Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` Offset int32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` AfterUid uint64 `protobuf:"fixed64,4,opt,name=after_uid,json=afterUid,proto3" json:"after_uid,omitempty"` DoCount bool `protobuf:"varint,5,opt,name=do_count,json=doCount,proto3" json:"do_count,omitempty"` // Exactly one of uids and terms is populated. Uids []uint64 `protobuf:"fixed64,6,rep,packed,name=uids" json:"uids,omitempty"` // Function to generate or filter UIDs. SrcFunc []string `protobuf:"bytes,7,rep,name=src_func,json=srcFunc" json:"src_func,omitempty"` Reverse bool `protobuf:"varint,8,opt,name=reverse,proto3" json:"reverse,omitempty"` }
func (*Query) Descriptor ¶ added in v0.7.0
func (*Query) GetAfterUid ¶ added in v0.7.2
func (*Query) GetDoCount ¶ added in v0.7.2
func (*Query) GetReverse ¶ added in v0.7.2
func (*Query) GetSrcFunc ¶ added in v0.7.2
func (*Query) ProtoMessage ¶ added in v0.7.0
func (*Query) ProtoMessage()
type RaftContext ¶ added in v0.7.0
type RaftContext struct { Id uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"` Group uint32 `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"` Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"` }
func (*RaftContext) Descriptor ¶ added in v0.7.0
func (*RaftContext) Descriptor() ([]byte, []int)
func (*RaftContext) GetAddr ¶ added in v0.7.2
func (m *RaftContext) GetAddr() string
func (*RaftContext) GetGroup ¶ added in v0.7.2
func (m *RaftContext) GetGroup() uint32
func (*RaftContext) GetId ¶ added in v0.7.2
func (m *RaftContext) GetId() uint64
func (*RaftContext) Marshal ¶ added in v0.7.0
func (m *RaftContext) Marshal() (dAtA []byte, err error)
func (*RaftContext) MarshalTo ¶ added in v0.7.0
func (m *RaftContext) MarshalTo(dAtA []byte) (int, error)
func (*RaftContext) ProtoMessage ¶ added in v0.7.0
func (*RaftContext) ProtoMessage()
func (*RaftContext) Reset ¶ added in v0.7.0
func (m *RaftContext) Reset()
func (*RaftContext) Size ¶ added in v0.7.0
func (m *RaftContext) Size() (n int)
func (*RaftContext) String ¶ added in v0.7.0
func (m *RaftContext) String() string
func (*RaftContext) Unmarshal ¶ added in v0.7.0
func (m *RaftContext) Unmarshal(dAtA []byte) error
type RebuildIndex ¶ added in v0.7.2
type RebuildIndex struct { GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` Attr string `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"` }
func (*RebuildIndex) Descriptor ¶ added in v0.7.2
func (*RebuildIndex) Descriptor() ([]byte, []int)
func (*RebuildIndex) GetAttr ¶ added in v0.7.2
func (m *RebuildIndex) GetAttr() string
func (*RebuildIndex) GetGroupId ¶ added in v0.7.2
func (m *RebuildIndex) GetGroupId() uint32
func (*RebuildIndex) Marshal ¶ added in v0.7.2
func (m *RebuildIndex) Marshal() (dAtA []byte, err error)
func (*RebuildIndex) MarshalTo ¶ added in v0.7.2
func (m *RebuildIndex) MarshalTo(dAtA []byte) (int, error)
func (*RebuildIndex) ProtoMessage ¶ added in v0.7.2
func (*RebuildIndex) ProtoMessage()
func (*RebuildIndex) Reset ¶ added in v0.7.2
func (m *RebuildIndex) Reset()
func (*RebuildIndex) Size ¶ added in v0.7.2
func (m *RebuildIndex) Size() (n int)
func (*RebuildIndex) String ¶ added in v0.7.2
func (m *RebuildIndex) String() string
func (*RebuildIndex) Unmarshal ¶ added in v0.7.2
func (m *RebuildIndex) Unmarshal(dAtA []byte) error
type Result ¶
type Result struct { UidMatrix []*List `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"` Values []*Value `protobuf:"bytes,2,rep,name=values" json:"values,omitempty"` Counts []uint32 `protobuf:"varint,3,rep,packed,name=counts" json:"counts,omitempty"` IntersectDest bool `protobuf:"varint,4,opt,name=intersect_dest,json=intersectDest,proto3" json:"intersect_dest,omitempty"` }
func (*Result) Descriptor ¶ added in v0.7.0
func (*Result) GetIntersectDest ¶ added in v0.7.2
func (*Result) GetUidMatrix ¶ added in v0.7.0
func (*Result) ProtoMessage ¶ added in v0.7.0
func (*Result) ProtoMessage()
type Sort ¶ added in v0.7.0
type Sort struct { Attr string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"` UidMatrix []*List `protobuf:"bytes,2,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"` Count int32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` Offset int32 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` Desc bool `protobuf:"varint,5,opt,name=desc,proto3" json:"desc,omitempty"` }
func (*Sort) Descriptor ¶ added in v0.7.0
func (*Sort) GetUidMatrix ¶ added in v0.7.0
func (*Sort) ProtoMessage ¶ added in v0.7.0
func (*Sort) ProtoMessage()
type SortResult ¶ added in v0.7.0
type SortResult struct {
UidMatrix []*List `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
}
func (*SortResult) Descriptor ¶ added in v0.7.0
func (*SortResult) Descriptor() ([]byte, []int)
func (*SortResult) GetUidMatrix ¶ added in v0.7.0
func (m *SortResult) GetUidMatrix() []*List
func (*SortResult) Marshal ¶ added in v0.7.0
func (m *SortResult) Marshal() (dAtA []byte, err error)
func (*SortResult) MarshalTo ¶ added in v0.7.0
func (m *SortResult) MarshalTo(dAtA []byte) (int, error)
func (*SortResult) ProtoMessage ¶ added in v0.7.0
func (*SortResult) ProtoMessage()
func (*SortResult) Reset ¶ added in v0.7.0
func (m *SortResult) Reset()
func (*SortResult) Size ¶ added in v0.7.0
func (m *SortResult) Size() (n int)
func (*SortResult) String ¶ added in v0.7.0
func (m *SortResult) String() string
func (*SortResult) Unmarshal ¶ added in v0.7.0
func (m *SortResult) Unmarshal(dAtA []byte) error
type Value ¶
type Value struct { Val []byte `protobuf:"bytes,1,opt,name=val,proto3" json:"val,omitempty"` ValType int32 `protobuf:"varint,2,opt,name=val_type,json=valType,proto3" json:"val_type,omitempty"` }
func (*Value) Descriptor ¶ added in v0.7.0
func (*Value) GetValType ¶ added in v0.7.2
func (*Value) ProtoMessage ¶ added in v0.7.0
func (*Value) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.