Versions in this module Expand all Collapse all v1 v1.0.4 Mar 9, 2018 Changes in this version type SchemaUpdate + Upsert bool + func (m *SchemaUpdate) GetUpsert() bool v1.0.3 Feb 7, 2018 v1.0.2 Jan 17, 2018 Changes in this version type RaftContext + SnapshotTs uint64 + func (m *RaftContext) GetSnapshotTs() uint64 type Result + List bool + func (m *Result) GetList() bool + type SnapshotMeta struct + ClientTs uint64 + GroupId uint32 + func (*SnapshotMeta) Descriptor() ([]byte, []int) + func (*SnapshotMeta) ProtoMessage() + func (m *SnapshotMeta) GetClientTs() uint64 + func (m *SnapshotMeta) GetGroupId() uint32 + func (m *SnapshotMeta) Marshal() (dAtA []byte, err error) + func (m *SnapshotMeta) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotMeta) Reset() + func (m *SnapshotMeta) Size() (n int) + func (m *SnapshotMeta) String() string + func (m *SnapshotMeta) Unmarshal(dAtA []byte) error v1.0.1 Dec 20, 2017 v1.0.0 Dec 18, 2017 Changes in this version type Tablet + Remove bool + func (m *Tablet) GetRemove() bool v0 v0.9.4 Dec 4, 2017 v0.9.3 Dec 1, 2017 Changes in this version + var DirectedEdge_Op_name = map[int32]string + var DirectedEdge_Op_value = map[string]int32 + var ErrIntOverflowInternal = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling") + var ExportPayload_Status_name = map[int32]string + var ExportPayload_Status_value = map[string]int32 + var Posting_PostingType_name = map[int32]string + var Posting_PostingType_value = map[string]int32 + var Posting_ValType_name = map[int32]string + var Posting_ValType_value = map[string]int32 + var SchemaUpdate_Directive_name = map[int32]string + var SchemaUpdate_Directive_value = map[string]int32 + func RegisterRaftServer(s *grpc.Server, srv RaftServer) + func RegisterWorkerServer(s *grpc.Server, srv WorkerServer) + func RegisterZeroServer(s *grpc.Server, srv ZeroServer) + type ConnectionState struct + Member *Member + State *MembershipState + func (*ConnectionState) Descriptor() ([]byte, []int) + func (*ConnectionState) ProtoMessage() + func (m *ConnectionState) GetMember() *Member + func (m *ConnectionState) GetState() *MembershipState + func (m *ConnectionState) Marshal() (dAtA []byte, err error) + func (m *ConnectionState) MarshalTo(dAtA []byte) (int, error) + func (m *ConnectionState) Reset() + func (m *ConnectionState) Size() (n int) + func (m *ConnectionState) String() string + func (m *ConnectionState) Unmarshal(dAtA []byte) error + type DirectedEdge struct + Attr string + Entity uint64 + Facets []*api.Facet + Label string + Lang string + Op DirectedEdge_Op + Value []byte + ValueId uint64 + ValueType Posting_ValType + func (*DirectedEdge) Descriptor() ([]byte, []int) + func (*DirectedEdge) ProtoMessage() + func (m *DirectedEdge) GetAttr() string + func (m *DirectedEdge) GetEntity() uint64 + func (m *DirectedEdge) GetFacets() []*api.Facet + func (m *DirectedEdge) GetLabel() string + func (m *DirectedEdge) GetLang() string + func (m *DirectedEdge) GetOp() DirectedEdge_Op + func (m *DirectedEdge) GetValue() []byte + func (m *DirectedEdge) GetValueId() uint64 + func (m *DirectedEdge) GetValueType() Posting_ValType + func (m *DirectedEdge) Marshal() (dAtA []byte, err error) + func (m *DirectedEdge) MarshalTo(dAtA []byte) (int, error) + 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 int32 + const DirectedEdge_DEL + const DirectedEdge_SET + func (DirectedEdge_Op) EnumDescriptor() ([]byte, []int) + func (x DirectedEdge_Op) String() string + type ExportPayload struct + GroupId uint32 + ReadTs uint64 + ReqId uint64 + Status ExportPayload_Status + func (*ExportPayload) Descriptor() ([]byte, []int) + func (*ExportPayload) ProtoMessage() + func (m *ExportPayload) GetGroupId() uint32 + func (m *ExportPayload) GetReadTs() uint64 + func (m *ExportPayload) GetReqId() uint64 + func (m *ExportPayload) GetStatus() ExportPayload_Status + func (m *ExportPayload) Marshal() (dAtA []byte, err error) + func (m *ExportPayload) MarshalTo(dAtA []byte) (int, error) + func (m *ExportPayload) Reset() + func (m *ExportPayload) Size() (n int) + func (m *ExportPayload) String() string + func (m *ExportPayload) Unmarshal(dAtA []byte) error + type ExportPayload_Status int32 + const ExportPayload_DUPLICATE + const ExportPayload_FAILED + const ExportPayload_NONE + const ExportPayload_SUCCESS + func (ExportPayload_Status) EnumDescriptor() ([]byte, []int) + func (x ExportPayload_Status) String() string + type FacetParam struct + Alias string + Key string + func (*FacetParam) Descriptor() ([]byte, []int) + func (*FacetParam) ProtoMessage() + func (m *FacetParam) GetAlias() string + func (m *FacetParam) GetKey() string + func (m *FacetParam) Marshal() (dAtA []byte, err error) + func (m *FacetParam) MarshalTo(dAtA []byte) (int, error) + func (m *FacetParam) Reset() + func (m *FacetParam) Size() (n int) + func (m *FacetParam) String() string + func (m *FacetParam) Unmarshal(dAtA []byte) error + type FacetParams struct + AllKeys bool + Param []*FacetParam + func (*FacetParams) Descriptor() ([]byte, []int) + func (*FacetParams) ProtoMessage() + func (m *FacetParams) GetAllKeys() bool + func (m *FacetParams) GetParam() []*FacetParam + func (m *FacetParams) Marshal() (dAtA []byte, err error) + func (m *FacetParams) MarshalTo(dAtA []byte) (int, error) + func (m *FacetParams) Reset() + func (m *FacetParams) Size() (n int) + func (m *FacetParams) String() string + func (m *FacetParams) Unmarshal(dAtA []byte) error + type Facets struct + Facets []*api.Facet + func (*Facets) Descriptor() ([]byte, []int) + func (*Facets) ProtoMessage() + func (m *Facets) GetFacets() []*api.Facet + func (m *Facets) Marshal() (dAtA []byte, err error) + func (m *Facets) MarshalTo(dAtA []byte) (int, error) + func (m *Facets) Reset() + func (m *Facets) Size() (n int) + func (m *Facets) String() string + func (m *Facets) Unmarshal(dAtA []byte) error + type FacetsList struct + FacetsList []*Facets + func (*FacetsList) Descriptor() ([]byte, []int) + func (*FacetsList) ProtoMessage() + func (m *FacetsList) GetFacetsList() []*Facets + func (m *FacetsList) Marshal() (dAtA []byte, err error) + func (m *FacetsList) MarshalTo(dAtA []byte) (int, error) + func (m *FacetsList) Reset() + func (m *FacetsList) Size() (n int) + func (m *FacetsList) String() string + func (m *FacetsList) Unmarshal(dAtA []byte) error + type FilterTree struct + Children []*FilterTree + Func *Function + Op string + func (*FilterTree) Descriptor() ([]byte, []int) + func (*FilterTree) ProtoMessage() + func (m *FilterTree) GetChildren() []*FilterTree + func (m *FilterTree) GetFunc() *Function + func (m *FilterTree) GetOp() string + func (m *FilterTree) Marshal() (dAtA []byte, err error) + func (m *FilterTree) MarshalTo(dAtA []byte) (int, error) + func (m *FilterTree) Reset() + func (m *FilterTree) Size() (n int) + func (m *FilterTree) String() string + func (m *FilterTree) Unmarshal(dAtA []byte) error + type Function struct + Args []string + Key string + Name string + func (*Function) Descriptor() ([]byte, []int) + func (*Function) ProtoMessage() + func (m *Function) GetArgs() []string + func (m *Function) GetKey() string + func (m *Function) GetName() string + func (m *Function) Marshal() (dAtA []byte, err error) + func (m *Function) MarshalTo(dAtA []byte) (int, error) + func (m *Function) Reset() + func (m *Function) Size() (n int) + func (m *Function) String() string + func (m *Function) Unmarshal(dAtA []byte) error + type Group struct + Members map[uint64]*Member + Tablets map[string]*Tablet + func (*Group) Descriptor() ([]byte, []int) + func (*Group) ProtoMessage() + func (m *Group) GetMembers() map[uint64]*Member + func (m *Group) GetTablets() map[string]*Tablet + func (m *Group) Marshal() (dAtA []byte, err error) + func (m *Group) MarshalTo(dAtA []byte) (int, error) + func (m *Group) Reset() + func (m *Group) Size() (n int) + func (m *Group) String() string + func (m *Group) Unmarshal(dAtA []byte) error + type GroupKeys struct + GroupId uint32 + Keys []*KC + func (*GroupKeys) Descriptor() ([]byte, []int) + func (*GroupKeys) ProtoMessage() + 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 (m *GroupKeys) Reset() + func (m *GroupKeys) Size() (n int) + func (m *GroupKeys) String() string + func (m *GroupKeys) Unmarshal(dAtA []byte) error + type KC struct + Key []byte + Timestamp uint64 + func (*KC) Descriptor() ([]byte, []int) + func (*KC) ProtoMessage() + func (m *KC) GetKey() []byte + func (m *KC) GetTimestamp() uint64 + func (m *KC) Marshal() (dAtA []byte, err error) + func (m *KC) MarshalTo(dAtA []byte) (int, error) + func (m *KC) Reset() + func (m *KC) Size() (n int) + func (m *KC) String() string + func (m *KC) Unmarshal(dAtA []byte) error + type KV struct + Key []byte + UserMeta []byte + Val []byte + Version uint64 + func (*KV) Descriptor() ([]byte, []int) + func (*KV) ProtoMessage() + func (m *KV) GetKey() []byte + func (m *KV) GetUserMeta() []byte + func (m *KV) GetVal() []byte + func (m *KV) GetVersion() uint64 + func (m *KV) Marshal() (dAtA []byte, err error) + func (m *KV) MarshalTo(dAtA []byte) (int, error) + func (m *KV) Reset() + func (m *KV) Size() (n int) + func (m *KV) String() string + func (m *KV) Unmarshal(dAtA []byte) error + type KeyValues struct + Kv []*KV + func (*KeyValues) Descriptor() ([]byte, []int) + func (*KeyValues) ProtoMessage() + func (m *KeyValues) GetKv() []*KV + func (m *KeyValues) Marshal() (dAtA []byte, err error) + func (m *KeyValues) MarshalTo(dAtA []byte) (int, error) + func (m *KeyValues) Reset() + func (m *KeyValues) Size() (n int) + func (m *KeyValues) String() string + func (m *KeyValues) Unmarshal(dAtA []byte) error + type LangList struct + Lang []string + func (*LangList) Descriptor() ([]byte, []int) + func (*LangList) ProtoMessage() + func (m *LangList) GetLang() []string + func (m *LangList) Marshal() (dAtA []byte, err error) + func (m *LangList) MarshalTo(dAtA []byte) (int, error) + func (m *LangList) Reset() + func (m *LangList) Size() (n int) + func (m *LangList) String() string + func (m *LangList) Unmarshal(dAtA []byte) error + type List struct + Uids []uint64 + func (*List) Descriptor() ([]byte, []int) + func (*List) ProtoMessage() + func (m *List) GetUids() []uint64 + func (m *List) Marshal() (dAtA []byte, err error) + func (m *List) MarshalTo(dAtA []byte) (int, error) + func (m *List) Reset() + func (m *List) Size() (n int) + func (m *List) String() string + func (m *List) Unmarshal(dAtA []byte) error + type MapEntry struct + Key []byte + Posting *Posting + Uid uint64 + func (*MapEntry) Descriptor() ([]byte, []int) + func (*MapEntry) ProtoMessage() + func (m *MapEntry) GetKey() []byte + func (m *MapEntry) GetPosting() *Posting + func (m *MapEntry) GetUid() uint64 + func (m *MapEntry) Marshal() (dAtA []byte, err error) + func (m *MapEntry) MarshalTo(dAtA []byte) (int, error) + func (m *MapEntry) Reset() + func (m *MapEntry) Size() (n int) + func (m *MapEntry) String() string + func (m *MapEntry) Unmarshal(dAtA []byte) error + type Member struct + Addr string + AmDead bool + ClusterInfoOnly bool + GroupId uint32 + Id uint64 + LastUpdate uint64 + Leader bool + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (m *Member) GetAddr() string + func (m *Member) GetAmDead() bool + func (m *Member) GetClusterInfoOnly() bool + func (m *Member) GetGroupId() uint32 + func (m *Member) GetId() uint64 + func (m *Member) GetLastUpdate() uint64 + func (m *Member) GetLeader() bool + func (m *Member) Marshal() (dAtA []byte, err error) + func (m *Member) MarshalTo(dAtA []byte) (int, error) + func (m *Member) Reset() + func (m *Member) Size() (n int) + func (m *Member) String() string + func (m *Member) Unmarshal(dAtA []byte) error + type MembershipState struct + Counter uint64 + Groups map[uint32]*Group + MaxLeaseId uint64 + MaxRaftId uint64 + MaxTxnTs uint64 + Removed []*Member + Zeros map[uint64]*Member + func (*MembershipState) Descriptor() ([]byte, []int) + func (*MembershipState) ProtoMessage() + func (m *MembershipState) GetCounter() uint64 + func (m *MembershipState) GetGroups() map[uint32]*Group + func (m *MembershipState) GetMaxLeaseId() uint64 + func (m *MembershipState) GetMaxRaftId() uint64 + func (m *MembershipState) GetMaxTxnTs() uint64 + func (m *MembershipState) GetRemoved() []*Member + func (m *MembershipState) GetZeros() map[uint64]*Member + func (m *MembershipState) Marshal() (dAtA []byte, err error) + func (m *MembershipState) MarshalTo(dAtA []byte) (int, error) + func (m *MembershipState) Reset() + func (m *MembershipState) Size() (n int) + func (m *MembershipState) String() string + func (m *MembershipState) Unmarshal(dAtA []byte) error + type MovePredicatePayload struct + DestGroupId uint32 + Predicate string + SourceGroupId uint32 + State *MembershipState + func (*MovePredicatePayload) Descriptor() ([]byte, []int) + func (*MovePredicatePayload) ProtoMessage() + func (m *MovePredicatePayload) GetDestGroupId() uint32 + func (m *MovePredicatePayload) GetPredicate() string + func (m *MovePredicatePayload) GetSourceGroupId() uint32 + func (m *MovePredicatePayload) GetState() *MembershipState + func (m *MovePredicatePayload) Marshal() (dAtA []byte, err error) + func (m *MovePredicatePayload) MarshalTo(dAtA []byte) (int, error) + func (m *MovePredicatePayload) Reset() + func (m *MovePredicatePayload) Size() (n int) + func (m *MovePredicatePayload) String() string + func (m *MovePredicatePayload) Unmarshal(dAtA []byte) error + type Mutations struct + DropAll bool + Edges []*DirectedEdge + GroupId uint32 + IgnoreIndexConflict bool + Schema []*SchemaUpdate + StartTs uint64 + func (*Mutations) Descriptor() ([]byte, []int) + func (*Mutations) ProtoMessage() + func (m *Mutations) GetDropAll() bool + func (m *Mutations) GetEdges() []*DirectedEdge + func (m *Mutations) GetGroupId() uint32 + func (m *Mutations) GetIgnoreIndexConflict() bool + func (m *Mutations) GetSchema() []*SchemaUpdate + func (m *Mutations) GetStartTs() uint64 + func (m *Mutations) Marshal() (dAtA []byte, err error) + func (m *Mutations) MarshalTo(dAtA []byte) (int, error) + func (m *Mutations) Reset() + func (m *Mutations) Size() (n int) + func (m *Mutations) String() string + func (m *Mutations) Unmarshal(dAtA []byte) error + type Num struct + Val uint64 + func (*Num) Descriptor() ([]byte, []int) + func (*Num) ProtoMessage() + func (m *Num) GetVal() uint64 + func (m *Num) Marshal() (dAtA []byte, err error) + func (m *Num) MarshalTo(dAtA []byte) (int, error) + func (m *Num) Reset() + func (m *Num) Size() (n int) + func (m *Num) String() string + func (m *Num) Unmarshal(dAtA []byte) error + type OracleDelta struct + Aborts []uint64 + Commits map[uint64]uint64 + MaxPending uint64 + func (*OracleDelta) Descriptor() ([]byte, []int) + func (*OracleDelta) ProtoMessage() + func (m *OracleDelta) GetAborts() []uint64 + func (m *OracleDelta) GetCommits() map[uint64]uint64 + func (m *OracleDelta) GetMaxPending() uint64 + func (m *OracleDelta) Marshal() (dAtA []byte, err error) + func (m *OracleDelta) MarshalTo(dAtA []byte) (int, error) + func (m *OracleDelta) Reset() + func (m *OracleDelta) Size() (n int) + func (m *OracleDelta) String() string + func (m *OracleDelta) Unmarshal(dAtA []byte) error + type Order struct + Attr string + Desc bool + Langs []string + func (*Order) Descriptor() ([]byte, []int) + func (*Order) ProtoMessage() + func (m *Order) GetAttr() string + func (m *Order) GetDesc() bool + func (m *Order) GetLangs() []string + func (m *Order) Marshal() (dAtA []byte, err error) + func (m *Order) MarshalTo(dAtA []byte) (int, error) + func (m *Order) Reset() + func (m *Order) Size() (n int) + func (m *Order) String() string + func (m *Order) Unmarshal(dAtA []byte) error + type Posting struct + CommitTs uint64 + Facets []*api.Facet + Label string + LangTag []byte + Op uint32 + PostingType Posting_PostingType + StartTs uint64 + Uid uint64 + ValType Posting_ValType + Value []byte + func (*Posting) Descriptor() ([]byte, []int) + func (*Posting) ProtoMessage() + func (m *Posting) GetCommitTs() uint64 + func (m *Posting) GetFacets() []*api.Facet + func (m *Posting) GetLabel() string + func (m *Posting) GetLangTag() []byte + func (m *Posting) GetOp() uint32 + func (m *Posting) GetPostingType() Posting_PostingType + func (m *Posting) GetStartTs() uint64 + func (m *Posting) GetUid() uint64 + func (m *Posting) GetValType() Posting_ValType + func (m *Posting) GetValue() []byte + func (m *Posting) Marshal() (dAtA []byte, err error) + func (m *Posting) MarshalTo(dAtA []byte) (int, error) + func (m *Posting) Reset() + func (m *Posting) Size() (n int) + func (m *Posting) String() string + func (m *Posting) Unmarshal(dAtA []byte) error + type PostingList struct + Checksum []byte + Commit uint64 + Postings []*Posting + Uids []byte + func (*PostingList) Descriptor() ([]byte, []int) + func (*PostingList) ProtoMessage() + func (m *PostingList) GetChecksum() []byte + func (m *PostingList) GetCommit() uint64 + func (m *PostingList) GetPostings() []*Posting + func (m *PostingList) GetUids() []byte + func (m *PostingList) Marshal() (dAtA []byte, err error) + func (m *PostingList) MarshalTo(dAtA []byte) (int, error) + func (m *PostingList) Reset() + func (m *PostingList) Size() (n int) + func (m *PostingList) String() string + func (m *PostingList) Unmarshal(dAtA []byte) error + type Posting_PostingType int32 + const Posting_REF + const Posting_VALUE + const Posting_VALUE_LANG + func (Posting_PostingType) EnumDescriptor() ([]byte, []int) + func (x Posting_PostingType) String() string + type Posting_ValType int32 + const Posting_BINARY + const Posting_BOOL + const Posting_DATETIME + const Posting_DEFAULT + const Posting_FLOAT + const Posting_GEO + const Posting_INT + const Posting_PASSWORD + const Posting_STRING + const Posting_UID + func (Posting_ValType) EnumDescriptor() ([]byte, []int) + func (x Posting_ValType) String() string + type Proposal struct + CleanPredicate string + Id uint32 + Kv []*KV + Mutations *Mutations + State *MembershipState + TxnContext *api.TxnContext + func (*Proposal) Descriptor() ([]byte, []int) + func (*Proposal) ProtoMessage() + func (m *Proposal) GetCleanPredicate() string + func (m *Proposal) GetId() uint32 + func (m *Proposal) GetKv() []*KV + func (m *Proposal) GetMutations() *Mutations + func (m *Proposal) GetState() *MembershipState + func (m *Proposal) GetTxnContext() *api.TxnContext + func (m *Proposal) Marshal() (dAtA []byte, err error) + func (m *Proposal) MarshalTo(dAtA []byte) (int, error) + func (m *Proposal) Reset() + func (m *Proposal) Size() (n int) + func (m *Proposal) String() string + func (m *Proposal) Unmarshal(dAtA []byte) error + type Query struct + AfterUid uint64 + Attr string + DoCount bool + ExpandAll bool + FacetParam *FacetParams + FacetsFilter *FilterTree + Langs []string + LinRead *api.LinRead + ReadTs uint64 + Reverse bool + SrcFunc *SrcFunction + UidList *List + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetAfterUid() uint64 + func (m *Query) GetAttr() string + func (m *Query) GetDoCount() bool + func (m *Query) GetExpandAll() bool + func (m *Query) GetFacetParam() *FacetParams + func (m *Query) GetFacetsFilter() *FilterTree + func (m *Query) GetLangs() []string + func (m *Query) GetLinRead() *api.LinRead + func (m *Query) GetReadTs() uint64 + func (m *Query) GetReverse() bool + func (m *Query) GetSrcFunc() *SrcFunction + func (m *Query) GetUidList() *List + func (m *Query) Marshal() (dAtA []byte, err error) + func (m *Query) MarshalTo(dAtA []byte) (int, error) + func (m *Query) Reset() + func (m *Query) Size() (n int) + func (m *Query) String() string + func (m *Query) Unmarshal(dAtA []byte) error + type RaftClient interface + Echo func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*api.Payload, error) + JoinCluster func(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*api.Payload, error) + RaftMessage func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*api.Payload, error) + func NewRaftClient(cc *grpc.ClientConn) RaftClient + type RaftContext struct + Addr string + Group uint32 + Id uint64 + func (*RaftContext) Descriptor() ([]byte, []int) + func (*RaftContext) ProtoMessage() + 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 (m *RaftContext) Reset() + func (m *RaftContext) Size() (n int) + func (m *RaftContext) String() string + func (m *RaftContext) Unmarshal(dAtA []byte) error + type RaftServer interface + Echo func(context.Context, *api.Payload) (*api.Payload, error) + JoinCluster func(context.Context, *RaftContext) (*api.Payload, error) + RaftMessage func(context.Context, *api.Payload) (*api.Payload, error) + type Result struct + Counts []uint32 + FacetMatrix []*FacetsList + IntersectDest bool + LangMatrix []*LangList + LinRead *api.LinRead + UidMatrix []*List + ValueMatrix []*ValueList + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (m *Result) GetCounts() []uint32 + func (m *Result) GetFacetMatrix() []*FacetsList + func (m *Result) GetIntersectDest() bool + func (m *Result) GetLangMatrix() []*LangList + func (m *Result) GetLinRead() *api.LinRead + func (m *Result) GetUidMatrix() []*List + func (m *Result) GetValueMatrix() []*ValueList + func (m *Result) Marshal() (dAtA []byte, err error) + func (m *Result) MarshalTo(dAtA []byte) (int, error) + func (m *Result) Reset() + func (m *Result) Size() (n int) + func (m *Result) String() string + func (m *Result) Unmarshal(dAtA []byte) error + type SchemaRequest struct + Fields []string + GroupId uint32 + Predicates []string + func (*SchemaRequest) Descriptor() ([]byte, []int) + func (*SchemaRequest) ProtoMessage() + func (m *SchemaRequest) GetFields() []string + func (m *SchemaRequest) GetGroupId() uint32 + func (m *SchemaRequest) GetPredicates() []string + func (m *SchemaRequest) Marshal() (dAtA []byte, err error) + func (m *SchemaRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SchemaRequest) Reset() + func (m *SchemaRequest) Size() (n int) + func (m *SchemaRequest) String() string + func (m *SchemaRequest) Unmarshal(dAtA []byte) error + type SchemaResult struct + Schema []*api.SchemaNode + func (*SchemaResult) Descriptor() ([]byte, []int) + func (*SchemaResult) ProtoMessage() + func (m *SchemaResult) GetSchema() []*api.SchemaNode + func (m *SchemaResult) Marshal() (dAtA []byte, err error) + func (m *SchemaResult) MarshalTo(dAtA []byte) (int, error) + func (m *SchemaResult) Reset() + func (m *SchemaResult) Size() (n int) + func (m *SchemaResult) String() string + func (m *SchemaResult) Unmarshal(dAtA []byte) error + type SchemaUpdate struct + Count bool + Directive SchemaUpdate_Directive + Explicit bool + List bool + Predicate string + Tokenizer []string + ValueType Posting_ValType + func (*SchemaUpdate) Descriptor() ([]byte, []int) + func (*SchemaUpdate) ProtoMessage() + func (m *SchemaUpdate) GetCount() bool + func (m *SchemaUpdate) GetDirective() SchemaUpdate_Directive + func (m *SchemaUpdate) GetExplicit() bool + func (m *SchemaUpdate) GetList() bool + func (m *SchemaUpdate) GetPredicate() string + func (m *SchemaUpdate) GetTokenizer() []string + func (m *SchemaUpdate) GetValueType() Posting_ValType + func (m *SchemaUpdate) Marshal() (dAtA []byte, err error) + func (m *SchemaUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *SchemaUpdate) Reset() + func (m *SchemaUpdate) Size() (n int) + func (m *SchemaUpdate) String() string + func (m *SchemaUpdate) Unmarshal(dAtA []byte) error + type SchemaUpdate_Directive int32 + const SchemaUpdate_DELETE + const SchemaUpdate_INDEX + const SchemaUpdate_NONE + const SchemaUpdate_REVERSE + func (SchemaUpdate_Directive) EnumDescriptor() ([]byte, []int) + func (x SchemaUpdate_Directive) String() string + type SortMessage struct + Count int32 + LinRead *api.LinRead + Offset int32 + Order []*Order + ReadTs uint64 + UidMatrix []*List + func (*SortMessage) Descriptor() ([]byte, []int) + func (*SortMessage) ProtoMessage() + func (m *SortMessage) GetCount() int32 + func (m *SortMessage) GetLinRead() *api.LinRead + func (m *SortMessage) GetOffset() int32 + func (m *SortMessage) GetOrder() []*Order + func (m *SortMessage) GetReadTs() uint64 + func (m *SortMessage) GetUidMatrix() []*List + func (m *SortMessage) Marshal() (dAtA []byte, err error) + func (m *SortMessage) MarshalTo(dAtA []byte) (int, error) + func (m *SortMessage) Reset() + func (m *SortMessage) Size() (n int) + func (m *SortMessage) String() string + func (m *SortMessage) Unmarshal(dAtA []byte) error + type SortResult struct + LinRead *api.LinRead + UidMatrix []*List + func (*SortResult) Descriptor() ([]byte, []int) + func (*SortResult) ProtoMessage() + func (m *SortResult) GetLinRead() *api.LinRead + func (m *SortResult) GetUidMatrix() []*List + func (m *SortResult) Marshal() (dAtA []byte, err error) + func (m *SortResult) MarshalTo(dAtA []byte) (int, error) + func (m *SortResult) Reset() + func (m *SortResult) Size() (n int) + func (m *SortResult) String() string + func (m *SortResult) Unmarshal(dAtA []byte) error + type SrcFunction struct + Args []string + IsCount bool + Name string + func (*SrcFunction) Descriptor() ([]byte, []int) + func (*SrcFunction) ProtoMessage() + func (m *SrcFunction) GetArgs() []string + func (m *SrcFunction) GetIsCount() bool + func (m *SrcFunction) GetName() string + func (m *SrcFunction) Marshal() (dAtA []byte, err error) + func (m *SrcFunction) MarshalTo(dAtA []byte) (int, error) + func (m *SrcFunction) Reset() + func (m *SrcFunction) Size() (n int) + func (m *SrcFunction) String() string + func (m *SrcFunction) Unmarshal(dAtA []byte) error + type Tablet struct + Force bool + GroupId uint32 + Predicate string + ReadOnly bool + Space int64 + func (*Tablet) Descriptor() ([]byte, []int) + func (*Tablet) ProtoMessage() + func (m *Tablet) GetForce() bool + func (m *Tablet) GetGroupId() uint32 + func (m *Tablet) GetPredicate() string + func (m *Tablet) GetReadOnly() bool + func (m *Tablet) GetSpace() int64 + func (m *Tablet) Marshal() (dAtA []byte, err error) + func (m *Tablet) MarshalTo(dAtA []byte) (int, error) + func (m *Tablet) Reset() + func (m *Tablet) Size() (n int) + func (m *Tablet) String() string + func (m *Tablet) Unmarshal(dAtA []byte) error + type TaskValue struct + Val []byte + ValType Posting_ValType + func (*TaskValue) Descriptor() ([]byte, []int) + func (*TaskValue) ProtoMessage() + func (m *TaskValue) GetVal() []byte + func (m *TaskValue) GetValType() Posting_ValType + func (m *TaskValue) Marshal() (dAtA []byte, err error) + func (m *TaskValue) MarshalTo(dAtA []byte) (int, error) + func (m *TaskValue) Reset() + func (m *TaskValue) Size() (n int) + func (m *TaskValue) String() string + func (m *TaskValue) Unmarshal(dAtA []byte) error + type TxnTimestamps struct + Ts []uint64 + func (*TxnTimestamps) Descriptor() ([]byte, []int) + func (*TxnTimestamps) ProtoMessage() + func (m *TxnTimestamps) GetTs() []uint64 + func (m *TxnTimestamps) Marshal() (dAtA []byte, err error) + func (m *TxnTimestamps) MarshalTo(dAtA []byte) (int, error) + func (m *TxnTimestamps) Reset() + func (m *TxnTimestamps) Size() (n int) + func (m *TxnTimestamps) String() string + func (m *TxnTimestamps) Unmarshal(dAtA []byte) error + type ValueList struct + Values []*TaskValue + func (*ValueList) Descriptor() ([]byte, []int) + func (*ValueList) ProtoMessage() + func (m *ValueList) GetValues() []*TaskValue + func (m *ValueList) Marshal() (dAtA []byte, err error) + func (m *ValueList) MarshalTo(dAtA []byte) (int, error) + func (m *ValueList) Reset() + func (m *ValueList) Size() (n int) + func (m *ValueList) String() string + func (m *ValueList) Unmarshal(dAtA []byte) error + type WorkerClient interface + CommitOrAbort func(ctx context.Context, in *api.TxnContext, opts ...grpc.CallOption) (*api.Payload, error) + Export func(ctx context.Context, in *ExportPayload, opts ...grpc.CallOption) (*ExportPayload, error) + MinTxnTs func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*Num, error) + MovePredicate func(ctx context.Context, in *MovePredicatePayload, opts ...grpc.CallOption) (*api.Payload, error) + Mutate func(ctx context.Context, in *Mutations, opts ...grpc.CallOption) (*api.TxnContext, error) + PredicateAndSchemaData func(ctx context.Context, opts ...grpc.CallOption) (Worker_PredicateAndSchemaDataClient, error) + ReceivePredicate func(ctx context.Context, opts ...grpc.CallOption) (Worker_ReceivePredicateClient, error) + Schema func(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaResult, error) + ServeTask func(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Result, error) + Sort func(ctx context.Context, in *SortMessage, opts ...grpc.CallOption) (*SortResult, error) + func NewWorkerClient(cc *grpc.ClientConn) WorkerClient + type WorkerServer interface + CommitOrAbort func(context.Context, *api.TxnContext) (*api.Payload, error) + Export func(context.Context, *ExportPayload) (*ExportPayload, error) + MinTxnTs func(context.Context, *api.Payload) (*Num, error) + MovePredicate func(context.Context, *MovePredicatePayload) (*api.Payload, error) + Mutate func(context.Context, *Mutations) (*api.TxnContext, error) + PredicateAndSchemaData func(Worker_PredicateAndSchemaDataServer) error + ReceivePredicate func(Worker_ReceivePredicateServer) error + Schema func(context.Context, *SchemaRequest) (*SchemaResult, error) + ServeTask func(context.Context, *Query) (*Result, error) + Sort func(context.Context, *SortMessage) (*SortResult, error) + type Worker_PredicateAndSchemaDataClient interface + Recv func() (*KV, error) + Send func(*GroupKeys) error + type Worker_PredicateAndSchemaDataServer interface + Recv func() (*GroupKeys, error) + Send func(*KV) error + type Worker_ReceivePredicateClient interface + CloseAndRecv func() (*api.Payload, error) + Send func(*KV) error + type Worker_ReceivePredicateServer interface + Recv func() (*KV, error) + SendAndClose func(*api.Payload) error + type ZeroClient interface + AssignUids func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*api.AssignedIds, error) + CommitOrAbort func(ctx context.Context, in *api.TxnContext, opts ...grpc.CallOption) (*api.TxnContext, error) + Connect func(ctx context.Context, in *Member, opts ...grpc.CallOption) (*ConnectionState, error) + Oracle func(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (Zero_OracleClient, error) + ShouldServe func(ctx context.Context, in *Tablet, opts ...grpc.CallOption) (*Tablet, error) + Timestamps func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*api.AssignedIds, error) + TryAbort func(ctx context.Context, in *TxnTimestamps, opts ...grpc.CallOption) (*TxnTimestamps, error) + Update func(ctx context.Context, opts ...grpc.CallOption) (Zero_UpdateClient, error) + func NewZeroClient(cc *grpc.ClientConn) ZeroClient + type ZeroProposal struct + Id uint32 + MaxLeaseId uint64 + MaxRaftId uint64 + MaxTxnTs uint64 + Member *Member + Tablet *Tablet + Txn *api.TxnContext + func (*ZeroProposal) Descriptor() ([]byte, []int) + func (*ZeroProposal) ProtoMessage() + func (m *ZeroProposal) GetId() uint32 + func (m *ZeroProposal) GetMaxLeaseId() uint64 + func (m *ZeroProposal) GetMaxRaftId() uint64 + func (m *ZeroProposal) GetMaxTxnTs() uint64 + func (m *ZeroProposal) GetMember() *Member + func (m *ZeroProposal) GetTablet() *Tablet + func (m *ZeroProposal) GetTxn() *api.TxnContext + func (m *ZeroProposal) Marshal() (dAtA []byte, err error) + func (m *ZeroProposal) MarshalTo(dAtA []byte) (int, error) + func (m *ZeroProposal) Reset() + func (m *ZeroProposal) Size() (n int) + func (m *ZeroProposal) String() string + func (m *ZeroProposal) Unmarshal(dAtA []byte) error + type ZeroServer interface + AssignUids func(context.Context, *Num) (*api.AssignedIds, error) + CommitOrAbort func(context.Context, *api.TxnContext) (*api.TxnContext, error) + Connect func(context.Context, *Member) (*ConnectionState, error) + Oracle func(*api.Payload, Zero_OracleServer) error + ShouldServe func(context.Context, *Tablet) (*Tablet, error) + Timestamps func(context.Context, *Num) (*api.AssignedIds, error) + TryAbort func(context.Context, *TxnTimestamps) (*TxnTimestamps, error) + Update func(Zero_UpdateServer) error + type Zero_OracleClient interface + Recv func() (*OracleDelta, error) + type Zero_OracleServer interface + Send func(*OracleDelta) error + type Zero_UpdateClient interface + Recv func() (*MembershipState, error) + Send func(*Group) error + type Zero_UpdateServer interface + Recv func() (*Group, error) + Send func(*MembershipState) error
Go to main page