protos

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

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

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

Documentation

Overview

Package protos is a generated protocol buffer package.

It is generated from these files:

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

It has these top-level messages:

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

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterDgraphServer

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

func RegisterRaftServer

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

func RegisterWorkerServer

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

func RegisterZeroServer

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

Types

type AssignedIds

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

func (*AssignedIds) Descriptor

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

func (*AssignedIds) GetEndId

func (m *AssignedIds) GetEndId() uint64

func (*AssignedIds) GetStartId

func (m *AssignedIds) GetStartId() uint64

func (*AssignedIds) Marshal

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

func (*AssignedIds) MarshalTo

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

func (*AssignedIds) ProtoMessage

func (*AssignedIds) ProtoMessage()

func (*AssignedIds) Reset

func (m *AssignedIds) Reset()

func (*AssignedIds) Size

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

func (*AssignedIds) String

func (m *AssignedIds) String() string

func (*AssignedIds) Unmarshal

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

type Check

type Check struct {
}

func (*Check) Descriptor

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

func (*Check) Marshal

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

func (*Check) MarshalTo

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

func (*Check) ProtoMessage

func (*Check) ProtoMessage()

func (*Check) Reset

func (m *Check) Reset()

func (*Check) Size

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

func (*Check) String

func (m *Check) String() string

func (*Check) Unmarshal

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

type DgraphClient

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

func NewDgraphClient

func NewDgraphClient(cc *grpc.ClientConn) DgraphClient

type DgraphServer

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

type DirectedEdge

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

func (*DirectedEdge) Descriptor

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

func (*DirectedEdge) GetAttr

func (m *DirectedEdge) GetAttr() string

func (*DirectedEdge) GetEntity

func (m *DirectedEdge) GetEntity() uint64

func (*DirectedEdge) GetFacets

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

func (*DirectedEdge) GetLabel

func (m *DirectedEdge) GetLabel() string

func (*DirectedEdge) GetLang

func (m *DirectedEdge) GetLang() string

func (*DirectedEdge) GetOp

func (m *DirectedEdge) GetOp() DirectedEdge_Op

func (*DirectedEdge) GetValue

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

func (*DirectedEdge) GetValueId

func (m *DirectedEdge) GetValueId() uint64

func (*DirectedEdge) GetValueType

func (m *DirectedEdge) GetValueType() uint32

func (*DirectedEdge) Marshal

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

func (*DirectedEdge) MarshalTo

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

func (*DirectedEdge) ProtoMessage

func (*DirectedEdge) ProtoMessage()

func (*DirectedEdge) Reset

func (m *DirectedEdge) Reset()

func (*DirectedEdge) Size

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

func (*DirectedEdge) String

func (m *DirectedEdge) String() string

func (*DirectedEdge) Unmarshal

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

type DirectedEdge_Op

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

func (DirectedEdge_Op) EnumDescriptor

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

func (DirectedEdge_Op) String

func (x DirectedEdge_Op) String() string

type ExportPayload

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

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

func (*ExportPayload) Descriptor

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

func (*ExportPayload) GetGroupId

func (m *ExportPayload) GetGroupId() uint32

func (*ExportPayload) GetReqId

func (m *ExportPayload) GetReqId() uint64

func (*ExportPayload) GetStatus

func (m *ExportPayload) GetStatus() ExportPayload_Status

func (*ExportPayload) Marshal

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

func (*ExportPayload) MarshalTo

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

func (*ExportPayload) ProtoMessage

func (*ExportPayload) ProtoMessage()

func (*ExportPayload) Reset

func (m *ExportPayload) Reset()

func (*ExportPayload) Size

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

func (*ExportPayload) String

func (m *ExportPayload) String() string

func (*ExportPayload) Unmarshal

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

type ExportPayload_Status

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

func (ExportPayload_Status) EnumDescriptor

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

func (ExportPayload_Status) String

func (x ExportPayload_Status) String() string

type Facet

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

func (*Facet) Descriptor

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

func (*Facet) GetKey

func (m *Facet) GetKey() string

func (*Facet) GetTokens

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

func (*Facet) GetVal

func (m *Facet) GetVal() string

func (*Facet) GetValType

func (m *Facet) GetValType() Facet_ValType

func (*Facet) GetValue

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

func (*Facet) Marshal

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

func (*Facet) MarshalTo

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

func (*Facet) ProtoMessage

func (*Facet) ProtoMessage()

func (*Facet) Reset

func (m *Facet) Reset()

func (*Facet) Size

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

func (*Facet) String

func (m *Facet) String() string

func (*Facet) Unmarshal

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

type Facet_ValType

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

func (Facet_ValType) EnumDescriptor

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

func (Facet_ValType) String

func (x Facet_ValType) String() string

type Facets

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

func (*Facets) Descriptor

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

func (*Facets) GetFacets

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

func (*Facets) Marshal

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

func (*Facets) MarshalTo

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

func (*Facets) ProtoMessage

func (*Facets) ProtoMessage()

func (*Facets) Reset

func (m *Facets) Reset()

func (*Facets) Size

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

func (*Facets) String

func (m *Facets) String() string

func (*Facets) Unmarshal

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

type FacetsList

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

func (*FacetsList) Descriptor

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

func (*FacetsList) GetFacetsList

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

func (*FacetsList) Marshal

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

func (*FacetsList) MarshalTo

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

func (*FacetsList) ProtoMessage

func (*FacetsList) ProtoMessage()

func (*FacetsList) Reset

func (m *FacetsList) Reset()

func (*FacetsList) Size

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

func (*FacetsList) String

func (m *FacetsList) String() string

func (*FacetsList) Unmarshal

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

type FilterTree

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

Op and Children are internal nodes and Func on leaves.

func (*FilterTree) Descriptor

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

func (*FilterTree) GetChildren

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

func (*FilterTree) GetFunc

func (m *FilterTree) GetFunc() *Function

func (*FilterTree) GetOp

func (m *FilterTree) GetOp() string

func (*FilterTree) Marshal

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

func (*FilterTree) MarshalTo

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

func (*FilterTree) ProtoMessage

func (*FilterTree) ProtoMessage()

func (*FilterTree) Reset

func (m *FilterTree) Reset()

func (*FilterTree) Size

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

func (*FilterTree) String

func (m *FilterTree) String() string

func (*FilterTree) Unmarshal

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

type Function

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

func (*Function) Descriptor

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

func (*Function) GetArgs

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

func (*Function) GetKey

func (m *Function) GetKey() string

func (*Function) GetName

func (m *Function) GetName() string

func (*Function) Marshal

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

func (*Function) MarshalTo

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

func (*Function) ProtoMessage

func (*Function) ProtoMessage()

func (*Function) Reset

func (m *Function) Reset()

func (*Function) Size

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

func (*Function) String

func (m *Function) String() string

func (*Function) Unmarshal

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

type Group

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

func (*Group) Descriptor

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

func (*Group) GetMembers

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

func (*Group) GetTablets

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

func (*Group) Marshal

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

func (*Group) MarshalTo

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

func (*Group) ProtoMessage

func (*Group) ProtoMessage()

func (*Group) Reset

func (m *Group) Reset()

func (*Group) Size

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

func (*Group) String

func (m *Group) String() string

func (*Group) Unmarshal

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

type GroupKeys

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

func (*GroupKeys) Descriptor

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

func (*GroupKeys) GetGroupId

func (m *GroupKeys) GetGroupId() uint32

func (*GroupKeys) GetKeys

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

func (*GroupKeys) Marshal

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

func (*GroupKeys) MarshalTo

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

func (*GroupKeys) ProtoMessage

func (*GroupKeys) ProtoMessage()

func (*GroupKeys) Reset

func (m *GroupKeys) Reset()

func (*GroupKeys) Size

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

func (*GroupKeys) String

func (m *GroupKeys) String() string

func (*GroupKeys) Unmarshal

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

type KC

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

func (*KC) Descriptor

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

func (*KC) GetChecksum

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

func (*KC) GetKey

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

func (*KC) Marshal

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

func (*KC) MarshalTo

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

func (*KC) ProtoMessage

func (*KC) ProtoMessage()

func (*KC) Reset

func (m *KC) Reset()

func (*KC) Size

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

func (*KC) String

func (m *KC) String() string

func (*KC) Unmarshal

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

type KV

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

func (*KV) Descriptor

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

func (*KV) GetKey

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

func (*KV) GetUserMeta

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

func (*KV) GetVal

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

func (*KV) Marshal

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

func (*KV) MarshalTo

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

func (*KV) ProtoMessage

func (*KV) ProtoMessage()

func (*KV) Reset

func (m *KV) Reset()

func (*KV) Size

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

func (*KV) String

func (m *KV) String() string

func (*KV) Unmarshal

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

type KeyValues

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

func (*KeyValues) Descriptor

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

func (*KeyValues) GetKv

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

func (*KeyValues) Marshal

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

func (*KeyValues) MarshalTo

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

func (*KeyValues) ProtoMessage

func (*KeyValues) ProtoMessage()

func (*KeyValues) Reset

func (m *KeyValues) Reset()

func (*KeyValues) Size

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

func (*KeyValues) String

func (m *KeyValues) String() string

func (*KeyValues) Unmarshal

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

type Latency

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

func (*Latency) Descriptor

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

func (*Latency) GetParsing

func (m *Latency) GetParsing() string

func (*Latency) GetPb

func (m *Latency) GetPb() string

func (*Latency) GetProcessing

func (m *Latency) GetProcessing() string

func (*Latency) Marshal

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

func (*Latency) MarshalTo

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

func (*Latency) ProtoMessage

func (*Latency) ProtoMessage()

func (*Latency) Reset

func (m *Latency) Reset()

func (*Latency) Size

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

func (*Latency) String

func (m *Latency) String() string

func (*Latency) Unmarshal

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

type List

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

func (*List) Descriptor

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

func (*List) GetUids

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

func (*List) Marshal

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

func (*List) MarshalTo

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

func (*List) ProtoMessage

func (*List) ProtoMessage()

func (*List) Reset

func (m *List) Reset()

func (*List) Size

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

func (*List) String

func (m *List) String() string

func (*List) Unmarshal

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

type MapEntry

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

func (*MapEntry) Descriptor

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

func (*MapEntry) GetKey

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

func (*MapEntry) GetPosting

func (m *MapEntry) GetPosting() *Posting

func (*MapEntry) GetUid

func (m *MapEntry) GetUid() uint64

func (*MapEntry) Marshal

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

func (*MapEntry) MarshalTo

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

func (*MapEntry) ProtoMessage

func (*MapEntry) ProtoMessage()

func (*MapEntry) Reset

func (m *MapEntry) Reset()

func (*MapEntry) Size

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

func (*MapEntry) String

func (m *MapEntry) String() string

func (*MapEntry) Unmarshal

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

type Member

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

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

func (*Member) Descriptor

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

func (*Member) GetAddr

func (m *Member) GetAddr() string

func (*Member) GetAmDead

func (m *Member) GetAmDead() bool

func (*Member) GetGroupId

func (m *Member) GetGroupId() uint32

func (*Member) GetId

func (m *Member) GetId() uint64

func (*Member) GetLastUpdate

func (m *Member) GetLastUpdate() uint64

func (*Member) GetLeader

func (m *Member) GetLeader() bool

func (*Member) Marshal

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

func (*Member) MarshalTo

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

func (*Member) ProtoMessage

func (*Member) ProtoMessage()

func (*Member) Reset

func (m *Member) Reset()

func (*Member) Size

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

func (*Member) String

func (m *Member) String() string

func (*Member) Unmarshal

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

type MembershipState

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

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

func (*MembershipState) Descriptor

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

func (*MembershipState) GetCounter

func (m *MembershipState) GetCounter() uint64

func (*MembershipState) GetGroups

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

func (*MembershipState) GetMaxLeaseId

func (m *MembershipState) GetMaxLeaseId() uint64

func (*MembershipState) GetZeros

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

func (*MembershipState) Marshal

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

func (*MembershipState) MarshalTo

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

func (*MembershipState) ProtoMessage

func (*MembershipState) ProtoMessage()

func (*MembershipState) Reset

func (m *MembershipState) Reset()

func (*MembershipState) Size

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

func (*MembershipState) String

func (m *MembershipState) String() string

func (*MembershipState) Unmarshal

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

type MovePredicatePayload

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

func (*MovePredicatePayload) Descriptor

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

func (*MovePredicatePayload) GetDestGroupId

func (m *MovePredicatePayload) GetDestGroupId() uint32

func (*MovePredicatePayload) GetPredicate

func (m *MovePredicatePayload) GetPredicate() string

func (*MovePredicatePayload) GetSourceGroupId

func (m *MovePredicatePayload) GetSourceGroupId() uint32

func (*MovePredicatePayload) GetState

func (m *MovePredicatePayload) GetState() *MembershipState

func (*MovePredicatePayload) Marshal

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

func (*MovePredicatePayload) MarshalTo

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

func (*MovePredicatePayload) ProtoMessage

func (*MovePredicatePayload) ProtoMessage()

func (*MovePredicatePayload) Reset

func (m *MovePredicatePayload) Reset()

func (*MovePredicatePayload) Size

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

func (*MovePredicatePayload) String

func (m *MovePredicatePayload) String() string

func (*MovePredicatePayload) Unmarshal

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

type Mutation

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

func (*Mutation) Descriptor

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

func (*Mutation) GetDel

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

func (*Mutation) GetSchema

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

func (*Mutation) GetSet

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

func (*Mutation) Marshal

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

func (*Mutation) MarshalTo

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

func (*Mutation) ProtoMessage

func (*Mutation) ProtoMessage()

func (*Mutation) Reset

func (m *Mutation) Reset()

func (*Mutation) Size

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

func (*Mutation) String

func (m *Mutation) String() string

func (*Mutation) Unmarshal

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

type Mutations

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

func (*Mutations) Descriptor

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

func (*Mutations) GetEdges

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

func (*Mutations) GetGroupId

func (m *Mutations) GetGroupId() uint32

func (*Mutations) GetSchema

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

func (*Mutations) GetUpsert

func (m *Mutations) GetUpsert() *Query

func (*Mutations) Marshal

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

func (*Mutations) MarshalTo

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

func (*Mutations) ProtoMessage

func (*Mutations) ProtoMessage()

func (*Mutations) Reset

func (m *Mutations) Reset()

func (*Mutations) Size

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

func (*Mutations) String

func (m *Mutations) String() string

func (*Mutations) Unmarshal

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

type NQuad

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

func (*NQuad) Descriptor

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

func (*NQuad) GetFacets

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

func (*NQuad) GetLabel

func (m *NQuad) GetLabel() string

func (*NQuad) GetLang

func (m *NQuad) GetLang() string

func (*NQuad) GetObjectId

func (m *NQuad) GetObjectId() string

func (*NQuad) GetObjectType

func (m *NQuad) GetObjectType() int32

func (*NQuad) GetObjectValue

func (m *NQuad) GetObjectValue() *Value

func (*NQuad) GetObjectVar

func (m *NQuad) GetObjectVar() string

func (*NQuad) GetPredicate

func (m *NQuad) GetPredicate() string

func (*NQuad) GetSubject

func (m *NQuad) GetSubject() string

func (*NQuad) GetSubjectVar

func (m *NQuad) GetSubjectVar() string

func (*NQuad) Marshal

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

func (*NQuad) MarshalTo

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

func (*NQuad) ProtoMessage

func (*NQuad) ProtoMessage()

func (*NQuad) Reset

func (m *NQuad) Reset()

func (*NQuad) Size

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

func (*NQuad) String

func (m *NQuad) String() string

func (*NQuad) Unmarshal

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

type Node

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

func (*Node) Descriptor

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

func (*Node) GetAttribute

func (m *Node) GetAttribute() string

func (*Node) GetChildren

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

func (*Node) GetProperties

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

func (*Node) Marshal

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

func (*Node) MarshalTo

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

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

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

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

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

type Num

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

func (*Num) Descriptor

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

func (*Num) GetVal

func (m *Num) GetVal() uint64

func (*Num) Marshal

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

func (*Num) MarshalTo

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

func (*Num) ProtoMessage

func (*Num) ProtoMessage()

func (*Num) Reset

func (m *Num) Reset()

func (*Num) Size

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

func (*Num) String

func (m *Num) String() string

func (*Num) Unmarshal

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

type Order

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

func (*Order) Descriptor

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

func (*Order) GetAttr

func (m *Order) GetAttr() string

func (*Order) GetDesc

func (m *Order) GetDesc() bool

func (*Order) Marshal

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

func (*Order) MarshalTo

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

func (*Order) ProtoMessage

func (*Order) ProtoMessage()

func (*Order) Reset

func (m *Order) Reset()

func (*Order) Size

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

func (*Order) String

func (m *Order) String() string

func (*Order) Unmarshal

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

type Param

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

func (*Param) Descriptor

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

func (*Param) GetAllKeys

func (m *Param) GetAllKeys() bool

func (*Param) GetKeys

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

func (*Param) Marshal

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

func (*Param) MarshalTo

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

func (*Param) ProtoMessage

func (*Param) ProtoMessage()

func (*Param) Reset

func (m *Param) Reset()

func (*Param) Size

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

func (*Param) String

func (m *Param) String() string

func (*Param) Unmarshal

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

type Payload

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

func (*Payload) Descriptor

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

func (*Payload) GetData

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

func (*Payload) Marshal

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

func (*Payload) MarshalTo

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

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) Size

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

func (*Payload) String

func (m *Payload) String() string

func (*Payload) Unmarshal

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

type Posting

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

func (*Posting) Descriptor

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

func (*Posting) GetCommit

func (m *Posting) GetCommit() uint64

func (*Posting) GetFacets

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

func (*Posting) GetLabel

func (m *Posting) GetLabel() string

func (*Posting) GetMetadata

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

func (*Posting) GetOp

func (m *Posting) GetOp() uint32

func (*Posting) GetPostingType

func (m *Posting) GetPostingType() Posting_PostingType

func (*Posting) GetUid

func (m *Posting) GetUid() uint64

func (*Posting) GetValType

func (m *Posting) GetValType() Posting_ValType

func (*Posting) GetValue

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

func (*Posting) Marshal

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

func (*Posting) MarshalTo

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

func (*Posting) ProtoMessage

func (*Posting) ProtoMessage()

func (*Posting) Reset

func (m *Posting) Reset()

func (*Posting) Size

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

func (*Posting) String

func (m *Posting) String() string

func (*Posting) Unmarshal

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

type PostingList

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

func (*PostingList) Descriptor

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

func (*PostingList) GetChecksum

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

func (*PostingList) GetCommit

func (m *PostingList) GetCommit() uint64

func (*PostingList) GetPostings

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

func (*PostingList) GetUids

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

func (*PostingList) Marshal

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

func (*PostingList) MarshalTo

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

func (*PostingList) ProtoMessage

func (*PostingList) ProtoMessage()

func (*PostingList) Reset

func (m *PostingList) Reset()

func (*PostingList) Size

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

func (*PostingList) String

func (m *PostingList) String() string

func (*PostingList) Unmarshal

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

type Posting_PostingType

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

func (Posting_PostingType) EnumDescriptor

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

func (Posting_PostingType) String

func (x Posting_PostingType) String() string

type Posting_ValType

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

func (Posting_ValType) EnumDescriptor

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

func (Posting_ValType) String

func (x Posting_ValType) String() string

type Property

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

func (*Property) Descriptor

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

func (*Property) GetProp

func (m *Property) GetProp() string

func (*Property) GetValue

func (m *Property) GetValue() *Value

func (*Property) Marshal

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

func (*Property) MarshalTo

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

func (*Property) ProtoMessage

func (*Property) ProtoMessage()

func (*Property) Reset

func (m *Property) Reset()

func (*Property) Size

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

func (*Property) String

func (m *Property) String() string

func (*Property) Unmarshal

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

type Proposal

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

func (*Proposal) Descriptor

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

func (*Proposal) GetId

func (m *Proposal) GetId() uint32

func (*Proposal) GetKv

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

func (*Proposal) GetMembership

func (m *Proposal) GetMembership() *Member

func (*Proposal) GetMutations

func (m *Proposal) GetMutations() *Mutations

func (*Proposal) GetState

func (m *Proposal) GetState() *MembershipState

func (*Proposal) Marshal

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

func (*Proposal) MarshalTo

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

func (*Proposal) ProtoMessage

func (*Proposal) ProtoMessage()

func (*Proposal) Reset

func (m *Proposal) Reset()

func (*Proposal) Size

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

func (*Proposal) String

func (m *Proposal) String() string

func (*Proposal) Unmarshal

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

type Query

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

func (*Query) Descriptor

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

func (*Query) GetAfterUid

func (m *Query) GetAfterUid() uint64

func (*Query) GetAttr

func (m *Query) GetAttr() string

func (*Query) GetDoCount

func (m *Query) GetDoCount() bool

func (*Query) GetFacetParam

func (m *Query) GetFacetParam() *Param

func (*Query) GetFacetsFilter

func (m *Query) GetFacetsFilter() *FilterTree

func (*Query) GetLangs

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

func (*Query) GetReverse

func (m *Query) GetReverse() bool

func (*Query) GetSrcFunc

func (m *Query) GetSrcFunc() *SrcFunction

func (*Query) GetUidList

func (m *Query) GetUidList() *List

func (*Query) Marshal

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

func (*Query) MarshalTo

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

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) Reset

func (m *Query) Reset()

func (*Query) Size

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

func (*Query) String

func (m *Query) String() string

func (*Query) Unmarshal

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

type RaftClient

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

func NewRaftClient

func NewRaftClient(cc *grpc.ClientConn) RaftClient

type RaftContext

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

func (*RaftContext) Descriptor

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

func (*RaftContext) GetAddr

func (m *RaftContext) GetAddr() string

func (*RaftContext) GetGroup

func (m *RaftContext) GetGroup() uint32

func (*RaftContext) GetId

func (m *RaftContext) GetId() uint64

func (*RaftContext) Marshal

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

func (*RaftContext) MarshalTo

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

func (*RaftContext) ProtoMessage

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset

func (m *RaftContext) Reset()

func (*RaftContext) Size

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

func (*RaftContext) String

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal

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

type RaftServer

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

type Request

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

func (*Request) Descriptor

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

func (*Request) GetMutation

func (m *Request) GetMutation() *Mutation

func (*Request) GetQuery

func (m *Request) GetQuery() string

func (*Request) GetSchema

func (m *Request) GetSchema() *SchemaRequest

func (*Request) GetVars

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

func (*Request) Marshal

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

func (*Request) MarshalTo

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

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

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

func (*Request) String

func (m *Request) String() string

func (*Request) Unmarshal

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

type Response

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

func (*Response) Descriptor

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

func (*Response) GetAssignedUids

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

func (*Response) GetL

func (m *Response) GetL() *Latency

func (*Response) GetN

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

func (*Response) GetSchema

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

func (*Response) Marshal

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

func (*Response) MarshalTo

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

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

type Result

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

func (*Result) Descriptor

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

func (*Result) GetCounts

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

func (*Result) GetFacetMatrix

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

func (*Result) GetIntersectDest

func (m *Result) GetIntersectDest() bool

func (*Result) GetUidMatrix

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

func (*Result) GetValueMatrix

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

func (*Result) Marshal

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

func (*Result) MarshalTo

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

func (*Result) ProtoMessage

func (*Result) ProtoMessage()

func (*Result) Reset

func (m *Result) Reset()

func (*Result) Size

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

func (*Result) String

func (m *Result) String() string

func (*Result) Unmarshal

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

type SchemaNode

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

func (*SchemaNode) Descriptor

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

func (*SchemaNode) GetCount

func (m *SchemaNode) GetCount() bool

func (*SchemaNode) GetIndex

func (m *SchemaNode) GetIndex() bool

func (*SchemaNode) GetList

func (m *SchemaNode) GetList() bool

func (*SchemaNode) GetPredicate

func (m *SchemaNode) GetPredicate() string

func (*SchemaNode) GetReverse

func (m *SchemaNode) GetReverse() bool

func (*SchemaNode) GetTokenizer

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

func (*SchemaNode) GetType

func (m *SchemaNode) GetType() string

func (*SchemaNode) Marshal

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

func (*SchemaNode) MarshalTo

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

func (*SchemaNode) ProtoMessage

func (*SchemaNode) ProtoMessage()

func (*SchemaNode) Reset

func (m *SchemaNode) Reset()

func (*SchemaNode) Size

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

func (*SchemaNode) String

func (m *SchemaNode) String() string

func (*SchemaNode) Unmarshal

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

type SchemaRequest

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

func (*SchemaRequest) Descriptor

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

func (*SchemaRequest) GetFields

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

func (*SchemaRequest) GetGroupId

func (m *SchemaRequest) GetGroupId() uint32

func (*SchemaRequest) GetPredicates

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

func (*SchemaRequest) Marshal

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

func (*SchemaRequest) MarshalTo

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

func (*SchemaRequest) ProtoMessage

func (*SchemaRequest) ProtoMessage()

func (*SchemaRequest) Reset

func (m *SchemaRequest) Reset()

func (*SchemaRequest) Size

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

func (*SchemaRequest) String

func (m *SchemaRequest) String() string

func (*SchemaRequest) Unmarshal

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

type SchemaResult

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

func (*SchemaResult) Descriptor

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

func (*SchemaResult) GetSchema

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

func (*SchemaResult) Marshal

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

func (*SchemaResult) MarshalTo

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

func (*SchemaResult) ProtoMessage

func (*SchemaResult) ProtoMessage()

func (*SchemaResult) Reset

func (m *SchemaResult) Reset()

func (*SchemaResult) Size

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

func (*SchemaResult) String

func (m *SchemaResult) String() string

func (*SchemaResult) Unmarshal

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

type SchemaUpdate

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

func (*SchemaUpdate) Descriptor

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

func (*SchemaUpdate) GetCount

func (m *SchemaUpdate) GetCount() bool

func (*SchemaUpdate) GetDirective

func (m *SchemaUpdate) GetDirective() SchemaUpdate_Directive

func (*SchemaUpdate) GetExplicit

func (m *SchemaUpdate) GetExplicit() bool

func (*SchemaUpdate) GetList

func (m *SchemaUpdate) GetList() bool

func (*SchemaUpdate) GetPredicate

func (m *SchemaUpdate) GetPredicate() string

func (*SchemaUpdate) GetTokenizer

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

func (*SchemaUpdate) GetValueType

func (m *SchemaUpdate) GetValueType() uint32

func (*SchemaUpdate) Marshal

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

func (*SchemaUpdate) MarshalTo

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

func (*SchemaUpdate) ProtoMessage

func (*SchemaUpdate) ProtoMessage()

func (*SchemaUpdate) Reset

func (m *SchemaUpdate) Reset()

func (*SchemaUpdate) Size

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

func (*SchemaUpdate) String

func (m *SchemaUpdate) String() string

func (*SchemaUpdate) Unmarshal

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

type SchemaUpdate_Directive

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

func (SchemaUpdate_Directive) EnumDescriptor

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

func (SchemaUpdate_Directive) String

func (x SchemaUpdate_Directive) String() string

type SortMessage

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

func (*SortMessage) Descriptor

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

func (*SortMessage) GetCount

func (m *SortMessage) GetCount() int32

func (*SortMessage) GetLangs

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

func (*SortMessage) GetOffset

func (m *SortMessage) GetOffset() int32

func (*SortMessage) GetOrder

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

func (*SortMessage) GetUidMatrix

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

func (*SortMessage) Marshal

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

func (*SortMessage) MarshalTo

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

func (*SortMessage) ProtoMessage

func (*SortMessage) ProtoMessage()

func (*SortMessage) Reset

func (m *SortMessage) Reset()

func (*SortMessage) Size

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

func (*SortMessage) String

func (m *SortMessage) String() string

func (*SortMessage) Unmarshal

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

type SortResult

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

func (*SortResult) Descriptor

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

func (*SortResult) GetUidMatrix

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

func (*SortResult) Marshal

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

func (*SortResult) MarshalTo

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

func (*SortResult) ProtoMessage

func (*SortResult) ProtoMessage()

func (*SortResult) Reset

func (m *SortResult) Reset()

func (*SortResult) Size

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

func (*SortResult) String

func (m *SortResult) String() string

func (*SortResult) Unmarshal

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

type SrcFunction

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

func (*SrcFunction) Descriptor

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

func (*SrcFunction) GetArgs

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

func (*SrcFunction) GetIsCount

func (m *SrcFunction) GetIsCount() bool

func (*SrcFunction) GetName

func (m *SrcFunction) GetName() string

func (*SrcFunction) Marshal

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

func (*SrcFunction) MarshalTo

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

func (*SrcFunction) ProtoMessage

func (*SrcFunction) ProtoMessage()

func (*SrcFunction) Reset

func (m *SrcFunction) Reset()

func (*SrcFunction) Size

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

func (*SrcFunction) String

func (m *SrcFunction) String() string

func (*SrcFunction) Unmarshal

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

type Tablet

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

func (*Tablet) Descriptor

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

func (*Tablet) GetGroupId

func (m *Tablet) GetGroupId() uint32

func (*Tablet) GetNoUpdate

func (m *Tablet) GetNoUpdate() bool

func (*Tablet) GetPredicate

func (m *Tablet) GetPredicate() string

func (*Tablet) GetReadOnly

func (m *Tablet) GetReadOnly() bool

func (*Tablet) GetSize_

func (m *Tablet) GetSize_() int64

func (*Tablet) Marshal

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

func (*Tablet) MarshalTo

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

func (*Tablet) ProtoMessage

func (*Tablet) ProtoMessage()

func (*Tablet) Reset

func (m *Tablet) Reset()

func (*Tablet) Size

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

func (*Tablet) String

func (m *Tablet) String() string

func (*Tablet) Unmarshal

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

type TaskValue

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

func (*TaskValue) Descriptor

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

func (*TaskValue) GetVal

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

func (*TaskValue) GetValType

func (m *TaskValue) GetValType() int32

func (*TaskValue) Marshal

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

func (*TaskValue) MarshalTo

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

func (*TaskValue) ProtoMessage

func (*TaskValue) ProtoMessage()

func (*TaskValue) Reset

func (m *TaskValue) Reset()

func (*TaskValue) Size

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

func (*TaskValue) String

func (m *TaskValue) String() string

func (*TaskValue) Unmarshal

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

type Value

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

func (*Value) Descriptor

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

func (*Value) GetBoolVal

func (m *Value) GetBoolVal() bool

func (*Value) GetBytesVal

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

func (*Value) GetDateVal

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

func (*Value) GetDatetimeVal

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

func (*Value) GetDefaultVal

func (m *Value) GetDefaultVal() string

func (*Value) GetDoubleVal

func (m *Value) GetDoubleVal() float64

func (*Value) GetGeoVal

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

func (*Value) GetIntVal

func (m *Value) GetIntVal() int64

func (*Value) GetPasswordVal

func (m *Value) GetPasswordVal() string

func (*Value) GetStrVal

func (m *Value) GetStrVal() string

func (*Value) GetUidVal

func (m *Value) GetUidVal() uint64

func (*Value) GetVal

func (m *Value) GetVal() isValue_Val

func (*Value) Marshal

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

func (*Value) MarshalTo

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

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) Size

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

func (*Value) String

func (m *Value) String() string

func (*Value) Unmarshal

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

func (*Value) XXX_OneofFuncs

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

XXX_OneofFuncs is for the internal use of the proto package.

type ValueList

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

func (*ValueList) Descriptor

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

func (*ValueList) GetValues

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

func (*ValueList) Marshal

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

func (*ValueList) MarshalTo

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

func (*ValueList) ProtoMessage

func (*ValueList) ProtoMessage()

func (*ValueList) Reset

func (m *ValueList) Reset()

func (*ValueList) Size

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

func (*ValueList) String

func (m *ValueList) String() string

func (*ValueList) Unmarshal

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

type Value_BoolVal

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

func (*Value_BoolVal) MarshalTo

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

func (*Value_BoolVal) Size

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

type Value_BytesVal

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

func (*Value_BytesVal) MarshalTo

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

func (*Value_BytesVal) Size

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

type Value_DateVal

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

func (*Value_DateVal) MarshalTo

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

func (*Value_DateVal) Size

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

type Value_DatetimeVal

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

func (*Value_DatetimeVal) MarshalTo

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

func (*Value_DatetimeVal) Size

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

type Value_DefaultVal

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

func (*Value_DefaultVal) MarshalTo

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

func (*Value_DefaultVal) Size

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

type Value_DoubleVal

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

func (*Value_DoubleVal) MarshalTo

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

func (*Value_DoubleVal) Size

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

type Value_GeoVal

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

func (*Value_GeoVal) MarshalTo

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

func (*Value_GeoVal) Size

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

type Value_IntVal

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

func (*Value_IntVal) MarshalTo

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

func (*Value_IntVal) Size

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

type Value_PasswordVal

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

func (*Value_PasswordVal) MarshalTo

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

func (*Value_PasswordVal) Size

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

type Value_StrVal

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

func (*Value_StrVal) MarshalTo

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

func (*Value_StrVal) Size

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

type Value_UidVal

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

func (*Value_UidVal) MarshalTo

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

func (*Value_UidVal) Size

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

type Version

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

func (*Version) Descriptor

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

func (*Version) GetTag

func (m *Version) GetTag() string

func (*Version) Marshal

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

func (*Version) MarshalTo

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

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) Size

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

func (*Version) String

func (m *Version) String() string

func (*Version) Unmarshal

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

type WorkerClient

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

func NewWorkerClient

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerServer

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

type Worker_PredicateAndSchemaDataClient

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

type Worker_PredicateAndSchemaDataServer

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

type Worker_ReceivePredicateClient

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

type Worker_ReceivePredicateServer

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

type ZeroClient

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

func NewZeroClient

func NewZeroClient(cc *grpc.ClientConn) ZeroClient

type ZeroProposal

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

func (*ZeroProposal) Descriptor

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

func (*ZeroProposal) GetId

func (m *ZeroProposal) GetId() uint32

func (*ZeroProposal) GetMaxLeaseId

func (m *ZeroProposal) GetMaxLeaseId() uint64

func (*ZeroProposal) GetMember

func (m *ZeroProposal) GetMember() *Member

func (*ZeroProposal) GetTablet

func (m *ZeroProposal) GetTablet() *Tablet

func (*ZeroProposal) Marshal

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

func (*ZeroProposal) MarshalTo

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

func (*ZeroProposal) ProtoMessage

func (*ZeroProposal) ProtoMessage()

func (*ZeroProposal) Reset

func (m *ZeroProposal) Reset()

func (*ZeroProposal) Size

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

func (*ZeroProposal) String

func (m *ZeroProposal) String() string

func (*ZeroProposal) Unmarshal

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

type ZeroServer

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

type Zero_UpdateClient

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

type Zero_UpdateServer

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

Jump to

Keyboard shortcuts

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