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 added in v0.8.3 

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

func RegisterWorkerServer 

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

func RegisterZeroServer added in v0.8.3 

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

Types

type Assigned added in v0.9.0 

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 added in v0.9.0 

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

func (*Assigned) GetContext added in v0.9.0 

func (m *Assigned) GetContext() *TxnContext

func (*Assigned) GetError added in v0.9.0 

func (m *Assigned) GetError() string

func (*Assigned) GetUids added in v0.9.0 

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

func (*Assigned) Marshal added in v0.9.0 

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

func (*Assigned) MarshalTo added in v0.9.0 

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

func (*Assigned) ProtoMessage added in v0.9.0 

func (*Assigned) ProtoMessage()

func (*Assigned) Reset added in v0.9.0 

func (m *Assigned) Reset()

func (*Assigned) Size added in v0.9.0 

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

func (*Assigned) String added in v0.9.0 

func (m *Assigned) String() string

func (*Assigned) Unmarshal added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

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

func (*ConnectionState) GetMember added in v0.9.0 

func (m *ConnectionState) GetMember() *Member

func (*ConnectionState) GetState added in v0.9.0 

func (m *ConnectionState) GetState() *MembershipState

func (*ConnectionState) Marshal added in v0.9.0 

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

func (*ConnectionState) MarshalTo added in v0.9.0 

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

func (*ConnectionState) ProtoMessage added in v0.9.0 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) Reset added in v0.9.0 

func (m *ConnectionState) Reset()

func (*ConnectionState) Size added in v0.9.0 

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

func (*ConnectionState) String added in v0.9.0 

func (m *ConnectionState) String() string

func (*ConnectionState) Unmarshal added in v0.9.0 

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 added in v0.9.0 

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 added in v0.8.3 

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 added in v0.8.3 

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

func (*Group) GetMembers added in v0.8.3 

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

func (*Group) GetTablets added in v0.8.3 

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

func (*Group) Marshal added in v0.8.3 

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

func (*Group) MarshalTo added in v0.8.3 

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

func (*Group) ProtoMessage added in v0.8.3 

func (*Group) ProtoMessage()

func (*Group) Reset added in v0.8.3 

func (m *Group) Reset()

func (*Group) Size added in v0.8.3 

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

func (*Group) String added in v0.8.3 

func (m *Group) String() string

func (*Group) Unmarshal added in v0.8.3 

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 added in v0.9.0 

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 added in v0.8.3 

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

func (*KV) GetVal 

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

func (*KV) GetVersion added in v0.9.0 

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 added in v0.8.3 

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

func (*KeyValues) Descriptor added in v0.8.3 

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

func (*KeyValues) GetKv added in v0.8.3 

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

func (*KeyValues) Marshal added in v0.8.3 

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

func (*KeyValues) MarshalTo added in v0.8.3 

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

func (*KeyValues) ProtoMessage added in v0.8.3 

func (*KeyValues) ProtoMessage()

func (*KeyValues) Reset added in v0.8.3 

func (m *KeyValues) Reset()

func (*KeyValues) Size added in v0.8.3 

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

func (*KeyValues) String added in v0.8.3 

func (m *KeyValues) String() string

func (*KeyValues) Unmarshal added in v0.8.3 

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 added in v0.9.0 

func (m *Latency) GetEncodingNs() uint64

func (*Latency) GetParsingNs added in v0.9.0 

func (m *Latency) GetParsingNs() uint64

func (*Latency) GetProcessingNs added in v0.9.0 

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 added in v0.9.0 

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

func (*LinRead) Descriptor added in v0.9.0 

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

func (*LinRead) GetIds added in v0.9.0 

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

func (*LinRead) Marshal added in v0.9.0 

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

func (*LinRead) MarshalTo added in v0.9.0 

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

func (*LinRead) ProtoMessage added in v0.9.0 

func (*LinRead) ProtoMessage()

func (*LinRead) Reset added in v0.9.0 

func (m *LinRead) Reset()

func (*LinRead) Size added in v0.9.0 

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

func (*LinRead) String added in v0.9.0 

func (m *LinRead) String() string

func (*LinRead) Unmarshal added in v0.9.0 

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 added in v0.8.3 

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 added in v0.8.3 

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

func (*Member) GetAddr added in v0.8.3 

func (m *Member) GetAddr() string

func (*Member) GetAmDead added in v0.8.3 

func (m *Member) GetAmDead() bool

func (*Member) GetCluterInfoOnly added in v0.9.0 

func (m *Member) GetCluterInfoOnly() bool

func (*Member) GetGroupId added in v0.8.3 

func (m *Member) GetGroupId() uint32

func (*Member) GetId added in v0.8.3 

func (m *Member) GetId() uint64

func (*Member) GetLastUpdate added in v0.8.3 

func (m *Member) GetLastUpdate() uint64

func (*Member) GetLeader added in v0.8.3 

func (m *Member) GetLeader() bool

func (*Member) Marshal added in v0.8.3 

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

func (*Member) MarshalTo added in v0.8.3 

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

func (*Member) ProtoMessage added in v0.8.3 

func (*Member) ProtoMessage()

func (*Member) Reset added in v0.8.3 

func (m *Member) Reset()

func (*Member) Size added in v0.8.3 

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

func (*Member) String added in v0.8.3 

func (m *Member) String() string

func (*Member) Unmarshal added in v0.8.3 

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

type MembershipState added in v0.8.3 

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 added in v0.8.3 

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

func (*MembershipState) GetCounter added in v0.8.3 

func (m *MembershipState) GetCounter() uint64

func (*MembershipState) GetGroups added in v0.8.3 

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

func (*MembershipState) GetMaxLeaseId added in v0.8.3 

func (m *MembershipState) GetMaxLeaseId() uint64

func (*MembershipState) GetMaxRaftId added in v0.9.0 

func (m *MembershipState) GetMaxRaftId() uint64

func (*MembershipState) GetMaxTxnTs added in v0.9.0 

func (m *MembershipState) GetMaxTxnTs() uint64

func (*MembershipState) GetRemoved added in v0.9.2 

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

func (*MembershipState) GetZeros added in v0.8.3 

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

func (*MembershipState) Marshal added in v0.8.3 

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

func (*MembershipState) MarshalTo added in v0.8.3 

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

func (*MembershipState) ProtoMessage added in v0.8.3 

func (*MembershipState) ProtoMessage()

func (*MembershipState) Reset added in v0.8.3 

func (m *MembershipState) Reset()

func (*MembershipState) Size added in v0.8.3 

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

func (*MembershipState) String added in v0.8.3 

func (m *MembershipState) String() string

func (*MembershipState) Unmarshal added in v0.8.3 

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

type MovePredicatePayload added in v0.8.3 

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 added in v0.8.3 

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

func (*MovePredicatePayload) GetDestGroupId added in v0.8.3 

func (m *MovePredicatePayload) GetDestGroupId() uint32

func (*MovePredicatePayload) GetPredicate added in v0.8.3 

func (m *MovePredicatePayload) GetPredicate() string

func (*MovePredicatePayload) GetSourceGroupId added in v0.8.3 

func (m *MovePredicatePayload) GetSourceGroupId() uint32

func (*MovePredicatePayload) GetState added in v0.8.3 

func (m *MovePredicatePayload) GetState() *MembershipState

func (*MovePredicatePayload) Marshal added in v0.8.3 

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

func (*MovePredicatePayload) MarshalTo added in v0.8.3 

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

func (*MovePredicatePayload) ProtoMessage added in v0.8.3 

func (*MovePredicatePayload) ProtoMessage()

func (*MovePredicatePayload) Reset added in v0.8.3 

func (m *MovePredicatePayload) Reset()

func (*MovePredicatePayload) Size added in v0.8.3 

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

func (*MovePredicatePayload) String added in v0.8.3 

func (m *MovePredicatePayload) String() string

func (*MovePredicatePayload) Unmarshal added in v0.8.3 

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 added in v0.9.1 

func (m *Mutation) GetCommitNow() bool

func (*Mutation) GetDel 

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

func (*Mutation) GetDelNquads added in v0.9.0 

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

func (*Mutation) GetDeleteJson added in v0.8.3 

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

func (*Mutation) GetSet 

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

func (*Mutation) GetSetJson added in v0.8.3 

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

func (*Mutation) GetSetNquads added in v0.9.0 

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

func (*Mutation) GetStartTs added in v0.9.0 

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 added in v0.8.3 

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 added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

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

func (*Operation) GetDropAll added in v0.9.0 

func (m *Operation) GetDropAll() bool

func (*Operation) GetDropAttr added in v0.9.0 

func (m *Operation) GetDropAttr() string

func (*Operation) GetSchema added in v0.9.0 

func (m *Operation) GetSchema() string

func (*Operation) GetStartTs added in v0.9.0 

func (m *Operation) GetStartTs() uint64

func (*Operation) Marshal added in v0.9.0 

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

func (*Operation) MarshalTo added in v0.9.0 

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

func (*Operation) ProtoMessage added in v0.9.0 

func (*Operation) ProtoMessage()

func (*Operation) Reset added in v0.9.0 

func (m *Operation) Reset()

func (*Operation) Size added in v0.9.0 

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

func (*Operation) String added in v0.9.0 

func (m *Operation) String() string

func (*Operation) Unmarshal added in v0.9.0 

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

type OracleDelta added in v0.9.0 

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 added in v0.9.0 

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

func (*OracleDelta) GetAborts added in v0.9.0 

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

func (*OracleDelta) GetCommits added in v0.9.0 

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

func (*OracleDelta) GetMaxPending added in v0.9.0 

func (m *OracleDelta) GetMaxPending() uint64

func (*OracleDelta) Marshal added in v0.9.0 

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

func (*OracleDelta) MarshalTo added in v0.9.0 

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

func (*OracleDelta) ProtoMessage added in v0.9.0 

func (*OracleDelta) ProtoMessage()

func (*OracleDelta) Reset added in v0.9.0 

func (m *OracleDelta) Reset()

func (*OracleDelta) Size added in v0.9.0 

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

func (*OracleDelta) String added in v0.9.0 

func (m *OracleDelta) String() string

func (*OracleDelta) Unmarshal added in v0.9.0 

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 added in v0.8.3 

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 added in v0.9.0 

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 added in v0.9.0 

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 added in v0.8.3 

func (m *Proposal) GetCleanPredicate() string

func (*Proposal) GetId 

func (m *Proposal) GetId() uint32

func (*Proposal) GetKv added in v0.8.3 

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

func (*Proposal) GetMutations 

func (m *Proposal) GetMutations() *Mutations

func (*Proposal) GetState added in v0.8.3 

func (m *Proposal) GetState() *MembershipState

func (*Proposal) GetTxnContext added in v0.9.0 

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 added in v0.9.0 

func (m *Query) GetLinRead() *LinRead

func (*Query) GetReadTs added in v0.9.0 

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 added in v0.8.3 

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 added in v0.8.3 

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 added in v0.8.3 

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 added in v0.9.0 

func (m *Request) GetLinRead() *LinRead

func (*Request) GetQuery 

func (m *Request) GetQuery() string

func (*Request) GetStartTs added in v0.9.0 

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 added in v0.9.0 

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

func (*Response) GetLatency added in v0.9.0 

func (m *Response) GetLatency() *Latency

func (*Response) GetSchema 

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

func (*Response) GetTxn added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

func (m *SortMessage) GetLinRead() *LinRead

func (*SortMessage) GetOffset 

func (m *SortMessage) GetOffset() int32

func (*SortMessage) GetOrder 

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

func (*SortMessage) GetReadTs added in v0.9.0 

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 added in v0.9.0 

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 added in v0.8.3 

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 added in v0.8.3 

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

func (*Tablet) GetForce added in v0.8.3 

func (m *Tablet) GetForce() bool

func (*Tablet) GetGroupId added in v0.8.3 

func (m *Tablet) GetGroupId() uint32

func (*Tablet) GetPredicate added in v0.8.3 

func (m *Tablet) GetPredicate() string

func (*Tablet) GetReadOnly added in v0.8.3 

func (m *Tablet) GetReadOnly() bool

func (*Tablet) GetSpace added in v0.8.3 

func (m *Tablet) GetSpace() int64

func (*Tablet) Marshal added in v0.8.3 

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

func (*Tablet) MarshalTo added in v0.8.3 

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

func (*Tablet) ProtoMessage added in v0.8.3 

func (*Tablet) ProtoMessage()

func (*Tablet) Reset added in v0.8.3 

func (m *Tablet) Reset()

func (*Tablet) Size added in v0.8.3 

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

func (*Tablet) String added in v0.8.3 

func (m *Tablet) String() string

func (*Tablet) Unmarshal added in v0.8.3 

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 added in v0.9.0 

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 added in v0.9.0 

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

func (*TxnContext) GetAborted added in v0.9.0 

func (m *TxnContext) GetAborted() bool

func (*TxnContext) GetCommitTs added in v0.9.0 

func (m *TxnContext) GetCommitTs() uint64

func (*TxnContext) GetKeys added in v0.9.0 

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

func (*TxnContext) GetLinRead added in v0.9.0 

func (m *TxnContext) GetLinRead() *LinRead

func (*TxnContext) GetStartTs added in v0.9.0 

func (m *TxnContext) GetStartTs() uint64

func (*TxnContext) Marshal added in v0.9.0 

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

func (*TxnContext) MarshalTo added in v0.9.0 

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

func (*TxnContext) ProtoMessage added in v0.9.0 

func (*TxnContext) ProtoMessage()

func (*TxnContext) Reset added in v0.9.0 

func (m *TxnContext) Reset()

func (*TxnContext) Size added in v0.9.0 

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

func (*TxnContext) String added in v0.9.0 

func (m *TxnContext) String() string

func (*TxnContext) Unmarshal added in v0.9.0 

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

type TxnTimestamps added in v0.9.0 

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

func (*TxnTimestamps) Descriptor added in v0.9.0 

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

func (*TxnTimestamps) GetTs added in v0.9.0 

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

func (*TxnTimestamps) Marshal added in v0.9.0 

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

func (*TxnTimestamps) MarshalTo added in v0.9.0 

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

func (*TxnTimestamps) ProtoMessage added in v0.9.0 

func (*TxnTimestamps) ProtoMessage()

func (*TxnTimestamps) Reset added in v0.9.0 

func (m *TxnTimestamps) Reset()

func (*TxnTimestamps) Size added in v0.9.0 

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

func (*TxnTimestamps) String added in v0.9.0 

func (m *TxnTimestamps) String() string

func (*TxnTimestamps) Unmarshal added in v0.9.0 

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 added in v0.8.3 

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

type Worker_ReceivePredicateServer added in v0.8.3 

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

type ZeroClient added in v0.8.3 

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 added in v0.8.3 

func NewZeroClient(cc *grpc.ClientConn) ZeroClient

type ZeroProposal added in v0.8.3 

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 added in v0.8.3 

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

func (*ZeroProposal) GetId added in v0.8.3 

func (m *ZeroProposal) GetId() uint32

func (*ZeroProposal) GetMaxLeaseId added in v0.8.3 

func (m *ZeroProposal) GetMaxLeaseId() uint64

func (*ZeroProposal) GetMaxRaftId added in v0.9.0 

func (m *ZeroProposal) GetMaxRaftId() uint64

func (*ZeroProposal) GetMaxTxnTs added in v0.9.0 

func (m *ZeroProposal) GetMaxTxnTs() uint64

func (*ZeroProposal) GetMember added in v0.8.3 

func (m *ZeroProposal) GetMember() *Member

func (*ZeroProposal) GetTablet added in v0.8.3 

func (m *ZeroProposal) GetTablet() *Tablet

func (*ZeroProposal) GetTxn added in v0.9.0 

func (m *ZeroProposal) GetTxn() *TxnContext

func (*ZeroProposal) Marshal added in v0.8.3 

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

func (*ZeroProposal) MarshalTo added in v0.8.3 

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

func (*ZeroProposal) ProtoMessage added in v0.8.3 

func (*ZeroProposal) ProtoMessage()

func (*ZeroProposal) Reset added in v0.8.3 

func (m *ZeroProposal) Reset()

func (*ZeroProposal) Size added in v0.8.3 

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

func (*ZeroProposal) String added in v0.8.3 

func (m *ZeroProposal) String() string

func (*ZeroProposal) Unmarshal added in v0.8.3 

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

type ZeroServer added in v0.8.3 

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 added in v0.9.0 

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

type Zero_OracleServer added in v0.9.0 

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

type Zero_UpdateClient added in v0.8.3 

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

type Zero_UpdateServer added in v0.8.3 

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.