protos

package
v82.0.0-...-84d68f0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 22, 2017 License: AGPL-3.0, Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package protos is a generated protocol buffer package.

It is generated from these files: 

bulkloader.proto
facets.proto
graphresponse.proto
payload.proto
schema.proto
task.proto
types.proto

It has these top-level messages: 

MapEntry
Facet
Param
Facets
FacetsList
Function
FilterTree
Num
AssignedIds
NQuad
Value
Mutation
Request
Latency
Property
Node
Response
Check
Version
Payload
ExportPayload
SchemaRequest
SchemaResult
SchemaNode
SchemaUpdate
List
TaskValue
SrcFunction
Query
ValueList
Result
Order
SortMessage
SortResult
RaftContext
Member
Group
ZeroProposal
MembershipState
Tablet
DirectedEdge
Mutations
Proposal
KV
KC
GroupKeys
Posting
PostingList

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBulkloader = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBulkloader   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthFacets = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFacets   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthGraphresponse = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGraphresponse   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPayload = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPayload   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchema   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DirectedEdge_Op_name = map[int32]string{
	0: "SET",
	1: "DEL",
}
View Source 
var DirectedEdge_Op_value = map[string]int32{
	"SET": 0,
	"DEL": 1,
}
View Source 
var ExportPayload_Status_name = map[int32]string{
	0: "NONE",
	1: "SUCCESS",
	2: "DUPLICATE",
	3: "FAILED",
}
View Source 
var ExportPayload_Status_value = map[string]int32{
	"NONE":      0,
	"SUCCESS":   1,
	"DUPLICATE": 2,
	"FAILED":    3,
}
View Source 
var Facet_ValType_name = map[int32]string{
	0: "STRING",
	1: "INT",
	2: "FLOAT",
	3: "BOOL",
	4: "DATETIME",
}
View Source 
var Facet_ValType_value = map[string]int32{
	"STRING":   0,
	"INT":      1,
	"FLOAT":    2,
	"BOOL":     3,
	"DATETIME": 4,
}
View Source 
var Posting_PostingType_name = map[int32]string{
	0: "REF",
	1: "VALUE",
	2: "VALUE_LANG",
}
View Source 
var Posting_PostingType_value = map[string]int32{
	"REF":        0,
	"VALUE":      1,
	"VALUE_LANG": 2,
}
View Source 
var Posting_ValType_name = map[int32]string{
	0: "DEFAULT",
	1: "BINARY",
	2: "INT",
	3: "FLOAT",
	4: "BOOL",
	5: "DATETIME",
	6: "GEO",
	7: "UID",
	8: "PASSWORD",
	9: "STRING",
}
View Source 
var Posting_ValType_value = map[string]int32{
	"DEFAULT":  0,
	"BINARY":   1,
	"INT":      2,
	"FLOAT":    3,
	"BOOL":     4,
	"DATETIME": 5,
	"GEO":      6,
	"UID":      7,
	"PASSWORD": 8,
	"STRING":   9,
}
View Source 
var SchemaUpdate_Directive_name = map[int32]string{
	0: "NONE",
	1: "INDEX",
	2: "REVERSE",
	3: "DELETE",
}
View Source 
var SchemaUpdate_Directive_value = map[string]int32{
	"NONE":    0,
	"INDEX":   1,
	"REVERSE": 2,
	"DELETE":  3,
}

Functions

func RegisterDgraphServer 

func RegisterDgraphServer(s *grpc.Server, srv DgraphServer)

func RegisterRaftServer 

func RegisterRaftServer(s *grpc.Server, srv RaftServer)

func RegisterWorkerServer 

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

func RegisterZeroServer 

func RegisterZeroServer(s *grpc.Server, srv ZeroServer)

Types

type AssignedIds 

type AssignedIds struct {
	StartId uint64 `protobuf:"varint,1,opt,name=startId,proto3" json:"startId,omitempty"`
	EndId   uint64 `protobuf:"varint,2,opt,name=endId,proto3" json:"endId,omitempty"`
}

func (*AssignedIds) Descriptor 

func (*AssignedIds) Descriptor() ([]byte, []int)

func (*AssignedIds) GetEndId 

func (m *AssignedIds) GetEndId() uint64

func (*AssignedIds) GetStartId 

func (m *AssignedIds) GetStartId() uint64

func (*AssignedIds) Marshal 

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

func (*AssignedIds) MarshalTo 

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

func (*AssignedIds) ProtoMessage 

func (*AssignedIds) ProtoMessage()

func (*AssignedIds) Reset 

func (m *AssignedIds) Reset()

func (*AssignedIds) Size 

func (m *AssignedIds) Size() (n int)

func (*AssignedIds) String 

func (m *AssignedIds) String() string

func (*AssignedIds) Unmarshal 

func (m *AssignedIds) Unmarshal(dAtA []byte) error

type Check 

type Check struct {
}

func (*Check) Descriptor 

func (*Check) Descriptor() ([]byte, []int)

func (*Check) Marshal 

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

func (*Check) MarshalTo 

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

func (*Check) ProtoMessage 

func (*Check) ProtoMessage()

func (*Check) Reset 

func (m *Check) Reset()

func (*Check) Size 

func (m *Check) Size() (n int)

func (*Check) String 

func (m *Check) String() string

func (*Check) Unmarshal 

func (m *Check) Unmarshal(dAtA []byte) error

type DgraphClient 

type DgraphClient interface {
	Run(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	CheckVersion(ctx context.Context, in *Check, opts ...grpc.CallOption) (*Version, error)
	AssignUids(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error)
}

func NewDgraphClient 

func NewDgraphClient(cc *grpc.ClientConn) DgraphClient

type DgraphServer 

type DgraphServer interface {
	Run(context.Context, *Request) (*Response, error)
	CheckVersion(context.Context, *Check) (*Version, error)
	AssignUids(context.Context, *Num) (*AssignedIds, error)
}

type DirectedEdge 

type DirectedEdge struct {
	Entity    uint64          `protobuf:"fixed64,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Attr      string          `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"`
	Value     []byte          `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	ValueType uint32          `protobuf:"varint,4,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	ValueId   uint64          `protobuf:"fixed64,5,opt,name=value_id,json=valueId,proto3" json:"value_id,omitempty"`
	Label     string          `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"`
	Lang      string          `protobuf:"bytes,7,opt,name=lang,proto3" json:"lang,omitempty"`
	Op        DirectedEdge_Op `protobuf:"varint,8,opt,name=op,proto3,enum=protos.DirectedEdge_Op" json:"op,omitempty"`
	Facets    []*Facet        `protobuf:"bytes,9,rep,name=facets" json:"facets,omitempty"`
}

func (*DirectedEdge) Descriptor 

func (*DirectedEdge) Descriptor() ([]byte, []int)

func (*DirectedEdge) GetAttr 

func (m *DirectedEdge) GetAttr() string

func (*DirectedEdge) GetEntity 

func (m *DirectedEdge) GetEntity() uint64

func (*DirectedEdge) GetFacets 

func (m *DirectedEdge) GetFacets() []*Facet

func (*DirectedEdge) GetLabel 

func (m *DirectedEdge) GetLabel() string

func (*DirectedEdge) GetLang 

func (m *DirectedEdge) GetLang() string

func (*DirectedEdge) GetOp 

func (m *DirectedEdge) GetOp() DirectedEdge_Op

func (*DirectedEdge) GetValue 

func (m *DirectedEdge) GetValue() []byte

func (*DirectedEdge) GetValueId 

func (m *DirectedEdge) GetValueId() uint64

func (*DirectedEdge) GetValueType 

func (m *DirectedEdge) GetValueType() uint32

func (*DirectedEdge) Marshal 

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

func (*DirectedEdge) MarshalTo 

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

func (*DirectedEdge) ProtoMessage 

func (*DirectedEdge) ProtoMessage()

func (*DirectedEdge) Reset 

func (m *DirectedEdge) Reset()

func (*DirectedEdge) Size 

func (m *DirectedEdge) Size() (n int)

func (*DirectedEdge) String 

func (m *DirectedEdge) String() string

func (*DirectedEdge) Unmarshal 

func (m *DirectedEdge) Unmarshal(dAtA []byte) error

type DirectedEdge_Op 

type DirectedEdge_Op int32
const (
	DirectedEdge_SET DirectedEdge_Op = 0
	DirectedEdge_DEL DirectedEdge_Op = 1
)

func (DirectedEdge_Op) EnumDescriptor 

func (DirectedEdge_Op) EnumDescriptor() ([]byte, []int)

func (DirectedEdge_Op) String 

func (x DirectedEdge_Op) String() string

type ExportPayload 

type ExportPayload struct {
	ReqId   uint64               `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	GroupId uint32               `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Status  ExportPayload_Status `protobuf:"varint,3,opt,name=status,proto3,enum=protos.ExportPayload_Status" json:"status,omitempty"`
}

BackupPayload is used both as a request and a response. When used in request, groups represents the list of groups that need to be backed up. When used in response, groups represent the list of groups that were backed up.

func (*ExportPayload) Descriptor 

func (*ExportPayload) Descriptor() ([]byte, []int)

func (*ExportPayload) GetGroupId 

func (m *ExportPayload) GetGroupId() uint32

func (*ExportPayload) GetReqId 

func (m *ExportPayload) GetReqId() uint64

func (*ExportPayload) GetStatus 

func (m *ExportPayload) GetStatus() ExportPayload_Status

func (*ExportPayload) Marshal 

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

func (*ExportPayload) MarshalTo 

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

func (*ExportPayload) ProtoMessage 

func (*ExportPayload) ProtoMessage()

func (*ExportPayload) Reset 

func (m *ExportPayload) Reset()

func (*ExportPayload) Size 

func (m *ExportPayload) Size() (n int)

func (*ExportPayload) String 

func (m *ExportPayload) String() string

func (*ExportPayload) Unmarshal 

func (m *ExportPayload) Unmarshal(dAtA []byte) error

type ExportPayload_Status 

type ExportPayload_Status int32
const (
	ExportPayload_NONE      ExportPayload_Status = 0
	ExportPayload_SUCCESS   ExportPayload_Status = 1
	ExportPayload_DUPLICATE ExportPayload_Status = 2
	ExportPayload_FAILED    ExportPayload_Status = 3
)

func (ExportPayload_Status) EnumDescriptor 

func (ExportPayload_Status) EnumDescriptor() ([]byte, []int)

func (ExportPayload_Status) String 

func (x ExportPayload_Status) String() string

type Facet 

type Facet struct {
	Key     string        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte        `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	ValType Facet_ValType `protobuf:"varint,3,opt,name=val_type,json=valType,proto3,enum=protos.Facet_ValType" json:"val_type,omitempty"`
	Tokens  []string      `protobuf:"bytes,4,rep,name=tokens" json:"tokens,omitempty"`
	// Only used by the Go client, so that we can parse and tokenize facets
	// on the server.
	Val string `protobuf:"bytes,5,opt,name=val,proto3" json:"val,omitempty"`
}

func (*Facet) Descriptor 

func (*Facet) Descriptor() ([]byte, []int)

func (*Facet) GetKey 

func (m *Facet) GetKey() string

func (*Facet) GetTokens 

func (m *Facet) GetTokens() []string

func (*Facet) GetVal 

func (m *Facet) GetVal() string

func (*Facet) GetValType 

func (m *Facet) GetValType() Facet_ValType

func (*Facet) GetValue 

func (m *Facet) GetValue() []byte

func (*Facet) Marshal 

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

func (*Facet) MarshalTo 

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

func (*Facet) ProtoMessage 

func (*Facet) ProtoMessage()

func (*Facet) Reset 

func (m *Facet) Reset()

func (*Facet) Size 

func (m *Facet) Size() (n int)

func (*Facet) String 

func (m *Facet) String() string

func (*Facet) Unmarshal 

func (m *Facet) Unmarshal(dAtA []byte) error

type Facet_ValType 

type Facet_ValType int32
const (
	Facet_STRING   Facet_ValType = 0
	Facet_INT      Facet_ValType = 1
	Facet_FLOAT    Facet_ValType = 2
	Facet_BOOL     Facet_ValType = 3
	Facet_DATETIME Facet_ValType = 4
)

func (Facet_ValType) EnumDescriptor 

func (Facet_ValType) EnumDescriptor() ([]byte, []int)

func (Facet_ValType) String 

func (x Facet_ValType) String() string

type Facets 

type Facets struct {
	Facets []*Facet `protobuf:"bytes,1,rep,name=facets" json:"facets,omitempty"`
}

func (*Facets) Descriptor 

func (*Facets) Descriptor() ([]byte, []int)

func (*Facets) GetFacets 

func (m *Facets) GetFacets() []*Facet

func (*Facets) Marshal 

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

func (*Facets) MarshalTo 

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

func (*Facets) ProtoMessage 

func (*Facets) ProtoMessage()

func (*Facets) Reset 

func (m *Facets) Reset()

func (*Facets) Size 

func (m *Facets) Size() (n int)

func (*Facets) String 

func (m *Facets) String() string

func (*Facets) Unmarshal 

func (m *Facets) Unmarshal(dAtA []byte) error

type FacetsList 

type FacetsList struct {
	FacetsList []*Facets `protobuf:"bytes,1,rep,name=facets_list,json=facetsList" json:"facets_list,omitempty"`
}

func (*FacetsList) Descriptor 

func (*FacetsList) Descriptor() ([]byte, []int)

func (*FacetsList) GetFacetsList 

func (m *FacetsList) GetFacetsList() []*Facets

func (*FacetsList) Marshal 

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

func (*FacetsList) MarshalTo 

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

func (*FacetsList) ProtoMessage 

func (*FacetsList) ProtoMessage()

func (*FacetsList) Reset 

func (m *FacetsList) Reset()

func (*FacetsList) Size 

func (m *FacetsList) Size() (n int)

func (*FacetsList) String 

func (m *FacetsList) String() string

func (*FacetsList) Unmarshal 

func (m *FacetsList) Unmarshal(dAtA []byte) error

type FilterTree 

type FilterTree struct {
	Op       string        `protobuf:"bytes,1,opt,name=op,proto3" json:"op,omitempty"`
	Children []*FilterTree `protobuf:"bytes,2,rep,name=children" json:"children,omitempty"`
	Func     *Function     `protobuf:"bytes,3,opt,name=func" json:"func,omitempty"`
}

Op and Children are internal nodes and Func on leaves.

func (*FilterTree) Descriptor 

func (*FilterTree) Descriptor() ([]byte, []int)

func (*FilterTree) GetChildren 

func (m *FilterTree) GetChildren() []*FilterTree

func (*FilterTree) GetFunc 

func (m *FilterTree) GetFunc() *Function

func (*FilterTree) GetOp 

func (m *FilterTree) GetOp() string

func (*FilterTree) Marshal 

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

func (*FilterTree) MarshalTo 

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

func (*FilterTree) ProtoMessage 

func (*FilterTree) ProtoMessage()

func (*FilterTree) Reset 

func (m *FilterTree) Reset()

func (*FilterTree) Size 

func (m *FilterTree) Size() (n int)

func (*FilterTree) String 

func (m *FilterTree) String() string

func (*FilterTree) Unmarshal 

func (m *FilterTree) Unmarshal(dAtA []byte) error

type Function 

type Function struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Key  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Args []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
}

func (*Function) Descriptor 

func (*Function) Descriptor() ([]byte, []int)

func (*Function) GetArgs 

func (m *Function) GetArgs() []string

func (*Function) GetKey 

func (m *Function) GetKey() string

func (*Function) GetName 

func (m *Function) GetName() string

func (*Function) Marshal 

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

func (*Function) MarshalTo 

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

func (*Function) ProtoMessage 

func (*Function) ProtoMessage()

func (*Function) Reset 

func (m *Function) Reset()

func (*Function) Size 

func (m *Function) Size() (n int)

func (*Function) String 

func (m *Function) String() string

func (*Function) Unmarshal 

func (m *Function) Unmarshal(dAtA []byte) error

type Group 

type Group struct {
	Members map[uint64]*Member `` /* 142-byte string literal not displayed */
	Tablets map[string]*Tablet `` /* 141-byte string literal not displayed */
}

func (*Group) Descriptor 

func (*Group) Descriptor() ([]byte, []int)

func (*Group) GetMembers 

func (m *Group) GetMembers() map[uint64]*Member

func (*Group) GetTablets 

func (m *Group) GetTablets() map[string]*Tablet

func (*Group) Marshal 

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

func (*Group) MarshalTo 

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

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) Reset 

func (m *Group) Reset()

func (*Group) Size 

func (m *Group) Size() (n int)

func (*Group) String 

func (m *Group) String() string

func (*Group) Unmarshal 

func (m *Group) Unmarshal(dAtA []byte) error

type GroupKeys 

type GroupKeys struct {
	GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Keys    []*KC  `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
}

func (*GroupKeys) Descriptor 

func (*GroupKeys) Descriptor() ([]byte, []int)

func (*GroupKeys) GetGroupId 

func (m *GroupKeys) GetGroupId() uint32

func (*GroupKeys) GetKeys 

func (m *GroupKeys) GetKeys() []*KC

func (*GroupKeys) Marshal 

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

func (*GroupKeys) MarshalTo 

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

func (*GroupKeys) ProtoMessage 

func (*GroupKeys) ProtoMessage()

func (*GroupKeys) Reset 

func (m *GroupKeys) Reset()

func (*GroupKeys) Size 

func (m *GroupKeys) Size() (n int)

func (*GroupKeys) String 

func (m *GroupKeys) String() string

func (*GroupKeys) Unmarshal 

func (m *GroupKeys) Unmarshal(dAtA []byte) error

type KC 

type KC struct {
	Key      []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Checksum []byte `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*KC) Descriptor 

func (*KC) Descriptor() ([]byte, []int)

func (*KC) GetChecksum 

func (m *KC) GetChecksum() []byte

func (*KC) GetKey 

func (m *KC) GetKey() []byte

func (*KC) Marshal 

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

func (*KC) MarshalTo 

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

func (*KC) ProtoMessage 

func (*KC) ProtoMessage()

func (*KC) Reset 

func (m *KC) Reset()

func (*KC) Size 

func (m *KC) Size() (n int)

func (*KC) String 

func (m *KC) String() string

func (*KC) Unmarshal 

func (m *KC) Unmarshal(dAtA []byte) error

type KV 

type KV struct {
	Key      []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val      []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	UserMeta []byte `protobuf:"bytes,3,opt,name=userMeta,proto3" json:"userMeta,omitempty"`
}

func (*KV) Descriptor 

func (*KV) Descriptor() ([]byte, []int)

func (*KV) GetKey 

func (m *KV) GetKey() []byte

func (*KV) GetUserMeta 

func (m *KV) GetUserMeta() []byte

func (*KV) GetVal 

func (m *KV) GetVal() []byte

func (*KV) Marshal 

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

func (*KV) MarshalTo 

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

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) Size 

func (m *KV) Size() (n int)

func (*KV) String 

func (m *KV) String() string

func (*KV) Unmarshal 

func (m *KV) Unmarshal(dAtA []byte) error

type KeyValues 

type KeyValues struct {
	Kv []*KV `protobuf:"bytes,1,rep,name=kv" json:"kv,omitempty"`
}

func (*KeyValues) Descriptor 

func (*KeyValues) Descriptor() ([]byte, []int)

func (*KeyValues) GetKv 

func (m *KeyValues) GetKv() []*KV

func (*KeyValues) Marshal 

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

func (*KeyValues) MarshalTo 

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

func (*KeyValues) ProtoMessage 

func (*KeyValues) ProtoMessage()

func (*KeyValues) Reset 

func (m *KeyValues) Reset()

func (*KeyValues) Size 

func (m *KeyValues) Size() (n int)

func (*KeyValues) String 

func (m *KeyValues) String() string

func (*KeyValues) Unmarshal 

func (m *KeyValues) Unmarshal(dAtA []byte) error

type Latency 

type Latency struct {
	Parsing    string `protobuf:"bytes,1,opt,name=parsing,proto3" json:"parsing,omitempty"`
	Processing string `protobuf:"bytes,2,opt,name=processing,proto3" json:"processing,omitempty"`
	Pb         string `protobuf:"bytes,3,opt,name=pb,proto3" json:"pb,omitempty"`
}

func (*Latency) Descriptor 

func (*Latency) Descriptor() ([]byte, []int)

func (*Latency) GetParsing 

func (m *Latency) GetParsing() string

func (*Latency) GetPb 

func (m *Latency) GetPb() string

func (*Latency) GetProcessing 

func (m *Latency) GetProcessing() string

func (*Latency) Marshal 

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

func (*Latency) MarshalTo 

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

func (*Latency) ProtoMessage 

func (*Latency) ProtoMessage()

func (*Latency) Reset 

func (m *Latency) Reset()

func (*Latency) Size 

func (m *Latency) Size() (n int)

func (*Latency) String 

func (m *Latency) String() string

func (*Latency) Unmarshal 

func (m *Latency) Unmarshal(dAtA []byte) error

type List 

type List struct {
	Uids []uint64 `protobuf:"fixed64,1,rep,packed,name=uids" json:"uids,omitempty"`
}

func (*List) Descriptor 

func (*List) Descriptor() ([]byte, []int)

func (*List) GetUids 

func (m *List) GetUids() []uint64

func (*List) Marshal 

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

func (*List) MarshalTo 

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

func (*List) ProtoMessage 

func (*List) ProtoMessage()

func (*List) Reset 

func (m *List) Reset()

func (*List) Size 

func (m *List) Size() (n int)

func (*List) String 

func (m *List) String() string

func (*List) Unmarshal 

func (m *List) Unmarshal(dAtA []byte) error

type MapEntry 

type MapEntry struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Only one should be set.
	Uid     uint64   `protobuf:"fixed64,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Posting *Posting `protobuf:"bytes,3,opt,name=posting" json:"posting,omitempty"`
}

func (*MapEntry) Descriptor 

func (*MapEntry) Descriptor() ([]byte, []int)

func (*MapEntry) GetKey 

func (m *MapEntry) GetKey() []byte

func (*MapEntry) GetPosting 

func (m *MapEntry) GetPosting() *Posting

func (*MapEntry) GetUid 

func (m *MapEntry) GetUid() uint64

func (*MapEntry) Marshal 

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

func (*MapEntry) MarshalTo 

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

func (*MapEntry) ProtoMessage 

func (*MapEntry) ProtoMessage()

func (*MapEntry) Reset 

func (m *MapEntry) Reset()

func (*MapEntry) Size 

func (m *MapEntry) Size() (n int)

func (*MapEntry) String 

func (m *MapEntry) String() string

func (*MapEntry) Unmarshal 

func (m *MapEntry) Unmarshal(dAtA []byte) error

type Member 

type Member struct {
	Id         uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupId    uint32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Addr       string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Leader     bool   `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"`
	AmDead     bool   `protobuf:"varint,5,opt,name=am_dead,json=amDead,proto3" json:"am_dead,omitempty"`
	LastUpdate uint64 `protobuf:"varint,6,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
}

Member stores information about RAFT group member for a single RAFT node. Note that each server can be serving multiple RAFT groups. Each group would have one RAFT node per server serving that group.

func (*Member) Descriptor 

func (*Member) Descriptor() ([]byte, []int)

func (*Member) GetAddr 

func (m *Member) GetAddr() string

func (*Member) GetAmDead 

func (m *Member) GetAmDead() bool

func (*Member) GetGroupId 

func (m *Member) GetGroupId() uint32

func (*Member) GetId 

func (m *Member) GetId() uint64

func (*Member) GetLastUpdate 

func (m *Member) GetLastUpdate() uint64

func (*Member) GetLeader 

func (m *Member) GetLeader() bool

func (*Member) Marshal 

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

func (*Member) MarshalTo 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) Size 

func (m *Member) Size() (n int)

func (*Member) String 

func (m *Member) String() string

func (*Member) Unmarshal 

func (m *Member) Unmarshal(dAtA []byte) error

type MembershipState 

type MembershipState struct {
	Counter    uint64             `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	Groups     map[uint32]*Group  `` /* 140-byte string literal not displayed */
	Zeros      map[uint64]*Member `` /* 138-byte string literal not displayed */
	MaxLeaseId uint64             `protobuf:"varint,4,opt,name=maxLeaseId,proto3" json:"maxLeaseId,omitempty"`
}

MembershipState is used to pack together the current membership state of all the nodes in the caller server; and the membership updates recorded by the callee server since the provided lastUpdate.

func (*MembershipState) Descriptor 

func (*MembershipState) Descriptor() ([]byte, []int)

func (*MembershipState) GetCounter 

func (m *MembershipState) GetCounter() uint64

func (*MembershipState) GetGroups 

func (m *MembershipState) GetGroups() map[uint32]*Group

func (*MembershipState) GetMaxLeaseId 

func (m *MembershipState) GetMaxLeaseId() uint64

func (*MembershipState) GetZeros 

func (m *MembershipState) GetZeros() map[uint64]*Member

func (*MembershipState) Marshal 

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

func (*MembershipState) MarshalTo 

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

func (*MembershipState) ProtoMessage 

func (*MembershipState) ProtoMessage()

func (*MembershipState) Reset 

func (m *MembershipState) Reset()

func (*MembershipState) Size 

func (m *MembershipState) Size() (n int)

func (*MembershipState) String 

func (m *MembershipState) String() string

func (*MembershipState) Unmarshal 

func (m *MembershipState) Unmarshal(dAtA []byte) error

type MovePredicatePayload 

type MovePredicatePayload struct {
	Predicate     string           `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
	SourceGroupId uint32           `protobuf:"varint,2,opt,name=source_group_id,json=sourceGroupId,proto3" json:"source_group_id,omitempty"`
	DestGroupId   uint32           `protobuf:"varint,3,opt,name=dest_group_id,json=destGroupId,proto3" json:"dest_group_id,omitempty"`
	State         *MembershipState `protobuf:"bytes,4,opt,name=state" json:"state,omitempty"`
}

func (*MovePredicatePayload) Descriptor 

func (*MovePredicatePayload) Descriptor() ([]byte, []int)

func (*MovePredicatePayload) GetDestGroupId 

func (m *MovePredicatePayload) GetDestGroupId() uint32

func (*MovePredicatePayload) GetPredicate 

func (m *MovePredicatePayload) GetPredicate() string

func (*MovePredicatePayload) GetSourceGroupId 

func (m *MovePredicatePayload) GetSourceGroupId() uint32

func (*MovePredicatePayload) GetState 

func (m *MovePredicatePayload) GetState() *MembershipState

func (*MovePredicatePayload) Marshal 

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

func (*MovePredicatePayload) MarshalTo 

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

func (*MovePredicatePayload) ProtoMessage 

func (*MovePredicatePayload) ProtoMessage()

func (*MovePredicatePayload) Reset 

func (m *MovePredicatePayload) Reset()

func (*MovePredicatePayload) Size 

func (m *MovePredicatePayload) Size() (n int)

func (*MovePredicatePayload) String 

func (m *MovePredicatePayload) String() string

func (*MovePredicatePayload) Unmarshal 

func (m *MovePredicatePayload) Unmarshal(dAtA []byte) error

type Mutation 

type Mutation struct {
	Set    []*NQuad        `protobuf:"bytes,1,rep,name=set" json:"set,omitempty"`
	Del    []*NQuad        `protobuf:"bytes,2,rep,name=del" json:"del,omitempty"`
	Schema []*SchemaUpdate `protobuf:"bytes,3,rep,name=schema" json:"schema,omitempty"`
}

func (*Mutation) Descriptor 

func (*Mutation) Descriptor() ([]byte, []int)

func (*Mutation) GetDel 

func (m *Mutation) GetDel() []*NQuad

func (*Mutation) GetSchema 

func (m *Mutation) GetSchema() []*SchemaUpdate

func (*Mutation) GetSet 

func (m *Mutation) GetSet() []*NQuad

func (*Mutation) Marshal 

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

func (*Mutation) MarshalTo 

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

func (*Mutation) ProtoMessage 

func (*Mutation) ProtoMessage()

func (*Mutation) Reset 

func (m *Mutation) Reset()

func (*Mutation) Size 

func (m *Mutation) Size() (n int)

func (*Mutation) String 

func (m *Mutation) String() string

func (*Mutation) Unmarshal 

func (m *Mutation) Unmarshal(dAtA []byte) error

type Mutations 

type Mutations struct {
	GroupId uint32          `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Edges   []*DirectedEdge `protobuf:"bytes,2,rep,name=edges" json:"edges,omitempty"`
	Schema  []*SchemaUpdate `protobuf:"bytes,3,rep,name=schema" json:"schema,omitempty"`
	Upsert  *Query          `protobuf:"bytes,4,opt,name=upsert" json:"upsert,omitempty"`
}

func (*Mutations) Descriptor 

func (*Mutations) Descriptor() ([]byte, []int)

func (*Mutations) GetEdges 

func (m *Mutations) GetEdges() []*DirectedEdge

func (*Mutations) GetGroupId 

func (m *Mutations) GetGroupId() uint32

func (*Mutations) GetSchema 

func (m *Mutations) GetSchema() []*SchemaUpdate

func (*Mutations) GetUpsert 

func (m *Mutations) GetUpsert() *Query

func (*Mutations) Marshal 

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

func (*Mutations) MarshalTo 

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

func (*Mutations) ProtoMessage 

func (*Mutations) ProtoMessage()

func (*Mutations) Reset 

func (m *Mutations) Reset()

func (*Mutations) Size 

func (m *Mutations) Size() (n int)

func (*Mutations) String 

func (m *Mutations) String() string

func (*Mutations) Unmarshal 

func (m *Mutations) Unmarshal(dAtA []byte) error

type NQuad 

type NQuad struct {
	Subject     string   `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Predicate   string   `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	ObjectId    string   `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ObjectValue *Value   `protobuf:"bytes,4,opt,name=object_value,json=objectValue" json:"object_value,omitempty"`
	Label       string   `protobuf:"bytes,5,opt,name=label,proto3" json:"label,omitempty"`
	Lang        string   `protobuf:"bytes,7,opt,name=lang,proto3" json:"lang,omitempty"`
	ObjectType  int32    `protobuf:"zigzag32,6,opt,name=objectType,proto3" json:"objectType,omitempty"`
	Facets      []*Facet `protobuf:"bytes,8,rep,name=facets" json:"facets,omitempty"`
	SubjectVar  string   `protobuf:"bytes,9,opt,name=subject_var,json=subjectVar,proto3" json:"subject_var,omitempty"`
	ObjectVar   string   `protobuf:"bytes,10,opt,name=object_var,json=objectVar,proto3" json:"object_var,omitempty"`
}

func (*NQuad) Descriptor 

func (*NQuad) Descriptor() ([]byte, []int)

func (*NQuad) GetFacets 

func (m *NQuad) GetFacets() []*Facet

func (*NQuad) GetLabel 

func (m *NQuad) GetLabel() string

func (*NQuad) GetLang 

func (m *NQuad) GetLang() string

func (*NQuad) GetObjectId 

func (m *NQuad) GetObjectId() string

func (*NQuad) GetObjectType 

func (m *NQuad) GetObjectType() int32

func (*NQuad) GetObjectValue 

func (m *NQuad) GetObjectValue() *Value

func (*NQuad) GetObjectVar 

func (m *NQuad) GetObjectVar() string

func (*NQuad) GetPredicate 

func (m *NQuad) GetPredicate() string

func (*NQuad) GetSubject 

func (m *NQuad) GetSubject() string

func (*NQuad) GetSubjectVar 

func (m *NQuad) GetSubjectVar() string

func (*NQuad) Marshal 

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

func (*NQuad) MarshalTo 

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

func (*NQuad) ProtoMessage 

func (*NQuad) ProtoMessage()

func (*NQuad) Reset 

func (m *NQuad) Reset()

func (*NQuad) Size 

func (m *NQuad) Size() (n int)

func (*NQuad) String 

func (m *NQuad) String() string

func (*NQuad) Unmarshal 

func (m *NQuad) Unmarshal(dAtA []byte) error

type Node 

type Node struct {
	Attribute  string      `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
	Properties []*Property `protobuf:"bytes,2,rep,name=properties" json:"properties,omitempty"`
	Children   []*Node     `protobuf:"bytes,3,rep,name=children" json:"children,omitempty"`
}

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetAttribute 

func (m *Node) GetAttribute() string

func (*Node) GetChildren 

func (m *Node) GetChildren() []*Node

func (*Node) GetProperties 

func (m *Node) GetProperties() []*Property

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(dAtA []byte) error

type Num 

type Num struct {
	Val uint64 `protobuf:"varint,1,opt,name=val,proto3" json:"val,omitempty"`
}

func (*Num) Descriptor 

func (*Num) Descriptor() ([]byte, []int)

func (*Num) GetVal 

func (m *Num) GetVal() uint64

func (*Num) Marshal 

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

func (*Num) MarshalTo 

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

func (*Num) ProtoMessage 

func (*Num) ProtoMessage()

func (*Num) Reset 

func (m *Num) Reset()

func (*Num) Size 

func (m *Num) Size() (n int)

func (*Num) String 

func (m *Num) String() string

func (*Num) Unmarshal 

func (m *Num) Unmarshal(dAtA []byte) error

type Order 

type Order struct {
	Attr string `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Desc bool   `protobuf:"varint,2,opt,name=desc,proto3" json:"desc,omitempty"`
}

func (*Order) Descriptor 

func (*Order) Descriptor() ([]byte, []int)

func (*Order) GetAttr 

func (m *Order) GetAttr() string

func (*Order) GetDesc 

func (m *Order) GetDesc() bool

func (*Order) Marshal 

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

func (*Order) MarshalTo 

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

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) Reset 

func (m *Order) Reset()

func (*Order) Size 

func (m *Order) Size() (n int)

func (*Order) String 

func (m *Order) String() string

func (*Order) Unmarshal 

func (m *Order) Unmarshal(dAtA []byte) error

type Param 

type Param struct {
	AllKeys bool     `protobuf:"varint,1,opt,name=all_keys,json=allKeys,proto3" json:"all_keys,omitempty"`
	Keys    []string `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
}

func (*Param) Descriptor 

func (*Param) Descriptor() ([]byte, []int)

func (*Param) GetAllKeys 

func (m *Param) GetAllKeys() bool

func (*Param) GetKeys 

func (m *Param) GetKeys() []string

func (*Param) Marshal 

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

func (*Param) MarshalTo 

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

func (*Param) ProtoMessage 

func (*Param) ProtoMessage()

func (*Param) Reset 

func (m *Param) Reset()

func (*Param) Size 

func (m *Param) Size() (n int)

func (*Param) String 

func (m *Param) String() string

func (*Param) Unmarshal 

func (m *Param) Unmarshal(dAtA []byte) error

type Payload 

type Payload struct {
	Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
}

func (*Payload) Descriptor 

func (*Payload) Descriptor() ([]byte, []int)

func (*Payload) GetData 

func (m *Payload) GetData() []byte

func (*Payload) Marshal 

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

func (*Payload) MarshalTo 

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

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size 

func (m *Payload) Size() (n int)

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal 

func (m *Payload) Unmarshal(dAtA []byte) error

type Posting 

type Posting struct {
	Uid         uint64              `protobuf:"fixed64,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Value       []byte              `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	ValType     Posting_ValType     `protobuf:"varint,3,opt,name=val_type,json=valType,proto3,enum=protos.Posting_ValType" json:"val_type,omitempty"`
	PostingType Posting_PostingType `` /* 127-byte string literal not displayed */
	Metadata    []byte              `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Label       string              `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"`
	Commit      uint64              `protobuf:"varint,7,opt,name=commit,proto3" json:"commit,omitempty"`
	Facets      []*Facet            `protobuf:"bytes,8,rep,name=facets" json:"facets,omitempty"`
	// TODO: op is only used temporarily. See if we can remove it from here.
	Op uint32 `protobuf:"varint,12,opt,name=op,proto3" json:"op,omitempty"`
}

func (*Posting) Descriptor 

func (*Posting) Descriptor() ([]byte, []int)

func (*Posting) GetCommit 

func (m *Posting) GetCommit() uint64

func (*Posting) GetFacets 

func (m *Posting) GetFacets() []*Facet

func (*Posting) GetLabel 

func (m *Posting) GetLabel() string

func (*Posting) GetMetadata 

func (m *Posting) GetMetadata() []byte

func (*Posting) GetOp 

func (m *Posting) GetOp() uint32

func (*Posting) GetPostingType 

func (m *Posting) GetPostingType() Posting_PostingType

func (*Posting) GetUid 

func (m *Posting) GetUid() uint64

func (*Posting) GetValType 

func (m *Posting) GetValType() Posting_ValType

func (*Posting) GetValue 

func (m *Posting) GetValue() []byte

func (*Posting) Marshal 

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

func (*Posting) MarshalTo 

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

func (*Posting) ProtoMessage 

func (*Posting) ProtoMessage()

func (*Posting) Reset 

func (m *Posting) Reset()

func (*Posting) Size 

func (m *Posting) Size() (n int)

func (*Posting) String 

func (m *Posting) String() string

func (*Posting) Unmarshal 

func (m *Posting) Unmarshal(dAtA []byte) error

type PostingList 

type PostingList struct {
	Postings []*Posting `protobuf:"bytes,1,rep,name=postings" json:"postings,omitempty"`
	Checksum []byte     `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Commit   uint64     `protobuf:"varint,3,opt,name=commit,proto3" json:"commit,omitempty"`
	Uids     []byte     `protobuf:"bytes,4,opt,name=uids,proto3" json:"uids,omitempty"`
}

func (*PostingList) Descriptor 

func (*PostingList) Descriptor() ([]byte, []int)

func (*PostingList) GetChecksum 

func (m *PostingList) GetChecksum() []byte

func (*PostingList) GetCommit 

func (m *PostingList) GetCommit() uint64

func (*PostingList) GetPostings 

func (m *PostingList) GetPostings() []*Posting

func (*PostingList) GetUids 

func (m *PostingList) GetUids() []byte

func (*PostingList) Marshal 

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

func (*PostingList) MarshalTo 

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

func (*PostingList) ProtoMessage 

func (*PostingList) ProtoMessage()

func (*PostingList) Reset 

func (m *PostingList) Reset()

func (*PostingList) Size 

func (m *PostingList) Size() (n int)

func (*PostingList) String 

func (m *PostingList) String() string

func (*PostingList) Unmarshal 

func (m *PostingList) Unmarshal(dAtA []byte) error

type Posting_PostingType 

type Posting_PostingType int32
const (
	Posting_REF        Posting_PostingType = 0
	Posting_VALUE      Posting_PostingType = 1
	Posting_VALUE_LANG Posting_PostingType = 2
)

func (Posting_PostingType) EnumDescriptor 

func (Posting_PostingType) EnumDescriptor() ([]byte, []int)

func (Posting_PostingType) String 

func (x Posting_PostingType) String() string

type Posting_ValType 

type Posting_ValType int32
const (
	Posting_DEFAULT  Posting_ValType = 0
	Posting_BINARY   Posting_ValType = 1
	Posting_INT      Posting_ValType = 2
	Posting_FLOAT    Posting_ValType = 3
	Posting_BOOL     Posting_ValType = 4
	Posting_DATETIME Posting_ValType = 5
	Posting_GEO      Posting_ValType = 6
	Posting_UID      Posting_ValType = 7
	Posting_PASSWORD Posting_ValType = 8
	Posting_STRING   Posting_ValType = 9
)

func (Posting_ValType) EnumDescriptor 

func (Posting_ValType) EnumDescriptor() ([]byte, []int)

func (Posting_ValType) String 

func (x Posting_ValType) String() string

type Property 

type Property struct {
	Prop  string `protobuf:"bytes,1,opt,name=prop,proto3" json:"prop,omitempty"`
	Value *Value `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}

func (*Property) Descriptor 

func (*Property) Descriptor() ([]byte, []int)

func (*Property) GetProp 

func (m *Property) GetProp() string

func (*Property) GetValue 

func (m *Property) GetValue() *Value

func (*Property) Marshal 

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

func (*Property) MarshalTo 

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

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) Reset 

func (m *Property) Reset()

func (*Property) Size 

func (m *Property) Size() (n int)

func (*Property) String 

func (m *Property) String() string

func (*Property) Unmarshal 

func (m *Property) Unmarshal(dAtA []byte) error

type Proposal 

type Proposal struct {
	Id         uint32           `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Mutations  *Mutations       `protobuf:"bytes,2,opt,name=mutations" json:"mutations,omitempty"`
	Membership *Member          `protobuf:"bytes,3,opt,name=membership" json:"membership,omitempty"`
	Kv         []*KV            `protobuf:"bytes,4,rep,name=kv" json:"kv,omitempty"`
	State      *MembershipState `protobuf:"bytes,5,opt,name=state" json:"state,omitempty"`
}

func (*Proposal) Descriptor 

func (*Proposal) Descriptor() ([]byte, []int)

func (*Proposal) GetId 

func (m *Proposal) GetId() uint32

func (*Proposal) GetKv 

func (m *Proposal) GetKv() []*KV

func (*Proposal) GetMembership 

func (m *Proposal) GetMembership() *Member

func (*Proposal) GetMutations 

func (m *Proposal) GetMutations() *Mutations

func (*Proposal) GetState 

func (m *Proposal) GetState() *MembershipState

func (*Proposal) Marshal 

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

func (*Proposal) MarshalTo 

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

func (*Proposal) ProtoMessage 

func (*Proposal) ProtoMessage()

func (*Proposal) Reset 

func (m *Proposal) Reset()

func (*Proposal) Size 

func (m *Proposal) Size() (n int)

func (*Proposal) String 

func (m *Proposal) String() string

func (*Proposal) Unmarshal 

func (m *Proposal) Unmarshal(dAtA []byte) error

type Query 

type Query struct {
	Attr     string   `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Langs    []string `protobuf:"bytes,2,rep,name=langs" json:"langs,omitempty"`
	AfterUid uint64   `protobuf:"fixed64,3,opt,name=after_uid,json=afterUid,proto3" json:"after_uid,omitempty"`
	DoCount  bool     `protobuf:"varint,4,opt,name=do_count,json=doCount,proto3" json:"do_count,omitempty"`
	// Exactly one of uids and terms is populated.
	UidList *List `protobuf:"bytes,5,opt,name=uid_list,json=uidList" json:"uid_list,omitempty"`
	// Function to generate or filter UIDs.
	SrcFunc      *SrcFunction `protobuf:"bytes,6,opt,name=src_func,json=srcFunc" json:"src_func,omitempty"`
	Reverse      bool         `protobuf:"varint,7,opt,name=reverse,proto3" json:"reverse,omitempty"`
	FacetParam   *Param       `protobuf:"bytes,8,opt,name=facet_param,json=facetParam" json:"facet_param,omitempty"`
	FacetsFilter *FilterTree  `protobuf:"bytes,9,opt,name=facets_filter,json=facetsFilter" json:"facets_filter,omitempty"`
}

func (*Query) Descriptor 

func (*Query) Descriptor() ([]byte, []int)

func (*Query) GetAfterUid 

func (m *Query) GetAfterUid() uint64

func (*Query) GetAttr 

func (m *Query) GetAttr() string

func (*Query) GetDoCount 

func (m *Query) GetDoCount() bool

func (*Query) GetFacetParam 

func (m *Query) GetFacetParam() *Param

func (*Query) GetFacetsFilter 

func (m *Query) GetFacetsFilter() *FilterTree

func (*Query) GetLangs 

func (m *Query) GetLangs() []string

func (*Query) GetReverse 

func (m *Query) GetReverse() bool

func (*Query) GetSrcFunc 

func (m *Query) GetSrcFunc() *SrcFunction

func (*Query) GetUidList 

func (m *Query) GetUidList() *List

func (*Query) Marshal 

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

func (*Query) MarshalTo 

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

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) Size 

func (m *Query) Size() (n int)

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal 

func (m *Query) Unmarshal(dAtA []byte) error

type RaftClient 

type RaftClient interface {
	// Connection testing RPC.
	Echo(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
	RaftMessage(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
	JoinCluster(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*Payload, error)
}

func NewRaftClient 

func NewRaftClient(cc *grpc.ClientConn) RaftClient

type RaftContext 

type RaftContext struct {
	Id    uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	Group uint32 `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"`
	Addr  string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*RaftContext) Descriptor 

func (*RaftContext) Descriptor() ([]byte, []int)

func (*RaftContext) GetAddr 

func (m *RaftContext) GetAddr() string

func (*RaftContext) GetGroup 

func (m *RaftContext) GetGroup() uint32

func (*RaftContext) GetId 

func (m *RaftContext) GetId() uint64

func (*RaftContext) Marshal 

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

func (*RaftContext) MarshalTo 

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

func (*RaftContext) ProtoMessage 

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset 

func (m *RaftContext) Reset()

func (*RaftContext) Size 

func (m *RaftContext) Size() (n int)

func (*RaftContext) String 

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal 

func (m *RaftContext) Unmarshal(dAtA []byte) error

type RaftServer 

type RaftServer interface {
	// Connection testing RPC.
	Echo(context.Context, *Payload) (*Payload, error)
	RaftMessage(context.Context, *Payload) (*Payload, error)
	JoinCluster(context.Context, *RaftContext) (*Payload, error)
}

type Request 

type Request struct {
	Query    string            `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Mutation *Mutation         `protobuf:"bytes,2,opt,name=mutation" json:"mutation,omitempty"`
	Schema   *SchemaRequest    `protobuf:"bytes,3,opt,name=schema" json:"schema,omitempty"`
	Vars     map[string]string `` /* 142-byte string literal not displayed */
}

func (*Request) Descriptor 

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetMutation 

func (m *Request) GetMutation() *Mutation

func (*Request) GetQuery 

func (m *Request) GetQuery() string

func (*Request) GetSchema 

func (m *Request) GetSchema() *SchemaRequest

func (*Request) GetVars 

func (m *Request) GetVars() map[string]string

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

type Response 

type Response struct {
	N            []*Node           `protobuf:"bytes,1,rep,name=n" json:"n,omitempty"`
	L            *Latency          `protobuf:"bytes,2,opt,name=l" json:"l,omitempty"`
	AssignedUids map[string]uint64 `` /* 159-byte string literal not displayed */
	Schema       []*SchemaNode     `protobuf:"bytes,4,rep,name=schema" json:"schema,omitempty"`
}

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetAssignedUids 

func (m *Response) GetAssignedUids() map[string]uint64

func (*Response) GetL 

func (m *Response) GetL() *Latency

func (*Response) GetN 

func (m *Response) GetN() []*Node

func (*Response) GetSchema 

func (m *Response) GetSchema() []*SchemaNode

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

type Result 

type Result struct {
	UidMatrix     []*List       `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
	ValueMatrix   []*ValueList  `protobuf:"bytes,2,rep,name=value_matrix,json=valueMatrix" json:"value_matrix,omitempty"`
	Counts        []uint32      `protobuf:"varint,3,rep,packed,name=counts" json:"counts,omitempty"`
	IntersectDest bool          `protobuf:"varint,4,opt,name=intersect_dest,json=intersectDest,proto3" json:"intersect_dest,omitempty"`
	FacetMatrix   []*FacetsList `protobuf:"bytes,5,rep,name=facet_matrix,json=facetMatrix" json:"facet_matrix,omitempty"`
}

func (*Result) Descriptor 

func (*Result) Descriptor() ([]byte, []int)

func (*Result) GetCounts 

func (m *Result) GetCounts() []uint32

func (*Result) GetFacetMatrix 

func (m *Result) GetFacetMatrix() []*FacetsList

func (*Result) GetIntersectDest 

func (m *Result) GetIntersectDest() bool

func (*Result) GetUidMatrix 

func (m *Result) GetUidMatrix() []*List

func (*Result) GetValueMatrix 

func (m *Result) GetValueMatrix() []*ValueList

func (*Result) Marshal 

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

func (*Result) MarshalTo 

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

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

func (m *Result) Size() (n int)

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

func (m *Result) Unmarshal(dAtA []byte) error

type SchemaNode 

type SchemaNode struct {
	Predicate string   `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
	Type      string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Index     bool     `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Tokenizer []string `protobuf:"bytes,4,rep,name=tokenizer" json:"tokenizer,omitempty"`
	Reverse   bool     `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
	Count     bool     `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	List      bool     `protobuf:"varint,7,opt,name=list,proto3" json:"list,omitempty"`
}

func (*SchemaNode) Descriptor 

func (*SchemaNode) Descriptor() ([]byte, []int)

func (*SchemaNode) GetCount 

func (m *SchemaNode) GetCount() bool

func (*SchemaNode) GetIndex 

func (m *SchemaNode) GetIndex() bool

func (*SchemaNode) GetList 

func (m *SchemaNode) GetList() bool

func (*SchemaNode) GetPredicate 

func (m *SchemaNode) GetPredicate() string

func (*SchemaNode) GetReverse 

func (m *SchemaNode) GetReverse() bool

func (*SchemaNode) GetTokenizer 

func (m *SchemaNode) GetTokenizer() []string

func (*SchemaNode) GetType 

func (m *SchemaNode) GetType() string

func (*SchemaNode) Marshal 

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

func (*SchemaNode) MarshalTo 

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

func (*SchemaNode) ProtoMessage 

func (*SchemaNode) ProtoMessage()

func (*SchemaNode) Reset 

func (m *SchemaNode) Reset()

func (*SchemaNode) Size 

func (m *SchemaNode) Size() (n int)

func (*SchemaNode) String 

func (m *SchemaNode) String() string

func (*SchemaNode) Unmarshal 

func (m *SchemaNode) Unmarshal(dAtA []byte) error

type SchemaRequest 

type SchemaRequest struct {
	GroupId    uint32   `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Predicates []string `protobuf:"bytes,2,rep,name=predicates" json:"predicates,omitempty"`
	// fields can be on of type, index, reverse or tokenizer
	Fields []string `protobuf:"bytes,3,rep,name=fields" json:"fields,omitempty"`
}

func (*SchemaRequest) Descriptor 

func (*SchemaRequest) Descriptor() ([]byte, []int)

func (*SchemaRequest) GetFields 

func (m *SchemaRequest) GetFields() []string

func (*SchemaRequest) GetGroupId 

func (m *SchemaRequest) GetGroupId() uint32

func (*SchemaRequest) GetPredicates 

func (m *SchemaRequest) GetPredicates() []string

func (*SchemaRequest) Marshal 

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

func (*SchemaRequest) MarshalTo 

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

func (*SchemaRequest) ProtoMessage 

func (*SchemaRequest) ProtoMessage()

func (*SchemaRequest) Reset 

func (m *SchemaRequest) Reset()

func (*SchemaRequest) Size 

func (m *SchemaRequest) Size() (n int)

func (*SchemaRequest) String 

func (m *SchemaRequest) String() string

func (*SchemaRequest) Unmarshal 

func (m *SchemaRequest) Unmarshal(dAtA []byte) error

type SchemaResult 

type SchemaResult struct {
	Schema []*SchemaNode `protobuf:"bytes,1,rep,name=schema" json:"schema,omitempty"`
}

func (*SchemaResult) Descriptor 

func (*SchemaResult) Descriptor() ([]byte, []int)

func (*SchemaResult) GetSchema 

func (m *SchemaResult) GetSchema() []*SchemaNode

func (*SchemaResult) Marshal 

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

func (*SchemaResult) MarshalTo 

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

func (*SchemaResult) ProtoMessage 

func (*SchemaResult) ProtoMessage()

func (*SchemaResult) Reset 

func (m *SchemaResult) Reset()

func (*SchemaResult) Size 

func (m *SchemaResult) Size() (n int)

func (*SchemaResult) String 

func (m *SchemaResult) String() string

func (*SchemaResult) Unmarshal 

func (m *SchemaResult) Unmarshal(dAtA []byte) error

type SchemaUpdate 

type SchemaUpdate struct {
	Predicate string                 `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
	ValueType uint32                 `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	Directive SchemaUpdate_Directive `protobuf:"varint,3,opt,name=directive,proto3,enum=protos.SchemaUpdate_Directive" json:"directive,omitempty"`
	Tokenizer []string               `protobuf:"bytes,4,rep,name=tokenizer" json:"tokenizer,omitempty"`
	Count     bool                   `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	List      bool                   `protobuf:"varint,6,opt,name=list,proto3" json:"list,omitempty"`
	Explicit  bool                   `protobuf:"varint,7,opt,name=explicit,proto3" json:"explicit,omitempty"`
}

func (*SchemaUpdate) Descriptor 

func (*SchemaUpdate) Descriptor() ([]byte, []int)

func (*SchemaUpdate) GetCount 

func (m *SchemaUpdate) GetCount() bool

func (*SchemaUpdate) GetDirective 

func (m *SchemaUpdate) GetDirective() SchemaUpdate_Directive

func (*SchemaUpdate) GetExplicit 

func (m *SchemaUpdate) GetExplicit() bool

func (*SchemaUpdate) GetList 

func (m *SchemaUpdate) GetList() bool

func (*SchemaUpdate) GetPredicate 

func (m *SchemaUpdate) GetPredicate() string

func (*SchemaUpdate) GetTokenizer 

func (m *SchemaUpdate) GetTokenizer() []string

func (*SchemaUpdate) GetValueType 

func (m *SchemaUpdate) GetValueType() uint32

func (*SchemaUpdate) Marshal 

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

func (*SchemaUpdate) MarshalTo 

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

func (*SchemaUpdate) ProtoMessage 

func (*SchemaUpdate) ProtoMessage()

func (*SchemaUpdate) Reset 

func (m *SchemaUpdate) Reset()

func (*SchemaUpdate) Size 

func (m *SchemaUpdate) Size() (n int)

func (*SchemaUpdate) String 

func (m *SchemaUpdate) String() string

func (*SchemaUpdate) Unmarshal 

func (m *SchemaUpdate) Unmarshal(dAtA []byte) error

type SchemaUpdate_Directive 

type SchemaUpdate_Directive int32
const (
	SchemaUpdate_NONE    SchemaUpdate_Directive = 0
	SchemaUpdate_INDEX   SchemaUpdate_Directive = 1
	SchemaUpdate_REVERSE SchemaUpdate_Directive = 2
	SchemaUpdate_DELETE  SchemaUpdate_Directive = 3
)

func (SchemaUpdate_Directive) EnumDescriptor 

func (SchemaUpdate_Directive) EnumDescriptor() ([]byte, []int)

func (SchemaUpdate_Directive) String 

func (x SchemaUpdate_Directive) String() string

type SortMessage 

type SortMessage struct {
	Order     []*Order `protobuf:"bytes,1,rep,name=order" json:"order,omitempty"`
	Langs     []string `protobuf:"bytes,2,rep,name=langs" json:"langs,omitempty"`
	UidMatrix []*List  `protobuf:"bytes,3,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
	Count     int32    `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	Offset    int32    `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
}

func (*SortMessage) Descriptor 

func (*SortMessage) Descriptor() ([]byte, []int)

func (*SortMessage) GetCount 

func (m *SortMessage) GetCount() int32

func (*SortMessage) GetLangs 

func (m *SortMessage) GetLangs() []string

func (*SortMessage) GetOffset 

func (m *SortMessage) GetOffset() int32

func (*SortMessage) GetOrder 

func (m *SortMessage) GetOrder() []*Order

func (*SortMessage) GetUidMatrix 

func (m *SortMessage) GetUidMatrix() []*List

func (*SortMessage) Marshal 

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

func (*SortMessage) MarshalTo 

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

func (*SortMessage) ProtoMessage 

func (*SortMessage) ProtoMessage()

func (*SortMessage) Reset 

func (m *SortMessage) Reset()

func (*SortMessage) Size 

func (m *SortMessage) Size() (n int)

func (*SortMessage) String 

func (m *SortMessage) String() string

func (*SortMessage) Unmarshal 

func (m *SortMessage) Unmarshal(dAtA []byte) error

type SortResult 

type SortResult struct {
	UidMatrix []*List `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
}

func (*SortResult) Descriptor 

func (*SortResult) Descriptor() ([]byte, []int)

func (*SortResult) GetUidMatrix 

func (m *SortResult) GetUidMatrix() []*List

func (*SortResult) Marshal 

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

func (*SortResult) MarshalTo 

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

func (*SortResult) ProtoMessage 

func (*SortResult) ProtoMessage()

func (*SortResult) Reset 

func (m *SortResult) Reset()

func (*SortResult) Size 

func (m *SortResult) Size() (n int)

func (*SortResult) String 

func (m *SortResult) String() string

func (*SortResult) Unmarshal 

func (m *SortResult) Unmarshal(dAtA []byte) error

type SrcFunction 

type SrcFunction struct {
	Name    string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args    []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	IsCount bool     `protobuf:"varint,4,opt,name=isCount,proto3" json:"isCount,omitempty"`
}

func (*SrcFunction) Descriptor 

func (*SrcFunction) Descriptor() ([]byte, []int)

func (*SrcFunction) GetArgs 

func (m *SrcFunction) GetArgs() []string

func (*SrcFunction) GetIsCount 

func (m *SrcFunction) GetIsCount() bool

func (*SrcFunction) GetName 

func (m *SrcFunction) GetName() string

func (*SrcFunction) Marshal 

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

func (*SrcFunction) MarshalTo 

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

func (*SrcFunction) ProtoMessage 

func (*SrcFunction) ProtoMessage()

func (*SrcFunction) Reset 

func (m *SrcFunction) Reset()

func (*SrcFunction) Size 

func (m *SrcFunction) Size() (n int)

func (*SrcFunction) String 

func (m *SrcFunction) String() string

func (*SrcFunction) Unmarshal 

func (m *SrcFunction) Unmarshal(dAtA []byte) error

type Tablet 

type Tablet struct {
	GroupId   uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	NoUpdate  bool   `protobuf:"varint,3,opt,name=no_update,json=noUpdate,proto3" json:"no_update,omitempty"`
	Size_     int64  `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	ReadOnly  bool   `protobuf:"varint,7,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
}

func (*Tablet) Descriptor 

func (*Tablet) Descriptor() ([]byte, []int)

func (*Tablet) GetGroupId 

func (m *Tablet) GetGroupId() uint32

func (*Tablet) GetNoUpdate 

func (m *Tablet) GetNoUpdate() bool

func (*Tablet) GetPredicate 

func (m *Tablet) GetPredicate() string

func (*Tablet) GetReadOnly 

func (m *Tablet) GetReadOnly() bool

func (*Tablet) GetSize_ 

func (m *Tablet) GetSize_() int64

func (*Tablet) Marshal 

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

func (*Tablet) MarshalTo 

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

func (*Tablet) ProtoMessage 

func (*Tablet) ProtoMessage()

func (*Tablet) Reset 

func (m *Tablet) Reset()

func (*Tablet) Size 

func (m *Tablet) Size() (n int)

func (*Tablet) String 

func (m *Tablet) String() string

func (*Tablet) Unmarshal 

func (m *Tablet) Unmarshal(dAtA []byte) error

type TaskValue 

type TaskValue struct {
	Val     []byte `protobuf:"bytes,1,opt,name=val,proto3" json:"val,omitempty"`
	ValType int32  `protobuf:"varint,2,opt,name=val_type,json=valType,proto3" json:"val_type,omitempty"`
}

func (*TaskValue) Descriptor 

func (*TaskValue) Descriptor() ([]byte, []int)

func (*TaskValue) GetVal 

func (m *TaskValue) GetVal() []byte

func (*TaskValue) GetValType 

func (m *TaskValue) GetValType() int32

func (*TaskValue) Marshal 

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

func (*TaskValue) MarshalTo 

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

func (*TaskValue) ProtoMessage 

func (*TaskValue) ProtoMessage()

func (*TaskValue) Reset 

func (m *TaskValue) Reset()

func (*TaskValue) Size 

func (m *TaskValue) Size() (n int)

func (*TaskValue) String 

func (m *TaskValue) String() string

func (*TaskValue) Unmarshal 

func (m *TaskValue) Unmarshal(dAtA []byte) error

type Value 

type Value struct {
	// Types that are valid to be assigned to Val:
	//	*Value_DefaultVal
	//	*Value_BytesVal
	//	*Value_IntVal
	//	*Value_BoolVal
	//	*Value_StrVal
	//	*Value_DoubleVal
	//	*Value_GeoVal
	//	*Value_DateVal
	//	*Value_DatetimeVal
	//	*Value_PasswordVal
	//	*Value_UidVal
	Val isValue_Val `protobuf_oneof:"val"`
}

func (*Value) Descriptor 

func (*Value) Descriptor() ([]byte, []int)

func (*Value) GetBoolVal 

func (m *Value) GetBoolVal() bool

func (*Value) GetBytesVal 

func (m *Value) GetBytesVal() []byte

func (*Value) GetDateVal 

func (m *Value) GetDateVal() []byte

func (*Value) GetDatetimeVal 

func (m *Value) GetDatetimeVal() []byte

func (*Value) GetDefaultVal 

func (m *Value) GetDefaultVal() string

func (*Value) GetDoubleVal 

func (m *Value) GetDoubleVal() float64

func (*Value) GetGeoVal 

func (m *Value) GetGeoVal() []byte

func (*Value) GetIntVal 

func (m *Value) GetIntVal() int64

func (*Value) GetPasswordVal 

func (m *Value) GetPasswordVal() string

func (*Value) GetStrVal 

func (m *Value) GetStrVal() string

func (*Value) GetUidVal 

func (m *Value) GetUidVal() uint64

func (*Value) GetVal 

func (m *Value) GetVal() isValue_Val

func (*Value) Marshal 

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

func (*Value) MarshalTo 

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

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size 

func (m *Value) Size() (n int)

func (*Value) String 

func (m *Value) String() string

func (*Value) Unmarshal 

func (m *Value) Unmarshal(dAtA []byte) error

func (*Value) XXX_OneofFuncs 

func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ValueList 

type ValueList struct {
	Values []*TaskValue `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

func (*ValueList) Descriptor 

func (*ValueList) Descriptor() ([]byte, []int)

func (*ValueList) GetValues 

func (m *ValueList) GetValues() []*TaskValue

func (*ValueList) Marshal 

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

func (*ValueList) MarshalTo 

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

func (*ValueList) ProtoMessage 

func (*ValueList) ProtoMessage()

func (*ValueList) Reset 

func (m *ValueList) Reset()

func (*ValueList) Size 

func (m *ValueList) Size() (n int)

func (*ValueList) String 

func (m *ValueList) String() string

func (*ValueList) Unmarshal 

func (m *ValueList) Unmarshal(dAtA []byte) error

type Value_BoolVal 

type Value_BoolVal struct {
	BoolVal bool `protobuf:"varint,4,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

func (*Value_BoolVal) MarshalTo 

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

func (*Value_BoolVal) Size 

func (m *Value_BoolVal) Size() (n int)

type Value_BytesVal 

type Value_BytesVal struct {
	BytesVal []byte `protobuf:"bytes,2,opt,name=bytes_val,json=bytesVal,proto3,oneof"`
}

func (*Value_BytesVal) MarshalTo 

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

func (*Value_BytesVal) Size 

func (m *Value_BytesVal) Size() (n int)

type Value_DateVal 

type Value_DateVal struct {
	DateVal []byte `protobuf:"bytes,8,opt,name=date_val,json=dateVal,proto3,oneof"`
}

func (*Value_DateVal) MarshalTo 

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

func (*Value_DateVal) Size 

func (m *Value_DateVal) Size() (n int)

type Value_DatetimeVal 

type Value_DatetimeVal struct {
	DatetimeVal []byte `protobuf:"bytes,9,opt,name=datetime_val,json=datetimeVal,proto3,oneof"`
}

func (*Value_DatetimeVal) MarshalTo 

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

func (*Value_DatetimeVal) Size 

func (m *Value_DatetimeVal) Size() (n int)

type Value_DefaultVal 

type Value_DefaultVal struct {
	DefaultVal string `protobuf:"bytes,1,opt,name=default_val,json=defaultVal,proto3,oneof"`
}

func (*Value_DefaultVal) MarshalTo 

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

func (*Value_DefaultVal) Size 

func (m *Value_DefaultVal) Size() (n int)

type Value_DoubleVal 

type Value_DoubleVal struct {
	DoubleVal float64 `protobuf:"fixed64,6,opt,name=double_val,json=doubleVal,proto3,oneof"`
}

func (*Value_DoubleVal) MarshalTo 

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

func (*Value_DoubleVal) Size 

func (m *Value_DoubleVal) Size() (n int)

type Value_GeoVal 

type Value_GeoVal struct {
	GeoVal []byte `protobuf:"bytes,7,opt,name=geo_val,json=geoVal,proto3,oneof"`
}

func (*Value_GeoVal) MarshalTo 

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

func (*Value_GeoVal) Size 

func (m *Value_GeoVal) Size() (n int)

type Value_IntVal 

type Value_IntVal struct {
	IntVal int64 `protobuf:"varint,3,opt,name=int_val,json=intVal,proto3,oneof"`
}

func (*Value_IntVal) MarshalTo 

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

func (*Value_IntVal) Size 

func (m *Value_IntVal) Size() (n int)

type Value_PasswordVal 

type Value_PasswordVal struct {
	PasswordVal string `protobuf:"bytes,10,opt,name=password_val,json=passwordVal,proto3,oneof"`
}

func (*Value_PasswordVal) MarshalTo 

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

func (*Value_PasswordVal) Size 

func (m *Value_PasswordVal) Size() (n int)

type Value_StrVal 

type Value_StrVal struct {
	StrVal string `protobuf:"bytes,5,opt,name=str_val,json=strVal,proto3,oneof"`
}

func (*Value_StrVal) MarshalTo 

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

func (*Value_StrVal) Size 

func (m *Value_StrVal) Size() (n int)

type Value_UidVal 

type Value_UidVal struct {
	UidVal uint64 `protobuf:"varint,11,opt,name=uid_val,json=uidVal,proto3,oneof"`
}

func (*Value_UidVal) MarshalTo 

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

func (*Value_UidVal) Size 

func (m *Value_UidVal) Size() (n int)

type Version 

type Version struct {
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
}

func (*Version) Descriptor 

func (*Version) Descriptor() ([]byte, []int)

func (*Version) GetTag 

func (m *Version) GetTag() string

func (*Version) Marshal 

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

func (*Version) MarshalTo 

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

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) Reset 

func (m *Version) Reset()

func (*Version) Size 

func (m *Version) Size() (n int)

func (*Version) String 

func (m *Version) String() string

func (*Version) Unmarshal 

func (m *Version) Unmarshal(dAtA []byte) error

type WorkerClient 

type WorkerClient interface {
	// Data serving RPCs.
	Mutate(ctx context.Context, in *Mutations, opts ...grpc.CallOption) (*Payload, error)
	ServeTask(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Result, error)
	PredicateAndSchemaData(ctx context.Context, opts ...grpc.CallOption) (Worker_PredicateAndSchemaDataClient, error)
	Sort(ctx context.Context, in *SortMessage, opts ...grpc.CallOption) (*SortResult, error)
	Schema(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaResult, error)
	Export(ctx context.Context, in *ExportPayload, opts ...grpc.CallOption) (*ExportPayload, error)
	ReceivePredicate(ctx context.Context, opts ...grpc.CallOption) (Worker_ReceivePredicateClient, error)
	MovePredicate(ctx context.Context, in *MovePredicatePayload, opts ...grpc.CallOption) (*Payload, error)
}

func NewWorkerClient 

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerServer 

type WorkerServer interface {
	// Data serving RPCs.
	Mutate(context.Context, *Mutations) (*Payload, error)
	ServeTask(context.Context, *Query) (*Result, error)
	PredicateAndSchemaData(Worker_PredicateAndSchemaDataServer) error
	Sort(context.Context, *SortMessage) (*SortResult, error)
	Schema(context.Context, *SchemaRequest) (*SchemaResult, error)
	Export(context.Context, *ExportPayload) (*ExportPayload, error)
	ReceivePredicate(Worker_ReceivePredicateServer) error
	MovePredicate(context.Context, *MovePredicatePayload) (*Payload, error)
}

type Worker_PredicateAndSchemaDataClient 

type Worker_PredicateAndSchemaDataClient interface {
	Send(*GroupKeys) error
	Recv() (*KV, error)
	grpc.ClientStream
}

type Worker_PredicateAndSchemaDataServer 

type Worker_PredicateAndSchemaDataServer interface {
	Send(*KV) error
	Recv() (*GroupKeys, error)
	grpc.ServerStream
}

type Worker_ReceivePredicateClient 

type Worker_ReceivePredicateClient interface {
	Send(*KV) error
	CloseAndRecv() (*Payload, error)
	grpc.ClientStream
}

type Worker_ReceivePredicateServer 

type Worker_ReceivePredicateServer interface {
	SendAndClose(*Payload) error
	Recv() (*KV, error)
	grpc.ServerStream
}

type ZeroClient 

type ZeroClient interface {
	Connect(ctx context.Context, in *Member, opts ...grpc.CallOption) (*MembershipState, error)
	Update(ctx context.Context, opts ...grpc.CallOption) (Zero_UpdateClient, error)
	ShouldServe(ctx context.Context, in *Tablet, opts ...grpc.CallOption) (*Tablet, error)
	AssignUids(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error)
}

func NewZeroClient 

func NewZeroClient(cc *grpc.ClientConn) ZeroClient

type ZeroProposal 

type ZeroProposal struct {
	Id         uint32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Member     *Member `protobuf:"bytes,2,opt,name=member" json:"member,omitempty"`
	Tablet     *Tablet `protobuf:"bytes,3,opt,name=tablet" json:"tablet,omitempty"`
	MaxLeaseId uint64  `protobuf:"varint,4,opt,name=maxLeaseId,proto3" json:"maxLeaseId,omitempty"`
}

func (*ZeroProposal) Descriptor 

func (*ZeroProposal) Descriptor() ([]byte, []int)

func (*ZeroProposal) GetId 

func (m *ZeroProposal) GetId() uint32

func (*ZeroProposal) GetMaxLeaseId 

func (m *ZeroProposal) GetMaxLeaseId() uint64

func (*ZeroProposal) GetMember 

func (m *ZeroProposal) GetMember() *Member

func (*ZeroProposal) GetTablet 

func (m *ZeroProposal) GetTablet() *Tablet

func (*ZeroProposal) Marshal 

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

func (*ZeroProposal) MarshalTo 

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

func (*ZeroProposal) ProtoMessage 

func (*ZeroProposal) ProtoMessage()

func (*ZeroProposal) Reset 

func (m *ZeroProposal) Reset()

func (*ZeroProposal) Size 

func (m *ZeroProposal) Size() (n int)

func (*ZeroProposal) String 

func (m *ZeroProposal) String() string

func (*ZeroProposal) Unmarshal 

func (m *ZeroProposal) Unmarshal(dAtA []byte) error

type ZeroServer 

type ZeroServer interface {
	Connect(context.Context, *Member) (*MembershipState, error)
	Update(Zero_UpdateServer) error
	ShouldServe(context.Context, *Tablet) (*Tablet, error)
	AssignUids(context.Context, *Num) (*AssignedIds, error)
}

type Zero_UpdateClient 

type Zero_UpdateClient interface {
	Send(*Group) error
	Recv() (*MembershipState, error)
	grpc.ClientStream
}

type Zero_UpdateServer 

type Zero_UpdateServer interface {
	Send(*MembershipState) error
	Recv() (*Group, error)
	grpc.ServerStream
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.