protos

package
v0.9.2 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 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: 

task.proto

It has these top-level messages: 

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

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DirectedEdge_Op_name = map[int32]string{
	0: "SET",
	1: "DEL",
}
View Source 
var DirectedEdge_Op_value = map[string]int32{
	"SET": 0,
	"DEL": 1,
}
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 Assigned 

type Assigned struct {
	Uids    map[string]string `` /* 142-byte string literal not displayed */
	Context *TxnContext       `protobuf:"bytes,2,opt,name=context" json:"context,omitempty"`
	Error   string            `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*Assigned) Descriptor 

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

func (*Assigned) GetContext 

func (m *Assigned) GetContext() *TxnContext

func (*Assigned) GetError 

func (m *Assigned) GetError() string

func (*Assigned) GetUids 

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

func (*Assigned) Marshal 

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

func (*Assigned) MarshalTo 

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

func (*Assigned) ProtoMessage 

func (*Assigned) ProtoMessage()

func (*Assigned) Reset 

func (m *Assigned) Reset()

func (*Assigned) Size 

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

func (*Assigned) String 

func (m *Assigned) String() string

func (*Assigned) Unmarshal 

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

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 ConnectionState 

type ConnectionState struct {
	Member *Member          `protobuf:"bytes,1,opt,name=member" json:"member,omitempty"`
	State  *MembershipState `protobuf:"bytes,2,opt,name=state" json:"state,omitempty"`
}

func (*ConnectionState) Descriptor 

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

func (*ConnectionState) GetMember 

func (m *ConnectionState) GetMember() *Member

func (*ConnectionState) GetState 

func (m *ConnectionState) GetState() *MembershipState

func (*ConnectionState) Marshal 

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

func (*ConnectionState) MarshalTo 

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

func (*ConnectionState) ProtoMessage 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) Reset 

func (m *ConnectionState) Reset()

func (*ConnectionState) Size 

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

func (*ConnectionState) String 

func (m *ConnectionState) String() string

func (*ConnectionState) Unmarshal 

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

type DgraphClient 

type DgraphClient interface {
	Query(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Mutate(ctx context.Context, in *Mutation, opts ...grpc.CallOption) (*Assigned, error)
	Alter(ctx context.Context, in *Operation, opts ...grpc.CallOption) (*Payload, error)
	CommitOrAbort(ctx context.Context, in *TxnContext, opts ...grpc.CallOption) (*TxnContext, error)
	CheckVersion(ctx context.Context, in *Check, opts ...grpc.CallOption) (*Version, error)
}

func NewDgraphClient 

func NewDgraphClient(cc *grpc.ClientConn) DgraphClient

type DgraphServer 

type DgraphServer interface {
	Query(context.Context, *Request) (*Response, error)
	Mutate(context.Context, *Mutation) (*Assigned, error)
	Alter(context.Context, *Operation) (*Payload, error)
	CommitOrAbort(context.Context, *TxnContext) (*TxnContext, error)
	CheckVersion(context.Context, *Check) (*Version, 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 Posting_ValType `protobuf:"varint,4,opt,name=value_type,json=valueType,proto3,enum=protos.Posting_ValType" 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() Posting_ValType

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"`
	ReadTs  uint64               `protobuf:"varint,4,opt,name=read_ts,json=readTs,proto3" json:"read_ts,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) GetReadTs 

func (m *ExportPayload) GetReadTs() uint64

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"`
}

Facet messages.

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"`
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*KC) Descriptor 

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

func (*KC) GetKey 

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

func (*KC) GetTimestamp 

func (m *KC) GetTimestamp() uint64

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"`
	Version  uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,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) GetVersion 

func (m *KV) GetVersion() uint64

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 {
	ParsingNs    uint64 `protobuf:"varint,1,opt,name=parsing_ns,json=parsingNs,proto3" json:"parsing_ns,omitempty"`
	ProcessingNs uint64 `protobuf:"varint,2,opt,name=processing_ns,json=processingNs,proto3" json:"processing_ns,omitempty"`
	EncodingNs   uint64 `protobuf:"varint,3,opt,name=encoding_ns,json=encodingNs,proto3" json:"encoding_ns,omitempty"`
}

func (*Latency) Descriptor 

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

func (*Latency) GetEncodingNs 

func (m *Latency) GetEncodingNs() uint64

func (*Latency) GetParsingNs 

func (m *Latency) GetParsingNs() uint64

func (*Latency) GetProcessingNs 

func (m *Latency) GetProcessingNs() uint64

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 LinRead 

type LinRead struct {
	Ids map[uint32]uint64 `` /* 142-byte string literal not displayed */
}

func (*LinRead) Descriptor 

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

func (*LinRead) GetIds 

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

func (*LinRead) Marshal 

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

func (*LinRead) MarshalTo 

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

func (*LinRead) ProtoMessage 

func (*LinRead) ProtoMessage()

func (*LinRead) Reset 

func (m *LinRead) Reset()

func (*LinRead) Size 

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

func (*LinRead) String 

func (m *LinRead) String() string

func (*LinRead) Unmarshal 

func (m *LinRead) 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"`
}

Bulk loader proto.

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"`
	CluterInfoOnly bool   `protobuf:"varint,13,opt,name=cluter_info_only,json=cluterInfoOnly,proto3" json:"cluter_info_only,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) GetCluterInfoOnly 

func (m *Member) GetCluterInfoOnly() 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"`
	MaxTxnTs   uint64             `protobuf:"varint,5,opt,name=maxTxnTs,proto3" json:"maxTxnTs,omitempty"`
	MaxRaftId  uint64             `protobuf:"varint,6,opt,name=maxRaftId,proto3" json:"maxRaftId,omitempty"`
	Removed    []*Member          `protobuf:"bytes,7,rep,name=removed" json:"removed,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) GetMaxRaftId 

func (m *MembershipState) GetMaxRaftId() uint64

func (*MembershipState) GetMaxTxnTs 

func (m *MembershipState) GetMaxTxnTs() uint64

func (*MembershipState) GetRemoved 

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

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 {
	SetJson    []byte   `protobuf:"bytes,1,opt,name=set_json,json=setJson,proto3" json:"set_json,omitempty"`
	DeleteJson []byte   `protobuf:"bytes,2,opt,name=delete_json,json=deleteJson,proto3" json:"delete_json,omitempty"`
	SetNquads  []byte   `protobuf:"bytes,3,opt,name=set_nquads,json=setNquads,proto3" json:"set_nquads,omitempty"`
	DelNquads  []byte   `protobuf:"bytes,4,opt,name=del_nquads,json=delNquads,proto3" json:"del_nquads,omitempty"`
	Set        []*NQuad `protobuf:"bytes,10,rep,name=set" json:"set,omitempty"`
	Del        []*NQuad `protobuf:"bytes,11,rep,name=del" json:"del,omitempty"`
	StartTs    uint64   `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitNow  bool     `protobuf:"varint,14,opt,name=commit_now,json=commitNow,proto3" json:"commit_now,omitempty"`
}

func (*Mutation) Descriptor 

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

func (*Mutation) GetCommitNow 

func (m *Mutation) GetCommitNow() bool

func (*Mutation) GetDel 

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

func (*Mutation) GetDelNquads 

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

func (*Mutation) GetDeleteJson 

func (m *Mutation) GetDeleteJson() []byte

func (*Mutation) GetSet 

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

func (*Mutation) GetSetJson 

func (m *Mutation) GetSetJson() []byte

func (*Mutation) GetSetNquads 

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

func (*Mutation) GetStartTs 

func (m *Mutation) GetStartTs() uint64

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"`
	StartTs uint64          `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Edges   []*DirectedEdge `protobuf:"bytes,3,rep,name=edges" json:"edges,omitempty"`
	Schema  []*SchemaUpdate `protobuf:"bytes,4,rep,name=schema" json:"schema,omitempty"`
	DropAll bool            `protobuf:"varint,5,opt,name=DropAll,proto3" json:"DropAll,omitempty"`
}

func (*Mutations) Descriptor 

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

func (*Mutations) GetDropAll 

func (m *Mutations) GetDropAll() bool

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) GetStartTs 

func (m *Mutations) GetStartTs() uint64

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,6,opt,name=lang,proto3" json:"lang,omitempty"`
	Facets      []*Facet `protobuf:"bytes,7,rep,name=facets" json:"facets,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) GetObjectValue 

func (m *NQuad) GetObjectValue() *Value

func (*NQuad) GetPredicate 

func (m *NQuad) GetPredicate() string

func (*NQuad) GetSubject 

func (m *NQuad) GetSubject() 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 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 Operation 

type Operation struct {
	Schema   string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	DropAttr string `protobuf:"bytes,2,opt,name=drop_attr,json=dropAttr,proto3" json:"drop_attr,omitempty"`
	DropAll  bool   `protobuf:"varint,3,opt,name=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"`
	StartTs  uint64 `protobuf:"varint,4,opt,name=startTs,proto3" json:"startTs,omitempty"`
}

func (*Operation) Descriptor 

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

func (*Operation) GetDropAll 

func (m *Operation) GetDropAll() bool

func (*Operation) GetDropAttr 

func (m *Operation) GetDropAttr() string

func (*Operation) GetSchema 

func (m *Operation) GetSchema() string

func (*Operation) GetStartTs 

func (m *Operation) GetStartTs() uint64

func (*Operation) Marshal 

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

func (*Operation) MarshalTo 

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

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) Reset 

func (m *Operation) Reset()

func (*Operation) Size 

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

func (*Operation) String 

func (m *Operation) String() string

func (*Operation) Unmarshal 

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

type OracleDelta 

type OracleDelta struct {
	Commits    map[uint64]uint64 `` /* 150-byte string literal not displayed */
	Aborts     []uint64          `protobuf:"varint,2,rep,packed,name=aborts" json:"aborts,omitempty"`
	MaxPending uint64            `protobuf:"varint,3,opt,name=max_pending,json=maxPending,proto3" json:"max_pending,omitempty"`
}

func (*OracleDelta) Descriptor 

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

func (*OracleDelta) GetAborts 

func (m *OracleDelta) GetAborts() []uint64

func (*OracleDelta) GetCommits 

func (m *OracleDelta) GetCommits() map[uint64]uint64

func (*OracleDelta) GetMaxPending 

func (m *OracleDelta) GetMaxPending() uint64

func (*OracleDelta) Marshal 

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

func (*OracleDelta) MarshalTo 

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

func (*OracleDelta) ProtoMessage 

func (*OracleDelta) ProtoMessage()

func (*OracleDelta) Reset 

func (m *OracleDelta) Reset()

func (*OracleDelta) Size 

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

func (*OracleDelta) String 

func (m *OracleDelta) String() string

func (*OracleDelta) Unmarshal 

func (m *OracleDelta) 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"`
	Langs []string `protobuf:"bytes,3,rep,name=langs" json:"langs,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) GetLangs 

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

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"`
}

Worker services.

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"`
	Facets      []*Facet            `protobuf:"bytes,9,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"`
	StartTs  uint64 `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs uint64 `protobuf:"varint,14,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
}

Posting messages.

func (*Posting) Descriptor 

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

func (*Posting) GetCommitTs 

func (m *Posting) GetCommitTs() 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) GetStartTs 

func (m *Posting) GetStartTs() uint64

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 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"`
	TxnContext     *TxnContext      `protobuf:"bytes,3,opt,name=txn_context,json=txnContext" json:"txn_context,omitempty"`
	Kv             []*KV            `protobuf:"bytes,4,rep,name=kv" json:"kv,omitempty"`
	State          *MembershipState `protobuf:"bytes,5,opt,name=state" json:"state,omitempty"`
	CleanPredicate string           `protobuf:"bytes,6,opt,name=clean_predicate,json=cleanPredicate,proto3" json:"clean_predicate,omitempty"`
}

func (*Proposal) Descriptor 

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

func (*Proposal) GetCleanPredicate 

func (m *Proposal) GetCleanPredicate() string

func (*Proposal) GetId 

func (m *Proposal) GetId() uint32

func (*Proposal) GetKv 

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

func (*Proposal) GetMutations 

func (m *Proposal) GetMutations() *Mutations

func (*Proposal) GetState 

func (m *Proposal) GetState() *MembershipState

func (*Proposal) GetTxnContext 

func (m *Proposal) GetTxnContext() *TxnContext

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"`
	ReadTs       uint64       `protobuf:"varint,13,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
	LinRead      *LinRead     `protobuf:"bytes,14,opt,name=lin_read,json=linRead" json:"lin_read,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) GetLinRead 

func (m *Query) GetLinRead() *LinRead

func (*Query) GetReadTs 

func (m *Query) GetReadTs() uint64

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 {
	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 {
	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"`
	Vars    map[string]string `` /* 142-byte string literal not displayed */
	StartTs uint64            `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	LinRead *LinRead          `protobuf:"bytes,14,opt,name=lin_read,json=linRead" json:"lin_read,omitempty"`
}

func (*Request) Descriptor 

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

func (*Request) GetLinRead 

func (m *Request) GetLinRead() *LinRead

func (*Request) GetQuery 

func (m *Request) GetQuery() string

func (*Request) GetStartTs 

func (m *Request) GetStartTs() uint64

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 {
	Json    []byte        `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	Schema  []*SchemaNode `protobuf:"bytes,2,rep,name=schema" json:"schema,omitempty"`
	Txn     *TxnContext   `protobuf:"bytes,3,opt,name=txn" json:"txn,omitempty"`
	Latency *Latency      `protobuf:"bytes,12,opt,name=latency" json:"latency,omitempty"`
}

func (*Response) Descriptor 

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

func (*Response) GetJson 

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

func (*Response) GetLatency 

func (m *Response) GetLatency() *Latency

func (*Response) GetSchema 

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

func (*Response) GetTxn 

func (m *Response) GetTxn() *TxnContext

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"`
	LinRead       *LinRead      `protobuf:"bytes,14,opt,name=lin_read,json=linRead" json:"lin_read,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) GetLinRead 

func (m *Result) GetLinRead() *LinRead

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"`
}

Schema messages.

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 Posting_ValType        `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=protos.Posting_ValType" 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() Posting_ValType

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"`
	UidMatrix []*List  `protobuf:"bytes,2,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
	Count     int32    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	Offset    int32    `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	ReadTs    uint64   `protobuf:"varint,13,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
	LinRead   *LinRead `protobuf:"bytes,14,opt,name=lin_read,json=linRead" json:"lin_read,omitempty"`
}

func (*SortMessage) Descriptor 

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

func (*SortMessage) GetCount 

func (m *SortMessage) GetCount() int32

func (*SortMessage) GetLinRead 

func (m *SortMessage) GetLinRead() *LinRead

func (*SortMessage) GetOffset 

func (m *SortMessage) GetOffset() int32

func (*SortMessage) GetOrder 

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

func (*SortMessage) GetReadTs 

func (m *SortMessage) GetReadTs() uint64

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"`
	LinRead   *LinRead `protobuf:"bytes,14,opt,name=lin_read,json=linRead" json:"lin_read,omitempty"`
}

func (*SortResult) Descriptor 

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

func (*SortResult) GetLinRead 

func (m *SortResult) GetLinRead() *LinRead

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"`
	Force     bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	ReadOnly  bool   `protobuf:"varint,4,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	Space     int64  `protobuf:"varint,7,opt,name=space,proto3" json:"space,omitempty"`
}

func (*Tablet) Descriptor 

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

func (*Tablet) GetForce 

func (m *Tablet) GetForce() bool

func (*Tablet) GetGroupId 

func (m *Tablet) GetGroupId() uint32

func (*Tablet) GetPredicate 

func (m *Tablet) GetPredicate() string

func (*Tablet) GetReadOnly 

func (m *Tablet) GetReadOnly() bool

func (*Tablet) GetSpace 

func (m *Tablet) GetSpace() 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 TxnContext 

type TxnContext struct {
	StartTs  uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs uint64   `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	Aborted  bool     `protobuf:"varint,3,opt,name=aborted,proto3" json:"aborted,omitempty"`
	Keys     []string `protobuf:"bytes,4,rep,name=keys" json:"keys,omitempty"`
	LinRead  *LinRead `protobuf:"bytes,13,opt,name=lin_read,json=linRead" json:"lin_read,omitempty"`
}

func (*TxnContext) Descriptor 

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

func (*TxnContext) GetAborted 

func (m *TxnContext) GetAborted() bool

func (*TxnContext) GetCommitTs 

func (m *TxnContext) GetCommitTs() uint64

func (*TxnContext) GetKeys 

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

func (*TxnContext) GetLinRead 

func (m *TxnContext) GetLinRead() *LinRead

func (*TxnContext) GetStartTs 

func (m *TxnContext) GetStartTs() uint64

func (*TxnContext) Marshal 

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

func (*TxnContext) MarshalTo 

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

func (*TxnContext) ProtoMessage 

func (*TxnContext) ProtoMessage()

func (*TxnContext) Reset 

func (m *TxnContext) Reset()

func (*TxnContext) Size 

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

func (*TxnContext) String 

func (m *TxnContext) String() string

func (*TxnContext) Unmarshal 

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

type TxnTimestamps 

type TxnTimestamps struct {
	Ts []uint64 `protobuf:"varint,1,rep,packed,name=ts" json:"ts,omitempty"`
}

func (*TxnTimestamps) Descriptor 

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

func (*TxnTimestamps) GetTs 

func (m *TxnTimestamps) GetTs() []uint64

func (*TxnTimestamps) Marshal 

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

func (*TxnTimestamps) MarshalTo 

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

func (*TxnTimestamps) ProtoMessage 

func (*TxnTimestamps) ProtoMessage()

func (*TxnTimestamps) Reset 

func (m *TxnTimestamps) Reset()

func (*TxnTimestamps) Size 

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

func (*TxnTimestamps) String 

func (m *TxnTimestamps) String() string

func (*TxnTimestamps) Unmarshal 

func (m *TxnTimestamps) 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) (*TxnContext, error)
	CommitOrAbort(ctx context.Context, in *TxnContext, 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)
	MinTxnTs(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Num, 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) (*TxnContext, error)
	CommitOrAbort(context.Context, *TxnContext) (*Payload, error)
	ServeTask(context.Context, *Query) (*Result, error)
	PredicateAndSchemaData(Worker_PredicateAndSchemaDataServer) error
	Sort(context.Context, *SortMessage) (*SortResult, error)
	Schema(context.Context, *SchemaRequest) (*SchemaResult, error)
	MinTxnTs(context.Context, *Payload) (*Num, 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) (*ConnectionState, error)
	Update(ctx context.Context, opts ...grpc.CallOption) (Zero_UpdateClient, error)
	Oracle(ctx context.Context, in *Payload, opts ...grpc.CallOption) (Zero_OracleClient, error)
	ShouldServe(ctx context.Context, in *Tablet, opts ...grpc.CallOption) (*Tablet, error)
	AssignUids(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error)
	Timestamps(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error)
	CommitOrAbort(ctx context.Context, in *TxnContext, opts ...grpc.CallOption) (*TxnContext, error)
	TryAbort(ctx context.Context, in *TxnTimestamps, opts ...grpc.CallOption) (*TxnTimestamps, 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"`
	MaxTxnTs   uint64      `protobuf:"varint,5,opt,name=maxTxnTs,proto3" json:"maxTxnTs,omitempty"`
	MaxRaftId  uint64      `protobuf:"varint,6,opt,name=maxRaftId,proto3" json:"maxRaftId,omitempty"`
	Txn        *TxnContext `protobuf:"bytes,7,opt,name=txn" json:"txn,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) GetMaxRaftId 

func (m *ZeroProposal) GetMaxRaftId() uint64

func (*ZeroProposal) GetMaxTxnTs 

func (m *ZeroProposal) GetMaxTxnTs() uint64

func (*ZeroProposal) GetMember 

func (m *ZeroProposal) GetMember() *Member

func (*ZeroProposal) GetTablet 

func (m *ZeroProposal) GetTablet() *Tablet

func (*ZeroProposal) GetTxn 

func (m *ZeroProposal) GetTxn() *TxnContext

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) (*ConnectionState, error)
	Update(Zero_UpdateServer) error
	Oracle(*Payload, Zero_OracleServer) error
	ShouldServe(context.Context, *Tablet) (*Tablet, error)
	AssignUids(context.Context, *Num) (*AssignedIds, error)
	Timestamps(context.Context, *Num) (*AssignedIds, error)
	CommitOrAbort(context.Context, *TxnContext) (*TxnContext, error)
	TryAbort(context.Context, *TxnTimestamps) (*TxnTimestamps, error)
}

type Zero_OracleClient 

type Zero_OracleClient interface {
	Recv() (*OracleDelta, error)
	grpc.ClientStream
}

type Zero_OracleServer 

type Zero_OracleServer interface {
	Send(*OracleDelta) error
	grpc.ServerStream
}

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.