intern

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2018 License: AGPL-3.0, Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package intern is a generated protocol buffer package.

It is generated from these files: 

internal.proto

It has these top-level messages: 

List
TaskValue
SrcFunction
Query
ValueList
LangList
Result
Order
SortMessage
SortResult
RaftContext
Member
Group
ZeroProposal
MembershipState
ConnectionState
Tablet
DirectedEdge
Mutations
KeyValues
Proposal
KV
Posting
PostingList
FacetParam
FacetParams
Facets
FacetsList
Function
FilterTree
SchemaRequest
SchemaResult
SchemaUpdate
MapEntry
MovePredicatePayload
ExportPayload
OracleDelta
TxnTimestamps
Num
SnapshotMeta

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInternal   = 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 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 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 ConnectionState 

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

func (*ConnectionState) Descriptor 

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

func (*ConnectionState) GetMember 

func (m *ConnectionState) GetMember() *Member

func (*ConnectionState) GetState 

func (m *ConnectionState) GetState() *MembershipState

func (*ConnectionState) Marshal 

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

func (*ConnectionState) MarshalTo 

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

func (*ConnectionState) ProtoMessage 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) Reset 

func (m *ConnectionState) Reset()

func (*ConnectionState) Size 

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

func (*ConnectionState) String 

func (m *ConnectionState) String() string

func (*ConnectionState) Unmarshal 

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

type 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=intern.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=intern.DirectedEdge_Op" json:"op,omitempty"`
	Facets    []*api.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() []*api.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=intern.ExportPayload_Status" json:"status,omitempty"`
	ReadTs  uint64               `protobuf:"varint,4,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
}

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

func (*ExportPayload) Descriptor 

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

func (*ExportPayload) GetGroupId 

func (m *ExportPayload) GetGroupId() uint32

func (*ExportPayload) GetReadTs 

func (m *ExportPayload) GetReadTs() uint64

func (*ExportPayload) GetReqId 

func (m *ExportPayload) GetReqId() uint64

func (*ExportPayload) GetStatus 

func (m *ExportPayload) GetStatus() ExportPayload_Status

func (*ExportPayload) Marshal 

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

func (*ExportPayload) MarshalTo 

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

func (*ExportPayload) ProtoMessage 

func (*ExportPayload) ProtoMessage()

func (*ExportPayload) Reset 

func (m *ExportPayload) Reset()

func (*ExportPayload) Size 

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

func (*ExportPayload) String 

func (m *ExportPayload) String() string

func (*ExportPayload) Unmarshal 

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

type ExportPayload_Status 

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

func (ExportPayload_Status) EnumDescriptor 

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

func (ExportPayload_Status) String 

func (x ExportPayload_Status) String() string

type FacetParam 

type FacetParam struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Alias string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
}

func (*FacetParam) Descriptor 

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

func (*FacetParam) GetAlias 

func (m *FacetParam) GetAlias() string

func (*FacetParam) GetKey 

func (m *FacetParam) GetKey() string

func (*FacetParam) Marshal 

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

func (*FacetParam) MarshalTo 

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

func (*FacetParam) ProtoMessage 

func (*FacetParam) ProtoMessage()

func (*FacetParam) Reset 

func (m *FacetParam) Reset()

func (*FacetParam) Size 

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

func (*FacetParam) String 

func (m *FacetParam) String() string

func (*FacetParam) Unmarshal 

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

type FacetParams 

type FacetParams struct {
	AllKeys bool          `protobuf:"varint,1,opt,name=all_keys,json=allKeys,proto3" json:"all_keys,omitempty"`
	Param   []*FacetParam `protobuf:"bytes,2,rep,name=param" json:"param,omitempty"`
}

func (*FacetParams) Descriptor 

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

func (*FacetParams) GetAllKeys 

func (m *FacetParams) GetAllKeys() bool

func (*FacetParams) GetParam 

func (m *FacetParams) GetParam() []*FacetParam

func (*FacetParams) Marshal 

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

func (*FacetParams) MarshalTo 

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

func (*FacetParams) ProtoMessage 

func (*FacetParams) ProtoMessage()

func (*FacetParams) Reset 

func (m *FacetParams) Reset()

func (*FacetParams) Size 

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

func (*FacetParams) String 

func (m *FacetParams) String() string

func (*FacetParams) Unmarshal 

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

type Facets 

type Facets struct {
	Facets []*api.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() []*api.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 KV 

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

func (*KV) Descriptor 

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

func (*KV) GetKey 

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

func (*KV) GetUserMeta 

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

func (*KV) GetVal 

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

func (*KV) GetVersion 

func (m *KV) GetVersion() uint64

func (*KV) Marshal 

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

func (*KV) MarshalTo 

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

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) Size 

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

func (*KV) String 

func (m *KV) String() string

func (*KV) Unmarshal 

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

type KeyValues 

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

func (*KeyValues) Descriptor 

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

func (*KeyValues) GetKv 

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

func (*KeyValues) Marshal 

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

func (*KeyValues) MarshalTo 

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

func (*KeyValues) ProtoMessage 

func (*KeyValues) ProtoMessage()

func (*KeyValues) Reset 

func (m *KeyValues) Reset()

func (*KeyValues) Size 

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

func (*KeyValues) String 

func (m *KeyValues) String() string

func (*KeyValues) Unmarshal 

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

type LangList 

type LangList struct {
	Lang []string `protobuf:"bytes,1,rep,name=lang" json:"lang,omitempty"`
}

func (*LangList) Descriptor 

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

func (*LangList) GetLang 

func (m *LangList) GetLang() []string

func (*LangList) Marshal 

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

func (*LangList) MarshalTo 

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

func (*LangList) ProtoMessage 

func (*LangList) ProtoMessage()

func (*LangList) Reset 

func (m *LangList) Reset()

func (*LangList) Size 

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

func (*LangList) String 

func (m *LangList) String() string

func (*LangList) Unmarshal 

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

type List 

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

func (*List) Descriptor 

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

func (*List) GetUids 

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

func (*List) Marshal 

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

func (*List) MarshalTo 

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

func (*List) ProtoMessage 

func (*List) ProtoMessage()

func (*List) Reset 

func (m *List) Reset()

func (*List) Size 

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

func (*List) String 

func (m *List) String() string

func (*List) Unmarshal 

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

type MapEntry 

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

Bulk loader proto.

func (*MapEntry) Descriptor 

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

func (*MapEntry) GetKey 

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

func (*MapEntry) GetPosting 

func (m *MapEntry) GetPosting() *Posting

func (*MapEntry) GetUid 

func (m *MapEntry) GetUid() uint64

func (*MapEntry) Marshal 

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

func (*MapEntry) MarshalTo 

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

func (*MapEntry) ProtoMessage 

func (*MapEntry) ProtoMessage()

func (*MapEntry) Reset 

func (m *MapEntry) Reset()

func (*MapEntry) Size 

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

func (*MapEntry) String 

func (m *MapEntry) String() string

func (*MapEntry) Unmarshal 

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

type Member 

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

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

func (*Member) Descriptor 

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

func (*Member) GetAddr 

func (m *Member) GetAddr() string

func (*Member) GetAmDead 

func (m *Member) GetAmDead() bool

func (*Member) GetClusterInfoOnly 

func (m *Member) GetClusterInfoOnly() bool

func (*Member) GetGroupId 

func (m *Member) GetGroupId() uint32

func (*Member) GetId 

func (m *Member) GetId() uint64

func (*Member) GetLastUpdate 

func (m *Member) GetLastUpdate() uint64

func (*Member) GetLeader 

func (m *Member) GetLeader() bool

func (*Member) Marshal 

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

func (*Member) MarshalTo 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) Size 

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

func (*Member) String 

func (m *Member) String() string

func (*Member) Unmarshal 

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

type MembershipState 

type MembershipState struct {
	Counter    uint64             `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	Groups     map[uint32]*Group  `` /* 140-byte string literal not displayed */
	Zeros      map[uint64]*Member `` /* 138-byte string literal not displayed */
	MaxLeaseId uint64             `protobuf:"varint,4,opt,name=maxLeaseId,proto3" json:"maxLeaseId,omitempty"`
	MaxTxnTs   uint64             `protobuf:"varint,5,opt,name=maxTxnTs,proto3" json:"maxTxnTs,omitempty"`
	MaxRaftId  uint64             `protobuf:"varint,6,opt,name=maxRaftId,proto3" json:"maxRaftId,omitempty"`
	Removed    []*Member          `protobuf:"bytes,7,rep,name=removed" json:"removed,omitempty"`
}

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

func (*MembershipState) Descriptor 

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

func (*MembershipState) GetCounter 

func (m *MembershipState) GetCounter() uint64

func (*MembershipState) GetGroups 

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

func (*MembershipState) GetMaxLeaseId 

func (m *MembershipState) GetMaxLeaseId() uint64

func (*MembershipState) GetMaxRaftId 

func (m *MembershipState) GetMaxRaftId() uint64

func (*MembershipState) GetMaxTxnTs 

func (m *MembershipState) GetMaxTxnTs() uint64

func (*MembershipState) GetRemoved 

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

func (*MembershipState) GetZeros 

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

func (*MembershipState) Marshal 

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

func (*MembershipState) MarshalTo 

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

func (*MembershipState) ProtoMessage 

func (*MembershipState) ProtoMessage()

func (*MembershipState) Reset 

func (m *MembershipState) Reset()

func (*MembershipState) Size 

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

func (*MembershipState) String 

func (m *MembershipState) String() string

func (*MembershipState) Unmarshal 

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

type MovePredicatePayload 

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

func (*MovePredicatePayload) Descriptor 

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

func (*MovePredicatePayload) GetDestGroupId 

func (m *MovePredicatePayload) GetDestGroupId() uint32

func (*MovePredicatePayload) GetPredicate 

func (m *MovePredicatePayload) GetPredicate() string

func (*MovePredicatePayload) GetSourceGroupId 

func (m *MovePredicatePayload) GetSourceGroupId() uint32

func (*MovePredicatePayload) GetState 

func (m *MovePredicatePayload) GetState() *MembershipState

func (*MovePredicatePayload) Marshal 

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

func (*MovePredicatePayload) MarshalTo 

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

func (*MovePredicatePayload) ProtoMessage 

func (*MovePredicatePayload) ProtoMessage()

func (*MovePredicatePayload) Reset 

func (m *MovePredicatePayload) Reset()

func (*MovePredicatePayload) Size 

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

func (*MovePredicatePayload) String 

func (m *MovePredicatePayload) String() string

func (*MovePredicatePayload) Unmarshal 

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

type 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=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"`
	IgnoreIndexConflict bool            `protobuf:"varint,6,opt,name=ignore_index_conflict,json=ignoreIndexConflict,proto3" json:"ignore_index_conflict,omitempty"`
}

func (*Mutations) Descriptor 

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

func (*Mutations) GetDropAll 

func (m *Mutations) GetDropAll() bool

func (*Mutations) GetEdges 

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

func (*Mutations) GetGroupId 

func (m *Mutations) GetGroupId() uint32

func (*Mutations) GetIgnoreIndexConflict 

func (m *Mutations) GetIgnoreIndexConflict() bool

func (*Mutations) GetSchema 

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

func (*Mutations) GetStartTs 

func (m *Mutations) GetStartTs() uint64

func (*Mutations) Marshal 

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

func (*Mutations) MarshalTo 

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

func (*Mutations) ProtoMessage 

func (*Mutations) ProtoMessage()

func (*Mutations) Reset 

func (m *Mutations) Reset()

func (*Mutations) Size 

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

func (*Mutations) String 

func (m *Mutations) String() string

func (*Mutations) Unmarshal 

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

type 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 OracleDelta 

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

func (*OracleDelta) Descriptor 

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

func (*OracleDelta) GetAborts 

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

func (*OracleDelta) GetCommits 

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

func (*OracleDelta) GetMaxPending 

func (m *OracleDelta) GetMaxPending() uint64

func (*OracleDelta) Marshal 

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

func (*OracleDelta) MarshalTo 

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

func (*OracleDelta) ProtoMessage 

func (*OracleDelta) ProtoMessage()

func (*OracleDelta) Reset 

func (m *OracleDelta) Reset()

func (*OracleDelta) Size 

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

func (*OracleDelta) String 

func (m *OracleDelta) String() string

func (*OracleDelta) Unmarshal 

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

type Order 

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

func (*Order) Descriptor 

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

func (*Order) GetAttr 

func (m *Order) GetAttr() string

func (*Order) GetDesc 

func (m *Order) GetDesc() bool

func (*Order) GetLangs 

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

func (*Order) Marshal 

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

func (*Order) MarshalTo 

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

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) Reset 

func (m *Order) Reset()

func (*Order) Size 

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

func (*Order) String 

func (m *Order) String() string

func (*Order) Unmarshal 

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

type 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=intern.Posting_ValType" json:"val_type,omitempty"`
	PostingType Posting_PostingType `` /* 127-byte string literal not displayed */
	LangTag     []byte              `protobuf:"bytes,5,opt,name=lang_tag,json=langTag,proto3" json:"lang_tag,omitempty"`
	Label       string              `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"`
	Facets      []*api.Facet        `protobuf:"bytes,9,rep,name=facets" json:"facets,omitempty"`
	// TODO: op is only used temporarily. See if we can remove it from here.
	Op       uint32 `protobuf:"varint,12,opt,name=op,proto3" json:"op,omitempty"`
	StartTs  uint64 `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs uint64 `protobuf:"varint,14,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
}

Posting messages.

func (*Posting) Descriptor 

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

func (*Posting) GetCommitTs 

func (m *Posting) GetCommitTs() uint64

func (*Posting) GetFacets 

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

func (*Posting) GetLabel 

func (m *Posting) GetLabel() string

func (*Posting) GetLangTag 

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

func (*Posting) GetOp 

func (m *Posting) GetOp() uint32

func (*Posting) GetPostingType 

func (m *Posting) GetPostingType() Posting_PostingType

func (*Posting) GetStartTs 

func (m *Posting) GetStartTs() uint64

func (*Posting) GetUid 

func (m *Posting) GetUid() uint64

func (*Posting) GetValType 

func (m *Posting) GetValType() Posting_ValType

func (*Posting) GetValue 

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

func (*Posting) Marshal 

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

func (*Posting) MarshalTo 

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

func (*Posting) ProtoMessage 

func (*Posting) ProtoMessage()

func (*Posting) Reset 

func (m *Posting) Reset()

func (*Posting) Size 

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

func (*Posting) String 

func (m *Posting) String() string

func (*Posting) Unmarshal 

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

type PostingList 

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

func (*PostingList) Descriptor 

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

func (*PostingList) GetChecksum 

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

func (*PostingList) GetCommit 

func (m *PostingList) GetCommit() uint64

func (*PostingList) GetPostings 

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

func (*PostingList) GetUids 

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

func (*PostingList) Marshal 

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

func (*PostingList) MarshalTo 

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

func (*PostingList) ProtoMessage 

func (*PostingList) ProtoMessage()

func (*PostingList) Reset 

func (m *PostingList) Reset()

func (*PostingList) Size 

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

func (*PostingList) String 

func (m *PostingList) String() string

func (*PostingList) Unmarshal 

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

type Posting_PostingType 

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

func (Posting_PostingType) EnumDescriptor 

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

func (Posting_PostingType) String 

func (x Posting_PostingType) String() string

type Posting_ValType 

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

func (Posting_ValType) EnumDescriptor 

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

func (Posting_ValType) String 

func (x Posting_ValType) String() string

type Proposal 

type Proposal struct {
	Id             uint32           `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Mutations      *Mutations       `protobuf:"bytes,2,opt,name=mutations" json:"mutations,omitempty"`
	TxnContext     *api.TxnContext  `protobuf:"bytes,3,opt,name=txn_context,json=txnContext" json:"txn_context,omitempty"`
	Kv             []*KV            `protobuf:"bytes,4,rep,name=kv" json:"kv,omitempty"`
	State          *MembershipState `protobuf:"bytes,5,opt,name=state" json:"state,omitempty"`
	CleanPredicate string           `protobuf:"bytes,6,opt,name=clean_predicate,json=cleanPredicate,proto3" json:"clean_predicate,omitempty"`
}

func (*Proposal) Descriptor 

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

func (*Proposal) GetCleanPredicate 

func (m *Proposal) GetCleanPredicate() string

func (*Proposal) GetId 

func (m *Proposal) GetId() uint32

func (*Proposal) GetKv 

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

func (*Proposal) GetMutations 

func (m *Proposal) GetMutations() *Mutations

func (*Proposal) GetState 

func (m *Proposal) GetState() *MembershipState

func (*Proposal) GetTxnContext 

func (m *Proposal) GetTxnContext() *api.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   *FacetParams `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"`
	ExpandAll    bool         `protobuf:"varint,10,opt,name=expand_all,json=expandAll,proto3" json:"expand_all,omitempty"`
	ReadTs       uint64       `protobuf:"varint,13,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
	LinRead      *api.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) GetExpandAll 

func (m *Query) GetExpandAll() bool

func (*Query) GetFacetParam 

func (m *Query) GetFacetParam() *FacetParams

func (*Query) GetFacetsFilter 

func (m *Query) GetFacetsFilter() *FilterTree

func (*Query) GetLangs 

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

func (*Query) GetLinRead 

func (m *Query) GetLinRead() *api.LinRead

func (*Query) GetReadTs 

func (m *Query) GetReadTs() uint64

func (*Query) GetReverse 

func (m *Query) GetReverse() bool

func (*Query) GetSrcFunc 

func (m *Query) GetSrcFunc() *SrcFunction

func (*Query) GetUidList 

func (m *Query) GetUidList() *List

func (*Query) Marshal 

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

func (*Query) MarshalTo 

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

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) Size 

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

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal 

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

type RaftClient 

type RaftClient interface {
	Echo(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*api.Payload, error)
	RaftMessage(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (*api.Payload, error)
	JoinCluster(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*api.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"`
	SnapshotTs uint64 `protobuf:"varint,4,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,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) GetSnapshotTs added in v1.0.2 

func (m *RaftContext) GetSnapshotTs() uint64

func (*RaftContext) Marshal 

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

func (*RaftContext) MarshalTo 

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

func (*RaftContext) ProtoMessage 

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset 

func (m *RaftContext) Reset()

func (*RaftContext) Size 

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

func (*RaftContext) String 

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal 

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

type RaftServer 

type RaftServer interface {
	Echo(context.Context, *api.Payload) (*api.Payload, error)
	RaftMessage(context.Context, *api.Payload) (*api.Payload, error)
	JoinCluster(context.Context, *RaftContext) (*api.Payload, 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"`
	LangMatrix    []*LangList   `protobuf:"bytes,6,rep,name=lang_matrix,json=langMatrix" json:"lang_matrix,omitempty"`
	List          bool          `protobuf:"varint,7,opt,name=list,proto3" json:"list,omitempty"`
	LinRead       *api.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) GetLangMatrix 

func (m *Result) GetLangMatrix() []*LangList

func (*Result) GetLinRead 

func (m *Result) GetLinRead() *api.LinRead

func (*Result) GetList added in v1.0.2 

func (m *Result) GetList() 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 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 []*api.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() []*api.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=intern.Posting_ValType" json:"value_type,omitempty"`
	Directive SchemaUpdate_Directive `protobuf:"varint,3,opt,name=directive,proto3,enum=intern.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"`
	Upsert    bool                   `protobuf:"varint,8,opt,name=upsert,proto3" json:"upsert,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) GetList 

func (m *SchemaUpdate) GetList() bool

func (*SchemaUpdate) GetPredicate 

func (m *SchemaUpdate) GetPredicate() string

func (*SchemaUpdate) GetTokenizer 

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

func (*SchemaUpdate) GetUpsert added in v1.0.4 

func (m *SchemaUpdate) GetUpsert() bool

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 SnapshotMeta added in v1.0.2 

type SnapshotMeta struct {
	ClientTs uint64 `protobuf:"varint,1,opt,name=client_ts,json=clientTs,proto3" json:"client_ts,omitempty"`
	GroupId  uint32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
}

func (*SnapshotMeta) Descriptor added in v1.0.2 

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

func (*SnapshotMeta) GetClientTs added in v1.0.2 

func (m *SnapshotMeta) GetClientTs() uint64

func (*SnapshotMeta) GetGroupId added in v1.0.2 

func (m *SnapshotMeta) GetGroupId() uint32

func (*SnapshotMeta) Marshal added in v1.0.2 

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

func (*SnapshotMeta) MarshalTo added in v1.0.2 

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

func (*SnapshotMeta) ProtoMessage added in v1.0.2 

func (*SnapshotMeta) ProtoMessage()

func (*SnapshotMeta) Reset added in v1.0.2 

func (m *SnapshotMeta) Reset()

func (*SnapshotMeta) Size added in v1.0.2 

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

func (*SnapshotMeta) String added in v1.0.2 

func (m *SnapshotMeta) String() string

func (*SnapshotMeta) Unmarshal added in v1.0.2 

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

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

func (*SortMessage) Descriptor 

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

func (*SortMessage) GetCount 

func (m *SortMessage) GetCount() int32

func (*SortMessage) GetLinRead 

func (m *SortMessage) GetLinRead() *api.LinRead

func (*SortMessage) GetOffset 

func (m *SortMessage) GetOffset() int32

func (*SortMessage) GetOrder 

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

func (*SortMessage) GetReadTs 

func (m *SortMessage) GetReadTs() uint64

func (*SortMessage) GetUidMatrix 

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

func (*SortMessage) Marshal 

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

func (*SortMessage) MarshalTo 

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

func (*SortMessage) ProtoMessage 

func (*SortMessage) ProtoMessage()

func (*SortMessage) Reset 

func (m *SortMessage) Reset()

func (*SortMessage) Size 

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

func (*SortMessage) String 

func (m *SortMessage) String() string

func (*SortMessage) Unmarshal 

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

type SortResult 

type SortResult struct {
	UidMatrix []*List      `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix" json:"uid_matrix,omitempty"`
	LinRead   *api.LinRead `protobuf:"bytes,14,opt,name=lin_read,json=linRead" json:"lin_read,omitempty"`
}

func (*SortResult) Descriptor 

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

func (*SortResult) GetLinRead 

func (m *SortResult) GetLinRead() *api.LinRead

func (*SortResult) GetUidMatrix 

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

func (*SortResult) Marshal 

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

func (*SortResult) MarshalTo 

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

func (*SortResult) ProtoMessage 

func (*SortResult) ProtoMessage()

func (*SortResult) Reset 

func (m *SortResult) Reset()

func (*SortResult) Size 

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

func (*SortResult) String 

func (m *SortResult) String() string

func (*SortResult) Unmarshal 

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

type SrcFunction 

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

func (*SrcFunction) Descriptor 

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

func (*SrcFunction) GetArgs 

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

func (*SrcFunction) GetIsCount 

func (m *SrcFunction) GetIsCount() bool

func (*SrcFunction) GetName 

func (m *SrcFunction) GetName() string

func (*SrcFunction) Marshal 

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

func (*SrcFunction) MarshalTo 

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

func (*SrcFunction) ProtoMessage 

func (*SrcFunction) ProtoMessage()

func (*SrcFunction) Reset 

func (m *SrcFunction) Reset()

func (*SrcFunction) Size 

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

func (*SrcFunction) String 

func (m *SrcFunction) String() string

func (*SrcFunction) Unmarshal 

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

type Tablet 

type Tablet struct {
	GroupId   uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	Force     bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	ReadOnly  bool   `protobuf:"varint,4,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	Space     int64  `protobuf:"varint,7,opt,name=space,proto3" json:"space,omitempty"`
	Remove    bool   `protobuf:"varint,8,opt,name=remove,proto3" json:"remove,omitempty"`
}

func (*Tablet) Descriptor 

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

func (*Tablet) GetForce 

func (m *Tablet) GetForce() bool

func (*Tablet) GetGroupId 

func (m *Tablet) GetGroupId() uint32

func (*Tablet) GetPredicate 

func (m *Tablet) GetPredicate() string

func (*Tablet) GetReadOnly 

func (m *Tablet) GetReadOnly() bool

func (*Tablet) GetRemove added in v1.0.0 

func (m *Tablet) GetRemove() bool

func (*Tablet) GetSpace 

func (m *Tablet) GetSpace() int64

func (*Tablet) Marshal 

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

func (*Tablet) MarshalTo 

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

func (*Tablet) ProtoMessage 

func (*Tablet) ProtoMessage()

func (*Tablet) Reset 

func (m *Tablet) Reset()

func (*Tablet) Size 

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

func (*Tablet) String 

func (m *Tablet) String() string

func (*Tablet) Unmarshal 

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

type TaskValue 

type TaskValue struct {
	Val     []byte          `protobuf:"bytes,1,opt,name=val,proto3" json:"val,omitempty"`
	ValType Posting_ValType `protobuf:"varint,2,opt,name=val_type,json=valType,proto3,enum=intern.Posting_ValType" 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() Posting_ValType

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 TxnTimestamps 

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

func (*TxnTimestamps) Descriptor 

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

func (*TxnTimestamps) GetTs 

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

func (*TxnTimestamps) Marshal 

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

func (*TxnTimestamps) MarshalTo 

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

func (*TxnTimestamps) ProtoMessage 

func (*TxnTimestamps) ProtoMessage()

func (*TxnTimestamps) Reset 

func (m *TxnTimestamps) Reset()

func (*TxnTimestamps) Size 

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

func (*TxnTimestamps) String 

func (m *TxnTimestamps) String() string

func (*TxnTimestamps) Unmarshal 

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

type 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 WorkerClient 

type WorkerClient interface {
	// Data serving RPCs.
	Mutate(ctx context.Context, in *Mutations, opts ...grpc.CallOption) (*api.TxnContext, error)
	ServeTask(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Result, error)
	PredicateAndSchemaData(ctx context.Context, in *SnapshotMeta, 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 *api.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) (*api.Payload, error)
}

func NewWorkerClient 

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerServer 

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

type Worker_PredicateAndSchemaDataClient 

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

type Worker_PredicateAndSchemaDataServer 

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

type Worker_ReceivePredicateClient 

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

type Worker_ReceivePredicateServer 

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

type ZeroClient 

type ZeroClient interface {
	Connect(ctx context.Context, in *Member, opts ...grpc.CallOption) (*ConnectionState, error)
	Update(ctx context.Context, opts ...grpc.CallOption) (Zero_UpdateClient, error)
	Oracle(ctx context.Context, in *api.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) (*api.AssignedIds, error)
	Timestamps(ctx context.Context, in *Num, opts ...grpc.CallOption) (*api.AssignedIds, error)
	CommitOrAbort(ctx context.Context, in *api.TxnContext, opts ...grpc.CallOption) (*api.TxnContext, error)
	TryAbort(ctx context.Context, in *TxnTimestamps, opts ...grpc.CallOption) (*TxnTimestamps, error)
}

func NewZeroClient 

func NewZeroClient(cc *grpc.ClientConn) ZeroClient

type ZeroProposal 

type ZeroProposal struct {
	Id         uint32          `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Member     *Member         `protobuf:"bytes,2,opt,name=member" json:"member,omitempty"`
	Tablet     *Tablet         `protobuf:"bytes,3,opt,name=tablet" json:"tablet,omitempty"`
	MaxLeaseId uint64          `protobuf:"varint,4,opt,name=maxLeaseId,proto3" json:"maxLeaseId,omitempty"`
	MaxTxnTs   uint64          `protobuf:"varint,5,opt,name=maxTxnTs,proto3" json:"maxTxnTs,omitempty"`
	MaxRaftId  uint64          `protobuf:"varint,6,opt,name=maxRaftId,proto3" json:"maxRaftId,omitempty"`
	Txn        *api.TxnContext `protobuf:"bytes,7,opt,name=txn" json:"txn,omitempty"`
}

func (*ZeroProposal) Descriptor 

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

func (*ZeroProposal) GetId 

func (m *ZeroProposal) GetId() uint32

func (*ZeroProposal) GetMaxLeaseId 

func (m *ZeroProposal) GetMaxLeaseId() uint64

func (*ZeroProposal) GetMaxRaftId 

func (m *ZeroProposal) GetMaxRaftId() uint64

func (*ZeroProposal) GetMaxTxnTs 

func (m *ZeroProposal) GetMaxTxnTs() uint64

func (*ZeroProposal) GetMember 

func (m *ZeroProposal) GetMember() *Member

func (*ZeroProposal) GetTablet 

func (m *ZeroProposal) GetTablet() *Tablet

func (*ZeroProposal) GetTxn 

func (m *ZeroProposal) GetTxn() *api.TxnContext

func (*ZeroProposal) Marshal 

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

func (*ZeroProposal) MarshalTo 

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

func (*ZeroProposal) ProtoMessage 

func (*ZeroProposal) ProtoMessage()

func (*ZeroProposal) Reset 

func (m *ZeroProposal) Reset()

func (*ZeroProposal) Size 

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

func (*ZeroProposal) String 

func (m *ZeroProposal) String() string

func (*ZeroProposal) Unmarshal 

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

type ZeroServer 

type ZeroServer interface {
	Connect(context.Context, *Member) (*ConnectionState, error)
	Update(Zero_UpdateServer) error
	Oracle(*api.Payload, Zero_OracleServer) error
	ShouldServe(context.Context, *Tablet) (*Tablet, error)
	AssignUids(context.Context, *Num) (*api.AssignedIds, error)
	Timestamps(context.Context, *Num) (*api.AssignedIds, error)
	CommitOrAbort(context.Context, *api.TxnContext) (*api.TxnContext, error)
	TryAbort(context.Context, *TxnTimestamps) (*TxnTimestamps, error)
}

type Zero_OracleClient 

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

type Zero_OracleServer 

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

type Zero_UpdateClient 

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

type Zero_UpdateServer 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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