Versions in this module Expand all Collapse all v0 v0.8.3 Oct 9, 2017 Changes in this version + func RegisterRaftServer(s *grpc.Server, srv RaftServer) + func RegisterZeroServer(s *grpc.Server, srv ZeroServer) + 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 KV + UserMeta []byte + func (m *KV) GetUserMeta() []byte + 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 Member struct + Addr string + AmDead 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) 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 + 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) 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 Mutation + DeleteJson []byte + DropAll bool + SetJson []byte + func (m *Mutation) GetDeleteJson() []byte + func (m *Mutation) GetDropAll() bool + func (m *Mutation) GetSetJson() []byte type Mutations + DropAll bool + func (m *Mutations) GetDropAll() bool type Order + Langs []string + func (m *Order) GetLangs() []string type Proposal + CleanPredicate string + Kv []*KV + State *MembershipState + func (m *Proposal) GetCleanPredicate() string + func (m *Proposal) GetKv() []*KV + func (m *Proposal) GetState() *MembershipState + type RaftClient interface + Echo func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error) + JoinCluster func(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*Payload, error) + RaftMessage func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error) + func NewRaftClient(cc *grpc.ClientConn) RaftClient + type RaftServer interface + Echo func(context.Context, *Payload) (*Payload, error) + JoinCluster func(context.Context, *RaftContext) (*Payload, error) + RaftMessage func(context.Context, *Payload) (*Payload, 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 WorkerClient + MovePredicate func(ctx context.Context, in *MovePredicatePayload, opts ...grpc.CallOption) (*Payload, error) + ReceivePredicate func(ctx context.Context, opts ...grpc.CallOption) (Worker_ReceivePredicateClient, error) type WorkerServer + MovePredicate func(context.Context, *MovePredicatePayload) (*Payload, error) + ReceivePredicate func(Worker_ReceivePredicateServer) error + type Worker_ReceivePredicateClient interface + CloseAndRecv func() (*Payload, error) + Send func(*KV) error + type Worker_ReceivePredicateServer interface + Recv func() (*KV, error) + SendAndClose func(*Payload) error + type ZeroClient interface + AssignUids func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error) + Connect func(ctx context.Context, in *Member, opts ...grpc.CallOption) (*MembershipState, error) + ShouldServe func(ctx context.Context, in *Tablet, opts ...grpc.CallOption) (*Tablet, 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 + Member *Member + Tablet *Tablet + func (*ZeroProposal) Descriptor() ([]byte, []int) + func (*ZeroProposal) ProtoMessage() + func (m *ZeroProposal) GetId() uint32 + func (m *ZeroProposal) GetMaxLeaseId() uint64 + func (m *ZeroProposal) GetMember() *Member + func (m *ZeroProposal) GetTablet() *Tablet + 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) (*AssignedIds, error) + Connect func(context.Context, *Member) (*MembershipState, error) + ShouldServe func(context.Context, *Tablet) (*Tablet, error) + Update func(Zero_UpdateServer) 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 v0.8.2 Sep 20, 2017 Changes in this version + var DirectedEdge_Op_name = map[int32]string + var DirectedEdge_Op_value = map[string]int32 + var ErrIntOverflowBulkloader = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowFacets = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowGraphresponse = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowPayload = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSchema = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowTask = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthBulkloader = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthFacets = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthGraphresponse = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthPayload = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling") + var ExportPayload_Status_name = map[int32]string + var ExportPayload_Status_value = map[string]int32 + var Facet_ValType_name = map[int32]string + var Facet_ValType_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 RegisterDgraphServer(s *grpc.Server, srv DgraphServer) + func RegisterWorkerServer(s *grpc.Server, srv WorkerServer) + type AssignedIds struct + EndId uint64 + StartId uint64 + func (*AssignedIds) Descriptor() ([]byte, []int) + func (*AssignedIds) ProtoMessage() + func (m *AssignedIds) GetEndId() uint64 + func (m *AssignedIds) GetStartId() uint64 + func (m *AssignedIds) Marshal() (dAtA []byte, err error) + func (m *AssignedIds) MarshalTo(dAtA []byte) (int, error) + func (m *AssignedIds) Reset() + func (m *AssignedIds) Size() (n int) + func (m *AssignedIds) String() string + func (m *AssignedIds) Unmarshal(dAtA []byte) error + type Check struct + func (*Check) Descriptor() ([]byte, []int) + func (*Check) ProtoMessage() + func (m *Check) Marshal() (dAtA []byte, err error) + func (m *Check) MarshalTo(dAtA []byte) (int, error) + func (m *Check) Reset() + func (m *Check) Size() (n int) + func (m *Check) String() string + func (m *Check) Unmarshal(dAtA []byte) error + type DgraphClient interface + AssignUids func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error) + CheckVersion func(ctx context.Context, in *Check, opts ...grpc.CallOption) (*Version, error) + Run func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + func NewDgraphClient(cc *grpc.ClientConn) DgraphClient + type DgraphServer interface + AssignUids func(context.Context, *Num) (*AssignedIds, error) + CheckVersion func(context.Context, *Check) (*Version, error) + Run func(context.Context, *Request) (*Response, error) + type DirectedEdge struct + Attr string + Entity uint64 + Facets []*Facet + Label string + Lang string + Op DirectedEdge_Op + Value []byte + ValueId uint64 + ValueType uint32 + func (*DirectedEdge) Descriptor() ([]byte, []int) + func (*DirectedEdge) ProtoMessage() + func (m *DirectedEdge) GetAttr() string + func (m *DirectedEdge) GetEntity() uint64 + func (m *DirectedEdge) GetFacets() []*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() uint32 + 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 + ReqId uint64 + Status ExportPayload_Status + func (*ExportPayload) Descriptor() ([]byte, []int) + func (*ExportPayload) ProtoMessage() + func (m *ExportPayload) GetGroupId() uint32 + 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 Facet struct + Key string + Tokens []string + Val string + ValType Facet_ValType + Value []byte + func (*Facet) Descriptor() ([]byte, []int) + func (*Facet) ProtoMessage() + func (m *Facet) GetKey() string + func (m *Facet) GetTokens() []string + func (m *Facet) GetVal() string + func (m *Facet) GetValType() Facet_ValType + func (m *Facet) GetValue() []byte + func (m *Facet) Marshal() (dAtA []byte, err error) + func (m *Facet) MarshalTo(dAtA []byte) (int, error) + func (m *Facet) Reset() + func (m *Facet) Size() (n int) + func (m *Facet) String() string + func (m *Facet) Unmarshal(dAtA []byte) error + type Facet_ValType int32 + const Facet_BOOL + const Facet_DATETIME + const Facet_FLOAT + const Facet_INT + const Facet_STRING + func (Facet_ValType) EnumDescriptor() ([]byte, []int) + func (x Facet_ValType) String() string + type Facets struct + Facets []*Facet + func (*Facets) Descriptor() ([]byte, []int) + func (*Facets) ProtoMessage() + func (m *Facets) GetFacets() []*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 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 + Checksum []byte + Key []byte + func (*KC) Descriptor() ([]byte, []int) + func (*KC) ProtoMessage() + 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 (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 + Val []byte + func (*KV) Descriptor() ([]byte, []int) + func (*KV) ProtoMessage() + 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 (m *KV) Reset() + func (m *KV) Size() (n int) + func (m *KV) String() string + func (m *KV) Unmarshal(dAtA []byte) error + type Latency struct + Parsing string + Pb string + Processing string + func (*Latency) Descriptor() ([]byte, []int) + func (*Latency) ProtoMessage() + func (m *Latency) GetParsing() string + func (m *Latency) GetPb() string + func (m *Latency) GetProcessing() string + func (m *Latency) Marshal() (dAtA []byte, err error) + func (m *Latency) MarshalTo(dAtA []byte) (int, error) + func (m *Latency) Reset() + func (m *Latency) Size() (n int) + func (m *Latency) String() string + func (m *Latency) 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 Membership struct + Addr string + AmDead bool + GroupId uint32 + Id uint64 + LastUpdate uint64 + Leader bool + func (*Membership) Descriptor() ([]byte, []int) + func (*Membership) ProtoMessage() + 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 (m *Membership) Reset() + func (m *Membership) Size() (n int) + func (m *Membership) String() string + func (m *Membership) Unmarshal(dAtA []byte) error + type MembershipUpdate struct + LastUpdate uint64 + Members []*Membership + Redirect bool + RedirectAddr string + func (*MembershipUpdate) Descriptor() ([]byte, []int) + func (*MembershipUpdate) ProtoMessage() + 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 (m *MembershipUpdate) Reset() + func (m *MembershipUpdate) Size() (n int) + func (m *MembershipUpdate) String() string + func (m *MembershipUpdate) Unmarshal(dAtA []byte) error + type Mutation struct + Del []*NQuad + Schema []*SchemaUpdate + Set []*NQuad + func (*Mutation) Descriptor() ([]byte, []int) + func (*Mutation) ProtoMessage() + func (m *Mutation) GetDel() []*NQuad + func (m *Mutation) GetSchema() []*SchemaUpdate + func (m *Mutation) GetSet() []*NQuad + func (m *Mutation) Marshal() (dAtA []byte, err error) + func (m *Mutation) MarshalTo(dAtA []byte) (int, error) + func (m *Mutation) Reset() + func (m *Mutation) Size() (n int) + func (m *Mutation) String() string + func (m *Mutation) Unmarshal(dAtA []byte) error + type Mutations struct + Edges []*DirectedEdge + GroupId uint32 + Schema []*SchemaUpdate + Upsert *Query + func (*Mutations) Descriptor() ([]byte, []int) + func (*Mutations) ProtoMessage() + func (m *Mutations) GetEdges() []*DirectedEdge + func (m *Mutations) GetGroupId() uint32 + func (m *Mutations) GetSchema() []*SchemaUpdate + func (m *Mutations) GetUpsert() *Query + 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 NQuad struct + Facets []*Facet + Label string + Lang string + ObjectId string + ObjectType int32 + ObjectValue *Value + ObjectVar string + Predicate string + Subject string + SubjectVar string + func (*NQuad) Descriptor() ([]byte, []int) + func (*NQuad) ProtoMessage() + func (m *NQuad) GetFacets() []*Facet + func (m *NQuad) GetLabel() string + func (m *NQuad) GetLang() string + func (m *NQuad) GetObjectId() string + func (m *NQuad) GetObjectType() int32 + func (m *NQuad) GetObjectValue() *Value + func (m *NQuad) GetObjectVar() string + func (m *NQuad) GetPredicate() string + func (m *NQuad) GetSubject() string + func (m *NQuad) GetSubjectVar() string + func (m *NQuad) Marshal() (dAtA []byte, err error) + func (m *NQuad) MarshalTo(dAtA []byte) (int, error) + func (m *NQuad) Reset() + func (m *NQuad) Size() (n int) + func (m *NQuad) String() string + func (m *NQuad) Unmarshal(dAtA []byte) error + type Node struct + Attribute string + Children []*Node + Properties []*Property + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetAttribute() string + func (m *Node) GetChildren() []*Node + func (m *Node) GetProperties() []*Property + func (m *Node) Marshal() (dAtA []byte, err error) + func (m *Node) MarshalTo(dAtA []byte) (int, error) + func (m *Node) Reset() + func (m *Node) Size() (n int) + func (m *Node) String() string + func (m *Node) 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 Order struct + Attr string + Desc bool + func (*Order) Descriptor() ([]byte, []int) + func (*Order) ProtoMessage() + func (m *Order) GetAttr() string + func (m *Order) GetDesc() bool + 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 Param struct + AllKeys bool + Keys []string + func (*Param) Descriptor() ([]byte, []int) + func (*Param) ProtoMessage() + func (m *Param) GetAllKeys() bool + func (m *Param) GetKeys() []string + func (m *Param) Marshal() (dAtA []byte, err error) + func (m *Param) MarshalTo(dAtA []byte) (int, error) + func (m *Param) Reset() + func (m *Param) Size() (n int) + func (m *Param) String() string + func (m *Param) Unmarshal(dAtA []byte) error + type Payload struct + Data []byte + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (m *Payload) GetData() []byte + func (m *Payload) Marshal() (dAtA []byte, err error) + func (m *Payload) MarshalTo(dAtA []byte) (int, error) + func (m *Payload) Reset() + func (m *Payload) Size() (n int) + func (m *Payload) String() string + func (m *Payload) Unmarshal(dAtA []byte) error + type Posting struct + Commit uint64 + Facets []*Facet + Label string + Metadata []byte + Op uint32 + PostingType Posting_PostingType + Uid uint64 + ValType Posting_ValType + Value []byte + func (*Posting) Descriptor() ([]byte, []int) + func (*Posting) ProtoMessage() + func (m *Posting) GetCommit() uint64 + func (m *Posting) GetFacets() []*Facet + func (m *Posting) GetLabel() string + func (m *Posting) GetMetadata() []byte + func (m *Posting) GetOp() uint32 + func (m *Posting) GetPostingType() Posting_PostingType + 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 Property struct + Prop string + Value *Value + func (*Property) Descriptor() ([]byte, []int) + func (*Property) ProtoMessage() + func (m *Property) GetProp() string + func (m *Property) GetValue() *Value + func (m *Property) Marshal() (dAtA []byte, err error) + func (m *Property) MarshalTo(dAtA []byte) (int, error) + func (m *Property) Reset() + func (m *Property) Size() (n int) + func (m *Property) String() string + func (m *Property) Unmarshal(dAtA []byte) error + type Proposal struct + Id uint32 + Membership *Membership + Mutations *Mutations + func (*Proposal) Descriptor() ([]byte, []int) + func (*Proposal) ProtoMessage() + func (m *Proposal) GetId() uint32 + func (m *Proposal) GetMembership() *Membership + func (m *Proposal) GetMutations() *Mutations + 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 + FacetParam *Param + FacetsFilter *FilterTree + Langs []string + 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) GetFacetParam() *Param + func (m *Query) GetFacetsFilter() *FilterTree + func (m *Query) GetLangs() []string + 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 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 Request struct + Mutation *Mutation + Query string + Schema *SchemaRequest + Vars map[string]string + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetMutation() *Mutation + func (m *Request) GetQuery() string + func (m *Request) GetSchema() *SchemaRequest + func (m *Request) GetVars() map[string]string + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + type Response struct + AssignedUids map[string]uint64 + L *Latency + N []*Node + Schema []*SchemaNode + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetAssignedUids() map[string]uint64 + func (m *Response) GetL() *Latency + func (m *Response) GetN() []*Node + func (m *Response) GetSchema() []*SchemaNode + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + type Result struct + Counts []uint32 + FacetMatrix []*FacetsList + IntersectDest bool + 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) 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 SchemaNode struct + Count bool + Index bool + List bool + Predicate string + Reverse bool + Tokenizer []string + Type string + func (*SchemaNode) Descriptor() ([]byte, []int) + func (*SchemaNode) ProtoMessage() + func (m *SchemaNode) GetCount() bool + func (m *SchemaNode) GetIndex() bool + func (m *SchemaNode) GetList() bool + func (m *SchemaNode) GetPredicate() string + func (m *SchemaNode) GetReverse() bool + func (m *SchemaNode) GetTokenizer() []string + func (m *SchemaNode) GetType() string + func (m *SchemaNode) Marshal() (dAtA []byte, err error) + func (m *SchemaNode) MarshalTo(dAtA []byte) (int, error) + func (m *SchemaNode) Reset() + func (m *SchemaNode) Size() (n int) + func (m *SchemaNode) String() string + func (m *SchemaNode) 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 []*SchemaNode + func (*SchemaResult) Descriptor() ([]byte, []int) + func (*SchemaResult) ProtoMessage() + func (m *SchemaResult) GetSchema() []*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 uint32 + 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() uint32 + 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 + Langs []string + Offset int32 + Order []*Order + UidMatrix []*List + func (*SortMessage) Descriptor() ([]byte, []int) + func (*SortMessage) ProtoMessage() + func (m *SortMessage) GetCount() int32 + func (m *SortMessage) GetLangs() []string + func (m *SortMessage) GetOffset() int32 + func (m *SortMessage) GetOrder() []*Order + 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 + UidMatrix []*List + func (*SortResult) Descriptor() ([]byte, []int) + func (*SortResult) ProtoMessage() + 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 TaskValue struct + Val []byte + ValType int32 + func (*TaskValue) Descriptor() ([]byte, []int) + func (*TaskValue) ProtoMessage() + func (m *TaskValue) GetVal() []byte + func (m *TaskValue) GetValType() int32 + 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 Value struct + Val isValue_Val + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *Value) GetBoolVal() bool + func (m *Value) GetBytesVal() []byte + func (m *Value) GetDateVal() []byte + func (m *Value) GetDatetimeVal() []byte + func (m *Value) GetDefaultVal() string + func (m *Value) GetDoubleVal() float64 + func (m *Value) GetGeoVal() []byte + func (m *Value) GetIntVal() int64 + func (m *Value) GetPasswordVal() string + func (m *Value) GetStrVal() string + func (m *Value) GetUidVal() uint64 + func (m *Value) GetVal() isValue_Val + func (m *Value) Marshal() (dAtA []byte, err error) + func (m *Value) MarshalTo(dAtA []byte) (int, error) + func (m *Value) Reset() + func (m *Value) Size() (n int) + func (m *Value) String() string + func (m *Value) 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 Value_BoolVal struct + BoolVal bool + func (m *Value_BoolVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_BoolVal) Size() (n int) + type Value_BytesVal struct + BytesVal []byte + func (m *Value_BytesVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_BytesVal) Size() (n int) + type Value_DateVal struct + DateVal []byte + func (m *Value_DateVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_DateVal) Size() (n int) + type Value_DatetimeVal struct + DatetimeVal []byte + func (m *Value_DatetimeVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_DatetimeVal) Size() (n int) + type Value_DefaultVal struct + DefaultVal string + func (m *Value_DefaultVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_DefaultVal) Size() (n int) + type Value_DoubleVal struct + DoubleVal float64 + func (m *Value_DoubleVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_DoubleVal) Size() (n int) + type Value_GeoVal struct + GeoVal []byte + func (m *Value_GeoVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_GeoVal) Size() (n int) + type Value_IntVal struct + IntVal int64 + func (m *Value_IntVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_IntVal) Size() (n int) + type Value_PasswordVal struct + PasswordVal string + func (m *Value_PasswordVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_PasswordVal) Size() (n int) + type Value_StrVal struct + StrVal string + func (m *Value_StrVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_StrVal) Size() (n int) + type Value_UidVal struct + UidVal uint64 + func (m *Value_UidVal) MarshalTo(dAtA []byte) (int, error) + func (m *Value_UidVal) Size() (n int) + type Version struct + Tag string + func (*Version) Descriptor() ([]byte, []int) + func (*Version) ProtoMessage() + func (m *Version) GetTag() string + func (m *Version) Marshal() (dAtA []byte, err error) + func (m *Version) MarshalTo(dAtA []byte) (int, error) + func (m *Version) Reset() + func (m *Version) Size() (n int) + func (m *Version) String() string + func (m *Version) Unmarshal(dAtA []byte) error + type WorkerClient interface + AssignUids func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error) + Echo func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error) + Export func(ctx context.Context, in *ExportPayload, opts ...grpc.CallOption) (*ExportPayload, error) + JoinCluster func(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*Payload, error) + Mutate func(ctx context.Context, in *Mutations, opts ...grpc.CallOption) (*Payload, error) + PredicateAndSchemaData func(ctx context.Context, opts ...grpc.CallOption) (Worker_PredicateAndSchemaDataClient, error) + RaftMessage func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, 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) + UpdateMembership func(ctx context.Context, in *MembershipUpdate, opts ...grpc.CallOption) (*MembershipUpdate, error) + func NewWorkerClient(cc *grpc.ClientConn) WorkerClient + type WorkerServer interface + AssignUids func(context.Context, *Num) (*AssignedIds, error) + Echo func(context.Context, *Payload) (*Payload, error) + Export func(context.Context, *ExportPayload) (*ExportPayload, error) + JoinCluster func(context.Context, *RaftContext) (*Payload, error) + Mutate func(context.Context, *Mutations) (*Payload, error) + PredicateAndSchemaData func(Worker_PredicateAndSchemaDataServer) error + RaftMessage func(context.Context, *Payload) (*Payload, error) + Schema func(context.Context, *SchemaRequest) (*SchemaResult, error) + ServeTask func(context.Context, *Query) (*Result, error) + Sort func(context.Context, *SortMessage) (*SortResult, error) + UpdateMembership func(context.Context, *MembershipUpdate) (*MembershipUpdate, 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 v0.8.1 Aug 16, 2017 v0.8.0 Jul 17, 2017 v0.7.7 May 22, 2017 v0.7.6 May 1, 2017 v0.7.5 Apr 10, 2017 v0.7.4 Mar 31, 2017
Go to main page