protos

package

Go to main page

Versions in this module

v1

v1.0.1

Dec 20, 2017

v1.0.0

Dec 18, 2017

v0

v0.9.4

Dec 4, 2017

v0.9.3

Dec 1, 2017

v0.9.2

Nov 20, 2017

Changes in this version

type MembershipState

+ Removed []*Member

+ func (m *MembershipState) GetRemoved() []*Member

v0.9.1

Nov 15, 2017

Changes in this version

type Mutation

+ CommitNow bool

+ func (m *Mutation) GetCommitNow() bool

type WorkerClient

+ MinTxnTs func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Num, error)

type WorkerServer

+ MinTxnTs func(context.Context, *Payload) (*Num, error)

v0.9.0

Nov 14, 2017

Changes in this version

+ type Assigned struct

+ Context *TxnContext

+ Error string

+ Uids map[string]string

+ func (*Assigned) Descriptor() ([]byte, []int)

+ func (*Assigned) ProtoMessage()

+ func (m *Assigned) GetContext() *TxnContext

+ func (m *Assigned) GetError() string

+ func (m *Assigned) GetUids() map[string]string

+ func (m *Assigned) Marshal() (dAtA []byte, err error)

+ func (m *Assigned) MarshalTo(dAtA []byte) (int, error)

+ func (m *Assigned) Reset()

+ func (m *Assigned) Size() (n int)

+ func (m *Assigned) String() string

+ func (m *Assigned) Unmarshal(dAtA []byte) error

+ 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 DgraphClient

+ Alter func(ctx context.Context, in *Operation, opts ...grpc.CallOption) (*Payload, error)

+ CommitOrAbort func(ctx context.Context, in *TxnContext, opts ...grpc.CallOption) (*TxnContext, error)

+ Mutate func(ctx context.Context, in *Mutation, opts ...grpc.CallOption) (*Assigned, error)

+ Query func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

type DgraphServer

+ Alter func(context.Context, *Operation) (*Payload, error)

+ CommitOrAbort func(context.Context, *TxnContext) (*TxnContext, error)

+ Mutate func(context.Context, *Mutation) (*Assigned, error)

+ Query func(context.Context, *Request) (*Response, error)

type ExportPayload

+ ReadTs uint64

+ func (m *ExportPayload) GetReadTs() uint64

type KC

+ Timestamp uint64

+ func (m *KC) GetTimestamp() uint64

type KV

+ Version uint64

+ func (m *KV) GetVersion() uint64

type Latency

+ EncodingNs uint64

+ ParsingNs uint64

+ ProcessingNs uint64

+ func (m *Latency) GetEncodingNs() uint64

+ func (m *Latency) GetParsingNs() uint64

+ func (m *Latency) GetProcessingNs() uint64

+ type LinRead struct

+ Ids map[uint32]uint64

+ func (*LinRead) Descriptor() ([]byte, []int)

+ func (*LinRead) ProtoMessage()

+ func (m *LinRead) GetIds() map[uint32]uint64

+ func (m *LinRead) Marshal() (dAtA []byte, err error)

+ func (m *LinRead) MarshalTo(dAtA []byte) (int, error)

+ func (m *LinRead) Reset()

+ func (m *LinRead) Size() (n int)

+ func (m *LinRead) String() string

+ func (m *LinRead) Unmarshal(dAtA []byte) error

type Member

+ CluterInfoOnly bool

+ func (m *Member) GetCluterInfoOnly() bool

type MembershipState

+ MaxRaftId uint64

+ MaxTxnTs uint64

+ func (m *MembershipState) GetMaxRaftId() uint64

+ func (m *MembershipState) GetMaxTxnTs() uint64

type Mutation

+ CommitImmediately bool

+ DelNquads []byte

+ SetNquads []byte

+ StartTs uint64

+ func (m *Mutation) GetCommitImmediately() bool

+ func (m *Mutation) GetDelNquads() []byte

+ func (m *Mutation) GetSetNquads() []byte

+ func (m *Mutation) GetStartTs() uint64

type Mutations

+ StartTs uint64

+ func (m *Mutations) GetStartTs() uint64

+ type Operation struct

+ DropAll bool

+ DropAttr string

+ Schema string

+ StartTs uint64

+ func (*Operation) Descriptor() ([]byte, []int)

+ func (*Operation) ProtoMessage()

+ func (m *Operation) GetDropAll() bool

+ func (m *Operation) GetDropAttr() string

+ func (m *Operation) GetSchema() string

+ func (m *Operation) GetStartTs() uint64

+ func (m *Operation) Marshal() (dAtA []byte, err error)

+ func (m *Operation) MarshalTo(dAtA []byte) (int, error)

+ func (m *Operation) Reset()

+ func (m *Operation) Size() (n int)

+ func (m *Operation) String() string

+ func (m *Operation) 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 Posting

+ CommitTs uint64

+ StartTs uint64

+ func (m *Posting) GetCommitTs() uint64

+ func (m *Posting) GetStartTs() uint64

type Proposal

+ TxnContext *TxnContext

+ func (m *Proposal) GetTxnContext() *TxnContext

type Query

+ LinRead *LinRead

+ ReadTs uint64

+ func (m *Query) GetLinRead() *LinRead

+ func (m *Query) GetReadTs() uint64

type Request

+ LinRead *LinRead

+ StartTs uint64

+ func (m *Request) GetLinRead() *LinRead

+ func (m *Request) GetStartTs() uint64

type Response

+ Json []byte

+ Latency *Latency

+ Txn *TxnContext

+ func (m *Response) GetJson() []byte

+ func (m *Response) GetLatency() *Latency

+ func (m *Response) GetTxn() *TxnContext

type Result

+ LinRead *LinRead

+ func (m *Result) GetLinRead() *LinRead

type SortMessage

+ LinRead *LinRead

+ ReadTs uint64

+ func (m *SortMessage) GetLinRead() *LinRead

+ func (m *SortMessage) GetReadTs() uint64

type SortResult

+ LinRead *LinRead

+ func (m *SortResult) GetLinRead() *LinRead

+ type TxnContext struct

+ Aborted bool

+ CommitTs uint64

+ Keys []string

+ LinRead *LinRead

+ StartTs uint64

+ func (*TxnContext) Descriptor() ([]byte, []int)

+ func (*TxnContext) ProtoMessage()

+ func (m *TxnContext) GetAborted() bool

+ func (m *TxnContext) GetCommitTs() uint64

+ func (m *TxnContext) GetKeys() []string

+ func (m *TxnContext) GetLinRead() *LinRead

+ func (m *TxnContext) GetStartTs() uint64

+ func (m *TxnContext) Marshal() (dAtA []byte, err error)

+ func (m *TxnContext) MarshalTo(dAtA []byte) (int, error)

+ func (m *TxnContext) Reset()

+ func (m *TxnContext) Size() (n int)

+ func (m *TxnContext) String() string

+ func (m *TxnContext) 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 WorkerClient

+ CommitOrAbort func(ctx context.Context, in *TxnContext, opts ...grpc.CallOption) (*Payload, error)

type WorkerServer

+ CommitOrAbort func(context.Context, *TxnContext) (*Payload, error)

type ZeroClient

+ CommitOrAbort func(ctx context.Context, in *TxnContext, opts ...grpc.CallOption) (*TxnContext, error)

+ Oracle func(ctx context.Context, in *Payload, opts ...grpc.CallOption) (Zero_OracleClient, error)

+ Timestamps func(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error)

+ TryAbort func(ctx context.Context, in *TxnTimestamps, opts ...grpc.CallOption) (*TxnTimestamps, error)

type ZeroProposal

+ MaxRaftId uint64

+ MaxTxnTs uint64

+ Txn *TxnContext

+ func (m *ZeroProposal) GetMaxRaftId() uint64

+ func (m *ZeroProposal) GetMaxTxnTs() uint64

+ func (m *ZeroProposal) GetTxn() *TxnContext

type ZeroServer

+ CommitOrAbort func(context.Context, *TxnContext) (*TxnContext, error)

+ Oracle func(*Payload, Zero_OracleServer) error

+ Timestamps func(context.Context, *Num) (*AssignedIds, error)

+ TryAbort func(context.Context, *TxnTimestamps) (*TxnTimestamps, error)

+ type Zero_OracleClient interface

+ Recv func() (*OracleDelta, error)

+ type Zero_OracleServer interface

+ Send func(*OracleDelta) error

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL