intern

package
v1.0.3 Latest Latest
Warning

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

Go to latest
Published: Feb 7, 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"`
}

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) 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)
	CommitOrAbort(ctx context.Context, in *api.TxnContext, opts ...grpc.CallOption) (*api.Payload, 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)
	CommitOrAbort(context.Context, *api.TxnContext) (*api.Payload, 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
}

Jump to

Keyboard shortcuts

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