Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRaftServer(s grpc.ServiceRegistrar, srv RaftServer)
- func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)
- func RegisterZeroServer(s grpc.ServiceRegistrar, srv ZeroServer)
- type AssignedIds
- func (*AssignedIds) Descriptor() ([]byte, []int)deprecated
- func (x *AssignedIds) GetEndId() uint64
- func (x *AssignedIds) GetReadOnly() uint64
- func (x *AssignedIds) GetStartId() uint64
- func (*AssignedIds) ProtoMessage()
- func (x *AssignedIds) ProtoReflect() protoreflect.Message
- func (x *AssignedIds) Reset()
- func (x *AssignedIds) String() string
- type BackupKey
- func (*BackupKey) Descriptor() ([]byte, []int)deprecated
- func (x *BackupKey) GetAttr() string
- func (x *BackupKey) GetCount() uint32
- func (x *BackupKey) GetNamespace() uint64
- func (x *BackupKey) GetStartUid() uint64
- func (x *BackupKey) GetTerm() []byte
- func (x *BackupKey) GetType() BackupKey_KeyType
- func (x *BackupKey) GetUid() uint64
- func (*BackupKey) ProtoMessage()
- func (x *BackupKey) ProtoReflect() protoreflect.Message
- func (x *BackupKey) Reset()
- func (x *BackupKey) String() string
- type BackupKey_KeyType
- func (BackupKey_KeyType) Descriptor() protoreflect.EnumDescriptor
- func (x BackupKey_KeyType) Enum() *BackupKey_KeyType
- func (BackupKey_KeyType) EnumDescriptor() ([]byte, []int)deprecated
- func (x BackupKey_KeyType) Number() protoreflect.EnumNumber
- func (x BackupKey_KeyType) String() string
- func (BackupKey_KeyType) Type() protoreflect.EnumType
- type BackupPostingList
- func (*BackupPostingList) Descriptor() ([]byte, []int)deprecated
- func (x *BackupPostingList) GetCommitTs() uint64
- func (x *BackupPostingList) GetPostings() []*Posting
- func (x *BackupPostingList) GetSplits() []uint64
- func (x *BackupPostingList) GetUidBytes() []byte
- func (x *BackupPostingList) GetUids() []uint64
- func (*BackupPostingList) ProtoMessage()
- func (x *BackupPostingList) ProtoReflect() protoreflect.Message
- func (x *BackupPostingList) Reset()
- func (x *BackupPostingList) String() string
- type BackupRequest
- func (*BackupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BackupRequest) GetAccessKey() string
- func (x *BackupRequest) GetAnonymous() bool
- func (x *BackupRequest) GetDestination() string
- func (x *BackupRequest) GetForceFull() bool
- func (x *BackupRequest) GetGroupId() uint32
- func (x *BackupRequest) GetPredicates() []string
- func (x *BackupRequest) GetReadTs() uint64
- func (x *BackupRequest) GetSecretKey() Sensitive
- func (x *BackupRequest) GetSessionToken() Sensitive
- func (x *BackupRequest) GetSinceTs() uint64
- func (x *BackupRequest) GetUnixTs() string
- func (*BackupRequest) ProtoMessage()
- func (x *BackupRequest) ProtoReflect() protoreflect.Message
- func (x *BackupRequest) Reset()
- func (x *BackupRequest) String() string
- type BackupResponse
- type BulkMeta
- func (*BulkMeta) Descriptor() ([]byte, []int)deprecated
- func (x *BulkMeta) GetEdgeCount() int64
- func (x *BulkMeta) GetSchemaMap() map[string]*SchemaUpdate
- func (x *BulkMeta) GetTypes() []*TypeUpdate
- func (*BulkMeta) ProtoMessage()
- func (x *BulkMeta) ProtoReflect() protoreflect.Message
- func (x *BulkMeta) Reset()
- func (x *BulkMeta) String() string
- type CDCState
- type ConnectionState
- func (*ConnectionState) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionState) GetMaxPending() uint64
- func (x *ConnectionState) GetMember() *Member
- func (x *ConnectionState) GetState() *MembershipState
- func (*ConnectionState) ProtoMessage()
- func (x *ConnectionState) ProtoReflect() protoreflect.Message
- func (x *ConnectionState) Reset()
- func (x *ConnectionState) String() string
- type DeleteNsRequest
- func (*DeleteNsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNsRequest) GetGroupId() uint32
- func (x *DeleteNsRequest) GetNamespace() uint64
- func (*DeleteNsRequest) ProtoMessage()
- func (x *DeleteNsRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNsRequest) Reset()
- func (x *DeleteNsRequest) String() string
- type DirectedEdge
- func (*DirectedEdge) Descriptor() ([]byte, []int)deprecated
- func (x *DirectedEdge) GetAllowedPreds() []string
- func (x *DirectedEdge) GetAttr() string
- func (x *DirectedEdge) GetEntity() uint64
- func (x *DirectedEdge) GetFacets() []*api.Facet
- func (x *DirectedEdge) GetLang() string
- func (x *DirectedEdge) GetNamespace() uint64
- func (x *DirectedEdge) GetOp() DirectedEdge_Op
- func (x *DirectedEdge) GetValue() []byte
- func (x *DirectedEdge) GetValueId() uint64
- func (x *DirectedEdge) GetValueType() Posting_ValType
- func (*DirectedEdge) ProtoMessage()
- func (x *DirectedEdge) ProtoReflect() protoreflect.Message
- func (x *DirectedEdge) Reset()
- func (x *DirectedEdge) String() string
- type DirectedEdge_Op
- func (DirectedEdge_Op) Descriptor() protoreflect.EnumDescriptor
- func (x DirectedEdge_Op) Enum() *DirectedEdge_Op
- func (DirectedEdge_Op) EnumDescriptor() ([]byte, []int)deprecated
- func (x DirectedEdge_Op) Number() protoreflect.EnumNumber
- func (x DirectedEdge_Op) String() string
- func (DirectedEdge_Op) Type() protoreflect.EnumType
- type DrainModeRequest
- type DropOperation
- func (*DropOperation) Descriptor() ([]byte, []int)deprecated
- func (x *DropOperation) GetDropOp() DropOperation_DropOp
- func (x *DropOperation) GetDropValue() string
- func (*DropOperation) ProtoMessage()
- func (x *DropOperation) ProtoReflect() protoreflect.Message
- func (x *DropOperation) Reset()
- func (x *DropOperation) String() string
- type DropOperation_DropOp
- func (DropOperation_DropOp) Descriptor() protoreflect.EnumDescriptor
- func (x DropOperation_DropOp) Enum() *DropOperation_DropOp
- func (DropOperation_DropOp) EnumDescriptor() ([]byte, []int)deprecated
- func (x DropOperation_DropOp) Number() protoreflect.EnumNumber
- func (x DropOperation_DropOp) String() string
- func (DropOperation_DropOp) Type() protoreflect.EnumType
- type ExportRequest
- func (*ExportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExportRequest) GetAccessKey() string
- func (x *ExportRequest) GetAnonymous() bool
- func (x *ExportRequest) GetDestination() string
- func (x *ExportRequest) GetFormat() string
- func (x *ExportRequest) GetGroupId() uint32
- func (x *ExportRequest) GetNamespace() uint64
- func (x *ExportRequest) GetReadTs() uint64
- func (x *ExportRequest) GetSecretKey() Sensitive
- func (x *ExportRequest) GetSessionToken() Sensitive
- func (x *ExportRequest) GetUnixTs() int64
- func (*ExportRequest) ProtoMessage()
- func (x *ExportRequest) ProtoReflect() protoreflect.Message
- func (x *ExportRequest) Reset()
- func (x *ExportRequest) String() string
- type ExportResponse
- func (*ExportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExportResponse) GetCode() int32
- func (x *ExportResponse) GetFiles() []string
- func (x *ExportResponse) GetMsg() string
- func (*ExportResponse) ProtoMessage()
- func (x *ExportResponse) ProtoReflect() protoreflect.Message
- func (x *ExportResponse) Reset()
- func (x *ExportResponse) String() string
- type FacetParam
- type FacetParams
- func (*FacetParams) Descriptor() ([]byte, []int)deprecated
- func (x *FacetParams) GetAllKeys() bool
- func (x *FacetParams) GetParam() []*FacetParam
- func (*FacetParams) ProtoMessage()
- func (x *FacetParams) ProtoReflect() protoreflect.Message
- func (x *FacetParams) Reset()
- func (x *FacetParams) String() string
- type Facets
- type FacetsList
- type FilterTree
- func (*FilterTree) Descriptor() ([]byte, []int)deprecated
- func (x *FilterTree) GetChildren() []*FilterTree
- func (x *FilterTree) GetFunc() *Function
- func (x *FilterTree) GetOp() string
- func (*FilterTree) ProtoMessage()
- func (x *FilterTree) ProtoReflect() protoreflect.Message
- func (x *FilterTree) Reset()
- func (x *FilterTree) String() string
- type Function
- func (*Function) Descriptor() ([]byte, []int)deprecated
- func (x *Function) GetArgs() []string
- func (x *Function) GetKey() string
- func (x *Function) GetName() string
- func (*Function) ProtoMessage()
- func (x *Function) ProtoReflect() protoreflect.Message
- func (x *Function) Reset()
- func (x *Function) String() string
- type Group
- func (*Group) Descriptor() ([]byte, []int)deprecated
- func (x *Group) GetCheckpointTs() uint64
- func (x *Group) GetChecksum() uint64
- func (x *Group) GetMembers() map[uint64]*Member
- func (x *Group) GetSnapshotTs() uint64
- func (x *Group) GetTablets() map[string]*Tablet
- func (*Group) ProtoMessage()
- func (x *Group) ProtoReflect() protoreflect.Message
- func (x *Group) Reset()
- func (x *Group) String() string
- type HealthInfo
- func (*HealthInfo) Descriptor() ([]byte, []int)deprecated
- func (x *HealthInfo) GetAddress() string
- func (x *HealthInfo) GetEeFeatures() []string
- func (x *HealthInfo) GetGroup() string
- func (x *HealthInfo) GetIndexing() []string
- func (x *HealthInfo) GetInstance() string
- func (x *HealthInfo) GetLastEcho() int64
- func (x *HealthInfo) GetMaxAssigned() uint64
- func (x *HealthInfo) GetOngoing() []string
- func (x *HealthInfo) GetStatus() string
- func (x *HealthInfo) GetUptime() int64
- func (x *HealthInfo) GetVersion() string
- func (*HealthInfo) ProtoMessage()
- func (x *HealthInfo) ProtoReflect() protoreflect.Message
- func (x *HealthInfo) Reset()
- func (x *HealthInfo) String() string
- type KVS
- func (*KVS) Descriptor() ([]byte, []int)deprecated
- func (x *KVS) GetData() []byte
- func (x *KVS) GetDone() bool
- func (x *KVS) GetPredicates() []string
- func (x *KVS) GetTypes() []string
- func (*KVS) ProtoMessage()
- func (x *KVS) ProtoReflect() protoreflect.Message
- func (x *KVS) Reset()
- func (x *KVS) String() string
- type LangList
- type List
- type MapHeader
- type Member
- func (*Member) Descriptor() ([]byte, []int)deprecated
- func (x *Member) GetAddr() string
- func (x *Member) GetAmDead() bool
- func (x *Member) GetClusterInfoOnly() bool
- func (x *Member) GetForceGroupId() bool
- func (x *Member) GetGroupId() uint32
- func (x *Member) GetId() uint64
- func (x *Member) GetLastUpdate() uint64
- func (x *Member) GetLeader() bool
- func (x *Member) GetLearner() bool
- func (*Member) ProtoMessage()
- func (x *Member) ProtoReflect() protoreflect.Message
- func (x *Member) Reset()
- func (x *Member) String() string
- type MembershipState
- func (*MembershipState) Descriptor() ([]byte, []int)deprecated
- func (x *MembershipState) GetCid() string
- func (x *MembershipState) GetCounter() uint64
- func (x *MembershipState) GetGroups() map[uint32]*Group
- func (x *MembershipState) GetMaxNsID() uint64
- func (x *MembershipState) GetMaxRaftId() uint64
- func (x *MembershipState) GetMaxTxnTs() uint64
- func (x *MembershipState) GetMaxUID() uint64
- func (x *MembershipState) GetRemoved() []*Member
- func (x *MembershipState) GetZeros() map[uint64]*Member
- func (*MembershipState) ProtoMessage()
- func (x *MembershipState) ProtoReflect() protoreflect.Message
- func (x *MembershipState) Reset()
- func (x *MembershipState) String() string
- type Metadata
- type Metadata_HintType
- func (Metadata_HintType) Descriptor() protoreflect.EnumDescriptor
- func (x Metadata_HintType) Enum() *Metadata_HintType
- func (Metadata_HintType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Metadata_HintType) Number() protoreflect.EnumNumber
- func (x Metadata_HintType) String() string
- func (Metadata_HintType) Type() protoreflect.EnumType
- type MovePredicatePayload
- func (*MovePredicatePayload) Descriptor() ([]byte, []int)deprecated
- func (x *MovePredicatePayload) GetDestGid() uint32
- func (x *MovePredicatePayload) GetExpectedChecksum() uint64
- func (x *MovePredicatePayload) GetPredicate() string
- func (x *MovePredicatePayload) GetSourceGid() uint32
- func (x *MovePredicatePayload) GetTxnTs() uint64
- func (*MovePredicatePayload) ProtoMessage()
- func (x *MovePredicatePayload) ProtoReflect() protoreflect.Message
- func (x *MovePredicatePayload) Reset()
- func (x *MovePredicatePayload) String() string
- type MoveTabletRequest
- func (*MoveTabletRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MoveTabletRequest) GetDstGroup() uint32
- func (x *MoveTabletRequest) GetNamespace() uint64
- func (x *MoveTabletRequest) GetTablet() string
- func (*MoveTabletRequest) ProtoMessage()
- func (x *MoveTabletRequest) ProtoReflect() protoreflect.Message
- func (x *MoveTabletRequest) Reset()
- func (x *MoveTabletRequest) String() string
- type Mutations
- func (*Mutations) Descriptor() ([]byte, []int)deprecated
- func (x *Mutations) GetDropOp() Mutations_DropOp
- func (x *Mutations) GetDropValue() string
- func (x *Mutations) GetEdges() []*DirectedEdge
- func (x *Mutations) GetGroupId() uint32
- func (x *Mutations) GetMetadata() *Metadata
- func (x *Mutations) GetSchema() []*SchemaUpdate
- func (x *Mutations) GetStartTs() uint64
- func (x *Mutations) GetTypes() []*TypeUpdate
- func (*Mutations) ProtoMessage()
- func (x *Mutations) ProtoReflect() protoreflect.Message
- func (x *Mutations) Reset()
- func (x *Mutations) String() string
- type Mutations_DropOp
- func (Mutations_DropOp) Descriptor() protoreflect.EnumDescriptor
- func (x Mutations_DropOp) Enum() *Mutations_DropOp
- func (Mutations_DropOp) EnumDescriptor() ([]byte, []int)deprecated
- func (x Mutations_DropOp) Number() protoreflect.EnumNumber
- func (x Mutations_DropOp) String() string
- func (Mutations_DropOp) Type() protoreflect.EnumType
- type Num
- func (*Num) Descriptor() ([]byte, []int)deprecated
- func (x *Num) GetBump() bool
- func (x *Num) GetForwarded() bool
- func (x *Num) GetReadOnly() bool
- func (x *Num) GetType() NumLeaseType
- func (x *Num) GetVal() uint64
- func (*Num) ProtoMessage()
- func (x *Num) ProtoReflect() protoreflect.Message
- func (x *Num) Reset()
- func (x *Num) String() string
- type NumLeaseType
- func (NumLeaseType) Descriptor() protoreflect.EnumDescriptor
- func (x NumLeaseType) Enum() *NumLeaseType
- func (NumLeaseType) EnumDescriptor() ([]byte, []int)deprecated
- func (x NumLeaseType) Number() protoreflect.EnumNumber
- func (x NumLeaseType) String() string
- func (NumLeaseType) Type() protoreflect.EnumType
- type OptionPair
- type OracleDelta
- func (*OracleDelta) Descriptor() ([]byte, []int)deprecated
- func (x *OracleDelta) GetGroupChecksums() map[uint32]uint64
- func (x *OracleDelta) GetMaxAssigned() uint64
- func (x *OracleDelta) GetTxns() []*TxnStatus
- func (*OracleDelta) ProtoMessage()
- func (x *OracleDelta) ProtoReflect() protoreflect.Message
- func (x *OracleDelta) Reset()
- func (x *OracleDelta) String() string
- type Order
- type PeerResponse
- type Posting
- func (*Posting) Descriptor() ([]byte, []int)deprecated
- func (x *Posting) GetCommitTs() uint64
- func (x *Posting) GetFacets() []*api.Facet
- func (x *Posting) GetLangTag() []byte
- func (x *Posting) GetOp() uint32
- func (x *Posting) GetPostingType() Posting_PostingType
- func (x *Posting) GetStartTs() uint64
- func (x *Posting) GetUid() uint64
- func (x *Posting) GetValType() Posting_ValType
- func (x *Posting) GetValue() []byte
- func (*Posting) ProtoMessage()
- func (x *Posting) ProtoReflect() protoreflect.Message
- func (x *Posting) Reset()
- func (x *Posting) String() string
- type PostingList
- func (*PostingList) Descriptor() ([]byte, []int)deprecated
- func (x *PostingList) GetCommitTs() uint64
- func (x *PostingList) GetPack() *UidPack
- func (x *PostingList) GetPostings() []*Posting
- func (x *PostingList) GetSplits() []uint64
- func (*PostingList) ProtoMessage()
- func (x *PostingList) ProtoReflect() protoreflect.Message
- func (x *PostingList) Reset()
- func (x *PostingList) String() string
- type Posting_PostingType
- func (Posting_PostingType) Descriptor() protoreflect.EnumDescriptor
- func (x Posting_PostingType) Enum() *Posting_PostingType
- func (Posting_PostingType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Posting_PostingType) Number() protoreflect.EnumNumber
- func (x Posting_PostingType) String() string
- func (Posting_PostingType) Type() protoreflect.EnumType
- type Posting_ValType
- func (Posting_ValType) Descriptor() protoreflect.EnumDescriptor
- func (x Posting_ValType) Enum() *Posting_ValType
- func (Posting_ValType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Posting_ValType) Number() protoreflect.EnumNumber
- func (x Posting_ValType) String() string
- func (Posting_ValType) Type() protoreflect.EnumType
- type Proposal
- func (*Proposal) Descriptor() ([]byte, []int)deprecated
- func (x *Proposal) GetCdcState() *CDCState
- func (x *Proposal) GetCleanPredicate() string
- func (x *Proposal) GetDeleteNs() *DeleteNsRequest
- func (x *Proposal) GetDelta() *OracleDelta
- func (x *Proposal) GetDrainmode() *DrainModeRequest
- func (x *Proposal) GetExpectedChecksum() uint64
- func (x *Proposal) GetIndex() uint64
- func (x *Proposal) GetKv() []*pb.KV
- func (x *Proposal) GetMutations() *Mutations
- func (x *Proposal) GetRestore() *RestoreRequest
- func (x *Proposal) GetSnapshot() *Snapshot
- func (x *Proposal) GetStartTs() uint64
- func (x *Proposal) GetState() *MembershipState
- func (*Proposal) ProtoMessage()
- func (x *Proposal) ProtoReflect() protoreflect.Message
- func (x *Proposal) Reset()
- func (x *Proposal) String() string
- type Query
- func (*Query) Descriptor() ([]byte, []int)deprecated
- func (x *Query) GetAfterUid() uint64
- func (x *Query) GetAttr() string
- func (x *Query) GetCache() int32
- func (x *Query) GetDoCount() bool
- func (x *Query) GetExpandAll() bool
- func (x *Query) GetFacetParam() *FacetParams
- func (x *Query) GetFacetsFilter() *FilterTree
- func (x *Query) GetFirst() int32
- func (x *Query) GetLangs() []string
- func (x *Query) GetOffset() int32
- func (x *Query) GetReadTs() uint64
- func (x *Query) GetReverse() bool
- func (x *Query) GetSrcFunc() *SrcFunction
- func (x *Query) GetUidList() *List
- func (*Query) ProtoMessage()
- func (x *Query) ProtoReflect() protoreflect.Message
- func (x *Query) Reset()
- func (x *Query) String() string
- type RaftBatch
- func (*RaftBatch) Descriptor() ([]byte, []int)deprecated
- func (x *RaftBatch) GetContext() *RaftContext
- func (x *RaftBatch) GetPayload() *api.Payload
- func (*RaftBatch) ProtoMessage()
- func (x *RaftBatch) ProtoReflect() protoreflect.Message
- func (x *RaftBatch) Reset()
- func (x *RaftBatch) String() string
- type RaftClient
- type RaftContext
- func (*RaftContext) Descriptor() ([]byte, []int)deprecated
- func (x *RaftContext) GetAddr() string
- func (x *RaftContext) GetGroup() uint32
- func (x *RaftContext) GetId() uint64
- func (x *RaftContext) GetIsLearner() bool
- func (x *RaftContext) GetSnapshotTs() uint64
- func (*RaftContext) ProtoMessage()
- func (x *RaftContext) ProtoReflect() protoreflect.Message
- func (x *RaftContext) Reset()
- func (x *RaftContext) String() string
- type RaftServer
- type Raft_HeartbeatClient
- type Raft_HeartbeatServer
- type Raft_RaftMessageClient
- type Raft_RaftMessageServer
- type RemoveNodeRequest
- func (*RemoveNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveNodeRequest) GetGroupId() uint32
- func (x *RemoveNodeRequest) GetNodeId() uint64
- func (*RemoveNodeRequest) ProtoMessage()
- func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveNodeRequest) Reset()
- func (x *RemoveNodeRequest) String() string
- type RestoreRequest
- func (*RestoreRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreRequest) GetAccessKey() string
- func (x *RestoreRequest) GetAnonymous() bool
- func (x *RestoreRequest) GetBackupId() string
- func (x *RestoreRequest) GetBackupNum() uint64
- func (x *RestoreRequest) GetEncryptionKeyFile() string
- func (x *RestoreRequest) GetFromNamespace() uint64
- func (x *RestoreRequest) GetGroupId() uint32
- func (x *RestoreRequest) GetIncrementalFrom() uint64
- func (x *RestoreRequest) GetIsNamespaceAwareRestore() bool
- func (x *RestoreRequest) GetIsPartial() bool
- func (x *RestoreRequest) GetLocation() string
- func (x *RestoreRequest) GetRestoreTs() uint64
- func (x *RestoreRequest) GetSecretKey() Sensitive
- func (x *RestoreRequest) GetSessionToken() Sensitive
- func (x *RestoreRequest) GetVaultAddr() string
- func (x *RestoreRequest) GetVaultField() string
- func (x *RestoreRequest) GetVaultFormat() string
- func (x *RestoreRequest) GetVaultPath() string
- func (x *RestoreRequest) GetVaultRoleidFile() string
- func (x *RestoreRequest) GetVaultSecretidFile() string
- func (*RestoreRequest) ProtoMessage()
- func (x *RestoreRequest) ProtoReflect() protoreflect.Message
- func (x *RestoreRequest) Reset()
- func (x *RestoreRequest) String() string
- type Result
- func (*Result) Descriptor() ([]byte, []int)deprecated
- func (x *Result) GetCounts() []uint32
- func (x *Result) GetFacetMatrix() []*FacetsList
- func (x *Result) GetIntersectDest() bool
- func (x *Result) GetLangMatrix() []*LangList
- func (x *Result) GetList() bool
- func (x *Result) GetUidMatrix() []*List
- func (x *Result) GetValueMatrix() []*ValueList
- func (x *Result) GetVectorMetrics() map[string]uint64
- func (*Result) ProtoMessage()
- func (x *Result) ProtoReflect() protoreflect.Message
- func (x *Result) Reset()
- func (x *Result) String() string
- type SchemaNode
- func (*SchemaNode) Descriptor() ([]byte, []int)deprecated
- func (x *SchemaNode) GetCount() bool
- func (x *SchemaNode) GetIndex() bool
- func (x *SchemaNode) GetIndexSpecs() []*VectorIndexSpec
- func (x *SchemaNode) GetLang() bool
- func (x *SchemaNode) GetList() bool
- func (x *SchemaNode) GetNoConflict() bool
- func (x *SchemaNode) GetPredicate() string
- func (x *SchemaNode) GetReverse() bool
- func (x *SchemaNode) GetTokenizer() []string
- func (x *SchemaNode) GetType() string
- func (x *SchemaNode) GetUnique() bool
- func (x *SchemaNode) GetUpsert() bool
- func (*SchemaNode) ProtoMessage()
- func (x *SchemaNode) ProtoReflect() protoreflect.Message
- func (x *SchemaNode) Reset()
- func (x *SchemaNode) String() string
- type SchemaRequest
- func (*SchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SchemaRequest) GetFields() []string
- func (x *SchemaRequest) GetGroupId() uint32
- func (x *SchemaRequest) GetPredicates() []string
- func (x *SchemaRequest) GetTypes() []string
- func (*SchemaRequest) ProtoMessage()
- func (x *SchemaRequest) ProtoReflect() protoreflect.Message
- func (x *SchemaRequest) Reset()
- func (x *SchemaRequest) String() string
- type SchemaResult
- type SchemaUpdate
- func (*SchemaUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *SchemaUpdate) GetCount() bool
- func (x *SchemaUpdate) GetDirective() SchemaUpdate_Directive
- func (x *SchemaUpdate) GetIndexSpecs() []*VectorIndexSpec
- func (x *SchemaUpdate) GetLang() bool
- func (x *SchemaUpdate) GetList() bool
- func (x *SchemaUpdate) GetNoConflict() bool
- func (x *SchemaUpdate) GetNonNullable() bool
- func (x *SchemaUpdate) GetNonNullableList() bool
- func (x *SchemaUpdate) GetObjectTypeName() string
- func (x *SchemaUpdate) GetPredicate() string
- func (x *SchemaUpdate) GetTokenizer() []string
- func (x *SchemaUpdate) GetUnique() bool
- func (x *SchemaUpdate) GetUpsert() bool
- func (x *SchemaUpdate) GetValueType() Posting_ValType
- func (*SchemaUpdate) ProtoMessage()
- func (x *SchemaUpdate) ProtoReflect() protoreflect.Message
- func (x *SchemaUpdate) Reset()
- func (x *SchemaUpdate) String() string
- type SchemaUpdate_Directive
- func (SchemaUpdate_Directive) Descriptor() protoreflect.EnumDescriptor
- func (x SchemaUpdate_Directive) Enum() *SchemaUpdate_Directive
- func (SchemaUpdate_Directive) EnumDescriptor() ([]byte, []int)deprecated
- func (x SchemaUpdate_Directive) Number() protoreflect.EnumNumber
- func (x SchemaUpdate_Directive) String() string
- func (SchemaUpdate_Directive) Type() protoreflect.EnumType
- type Sensitive
- type Snapshot
- func (*Snapshot) Descriptor() ([]byte, []int)deprecated
- func (x *Snapshot) GetContext() *RaftContext
- func (x *Snapshot) GetDone() bool
- func (x *Snapshot) GetIndex() uint64
- func (x *Snapshot) GetReadTs() uint64
- func (x *Snapshot) GetSinceTs() uint64
- func (*Snapshot) ProtoMessage()
- func (x *Snapshot) ProtoReflect() protoreflect.Message
- func (x *Snapshot) Reset()
- func (x *Snapshot) String() string
- type SnapshotMeta
- func (*SnapshotMeta) Descriptor() ([]byte, []int)deprecated
- func (x *SnapshotMeta) GetClientTs() uint64
- func (x *SnapshotMeta) GetGroupId() uint32
- func (*SnapshotMeta) ProtoMessage()
- func (x *SnapshotMeta) ProtoReflect() protoreflect.Message
- func (x *SnapshotMeta) Reset()
- func (x *SnapshotMeta) String() string
- type SortMessage
- func (*SortMessage) Descriptor() ([]byte, []int)deprecated
- func (x *SortMessage) GetCount() int32
- func (x *SortMessage) GetOffset() int32
- func (x *SortMessage) GetOrder() []*Order
- func (x *SortMessage) GetReadTs() uint64
- func (x *SortMessage) GetUidMatrix() []*List
- func (*SortMessage) ProtoMessage()
- func (x *SortMessage) ProtoReflect() protoreflect.Message
- func (x *SortMessage) Reset()
- func (x *SortMessage) String() string
- type SortResult
- type SrcFunction
- func (*SrcFunction) Descriptor() ([]byte, []int)deprecated
- func (x *SrcFunction) GetArgs() []string
- func (x *SrcFunction) GetIsCount() bool
- func (x *SrcFunction) GetName() string
- func (*SrcFunction) ProtoMessage()
- func (x *SrcFunction) ProtoReflect() protoreflect.Message
- func (x *SrcFunction) Reset()
- func (x *SrcFunction) String() string
- type Status
- type SubscriptionRequest
- func (*SubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionRequest) GetMatches() []*pb.Match
- func (x *SubscriptionRequest) GetPrefixes() [][]byte
- func (*SubscriptionRequest) ProtoMessage()
- func (x *SubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *SubscriptionRequest) Reset()
- func (x *SubscriptionRequest) String() string
- type SubscriptionResponse
- func (*SubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionResponse) GetKvs() *pb.KVList
- func (*SubscriptionResponse) ProtoMessage()
- func (x *SubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *SubscriptionResponse) Reset()
- func (x *SubscriptionResponse) String() string
- type Tablet
- func (*Tablet) Descriptor() ([]byte, []int)deprecated
- func (x *Tablet) GetForce() bool
- func (x *Tablet) GetGroupId() uint32
- func (x *Tablet) GetMoveTs() uint64
- func (x *Tablet) GetOnDiskBytes() int64
- func (x *Tablet) GetPredicate() string
- func (x *Tablet) GetReadOnly() bool
- func (x *Tablet) GetRemove() bool
- func (x *Tablet) GetUncompressedBytes() int64
- func (*Tablet) ProtoMessage()
- func (x *Tablet) ProtoReflect() protoreflect.Message
- func (x *Tablet) Reset()
- func (x *Tablet) String() string
- type TabletRequest
- func (*TabletRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TabletRequest) GetGroupId() uint32
- func (x *TabletRequest) GetTablets() []*Tablet
- func (*TabletRequest) ProtoMessage()
- func (x *TabletRequest) ProtoReflect() protoreflect.Message
- func (x *TabletRequest) Reset()
- func (x *TabletRequest) String() string
- type TabletResponse
- type TaskStatusRequest
- type TaskStatusResponse
- func (*TaskStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TaskStatusResponse) GetTaskMeta() uint64
- func (*TaskStatusResponse) ProtoMessage()
- func (x *TaskStatusResponse) ProtoReflect() protoreflect.Message
- func (x *TaskStatusResponse) Reset()
- func (x *TaskStatusResponse) String() string
- type TaskValue
- type TxnStatus
- type TxnTimestamps
- type TypeUpdate
- func (*TypeUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *TypeUpdate) GetFields() []*SchemaUpdate
- func (x *TypeUpdate) GetTypeName() string
- func (*TypeUpdate) ProtoMessage()
- func (x *TypeUpdate) ProtoReflect() protoreflect.Message
- func (x *TypeUpdate) Reset()
- func (x *TypeUpdate) String() string
- type UidBlock
- func (*UidBlock) Descriptor() ([]byte, []int)deprecated
- func (x *UidBlock) GetBase() uint64
- func (x *UidBlock) GetDeltas() []byte
- func (x *UidBlock) GetNumUids() uint32
- func (*UidBlock) ProtoMessage()
- func (x *UidBlock) ProtoReflect() protoreflect.Message
- func (x *UidBlock) Reset()
- func (x *UidBlock) String() string
- type UidPack
- func (*UidPack) Descriptor() ([]byte, []int)deprecated
- func (x *UidPack) GetAllocRef() uint64
- func (x *UidPack) GetBlockSize() uint32
- func (x *UidPack) GetBlocks() []*UidBlock
- func (*UidPack) ProtoMessage()
- func (x *UidPack) ProtoReflect() protoreflect.Message
- func (x *UidPack) Reset()
- func (x *UidPack) String() string
- type UnimplementedRaftServer
- func (UnimplementedRaftServer) Heartbeat(*api.Payload, Raft_HeartbeatServer) error
- func (UnimplementedRaftServer) IsPeer(context.Context, *RaftContext) (*PeerResponse, error)
- func (UnimplementedRaftServer) JoinCluster(context.Context, *RaftContext) (*api.Payload, error)
- func (UnimplementedRaftServer) RaftMessage(Raft_RaftMessageServer) error
- type UnimplementedWorkerServer
- func (UnimplementedWorkerServer) ApplyDrainmode(context.Context, *DrainModeRequest) (*Status, error)
- func (UnimplementedWorkerServer) Backup(context.Context, *BackupRequest) (*BackupResponse, error)
- func (UnimplementedWorkerServer) DeleteNamespace(context.Context, *DeleteNsRequest) (*Status, error)
- func (UnimplementedWorkerServer) Export(context.Context, *ExportRequest) (*ExportResponse, error)
- func (UnimplementedWorkerServer) InternalStreamPDir(Worker_InternalStreamPDirServer) error
- func (UnimplementedWorkerServer) MovePredicate(context.Context, *MovePredicatePayload) (*api.Payload, error)
- func (UnimplementedWorkerServer) Mutate(context.Context, *Mutations) (*api.TxnContext, error)
- func (UnimplementedWorkerServer) ReceivePredicate(Worker_ReceivePredicateServer) error
- func (UnimplementedWorkerServer) Restore(context.Context, *RestoreRequest) (*Status, error)
- func (UnimplementedWorkerServer) Schema(context.Context, *SchemaRequest) (*SchemaResult, error)
- func (UnimplementedWorkerServer) ServeTask(context.Context, *Query) (*Result, error)
- func (UnimplementedWorkerServer) Sort(context.Context, *SortMessage) (*SortResult, error)
- func (UnimplementedWorkerServer) StreamSnapshot(Worker_StreamSnapshotServer) error
- func (UnimplementedWorkerServer) Subscribe(*SubscriptionRequest, Worker_SubscribeServer) error
- func (UnimplementedWorkerServer) TaskStatus(context.Context, *TaskStatusRequest) (*TaskStatusResponse, error)
- func (UnimplementedWorkerServer) UpdateGraphQLSchema(context.Context, *UpdateGraphQLSchemaRequest) (*UpdateGraphQLSchemaResponse, error)
- type UnimplementedZeroServer
- func (UnimplementedZeroServer) AssignIds(context.Context, *Num) (*AssignedIds, error)
- func (UnimplementedZeroServer) CommitOrAbort(context.Context, *api.TxnContext) (*api.TxnContext, error)
- func (UnimplementedZeroServer) Connect(context.Context, *Member) (*ConnectionState, error)
- func (UnimplementedZeroServer) DeleteNamespace(context.Context, *DeleteNsRequest) (*Status, error)
- func (UnimplementedZeroServer) Inform(context.Context, *TabletRequest) (*TabletResponse, error)
- func (UnimplementedZeroServer) MoveTablet(context.Context, *MoveTabletRequest) (*Status, error)
- func (UnimplementedZeroServer) Oracle(*api.Payload, Zero_OracleServer) error
- func (UnimplementedZeroServer) RemoveNode(context.Context, *RemoveNodeRequest) (*Status, error)
- func (UnimplementedZeroServer) ShouldServe(context.Context, *Tablet) (*Tablet, error)
- func (UnimplementedZeroServer) StreamMembership(*api.Payload, Zero_StreamMembershipServer) error
- func (UnimplementedZeroServer) Timestamps(context.Context, *Num) (*AssignedIds, error)
- func (UnimplementedZeroServer) TryAbort(context.Context, *TxnTimestamps) (*OracleDelta, error)
- func (UnimplementedZeroServer) UpdateMembership(context.Context, *Group) (*api.Payload, error)
- type UnsafeRaftServer
- type UnsafeWorkerServer
- type UnsafeZeroServer
- type UpdateGraphQLSchemaRequest
- func (*UpdateGraphQLSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateGraphQLSchemaRequest) GetDgraphPreds() []*SchemaUpdate
- func (x *UpdateGraphQLSchemaRequest) GetDgraphTypes() []*TypeUpdate
- func (x *UpdateGraphQLSchemaRequest) GetGraphqlSchema() string
- func (x *UpdateGraphQLSchemaRequest) GetStartTs() uint64
- func (*UpdateGraphQLSchemaRequest) ProtoMessage()
- func (x *UpdateGraphQLSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateGraphQLSchemaRequest) Reset()
- func (x *UpdateGraphQLSchemaRequest) String() string
- type UpdateGraphQLSchemaResponse
- func (*UpdateGraphQLSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateGraphQLSchemaResponse) GetUid() uint64
- func (*UpdateGraphQLSchemaResponse) ProtoMessage()
- func (x *UpdateGraphQLSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateGraphQLSchemaResponse) Reset()
- func (x *UpdateGraphQLSchemaResponse) String() string
- type ValueList
- type VectorIndexSpec
- func (*VectorIndexSpec) Descriptor() ([]byte, []int)deprecated
- func (x *VectorIndexSpec) GetName() string
- func (x *VectorIndexSpec) GetOptions() []*OptionPair
- func (*VectorIndexSpec) ProtoMessage()
- func (x *VectorIndexSpec) ProtoReflect() protoreflect.Message
- func (x *VectorIndexSpec) Reset()
- func (x *VectorIndexSpec) String() string
- type WorkerClient
- type WorkerServer
- type Worker_InternalStreamPDirClient
- type Worker_InternalStreamPDirServer
- type Worker_ReceivePredicateClient
- type Worker_ReceivePredicateServer
- type Worker_StreamSnapshotClient
- type Worker_StreamSnapshotServer
- type Worker_SubscribeClient
- type Worker_SubscribeServer
- type ZeroClient
- type ZeroProposal
- func (*ZeroProposal) Descriptor() ([]byte, []int)deprecated
- func (x *ZeroProposal) GetCid() string
- func (x *ZeroProposal) GetDeleteNs() *DeleteNsRequest
- func (x *ZeroProposal) GetMaxNsID() uint64
- func (x *ZeroProposal) GetMaxRaftId() uint64
- func (x *ZeroProposal) GetMaxTxnTs() uint64
- func (x *ZeroProposal) GetMaxUID() uint64
- func (x *ZeroProposal) GetMember() *Member
- func (x *ZeroProposal) GetSnapshot() *ZeroSnapshot
- func (x *ZeroProposal) GetSnapshotTs() map[uint32]uint64
- func (x *ZeroProposal) GetTablet() *Tablet
- func (x *ZeroProposal) GetTablets() []*Tablet
- func (x *ZeroProposal) GetTxn() *api.TxnContext
- func (*ZeroProposal) ProtoMessage()
- func (x *ZeroProposal) ProtoReflect() protoreflect.Message
- func (x *ZeroProposal) Reset()
- func (x *ZeroProposal) String() string
- type ZeroServer
- type ZeroSnapshot
- func (*ZeroSnapshot) Descriptor() ([]byte, []int)deprecated
- func (x *ZeroSnapshot) GetCheckpointTs() uint64
- func (x *ZeroSnapshot) GetIndex() uint64
- func (x *ZeroSnapshot) GetState() *MembershipState
- func (*ZeroSnapshot) ProtoMessage()
- func (x *ZeroSnapshot) ProtoReflect() protoreflect.Message
- func (x *ZeroSnapshot) Reset()
- func (x *ZeroSnapshot) String() string
- type Zero_OracleClient
- type Zero_OracleServer
- type Zero_StreamMembershipClient
- type Zero_StreamMembershipServer
Constants ¶
const ( Raft_Heartbeat_FullMethodName = "/pb.Raft/Heartbeat" Raft_RaftMessage_FullMethodName = "/pb.Raft/RaftMessage" Raft_JoinCluster_FullMethodName = "/pb.Raft/JoinCluster" Raft_IsPeer_FullMethodName = "/pb.Raft/IsPeer" )
const ( Zero_Connect_FullMethodName = "/pb.Zero/Connect" Zero_UpdateMembership_FullMethodName = "/pb.Zero/UpdateMembership" Zero_StreamMembership_FullMethodName = "/pb.Zero/StreamMembership" Zero_Oracle_FullMethodName = "/pb.Zero/Oracle" Zero_ShouldServe_FullMethodName = "/pb.Zero/ShouldServe" Zero_Inform_FullMethodName = "/pb.Zero/Inform" Zero_AssignIds_FullMethodName = "/pb.Zero/AssignIds" Zero_Timestamps_FullMethodName = "/pb.Zero/Timestamps" Zero_CommitOrAbort_FullMethodName = "/pb.Zero/CommitOrAbort" Zero_TryAbort_FullMethodName = "/pb.Zero/TryAbort" Zero_DeleteNamespace_FullMethodName = "/pb.Zero/DeleteNamespace" Zero_RemoveNode_FullMethodName = "/pb.Zero/RemoveNode" Zero_MoveTablet_FullMethodName = "/pb.Zero/MoveTablet" )
const ( Worker_Mutate_FullMethodName = "/pb.Worker/Mutate" Worker_ServeTask_FullMethodName = "/pb.Worker/ServeTask" Worker_StreamSnapshot_FullMethodName = "/pb.Worker/StreamSnapshot" Worker_Sort_FullMethodName = "/pb.Worker/Sort" Worker_Schema_FullMethodName = "/pb.Worker/Schema" Worker_Backup_FullMethodName = "/pb.Worker/Backup" Worker_Restore_FullMethodName = "/pb.Worker/Restore" Worker_Export_FullMethodName = "/pb.Worker/Export" Worker_ReceivePredicate_FullMethodName = "/pb.Worker/ReceivePredicate" Worker_MovePredicate_FullMethodName = "/pb.Worker/MovePredicate" Worker_Subscribe_FullMethodName = "/pb.Worker/Subscribe" Worker_UpdateGraphQLSchema_FullMethodName = "/pb.Worker/UpdateGraphQLSchema" Worker_DeleteNamespace_FullMethodName = "/pb.Worker/DeleteNamespace" Worker_TaskStatus_FullMethodName = "/pb.Worker/TaskStatus" Worker_ApplyDrainmode_FullMethodName = "/pb.Worker/ApplyDrainmode" Worker_InternalStreamPDir_FullMethodName = "/pb.Worker/InternalStreamPDir" )
Variables ¶
var ( DirectedEdge_Op_name = map[int32]string{ 0: "SET", 1: "DEL", 2: "OVR", } DirectedEdge_Op_value = map[string]int32{ "SET": 0, "DEL": 1, "OVR": 2, } )
Enum value maps for DirectedEdge_Op.
var ( Mutations_DropOp_name = map[int32]string{ 0: "NONE", 1: "ALL", 2: "DATA", 3: "TYPE", 4: "ALL_IN_NS", } Mutations_DropOp_value = map[string]int32{ "NONE": 0, "ALL": 1, "DATA": 2, "TYPE": 3, "ALL_IN_NS": 4, } )
Enum value maps for Mutations_DropOp.
var ( Metadata_HintType_name = map[int32]string{ 0: "DEFAULT", 1: "SINGLE", 2: "LIST", } Metadata_HintType_value = map[string]int32{ "DEFAULT": 0, "SINGLE": 1, "LIST": 2, } )
Enum value maps for Metadata_HintType.
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", 10: "OBJECT", 11: "BIGFLOAT", 12: "VFLOAT", } 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, "OBJECT": 10, "BIGFLOAT": 11, "VFLOAT": 12, } )
Enum value maps for Posting_ValType.
var ( Posting_PostingType_name = map[int32]string{ 0: "REF", 1: "VALUE", 2: "VALUE_LANG", } Posting_PostingType_value = map[string]int32{ "REF": 0, "VALUE": 1, "VALUE_LANG": 2, } )
Enum value maps for Posting_PostingType.
var ( SchemaUpdate_Directive_name = map[int32]string{ 0: "NONE", 1: "INDEX", 2: "REVERSE", 3: "DELETE", } SchemaUpdate_Directive_value = map[string]int32{ "NONE": 0, "INDEX": 1, "REVERSE": 2, "DELETE": 3, } )
Enum value maps for SchemaUpdate_Directive.
var ( NumLeaseType_name = map[int32]string{ 0: "NS_ID", 1: "UID", 2: "TXN_TS", } NumLeaseType_value = map[string]int32{ "NS_ID": 0, "UID": 1, "TXN_TS": 2, } )
Enum value maps for NumLeaseType.
var ( DropOperation_DropOp_name = map[int32]string{ 0: "ALL", 1: "DATA", 2: "ATTR", 3: "NS", } DropOperation_DropOp_value = map[string]int32{ "ALL": 0, "DATA": 1, "ATTR": 2, "NS": 3, } )
Enum value maps for DropOperation_DropOp.
var ( BackupKey_KeyType_name = map[int32]string{ 0: "UNKNOWN", 1: "DATA", 2: "INDEX", 3: "REVERSE", 4: "COUNT", 5: "COUNT_REV", 6: "SCHEMA", 7: "TYPE", } BackupKey_KeyType_value = map[string]int32{ "UNKNOWN": 0, "DATA": 1, "INDEX": 2, "REVERSE": 3, "COUNT": 4, "COUNT_REV": 5, "SCHEMA": 6, "TYPE": 7, } )
Enum value maps for BackupKey_KeyType.
var File_pb_proto protoreflect.FileDescriptor
var Raft_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.Raft", HandlerType: (*RaftServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "JoinCluster", Handler: _Raft_JoinCluster_Handler, }, { MethodName: "IsPeer", Handler: _Raft_IsPeer_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Heartbeat", Handler: _Raft_Heartbeat_Handler, ServerStreams: true, }, { StreamName: "RaftMessage", Handler: _Raft_RaftMessage_Handler, ClientStreams: true, }, }, Metadata: "pb.proto", }
Raft_ServiceDesc is the grpc.ServiceDesc for Raft service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Worker_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.Worker", HandlerType: (*WorkerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Mutate", Handler: _Worker_Mutate_Handler, }, { MethodName: "ServeTask", Handler: _Worker_ServeTask_Handler, }, { MethodName: "Sort", Handler: _Worker_Sort_Handler, }, { MethodName: "Schema", Handler: _Worker_Schema_Handler, }, { MethodName: "Backup", Handler: _Worker_Backup_Handler, }, { MethodName: "Restore", Handler: _Worker_Restore_Handler, }, { MethodName: "Export", Handler: _Worker_Export_Handler, }, { MethodName: "MovePredicate", Handler: _Worker_MovePredicate_Handler, }, { MethodName: "UpdateGraphQLSchema", Handler: _Worker_UpdateGraphQLSchema_Handler, }, { MethodName: "DeleteNamespace", Handler: _Worker_DeleteNamespace_Handler, }, { MethodName: "TaskStatus", Handler: _Worker_TaskStatus_Handler, }, { MethodName: "ApplyDrainmode", Handler: _Worker_ApplyDrainmode_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamSnapshot", Handler: _Worker_StreamSnapshot_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "ReceivePredicate", Handler: _Worker_ReceivePredicate_Handler, ClientStreams: true, }, { StreamName: "Subscribe", Handler: _Worker_Subscribe_Handler, ServerStreams: true, }, { StreamName: "InternalStreamPDir", Handler: _Worker_InternalStreamPDir_Handler, ClientStreams: true, }, }, Metadata: "pb.proto", }
Worker_ServiceDesc is the grpc.ServiceDesc for Worker service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Zero_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.Zero", HandlerType: (*ZeroServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Connect", Handler: _Zero_Connect_Handler, }, { MethodName: "UpdateMembership", Handler: _Zero_UpdateMembership_Handler, }, { MethodName: "ShouldServe", Handler: _Zero_ShouldServe_Handler, }, { MethodName: "Inform", Handler: _Zero_Inform_Handler, }, { MethodName: "AssignIds", Handler: _Zero_AssignIds_Handler, }, { MethodName: "Timestamps", Handler: _Zero_Timestamps_Handler, }, { MethodName: "CommitOrAbort", Handler: _Zero_CommitOrAbort_Handler, }, { MethodName: "TryAbort", Handler: _Zero_TryAbort_Handler, }, { MethodName: "DeleteNamespace", Handler: _Zero_DeleteNamespace_Handler, }, { MethodName: "RemoveNode", Handler: _Zero_RemoveNode_Handler, }, { MethodName: "MoveTablet", Handler: _Zero_MoveTablet_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamMembership", Handler: _Zero_StreamMembership_Handler, ServerStreams: true, }, { StreamName: "Oracle", Handler: _Zero_Oracle_Handler, ServerStreams: true, }, }, Metadata: "pb.proto", }
Zero_ServiceDesc is the grpc.ServiceDesc for Zero service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRaftServer ¶
func RegisterRaftServer(s grpc.ServiceRegistrar, srv RaftServer)
func RegisterWorkerServer ¶
func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)
func RegisterZeroServer ¶
func RegisterZeroServer(s grpc.ServiceRegistrar, srv ZeroServer)
Types ¶
type AssignedIds ¶
type AssignedIds struct {
StartId uint64 `protobuf:"varint,1,opt,name=startId,proto3" json:"startId,omitempty"`
EndId uint64 `protobuf:"varint,2,opt,name=endId,proto3" json:"endId,omitempty"`
// The following is used for read only transactions.
ReadOnly uint64 `protobuf:"varint,5,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
// contains filtered or unexported fields
}
func (*AssignedIds) Descriptor
deprecated
func (*AssignedIds) Descriptor() ([]byte, []int)
Deprecated: Use AssignedIds.ProtoReflect.Descriptor instead.
func (*AssignedIds) GetEndId ¶
func (x *AssignedIds) GetEndId() uint64
func (*AssignedIds) GetReadOnly ¶
func (x *AssignedIds) GetReadOnly() uint64
func (*AssignedIds) GetStartId ¶
func (x *AssignedIds) GetStartId() uint64
func (*AssignedIds) ProtoMessage ¶
func (*AssignedIds) ProtoMessage()
func (*AssignedIds) ProtoReflect ¶
func (x *AssignedIds) ProtoReflect() protoreflect.Message
func (*AssignedIds) Reset ¶
func (x *AssignedIds) Reset()
func (*AssignedIds) String ¶
func (x *AssignedIds) String() string
type BackupKey ¶
type BackupKey struct {
Type BackupKey_KeyType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.BackupKey_KeyType" json:"type,omitempty"`
Attr string `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"`
Uid uint64 `protobuf:"varint,3,opt,name=uid,proto3" json:"uid,omitempty"`
StartUid uint64 `protobuf:"varint,4,opt,name=start_uid,json=startUid,proto3" json:"start_uid,omitempty"`
Term []byte `protobuf:"bytes,5,opt,name=term,proto3" json:"term,omitempty"`
Count uint32 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
Namespace uint64 `protobuf:"varint,7,opt,name=namespace,proto3" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
A key stored in the format used for writing backups.
func (*BackupKey) Descriptor
deprecated
func (*BackupKey) GetNamespace ¶
func (*BackupKey) GetStartUid ¶
func (*BackupKey) GetType ¶
func (x *BackupKey) GetType() BackupKey_KeyType
func (*BackupKey) ProtoMessage ¶
func (*BackupKey) ProtoMessage()
func (*BackupKey) ProtoReflect ¶
func (x *BackupKey) ProtoReflect() protoreflect.Message
type BackupKey_KeyType ¶
type BackupKey_KeyType int32
const ( BackupKey_UNKNOWN BackupKey_KeyType = 0 BackupKey_DATA BackupKey_KeyType = 1 BackupKey_INDEX BackupKey_KeyType = 2 BackupKey_REVERSE BackupKey_KeyType = 3 BackupKey_COUNT BackupKey_KeyType = 4 BackupKey_COUNT_REV BackupKey_KeyType = 5 BackupKey_SCHEMA BackupKey_KeyType = 6 BackupKey_TYPE BackupKey_KeyType = 7 )
func (BackupKey_KeyType) Descriptor ¶
func (BackupKey_KeyType) Descriptor() protoreflect.EnumDescriptor
func (BackupKey_KeyType) Enum ¶
func (x BackupKey_KeyType) Enum() *BackupKey_KeyType
func (BackupKey_KeyType) EnumDescriptor
deprecated
func (BackupKey_KeyType) EnumDescriptor() ([]byte, []int)
Deprecated: Use BackupKey_KeyType.Descriptor instead.
func (BackupKey_KeyType) Number ¶
func (x BackupKey_KeyType) Number() protoreflect.EnumNumber
func (BackupKey_KeyType) String ¶
func (x BackupKey_KeyType) String() string
func (BackupKey_KeyType) Type ¶
func (BackupKey_KeyType) Type() protoreflect.EnumType
type BackupPostingList ¶
type BackupPostingList struct {
Uids []uint64 `protobuf:"varint,1,rep,packed,name=uids,proto3" json:"uids,omitempty"`
Postings []*Posting `protobuf:"bytes,2,rep,name=postings,proto3" json:"postings,omitempty"`
CommitTs uint64 `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
Splits []uint64 `protobuf:"varint,4,rep,packed,name=splits,proto3" json:"splits,omitempty"`
UidBytes []byte `protobuf:"bytes,5,opt,name=uid_bytes,json=uidBytes,proto3" json:"uid_bytes,omitempty"`
// contains filtered or unexported fields
}
A posting list stored in the format used for writing backups.
func (*BackupPostingList) Descriptor
deprecated
func (*BackupPostingList) Descriptor() ([]byte, []int)
Deprecated: Use BackupPostingList.ProtoReflect.Descriptor instead.
func (*BackupPostingList) GetCommitTs ¶
func (x *BackupPostingList) GetCommitTs() uint64
func (*BackupPostingList) GetPostings ¶
func (x *BackupPostingList) GetPostings() []*Posting
func (*BackupPostingList) GetSplits ¶
func (x *BackupPostingList) GetSplits() []uint64
func (*BackupPostingList) GetUidBytes ¶
func (x *BackupPostingList) GetUidBytes() []byte
func (*BackupPostingList) GetUids ¶
func (x *BackupPostingList) GetUids() []uint64
func (*BackupPostingList) ProtoMessage ¶
func (*BackupPostingList) ProtoMessage()
func (*BackupPostingList) ProtoReflect ¶
func (x *BackupPostingList) ProtoReflect() protoreflect.Message
func (*BackupPostingList) Reset ¶
func (x *BackupPostingList) Reset()
func (*BackupPostingList) String ¶
func (x *BackupPostingList) String() string
type BackupRequest ¶
type BackupRequest struct {
ReadTs uint64 `protobuf:"varint,1,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
SinceTs uint64 `protobuf:"varint,2,opt,name=since_ts,json=sinceTs,proto3" json:"since_ts,omitempty"`
GroupId uint32 `protobuf:"varint,3,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
UnixTs string `protobuf:"bytes,4,opt,name=unix_ts,json=unixTs,proto3" json:"unix_ts,omitempty"`
Destination string `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"`
AccessKey string `protobuf:"bytes,6,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
SecretKey Sensitive `protobuf:"bytes,7,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
SessionToken Sensitive `protobuf:"bytes,8,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`
// True if no credentials should be used to access the S3 or minio bucket.
// For example, when using a bucket with a public policy.
Anonymous bool `protobuf:"varint,9,opt,name=anonymous,proto3" json:"anonymous,omitempty"`
// The predicates to backup. All other predicates present in the group (e.g
// stale data from a predicate move) will be ignored.
Predicates []string `protobuf:"bytes,10,rep,name=predicates,proto3" json:"predicates,omitempty"`
ForceFull bool `protobuf:"varint,11,opt,name=force_full,json=forceFull,proto3" json:"force_full,omitempty"`
// contains filtered or unexported fields
}
Backups record all data from since_ts to read_ts. With incremental backups, the read_ts of the first backup becomes the since_ts of the second backup. Incremental backups can be disabled using the force_full field.
func (*BackupRequest) Descriptor
deprecated
func (*BackupRequest) Descriptor() ([]byte, []int)
Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.
func (*BackupRequest) GetAccessKey ¶
func (x *BackupRequest) GetAccessKey() string
func (*BackupRequest) GetAnonymous ¶
func (x *BackupRequest) GetAnonymous() bool
func (*BackupRequest) GetDestination ¶
func (x *BackupRequest) GetDestination() string
func (*BackupRequest) GetForceFull ¶
func (x *BackupRequest) GetForceFull() bool
func (*BackupRequest) GetGroupId ¶
func (x *BackupRequest) GetGroupId() uint32
func (*BackupRequest) GetPredicates ¶
func (x *BackupRequest) GetPredicates() []string
func (*BackupRequest) GetReadTs ¶
func (x *BackupRequest) GetReadTs() uint64
func (*BackupRequest) GetSecretKey ¶
func (x *BackupRequest) GetSecretKey() Sensitive
func (*BackupRequest) GetSessionToken ¶
func (x *BackupRequest) GetSessionToken() Sensitive
func (*BackupRequest) GetSinceTs ¶
func (x *BackupRequest) GetSinceTs() uint64
func (*BackupRequest) GetUnixTs ¶
func (x *BackupRequest) GetUnixTs() string
func (*BackupRequest) ProtoMessage ¶
func (*BackupRequest) ProtoMessage()
func (*BackupRequest) ProtoReflect ¶
func (x *BackupRequest) ProtoReflect() protoreflect.Message
func (*BackupRequest) Reset ¶
func (x *BackupRequest) Reset()
func (*BackupRequest) String ¶
func (x *BackupRequest) String() string
type BackupResponse ¶
type BackupResponse struct {
DropOperations []*DropOperation `protobuf:"bytes,1,rep,name=drop_operations,json=dropOperations,proto3" json:"drop_operations,omitempty"`
// contains filtered or unexported fields
}
func (*BackupResponse) Descriptor
deprecated
func (*BackupResponse) Descriptor() ([]byte, []int)
Deprecated: Use BackupResponse.ProtoReflect.Descriptor instead.
func (*BackupResponse) GetDropOperations ¶
func (x *BackupResponse) GetDropOperations() []*DropOperation
func (*BackupResponse) ProtoMessage ¶
func (*BackupResponse) ProtoMessage()
func (*BackupResponse) ProtoReflect ¶
func (x *BackupResponse) ProtoReflect() protoreflect.Message
func (*BackupResponse) Reset ¶
func (x *BackupResponse) Reset()
func (*BackupResponse) String ¶
func (x *BackupResponse) String() string
type BulkMeta ¶
type BulkMeta struct {
EdgeCount int64 `protobuf:"varint,1,opt,name=edge_count,json=edgeCount,proto3" json:"edge_count,omitempty"`
SchemaMap map[string]*SchemaUpdate `` /* 176-byte string literal not displayed */
Types []*TypeUpdate `protobuf:"bytes,3,rep,name=types,proto3" json:"types,omitempty"`
// contains filtered or unexported fields
}
BulkMeta stores metadata from the map phase of the bulk loader.
func (*BulkMeta) Descriptor
deprecated
func (*BulkMeta) GetEdgeCount ¶
func (*BulkMeta) GetSchemaMap ¶
func (x *BulkMeta) GetSchemaMap() map[string]*SchemaUpdate
func (*BulkMeta) GetTypes ¶
func (x *BulkMeta) GetTypes() []*TypeUpdate
func (*BulkMeta) ProtoMessage ¶
func (*BulkMeta) ProtoMessage()
func (*BulkMeta) ProtoReflect ¶
func (x *BulkMeta) ProtoReflect() protoreflect.Message
type CDCState ¶
type CDCState struct {
SentTs uint64 `protobuf:"varint,1,opt,name=sent_ts,json=sentTs,proto3" json:"sent_ts,omitempty"`
// contains filtered or unexported fields
}
func (*CDCState) Descriptor
deprecated
func (*CDCState) ProtoMessage ¶
func (*CDCState) ProtoMessage()
func (*CDCState) ProtoReflect ¶
func (x *CDCState) ProtoReflect() protoreflect.Message
type ConnectionState ¶
type ConnectionState struct {
Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
State *MembershipState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
MaxPending uint64 `protobuf:"varint,3,opt,name=max_pending,json=maxPending,proto3" json:"max_pending,omitempty"` // Used to determine the timstamp for reading after bulk load
// contains filtered or unexported fields
}
func (*ConnectionState) Descriptor
deprecated
func (*ConnectionState) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionState.ProtoReflect.Descriptor instead.
func (*ConnectionState) GetMaxPending ¶
func (x *ConnectionState) GetMaxPending() uint64
func (*ConnectionState) GetMember ¶
func (x *ConnectionState) GetMember() *Member
func (*ConnectionState) GetState ¶
func (x *ConnectionState) GetState() *MembershipState
func (*ConnectionState) ProtoMessage ¶
func (*ConnectionState) ProtoMessage()
func (*ConnectionState) ProtoReflect ¶
func (x *ConnectionState) ProtoReflect() protoreflect.Message
func (*ConnectionState) Reset ¶
func (x *ConnectionState) Reset()
func (*ConnectionState) String ¶
func (x *ConnectionState) String() string
type DeleteNsRequest ¶
type DeleteNsRequest struct {
GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
Namespace uint64 `protobuf:"varint,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteNsRequest) Descriptor
deprecated
func (*DeleteNsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNsRequest.ProtoReflect.Descriptor instead.
func (*DeleteNsRequest) GetGroupId ¶
func (x *DeleteNsRequest) GetGroupId() uint32
func (*DeleteNsRequest) GetNamespace ¶
func (x *DeleteNsRequest) GetNamespace() uint64
func (*DeleteNsRequest) ProtoMessage ¶
func (*DeleteNsRequest) ProtoMessage()
func (*DeleteNsRequest) ProtoReflect ¶
func (x *DeleteNsRequest) ProtoReflect() protoreflect.Message
func (*DeleteNsRequest) Reset ¶
func (x *DeleteNsRequest) Reset()
func (*DeleteNsRequest) String ¶
func (x *DeleteNsRequest) String() string
type DirectedEdge ¶
type DirectedEdge struct {
Entity uint64 `protobuf:"fixed64,1,opt,name=entity,proto3" json:"entity,omitempty"` // Subject or source node / UID.
Attr string `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"` // Attribute or predicate. Labels the edge.
Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // Edge points to a value.
ValueType Posting_ValType `protobuf:"varint,4,opt,name=value_type,json=valueType,proto3,enum=pb.Posting_ValType" json:"value_type,omitempty"` // The type of the value
ValueId uint64 `protobuf:"fixed64,5,opt,name=value_id,json=valueId,proto3" json:"value_id,omitempty"` // Object or destination node / UID.
Lang string `protobuf:"bytes,7,opt,name=lang,proto3" json:"lang,omitempty"`
Op DirectedEdge_Op `protobuf:"varint,8,opt,name=op,proto3,enum=pb.DirectedEdge_Op" json:"op,omitempty"`
Facets []*api.Facet `protobuf:"bytes,9,rep,name=facets,proto3" json:"facets,omitempty"`
AllowedPreds []string `protobuf:"bytes,10,rep,name=allowedPreds,proto3" json:"allowedPreds,omitempty"`
Namespace uint64 `protobuf:"varint,11,opt,name=namespace,proto3" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*DirectedEdge) Descriptor
deprecated
func (*DirectedEdge) Descriptor() ([]byte, []int)
Deprecated: Use DirectedEdge.ProtoReflect.Descriptor instead.
func (*DirectedEdge) GetAllowedPreds ¶
func (x *DirectedEdge) GetAllowedPreds() []string
func (*DirectedEdge) GetAttr ¶
func (x *DirectedEdge) GetAttr() string
func (*DirectedEdge) GetEntity ¶
func (x *DirectedEdge) GetEntity() uint64
func (*DirectedEdge) GetFacets ¶
func (x *DirectedEdge) GetFacets() []*api.Facet
func (*DirectedEdge) GetLang ¶
func (x *DirectedEdge) GetLang() string
func (*DirectedEdge) GetNamespace ¶
func (x *DirectedEdge) GetNamespace() uint64
func (*DirectedEdge) GetOp ¶
func (x *DirectedEdge) GetOp() DirectedEdge_Op
func (*DirectedEdge) GetValue ¶
func (x *DirectedEdge) GetValue() []byte
func (*DirectedEdge) GetValueId ¶
func (x *DirectedEdge) GetValueId() uint64
func (*DirectedEdge) GetValueType ¶
func (x *DirectedEdge) GetValueType() Posting_ValType
func (*DirectedEdge) ProtoMessage ¶
func (*DirectedEdge) ProtoMessage()
func (*DirectedEdge) ProtoReflect ¶
func (x *DirectedEdge) ProtoReflect() protoreflect.Message
func (*DirectedEdge) Reset ¶
func (x *DirectedEdge) Reset()
func (*DirectedEdge) String ¶
func (x *DirectedEdge) String() string
type DirectedEdge_Op ¶
type DirectedEdge_Op int32
const ( DirectedEdge_SET DirectedEdge_Op = 0 DirectedEdge_DEL DirectedEdge_Op = 1 DirectedEdge_OVR DirectedEdge_Op = 2 )
func (DirectedEdge_Op) Descriptor ¶
func (DirectedEdge_Op) Descriptor() protoreflect.EnumDescriptor
func (DirectedEdge_Op) Enum ¶
func (x DirectedEdge_Op) Enum() *DirectedEdge_Op
func (DirectedEdge_Op) EnumDescriptor
deprecated
func (DirectedEdge_Op) EnumDescriptor() ([]byte, []int)
Deprecated: Use DirectedEdge_Op.Descriptor instead.
func (DirectedEdge_Op) Number ¶
func (x DirectedEdge_Op) Number() protoreflect.EnumNumber
func (DirectedEdge_Op) String ¶
func (x DirectedEdge_Op) String() string
func (DirectedEdge_Op) Type ¶
func (DirectedEdge_Op) Type() protoreflect.EnumType
type DrainModeRequest ¶
type DrainModeRequest struct {
State bool `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*DrainModeRequest) Descriptor
deprecated
func (*DrainModeRequest) Descriptor() ([]byte, []int)
Deprecated: Use DrainModeRequest.ProtoReflect.Descriptor instead.
func (*DrainModeRequest) GetState ¶
func (x *DrainModeRequest) GetState() bool
func (*DrainModeRequest) ProtoMessage ¶
func (*DrainModeRequest) ProtoMessage()
func (*DrainModeRequest) ProtoReflect ¶
func (x *DrainModeRequest) ProtoReflect() protoreflect.Message
func (*DrainModeRequest) Reset ¶
func (x *DrainModeRequest) Reset()
func (*DrainModeRequest) String ¶
func (x *DrainModeRequest) String() string
type DropOperation ¶
type DropOperation struct {
DropOp DropOperation_DropOp `protobuf:"varint,1,opt,name=drop_op,json=dropOp,proto3,enum=pb.DropOperation_DropOp" json:"drop_op,omitempty"`
// When drop_op is ATTR, drop_value will be the name of the ATTR; empty
// otherwise.
DropValue string `protobuf:"bytes,2,opt,name=drop_value,json=dropValue,proto3" json:"drop_value,omitempty"`
// contains filtered or unexported fields
}
func (*DropOperation) Descriptor
deprecated
func (*DropOperation) Descriptor() ([]byte, []int)
Deprecated: Use DropOperation.ProtoReflect.Descriptor instead.
func (*DropOperation) GetDropOp ¶
func (x *DropOperation) GetDropOp() DropOperation_DropOp
func (*DropOperation) GetDropValue ¶
func (x *DropOperation) GetDropValue() string
func (*DropOperation) ProtoMessage ¶
func (*DropOperation) ProtoMessage()
func (*DropOperation) ProtoReflect ¶
func (x *DropOperation) ProtoReflect() protoreflect.Message
func (*DropOperation) Reset ¶
func (x *DropOperation) Reset()
func (*DropOperation) String ¶
func (x *DropOperation) String() string
type DropOperation_DropOp ¶
type DropOperation_DropOp int32
const ( DropOperation_ALL DropOperation_DropOp = 0 DropOperation_DATA DropOperation_DropOp = 1 DropOperation_ATTR DropOperation_DropOp = 2 DropOperation_NS DropOperation_DropOp = 3 )
func (DropOperation_DropOp) Descriptor ¶
func (DropOperation_DropOp) Descriptor() protoreflect.EnumDescriptor
func (DropOperation_DropOp) Enum ¶
func (x DropOperation_DropOp) Enum() *DropOperation_DropOp
func (DropOperation_DropOp) EnumDescriptor
deprecated
func (DropOperation_DropOp) EnumDescriptor() ([]byte, []int)
Deprecated: Use DropOperation_DropOp.Descriptor instead.
func (DropOperation_DropOp) Number ¶
func (x DropOperation_DropOp) Number() protoreflect.EnumNumber
func (DropOperation_DropOp) String ¶
func (x DropOperation_DropOp) String() string
func (DropOperation_DropOp) Type ¶
func (DropOperation_DropOp) Type() protoreflect.EnumType
type ExportRequest ¶
type ExportRequest struct {
GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` // Group id to back up.
ReadTs uint64 `protobuf:"varint,2,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
UnixTs int64 `protobuf:"varint,3,opt,name=unix_ts,json=unixTs,proto3" json:"unix_ts,omitempty"`
Format string `protobuf:"bytes,4,opt,name=format,proto3" json:"format,omitempty"`
Destination string `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"`
// These credentials are used to access the S3 or minio bucket.
AccessKey string `protobuf:"bytes,6,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
SecretKey Sensitive `protobuf:"bytes,7,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
SessionToken Sensitive `protobuf:"bytes,8,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`
Anonymous bool `protobuf:"varint,9,opt,name=anonymous,proto3" json:"anonymous,omitempty"`
Namespace uint64 `protobuf:"varint,10,opt,name=namespace,proto3" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*ExportRequest) Descriptor
deprecated
func (*ExportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.
func (*ExportRequest) GetAccessKey ¶
func (x *ExportRequest) GetAccessKey() string
func (*ExportRequest) GetAnonymous ¶
func (x *ExportRequest) GetAnonymous() bool
func (*ExportRequest) GetDestination ¶
func (x *ExportRequest) GetDestination() string
func (*ExportRequest) GetFormat ¶
func (x *ExportRequest) GetFormat() string
func (*ExportRequest) GetGroupId ¶
func (x *ExportRequest) GetGroupId() uint32
func (*ExportRequest) GetNamespace ¶
func (x *ExportRequest) GetNamespace() uint64
func (*ExportRequest) GetReadTs ¶
func (x *ExportRequest) GetReadTs() uint64
func (*ExportRequest) GetSecretKey ¶
func (x *ExportRequest) GetSecretKey() Sensitive
func (*ExportRequest) GetSessionToken ¶
func (x *ExportRequest) GetSessionToken() Sensitive
func (*ExportRequest) GetUnixTs ¶
func (x *ExportRequest) GetUnixTs() int64
func (*ExportRequest) ProtoMessage ¶
func (*ExportRequest) ProtoMessage()
func (*ExportRequest) ProtoReflect ¶
func (x *ExportRequest) ProtoReflect() protoreflect.Message
func (*ExportRequest) Reset ¶
func (x *ExportRequest) Reset()
func (*ExportRequest) String ¶
func (x *ExportRequest) String() string
type ExportResponse ¶
type ExportResponse struct {
// 0 indicates a success, and a non-zero code indicates failure
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
Files []string `protobuf:"bytes,3,rep,name=files,proto3" json:"files,omitempty"`
// contains filtered or unexported fields
}
func (*ExportResponse) Descriptor
deprecated
func (*ExportResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExportResponse.ProtoReflect.Descriptor instead.
func (*ExportResponse) GetCode ¶
func (x *ExportResponse) GetCode() int32
func (*ExportResponse) GetFiles ¶
func (x *ExportResponse) GetFiles() []string
func (*ExportResponse) GetMsg ¶
func (x *ExportResponse) GetMsg() string
func (*ExportResponse) ProtoMessage ¶
func (*ExportResponse) ProtoMessage()
func (*ExportResponse) ProtoReflect ¶
func (x *ExportResponse) ProtoReflect() protoreflect.Message
func (*ExportResponse) Reset ¶
func (x *ExportResponse) Reset()
func (*ExportResponse) String ¶
func (x *ExportResponse) 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"`
// contains filtered or unexported fields
}
func (*FacetParam) Descriptor
deprecated
func (*FacetParam) Descriptor() ([]byte, []int)
Deprecated: Use FacetParam.ProtoReflect.Descriptor instead.
func (*FacetParam) GetAlias ¶
func (x *FacetParam) GetAlias() string
func (*FacetParam) GetKey ¶
func (x *FacetParam) GetKey() string
func (*FacetParam) ProtoMessage ¶
func (*FacetParam) ProtoMessage()
func (*FacetParam) ProtoReflect ¶
func (x *FacetParam) ProtoReflect() protoreflect.Message
func (*FacetParam) Reset ¶
func (x *FacetParam) Reset()
func (*FacetParam) String ¶
func (x *FacetParam) String() string
type FacetParams ¶
type FacetParams struct {
AllKeys bool `protobuf:"varint,1,opt,name=all_keys,json=allKeys,proto3" json:"all_keys,omitempty"` // keys should be in sorted order.
Param []*FacetParam `protobuf:"bytes,2,rep,name=param,proto3" json:"param,omitempty"`
// contains filtered or unexported fields
}
func (*FacetParams) Descriptor
deprecated
func (*FacetParams) Descriptor() ([]byte, []int)
Deprecated: Use FacetParams.ProtoReflect.Descriptor instead.
func (*FacetParams) GetAllKeys ¶
func (x *FacetParams) GetAllKeys() bool
func (*FacetParams) GetParam ¶
func (x *FacetParams) GetParam() []*FacetParam
func (*FacetParams) ProtoMessage ¶
func (*FacetParams) ProtoMessage()
func (*FacetParams) ProtoReflect ¶
func (x *FacetParams) ProtoReflect() protoreflect.Message
func (*FacetParams) Reset ¶
func (x *FacetParams) Reset()
func (*FacetParams) String ¶
func (x *FacetParams) String() string
type Facets ¶
type Facets struct {
Facets []*api.Facet `protobuf:"bytes,1,rep,name=facets,proto3" json:"facets,omitempty"`
// contains filtered or unexported fields
}
func (*Facets) Descriptor
deprecated
func (*Facets) ProtoMessage ¶
func (*Facets) ProtoMessage()
func (*Facets) ProtoReflect ¶
func (x *Facets) ProtoReflect() protoreflect.Message
type FacetsList ¶
type FacetsList struct {
FacetsList []*Facets `protobuf:"bytes,1,rep,name=facets_list,json=facetsList,proto3" json:"facets_list,omitempty"`
// contains filtered or unexported fields
}
func (*FacetsList) Descriptor
deprecated
func (*FacetsList) Descriptor() ([]byte, []int)
Deprecated: Use FacetsList.ProtoReflect.Descriptor instead.
func (*FacetsList) GetFacetsList ¶
func (x *FacetsList) GetFacetsList() []*Facets
func (*FacetsList) ProtoMessage ¶
func (*FacetsList) ProtoMessage()
func (*FacetsList) ProtoReflect ¶
func (x *FacetsList) ProtoReflect() protoreflect.Message
func (*FacetsList) Reset ¶
func (x *FacetsList) Reset()
func (*FacetsList) String ¶
func (x *FacetsList) String() string
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,proto3" json:"children,omitempty"`
Func *Function `protobuf:"bytes,3,opt,name=func,proto3" json:"func,omitempty"`
// contains filtered or unexported fields
}
Op and Children are internal nodes and Func on leaves.
func (*FilterTree) Descriptor
deprecated
func (*FilterTree) Descriptor() ([]byte, []int)
Deprecated: Use FilterTree.ProtoReflect.Descriptor instead.
func (*FilterTree) GetChildren ¶
func (x *FilterTree) GetChildren() []*FilterTree
func (*FilterTree) GetFunc ¶
func (x *FilterTree) GetFunc() *Function
func (*FilterTree) GetOp ¶
func (x *FilterTree) GetOp() string
func (*FilterTree) ProtoMessage ¶
func (*FilterTree) ProtoMessage()
func (*FilterTree) ProtoReflect ¶
func (x *FilterTree) ProtoReflect() protoreflect.Message
func (*FilterTree) Reset ¶
func (x *FilterTree) Reset()
func (*FilterTree) String ¶
func (x *FilterTree) String() string
type Function ¶
type Function struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the function : eq, le
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // Facet key over which to run the function.
Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"` // Arguments of the function.
// contains filtered or unexported fields
}
func (*Function) Descriptor
deprecated
func (*Function) ProtoMessage ¶
func (*Function) ProtoMessage()
func (*Function) ProtoReflect ¶
func (x *Function) ProtoReflect() protoreflect.Message
type Group ¶
type Group struct {
Members map[uint64]*Member `` // Raft ID is the key.
/* 156-byte string literal not displayed */
Tablets map[string]*Tablet `` // Predicate + others are key.
/* 155-byte string literal not displayed */
SnapshotTs uint64 `protobuf:"varint,3,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,omitempty"` // Stores Snapshot transaction ts.
Checksum uint64 `protobuf:"varint,4,opt,name=checksum,proto3" json:"checksum,omitempty"` // Stores a checksum.
CheckpointTs uint64 `protobuf:"varint,5,opt,name=checkpoint_ts,json=checkpointTs,proto3" json:"checkpoint_ts,omitempty"` // Stores checkpoint ts as seen by leader.
// contains filtered or unexported fields
}
func (*Group) Descriptor
deprecated
func (*Group) GetCheckpointTs ¶
func (*Group) GetChecksum ¶
func (*Group) GetMembers ¶
func (*Group) GetSnapshotTs ¶
func (*Group) GetTablets ¶
func (*Group) ProtoMessage ¶
func (*Group) ProtoMessage()
func (*Group) ProtoReflect ¶
func (x *Group) ProtoReflect() protoreflect.Message
type HealthInfo ¶
type HealthInfo struct {
Instance string `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` // string so group = 0 can be printed in JSON.
Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
Uptime int64 `protobuf:"varint,6,opt,name=uptime,proto3" json:"uptime,omitempty"`
LastEcho int64 `protobuf:"varint,7,opt,name=lastEcho,proto3" json:"lastEcho,omitempty"`
Ongoing []string `protobuf:"bytes,8,rep,name=ongoing,proto3" json:"ongoing,omitempty"`
Indexing []string `protobuf:"bytes,9,rep,name=indexing,proto3" json:"indexing,omitempty"`
EeFeatures []string `protobuf:"bytes,10,rep,name=ee_features,json=eeFeatures,proto3" json:"ee_features,omitempty"`
MaxAssigned uint64 `protobuf:"varint,11,opt,name=max_assigned,json=maxAssigned,proto3" json:"max_assigned,omitempty"`
// contains filtered or unexported fields
}
func (*HealthInfo) Descriptor
deprecated
func (*HealthInfo) Descriptor() ([]byte, []int)
Deprecated: Use HealthInfo.ProtoReflect.Descriptor instead.
func (*HealthInfo) GetAddress ¶
func (x *HealthInfo) GetAddress() string
func (*HealthInfo) GetEeFeatures ¶
func (x *HealthInfo) GetEeFeatures() []string
func (*HealthInfo) GetGroup ¶
func (x *HealthInfo) GetGroup() string
func (*HealthInfo) GetIndexing ¶
func (x *HealthInfo) GetIndexing() []string
func (*HealthInfo) GetInstance ¶
func (x *HealthInfo) GetInstance() string
func (*HealthInfo) GetLastEcho ¶
func (x *HealthInfo) GetLastEcho() int64
func (*HealthInfo) GetMaxAssigned ¶
func (x *HealthInfo) GetMaxAssigned() uint64
func (*HealthInfo) GetOngoing ¶
func (x *HealthInfo) GetOngoing() []string
func (*HealthInfo) GetStatus ¶
func (x *HealthInfo) GetStatus() string
func (*HealthInfo) GetUptime ¶
func (x *HealthInfo) GetUptime() int64
func (*HealthInfo) GetVersion ¶
func (x *HealthInfo) GetVersion() string
func (*HealthInfo) ProtoMessage ¶
func (*HealthInfo) ProtoMessage()
func (*HealthInfo) ProtoReflect ¶
func (x *HealthInfo) ProtoReflect() protoreflect.Message
func (*HealthInfo) Reset ¶
func (x *HealthInfo) Reset()
func (*HealthInfo) String ¶
func (x *HealthInfo) String() string
type KVS ¶
type KVS struct {
Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
// done used to indicate if the stream of KVS is over.
Done bool `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
// predicates is the list of predicates known by the leader at the time of the
// snapshot.
Predicates []string `protobuf:"bytes,3,rep,name=predicates,proto3" json:"predicates,omitempty"`
// types is the list of types known by the leader at the time of the snapshot.
Types []string `protobuf:"bytes,4,rep,name=types,proto3" json:"types,omitempty"`
// contains filtered or unexported fields
}
func (*KVS) Descriptor
deprecated
func (*KVS) GetPredicates ¶
func (*KVS) ProtoMessage ¶
func (*KVS) ProtoMessage()
func (*KVS) ProtoReflect ¶
func (x *KVS) ProtoReflect() protoreflect.Message
type LangList ¶
type LangList struct {
Lang []string `protobuf:"bytes,1,rep,name=lang,proto3" json:"lang,omitempty"`
// contains filtered or unexported fields
}
func (*LangList) Descriptor
deprecated
func (*LangList) ProtoMessage ¶
func (*LangList) ProtoMessage()
func (*LangList) ProtoReflect ¶
func (x *LangList) ProtoReflect() protoreflect.Message
type List ¶
type List struct {
Uids []uint64 `protobuf:"fixed64,1,rep,packed,name=uids,proto3" json:"uids,omitempty"`
// contains filtered or unexported fields
}
func (*List) Descriptor
deprecated
func (*List) ProtoMessage ¶
func (*List) ProtoMessage()
func (*List) ProtoReflect ¶
func (x *List) ProtoReflect() protoreflect.Message
type MapHeader ¶
type MapHeader struct {
PartitionKeys [][]byte `protobuf:"bytes,1,rep,name=partition_keys,json=partitionKeys,proto3" json:"partition_keys,omitempty"`
// contains filtered or unexported fields
}
func (*MapHeader) Descriptor
deprecated
func (*MapHeader) GetPartitionKeys ¶
func (*MapHeader) ProtoMessage ¶
func (*MapHeader) ProtoMessage()
func (*MapHeader) ProtoReflect ¶
func (x *MapHeader) ProtoReflect() protoreflect.Message
type Member ¶
type Member struct {
Id uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
GroupId uint32 `protobuf:"varint,2,opt,name=groupId,proto3" json:"groupId,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=amDead,proto3" json:"amDead,omitempty"`
LastUpdate uint64 `protobuf:"varint,6,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
Learner bool `protobuf:"varint,7,opt,name=learner,proto3" json:"learner,omitempty"`
ClusterInfoOnly bool `protobuf:"varint,13,opt,name=clusterInfoOnly,proto3" json:"clusterInfoOnly,omitempty"`
ForceGroupId bool `protobuf:"varint,14,opt,name=forceGroupId,proto3" json:"forceGroupId,omitempty"`
// contains filtered or unexported fields
}
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
deprecated
func (*Member) GetClusterInfoOnly ¶
func (*Member) GetForceGroupId ¶
func (*Member) GetGroupId ¶
func (*Member) GetLastUpdate ¶
func (*Member) GetLearner ¶
func (*Member) ProtoMessage ¶
func (*Member) ProtoMessage()
func (*Member) ProtoReflect ¶
func (x *Member) ProtoReflect() protoreflect.Message
type MembershipState ¶
type MembershipState struct {
Counter uint64 `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"` // used to find latest membershipState in case of race.
Groups map[uint32]*Group `` /* 154-byte string literal not displayed */
Zeros map[uint64]*Member `` /* 152-byte string literal not displayed */
MaxUID uint64 `protobuf:"varint,4,opt,name=maxUID,proto3" json:"maxUID,omitempty"`
MaxTxnTs uint64 `protobuf:"varint,5,opt,name=maxTxnTs,proto3" json:"maxTxnTs,omitempty"`
MaxNsID uint64 `protobuf:"varint,10,opt,name=maxNsID,proto3" json:"maxNsID,omitempty"`
MaxRaftId uint64 `protobuf:"varint,6,opt,name=maxRaftId,proto3" json:"maxRaftId,omitempty"`
Removed []*Member `protobuf:"bytes,7,rep,name=removed,proto3" json:"removed,omitempty"`
Cid string `protobuf:"bytes,8,opt,name=cid,proto3" json:"cid,omitempty"` // Used to uniquely identify the Dgraph cluster.
// contains filtered or unexported fields
}
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
deprecated
func (*MembershipState) Descriptor() ([]byte, []int)
Deprecated: Use MembershipState.ProtoReflect.Descriptor instead.
func (*MembershipState) GetCid ¶
func (x *MembershipState) GetCid() string
func (*MembershipState) GetCounter ¶
func (x *MembershipState) GetCounter() uint64
func (*MembershipState) GetGroups ¶
func (x *MembershipState) GetGroups() map[uint32]*Group
func (*MembershipState) GetMaxNsID ¶
func (x *MembershipState) GetMaxNsID() uint64
func (*MembershipState) GetMaxRaftId ¶
func (x *MembershipState) GetMaxRaftId() uint64
func (*MembershipState) GetMaxTxnTs ¶
func (x *MembershipState) GetMaxTxnTs() uint64
func (*MembershipState) GetMaxUID ¶
func (x *MembershipState) GetMaxUID() uint64
func (*MembershipState) GetRemoved ¶
func (x *MembershipState) GetRemoved() []*Member
func (*MembershipState) GetZeros ¶
func (x *MembershipState) GetZeros() map[uint64]*Member
func (*MembershipState) ProtoMessage ¶
func (*MembershipState) ProtoMessage()
func (*MembershipState) ProtoReflect ¶
func (x *MembershipState) ProtoReflect() protoreflect.Message
func (*MembershipState) Reset ¶
func (x *MembershipState) Reset()
func (*MembershipState) String ¶
func (x *MembershipState) String() string
type Metadata ¶
type Metadata struct {
// Map of predicates to their hints.
PredHints map[string]Metadata_HintType `` /* 203-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*Metadata) Descriptor
deprecated
func (*Metadata) GetPredHints ¶
func (x *Metadata) GetPredHints() map[string]Metadata_HintType
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶
func (x *Metadata) ProtoReflect() protoreflect.Message
type Metadata_HintType ¶
type Metadata_HintType int32
HintType represents a hint that will be passed along the mutation and used to add the predicate to the schema if it's not already there.
const ( // DEFAULT means no hint is provided and Dgraph will follow the default // behavior. Metadata_DEFAULT Metadata_HintType = 0 // SINGLE signals that the predicate should be created as a single type (e.g // string, uid). Metadata_SINGLE Metadata_HintType = 1 // LIST signals that the predicate should be created as a list (e.g // [string], [uid]). Metadata_LIST Metadata_HintType = 2 )
func (Metadata_HintType) Descriptor ¶
func (Metadata_HintType) Descriptor() protoreflect.EnumDescriptor
func (Metadata_HintType) Enum ¶
func (x Metadata_HintType) Enum() *Metadata_HintType
func (Metadata_HintType) EnumDescriptor
deprecated
func (Metadata_HintType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Metadata_HintType.Descriptor instead.
func (Metadata_HintType) Number ¶
func (x Metadata_HintType) Number() protoreflect.EnumNumber
func (Metadata_HintType) String ¶
func (x Metadata_HintType) String() string
func (Metadata_HintType) Type ¶
func (Metadata_HintType) Type() protoreflect.EnumType
type MovePredicatePayload ¶
type MovePredicatePayload struct {
Predicate string `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
SourceGid uint32 `protobuf:"varint,2,opt,name=source_gid,json=sourceGid,proto3" json:"source_gid,omitempty"`
DestGid uint32 `protobuf:"varint,3,opt,name=dest_gid,json=destGid,proto3" json:"dest_gid,omitempty"`
TxnTs uint64 `protobuf:"varint,4,opt,name=txn_ts,json=txnTs,proto3" json:"txn_ts,omitempty"`
ExpectedChecksum uint64 `protobuf:"varint,5,opt,name=expected_checksum,json=expectedChecksum,proto3" json:"expected_checksum,omitempty"`
// contains filtered or unexported fields
}
func (*MovePredicatePayload) Descriptor
deprecated
func (*MovePredicatePayload) Descriptor() ([]byte, []int)
Deprecated: Use MovePredicatePayload.ProtoReflect.Descriptor instead.
func (*MovePredicatePayload) GetDestGid ¶
func (x *MovePredicatePayload) GetDestGid() uint32
func (*MovePredicatePayload) GetExpectedChecksum ¶
func (x *MovePredicatePayload) GetExpectedChecksum() uint64
func (*MovePredicatePayload) GetPredicate ¶
func (x *MovePredicatePayload) GetPredicate() string
func (*MovePredicatePayload) GetSourceGid ¶
func (x *MovePredicatePayload) GetSourceGid() uint32
func (*MovePredicatePayload) GetTxnTs ¶
func (x *MovePredicatePayload) GetTxnTs() uint64
func (*MovePredicatePayload) ProtoMessage ¶
func (*MovePredicatePayload) ProtoMessage()
func (*MovePredicatePayload) ProtoReflect ¶
func (x *MovePredicatePayload) ProtoReflect() protoreflect.Message
func (*MovePredicatePayload) Reset ¶
func (x *MovePredicatePayload) Reset()
func (*MovePredicatePayload) String ¶
func (x *MovePredicatePayload) String() string
type MoveTabletRequest ¶
type MoveTabletRequest struct {
Namespace uint64 `protobuf:"varint,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Tablet string `protobuf:"bytes,2,opt,name=tablet,proto3" json:"tablet,omitempty"`
DstGroup uint32 `protobuf:"varint,3,opt,name=dstGroup,proto3" json:"dstGroup,omitempty"`
// contains filtered or unexported fields
}
func (*MoveTabletRequest) Descriptor
deprecated
func (*MoveTabletRequest) Descriptor() ([]byte, []int)
Deprecated: Use MoveTabletRequest.ProtoReflect.Descriptor instead.
func (*MoveTabletRequest) GetDstGroup ¶
func (x *MoveTabletRequest) GetDstGroup() uint32
func (*MoveTabletRequest) GetNamespace ¶
func (x *MoveTabletRequest) GetNamespace() uint64
func (*MoveTabletRequest) GetTablet ¶
func (x *MoveTabletRequest) GetTablet() string
func (*MoveTabletRequest) ProtoMessage ¶
func (*MoveTabletRequest) ProtoMessage()
func (*MoveTabletRequest) ProtoReflect ¶
func (x *MoveTabletRequest) ProtoReflect() protoreflect.Message
func (*MoveTabletRequest) Reset ¶
func (x *MoveTabletRequest) Reset()
func (*MoveTabletRequest) String ¶
func (x *MoveTabletRequest) String() string
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,proto3" json:"edges,omitempty"`
Schema []*SchemaUpdate `protobuf:"bytes,4,rep,name=schema,proto3" json:"schema,omitempty"`
Types []*TypeUpdate `protobuf:"bytes,6,rep,name=types,proto3" json:"types,omitempty"`
DropOp Mutations_DropOp `protobuf:"varint,7,opt,name=drop_op,json=dropOp,proto3,enum=pb.Mutations_DropOp" json:"drop_op,omitempty"`
DropValue string `protobuf:"bytes,8,opt,name=drop_value,json=dropValue,proto3" json:"drop_value,omitempty"`
Metadata *Metadata `protobuf:"bytes,9,opt,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
func (*Mutations) Descriptor
deprecated
func (*Mutations) GetDropOp ¶
func (x *Mutations) GetDropOp() Mutations_DropOp
func (*Mutations) GetDropValue ¶
func (*Mutations) GetEdges ¶
func (x *Mutations) GetEdges() []*DirectedEdge
func (*Mutations) GetGroupId ¶
func (*Mutations) GetMetadata ¶
func (*Mutations) GetSchema ¶
func (x *Mutations) GetSchema() []*SchemaUpdate
func (*Mutations) GetStartTs ¶
func (*Mutations) GetTypes ¶
func (x *Mutations) GetTypes() []*TypeUpdate
func (*Mutations) ProtoMessage ¶
func (*Mutations) ProtoMessage()
func (*Mutations) ProtoReflect ¶
func (x *Mutations) ProtoReflect() protoreflect.Message
type Mutations_DropOp ¶
type Mutations_DropOp int32
const ( Mutations_NONE Mutations_DropOp = 0 Mutations_ALL Mutations_DropOp = 1 Mutations_DATA Mutations_DropOp = 2 Mutations_TYPE Mutations_DropOp = 3 Mutations_ALL_IN_NS Mutations_DropOp = 4 )
func (Mutations_DropOp) Descriptor ¶
func (Mutations_DropOp) Descriptor() protoreflect.EnumDescriptor
func (Mutations_DropOp) Enum ¶
func (x Mutations_DropOp) Enum() *Mutations_DropOp
func (Mutations_DropOp) EnumDescriptor
deprecated
func (Mutations_DropOp) EnumDescriptor() ([]byte, []int)
Deprecated: Use Mutations_DropOp.Descriptor instead.
func (Mutations_DropOp) Number ¶
func (x Mutations_DropOp) Number() protoreflect.EnumNumber
func (Mutations_DropOp) String ¶
func (x Mutations_DropOp) String() string
func (Mutations_DropOp) Type ¶
func (Mutations_DropOp) Type() protoreflect.EnumType
type Num ¶
type Num struct {
Val uint64 `protobuf:"varint,1,opt,name=val,proto3" json:"val,omitempty"`
ReadOnly bool `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
Forwarded bool `protobuf:"varint,3,opt,name=forwarded,proto3" json:"forwarded,omitempty"` // True if this request was forwarded by a peer.
// If bump is set to true then we bump the lease to val. If false, we assign new ids with count
// equal to val.
Bump bool `protobuf:"varint,5,opt,name=bump,proto3" json:"bump,omitempty"`
Type NumLeaseType `protobuf:"varint,4,opt,name=type,proto3,enum=pb.NumLeaseType" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*Num) Descriptor
deprecated
func (*Num) GetForwarded ¶
func (*Num) GetReadOnly ¶
func (*Num) GetType ¶
func (x *Num) GetType() NumLeaseType
func (*Num) ProtoMessage ¶
func (*Num) ProtoMessage()
func (*Num) ProtoReflect ¶
func (x *Num) ProtoReflect() protoreflect.Message
type NumLeaseType ¶
type NumLeaseType int32
const ( Num_NS_ID NumLeaseType = 0 Num_UID NumLeaseType = 1 Num_TXN_TS NumLeaseType = 2 )
func (NumLeaseType) Descriptor ¶
func (NumLeaseType) Descriptor() protoreflect.EnumDescriptor
func (NumLeaseType) Enum ¶
func (x NumLeaseType) Enum() *NumLeaseType
func (NumLeaseType) EnumDescriptor
deprecated
func (NumLeaseType) EnumDescriptor() ([]byte, []int)
Deprecated: Use NumLeaseType.Descriptor instead.
func (NumLeaseType) Number ¶
func (x NumLeaseType) Number() protoreflect.EnumNumber
func (NumLeaseType) String ¶
func (x NumLeaseType) String() string
func (NumLeaseType) Type ¶
func (NumLeaseType) Type() protoreflect.EnumType
type OptionPair ¶
type OptionPair struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*OptionPair) Descriptor
deprecated
func (*OptionPair) Descriptor() ([]byte, []int)
Deprecated: Use OptionPair.ProtoReflect.Descriptor instead.
func (*OptionPair) GetKey ¶
func (x *OptionPair) GetKey() string
func (*OptionPair) GetValue ¶
func (x *OptionPair) GetValue() string
func (*OptionPair) ProtoMessage ¶
func (*OptionPair) ProtoMessage()
func (*OptionPair) ProtoReflect ¶
func (x *OptionPair) ProtoReflect() protoreflect.Message
func (*OptionPair) Reset ¶
func (x *OptionPair) Reset()
func (*OptionPair) String ¶
func (x *OptionPair) String() string
type OracleDelta ¶
type OracleDelta struct {
Txns []*TxnStatus `protobuf:"bytes,1,rep,name=txns,proto3" json:"txns,omitempty"`
MaxAssigned uint64 `protobuf:"varint,2,opt,name=max_assigned,json=maxAssigned,proto3" json:"max_assigned,omitempty"`
GroupChecksums map[uint32]uint64 `` // implement tmax.
/* 193-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*OracleDelta) Descriptor
deprecated
func (*OracleDelta) Descriptor() ([]byte, []int)
Deprecated: Use OracleDelta.ProtoReflect.Descriptor instead.
func (*OracleDelta) GetGroupChecksums ¶
func (x *OracleDelta) GetGroupChecksums() map[uint32]uint64
func (*OracleDelta) GetMaxAssigned ¶
func (x *OracleDelta) GetMaxAssigned() uint64
func (*OracleDelta) GetTxns ¶
func (x *OracleDelta) GetTxns() []*TxnStatus
func (*OracleDelta) ProtoMessage ¶
func (*OracleDelta) ProtoMessage()
func (*OracleDelta) ProtoReflect ¶
func (x *OracleDelta) ProtoReflect() protoreflect.Message
func (*OracleDelta) Reset ¶
func (x *OracleDelta) Reset()
func (*OracleDelta) String ¶
func (x *OracleDelta) String() string
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,proto3" json:"langs,omitempty"`
// contains filtered or unexported fields
}
func (*Order) Descriptor
deprecated
func (*Order) ProtoMessage ¶
func (*Order) ProtoMessage()
func (*Order) ProtoReflect ¶
func (x *Order) ProtoReflect() protoreflect.Message
type PeerResponse ¶
type PeerResponse struct {
Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*PeerResponse) Descriptor
deprecated
func (*PeerResponse) Descriptor() ([]byte, []int)
Deprecated: Use PeerResponse.ProtoReflect.Descriptor instead.
func (*PeerResponse) GetStatus ¶
func (x *PeerResponse) GetStatus() bool
func (*PeerResponse) ProtoMessage ¶
func (*PeerResponse) ProtoMessage()
func (*PeerResponse) ProtoReflect ¶
func (x *PeerResponse) ProtoReflect() protoreflect.Message
func (*PeerResponse) Reset ¶
func (x *PeerResponse) Reset()
func (*PeerResponse) String ¶
func (x *PeerResponse) String() string
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=pb.Posting_ValType" json:"val_type,omitempty"`
PostingType Posting_PostingType `protobuf:"varint,4,opt,name=posting_type,json=postingType,proto3,enum=pb.Posting_PostingType" json:"posting_type,omitempty"`
LangTag []byte `protobuf:"bytes,5,opt,name=lang_tag,json=langTag,proto3" json:"lang_tag,omitempty"` // Only set for VALUE_LANG
Facets []*api.Facet `protobuf:"bytes,9,rep,name=facets,proto3" 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"` // Meant to use only inmemory
CommitTs uint64 `protobuf:"varint,14,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"` // Meant to use only inmemory
// contains filtered or unexported fields
}
Posting messages.
func (*Posting) Descriptor
deprecated
func (*Posting) GetCommitTs ¶
func (*Posting) GetLangTag ¶
func (*Posting) GetPostingType ¶
func (x *Posting) GetPostingType() Posting_PostingType
func (*Posting) GetStartTs ¶
func (*Posting) GetValType ¶
func (x *Posting) GetValType() Posting_ValType
func (*Posting) ProtoMessage ¶
func (*Posting) ProtoMessage()
func (*Posting) ProtoReflect ¶
func (x *Posting) ProtoReflect() protoreflect.Message
type PostingList ¶
type PostingList struct {
Pack *UidPack `protobuf:"bytes,1,opt,name=pack,proto3" json:"pack,omitempty"` // Encoded list of uids in this posting list.
Postings []*Posting `protobuf:"bytes,2,rep,name=postings,proto3" json:"postings,omitempty"`
CommitTs uint64 `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"` // More inclination towards smaller values.
Splits []uint64 `protobuf:"varint,4,rep,packed,name=splits,proto3" json:"splits,omitempty"`
// contains filtered or unexported fields
}
func (*PostingList) Descriptor
deprecated
func (*PostingList) Descriptor() ([]byte, []int)
Deprecated: Use PostingList.ProtoReflect.Descriptor instead.
func (*PostingList) GetCommitTs ¶
func (x *PostingList) GetCommitTs() uint64
func (*PostingList) GetPack ¶
func (x *PostingList) GetPack() *UidPack
func (*PostingList) GetPostings ¶
func (x *PostingList) GetPostings() []*Posting
func (*PostingList) GetSplits ¶
func (x *PostingList) GetSplits() []uint64
func (*PostingList) ProtoMessage ¶
func (*PostingList) ProtoMessage()
func (*PostingList) ProtoReflect ¶
func (x *PostingList) ProtoReflect() protoreflect.Message
func (*PostingList) Reset ¶
func (x *PostingList) Reset()
func (*PostingList) String ¶
func (x *PostingList) String() string
type Posting_PostingType ¶
type Posting_PostingType int32
const ( Posting_REF Posting_PostingType = 0 // UID Posting_VALUE Posting_PostingType = 1 // simple, plain value Posting_VALUE_LANG Posting_PostingType = 2 // value with specified language )
func (Posting_PostingType) Descriptor ¶
func (Posting_PostingType) Descriptor() protoreflect.EnumDescriptor
func (Posting_PostingType) Enum ¶
func (x Posting_PostingType) Enum() *Posting_PostingType
func (Posting_PostingType) EnumDescriptor
deprecated
func (Posting_PostingType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Posting_PostingType.Descriptor instead.
func (Posting_PostingType) Number ¶
func (x Posting_PostingType) Number() protoreflect.EnumNumber
func (Posting_PostingType) String ¶
func (x Posting_PostingType) String() string
func (Posting_PostingType) Type ¶
func (Posting_PostingType) Type() protoreflect.EnumType
type Posting_ValType ¶
type Posting_ValType int32
const ( Posting_DEFAULT Posting_ValType = 0 Posting_BINARY Posting_ValType = 1 Posting_INT Posting_ValType = 2 // We treat it as int64. 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 Posting_OBJECT Posting_ValType = 10 Posting_BIGFLOAT Posting_ValType = 11 Posting_VFLOAT Posting_ValType = 12 // Float64 Vector )
func (Posting_ValType) Descriptor ¶
func (Posting_ValType) Descriptor() protoreflect.EnumDescriptor
func (Posting_ValType) Enum ¶
func (x Posting_ValType) Enum() *Posting_ValType
func (Posting_ValType) EnumDescriptor
deprecated
func (Posting_ValType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Posting_ValType.Descriptor instead.
func (Posting_ValType) Number ¶
func (x Posting_ValType) Number() protoreflect.EnumNumber
func (Posting_ValType) String ¶
func (x Posting_ValType) String() string
func (Posting_ValType) Type ¶
func (Posting_ValType) Type() protoreflect.EnumType
type Proposal ¶
type Proposal struct {
Mutations *Mutations `protobuf:"bytes,2,opt,name=mutations,proto3" json:"mutations,omitempty"`
Kv []*pb.KV `protobuf:"bytes,4,rep,name=kv,proto3" json:"kv,omitempty"`
State *MembershipState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
CleanPredicate string `protobuf:"bytes,6,opt,name=clean_predicate,json=cleanPredicate,proto3" json:"clean_predicate,omitempty"` // Delete the predicate which was moved to other group.
Delta *OracleDelta `protobuf:"bytes,8,opt,name=delta,proto3" json:"delta,omitempty"`
Snapshot *Snapshot `protobuf:"bytes,9,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // Used to tell the group when to take snapshot.
Index uint64 `protobuf:"varint,10,opt,name=index,proto3" json:"index,omitempty"` // Used to store Raft index, in raft.Ready.
ExpectedChecksum uint64 `protobuf:"varint,11,opt,name=expected_checksum,json=expectedChecksum,proto3" json:"expected_checksum,omitempty"` // Block an operation until membership reaches this checksum.
Restore *RestoreRequest `protobuf:"bytes,12,opt,name=restore,proto3" json:"restore,omitempty"`
CdcState *CDCState `protobuf:"bytes,13,opt,name=cdc_state,json=cdcState,proto3" json:"cdc_state,omitempty"`
DeleteNs *DeleteNsRequest `protobuf:"bytes,14,opt,name=delete_ns,json=deleteNs,proto3" json:"delete_ns,omitempty"` // Used to delete namespace.
// Skipping 15 as it is used for uint64 key in master and might be needed later here.
StartTs uint64 `protobuf:"varint,16,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
Drainmode *DrainModeRequest `protobuf:"bytes,17,opt,name=drainmode,proto3" json:"drainmode,omitempty"`
// contains filtered or unexported fields
}
func (*Proposal) Descriptor
deprecated
func (*Proposal) GetCdcState ¶
func (*Proposal) GetCleanPredicate ¶
func (*Proposal) GetDeleteNs ¶
func (x *Proposal) GetDeleteNs() *DeleteNsRequest
func (*Proposal) GetDelta ¶
func (x *Proposal) GetDelta() *OracleDelta
func (*Proposal) GetDrainmode ¶
func (x *Proposal) GetDrainmode() *DrainModeRequest
func (*Proposal) GetExpectedChecksum ¶
func (*Proposal) GetMutations ¶
func (*Proposal) GetRestore ¶
func (x *Proposal) GetRestore() *RestoreRequest
func (*Proposal) GetSnapshot ¶
func (*Proposal) GetStartTs ¶
func (*Proposal) GetState ¶
func (x *Proposal) GetState() *MembershipState
func (*Proposal) ProtoMessage ¶
func (*Proposal) ProtoMessage()
func (*Proposal) ProtoReflect ¶
func (x *Proposal) ProtoReflect() protoreflect.Message
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,proto3" json:"langs,omitempty"` // language list for attribute
AfterUid uint64 `protobuf:"fixed64,3,opt,name=after_uid,json=afterUid,proto3" json:"after_uid,omitempty"` // Only return UIDs greater than this.
DoCount bool `protobuf:"varint,4,opt,name=do_count,json=doCount,proto3" json:"do_count,omitempty"` // Are we just getting lengths?
// Exactly one of uids and terms is populated.
UidList *List `protobuf:"bytes,5,opt,name=uid_list,json=uidList,proto3" json:"uid_list,omitempty"`
// Function to generate or filter UIDs.
SrcFunc *SrcFunction `protobuf:"bytes,6,opt,name=src_func,json=srcFunc,proto3" json:"src_func,omitempty"`
Reverse bool `protobuf:"varint,7,opt,name=reverse,proto3" json:"reverse,omitempty"` // Whether this is a reverse edge.
FacetParam *FacetParams `protobuf:"bytes,8,opt,name=facet_param,json=facetParam,proto3" json:"facet_param,omitempty"` // which facets to fetch
FacetsFilter *FilterTree `protobuf:"bytes,9,opt,name=facets_filter,json=facetsFilter,proto3" json:"facets_filter,omitempty"` // filtering on facets : has Op (and/or/not) tree
ExpandAll bool `protobuf:"varint,10,opt,name=expand_all,json=expandAll,proto3" json:"expand_all,omitempty"` // expand all language variants.
ReadTs uint64 `protobuf:"varint,13,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
Cache int32 `protobuf:"varint,14,opt,name=cache,proto3" json:"cache,omitempty"`
First int32 `protobuf:"varint,15,opt,name=first,proto3" json:"first,omitempty"` // used to limit the number of result. Typically, the count is value of first
// field. Now, It's been used only for has query.
Offset int32 `protobuf:"varint,16,opt,name=offset,proto3" json:"offset,omitempty"` // offset helps in fetching lesser results for the has query when there is
// contains filtered or unexported fields
}
func (*Query) Descriptor
deprecated
func (*Query) GetAfterUid ¶
func (*Query) GetDoCount ¶
func (*Query) GetExpandAll ¶
func (*Query) GetFacetParam ¶
func (x *Query) GetFacetParam() *FacetParams
func (*Query) GetFacetsFilter ¶
func (x *Query) GetFacetsFilter() *FilterTree
func (*Query) GetReverse ¶
func (*Query) GetSrcFunc ¶
func (x *Query) GetSrcFunc() *SrcFunction
func (*Query) GetUidList ¶
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type RaftBatch ¶
type RaftBatch struct {
Context *RaftContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
Payload *api.Payload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
// contains filtered or unexported fields
}
func (*RaftBatch) Descriptor
deprecated
func (*RaftBatch) GetContext ¶
func (x *RaftBatch) GetContext() *RaftContext
func (*RaftBatch) GetPayload ¶
func (*RaftBatch) ProtoMessage ¶
func (*RaftBatch) ProtoMessage()
func (*RaftBatch) ProtoReflect ¶
func (x *RaftBatch) ProtoReflect() protoreflect.Message
type RaftClient ¶
type RaftClient interface {
Heartbeat(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (Raft_HeartbeatClient, error)
RaftMessage(ctx context.Context, opts ...grpc.CallOption) (Raft_RaftMessageClient, error)
JoinCluster(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*api.Payload, error)
IsPeer(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*PeerResponse, error)
}
RaftClient is the client API for Raft service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRaftClient ¶
func NewRaftClient(cc grpc.ClientConnInterface) 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"`
IsLearner bool `protobuf:"varint,5,opt,name=is_learner,json=isLearner,proto3" json:"is_learner,omitempty"`
// contains filtered or unexported fields
}
func (*RaftContext) Descriptor
deprecated
func (*RaftContext) Descriptor() ([]byte, []int)
Deprecated: Use RaftContext.ProtoReflect.Descriptor instead.
func (*RaftContext) GetAddr ¶
func (x *RaftContext) GetAddr() string
func (*RaftContext) GetGroup ¶
func (x *RaftContext) GetGroup() uint32
func (*RaftContext) GetId ¶
func (x *RaftContext) GetId() uint64
func (*RaftContext) GetIsLearner ¶
func (x *RaftContext) GetIsLearner() bool
func (*RaftContext) GetSnapshotTs ¶
func (x *RaftContext) GetSnapshotTs() uint64
func (*RaftContext) ProtoMessage ¶
func (*RaftContext) ProtoMessage()
func (*RaftContext) ProtoReflect ¶
func (x *RaftContext) ProtoReflect() protoreflect.Message
func (*RaftContext) Reset ¶
func (x *RaftContext) Reset()
func (*RaftContext) String ¶
func (x *RaftContext) String() string
type RaftServer ¶
type RaftServer interface {
Heartbeat(*api.Payload, Raft_HeartbeatServer) error
RaftMessage(Raft_RaftMessageServer) error
JoinCluster(context.Context, *RaftContext) (*api.Payload, error)
IsPeer(context.Context, *RaftContext) (*PeerResponse, error)
// contains filtered or unexported methods
}
RaftServer is the server API for Raft service. All implementations must embed UnimplementedRaftServer for forward compatibility
type Raft_HeartbeatClient ¶
type Raft_HeartbeatClient interface {
Recv() (*HealthInfo, error)
grpc.ClientStream
}
type Raft_HeartbeatServer ¶
type Raft_HeartbeatServer interface {
Send(*HealthInfo) error
grpc.ServerStream
}
type Raft_RaftMessageClient ¶
type Raft_RaftMessageServer ¶
type RemoveNodeRequest ¶
type RemoveNodeRequest struct {
NodeId uint64 `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
GroupId uint32 `protobuf:"varint,2,opt,name=groupId,proto3" json:"groupId,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveNodeRequest) Descriptor
deprecated
func (*RemoveNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.
func (*RemoveNodeRequest) GetGroupId ¶
func (x *RemoveNodeRequest) GetGroupId() uint32
func (*RemoveNodeRequest) GetNodeId ¶
func (x *RemoveNodeRequest) GetNodeId() uint64
func (*RemoveNodeRequest) ProtoMessage ¶
func (*RemoveNodeRequest) ProtoMessage()
func (*RemoveNodeRequest) ProtoReflect ¶
func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message
func (*RemoveNodeRequest) Reset ¶
func (x *RemoveNodeRequest) Reset()
func (*RemoveNodeRequest) String ¶
func (x *RemoveNodeRequest) String() string
type RestoreRequest ¶
type RestoreRequest struct {
GroupId uint32 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
RestoreTs uint64 `protobuf:"varint,2,opt,name=restore_ts,json=restoreTs,proto3" json:"restore_ts,omitempty"`
Location string `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
BackupId string `protobuf:"bytes,4,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
// Credentials when using a minio or S3 bucket as the backup location.
AccessKey string `protobuf:"bytes,5,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
SecretKey Sensitive `protobuf:"bytes,6,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
SessionToken Sensitive `protobuf:"bytes,7,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`
Anonymous bool `protobuf:"varint,8,opt,name=anonymous,proto3" json:"anonymous,omitempty"`
// Info needed to process encrypted backups.
EncryptionKeyFile string `protobuf:"bytes,9,opt,name=encryption_key_file,json=encryptionKeyFile,proto3" json:"encryption_key_file,omitempty"`
// Vault options
VaultAddr string `protobuf:"bytes,10,opt,name=vault_addr,json=vaultAddr,proto3" json:"vault_addr,omitempty"`
VaultRoleidFile string `protobuf:"bytes,11,opt,name=vault_roleid_file,json=vaultRoleidFile,proto3" json:"vault_roleid_file,omitempty"`
VaultSecretidFile string `protobuf:"bytes,12,opt,name=vault_secretid_file,json=vaultSecretidFile,proto3" json:"vault_secretid_file,omitempty"`
VaultPath string `protobuf:"bytes,13,opt,name=vault_path,json=vaultPath,proto3" json:"vault_path,omitempty"`
VaultField string `protobuf:"bytes,14,opt,name=vault_field,json=vaultField,proto3" json:"vault_field,omitempty"`
VaultFormat string `protobuf:"bytes,15,opt,name=vault_format,json=vaultFormat,proto3" json:"vault_format,omitempty"`
BackupNum uint64 `protobuf:"varint,16,opt,name=backup_num,json=backupNum,proto3" json:"backup_num,omitempty"`
IncrementalFrom uint64 `protobuf:"varint,17,opt,name=incremental_from,json=incrementalFrom,proto3" json:"incremental_from,omitempty"`
IsPartial bool `protobuf:"varint,18,opt,name=is_partial,json=isPartial,proto3" json:"is_partial,omitempty"`
FromNamespace uint64 `protobuf:"varint,19,opt,name=fromNamespace,proto3" json:"fromNamespace,omitempty"`
IsNamespaceAwareRestore bool `protobuf:"varint,20,opt,name=isNamespaceAwareRestore,proto3" json:"isNamespaceAwareRestore,omitempty"`
// contains filtered or unexported fields
}
func (*RestoreRequest) Descriptor
deprecated
func (*RestoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.
func (*RestoreRequest) GetAccessKey ¶
func (x *RestoreRequest) GetAccessKey() string
func (*RestoreRequest) GetAnonymous ¶
func (x *RestoreRequest) GetAnonymous() bool
func (*RestoreRequest) GetBackupId ¶
func (x *RestoreRequest) GetBackupId() string
func (*RestoreRequest) GetBackupNum ¶
func (x *RestoreRequest) GetBackupNum() uint64
func (*RestoreRequest) GetEncryptionKeyFile ¶
func (x *RestoreRequest) GetEncryptionKeyFile() string
func (*RestoreRequest) GetFromNamespace ¶
func (x *RestoreRequest) GetFromNamespace() uint64
func (*RestoreRequest) GetGroupId ¶
func (x *RestoreRequest) GetGroupId() uint32
func (*RestoreRequest) GetIncrementalFrom ¶
func (x *RestoreRequest) GetIncrementalFrom() uint64
func (*RestoreRequest) GetIsNamespaceAwareRestore ¶
func (x *RestoreRequest) GetIsNamespaceAwareRestore() bool
func (*RestoreRequest) GetIsPartial ¶
func (x *RestoreRequest) GetIsPartial() bool
func (*RestoreRequest) GetLocation ¶
func (x *RestoreRequest) GetLocation() string
func (*RestoreRequest) GetRestoreTs ¶
func (x *RestoreRequest) GetRestoreTs() uint64
func (*RestoreRequest) GetSecretKey ¶
func (x *RestoreRequest) GetSecretKey() Sensitive
func (*RestoreRequest) GetSessionToken ¶
func (x *RestoreRequest) GetSessionToken() Sensitive
func (*RestoreRequest) GetVaultAddr ¶
func (x *RestoreRequest) GetVaultAddr() string
func (*RestoreRequest) GetVaultField ¶
func (x *RestoreRequest) GetVaultField() string
func (*RestoreRequest) GetVaultFormat ¶
func (x *RestoreRequest) GetVaultFormat() string
func (*RestoreRequest) GetVaultPath ¶
func (x *RestoreRequest) GetVaultPath() string
func (*RestoreRequest) GetVaultRoleidFile ¶
func (x *RestoreRequest) GetVaultRoleidFile() string
func (*RestoreRequest) GetVaultSecretidFile ¶
func (x *RestoreRequest) GetVaultSecretidFile() string
func (*RestoreRequest) ProtoMessage ¶
func (*RestoreRequest) ProtoMessage()
func (*RestoreRequest) ProtoReflect ¶
func (x *RestoreRequest) ProtoReflect() protoreflect.Message
func (*RestoreRequest) Reset ¶
func (x *RestoreRequest) Reset()
func (*RestoreRequest) String ¶
func (x *RestoreRequest) String() string
type Result ¶
type Result struct {
UidMatrix []*List `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix,proto3" json:"uid_matrix,omitempty"`
ValueMatrix []*ValueList `protobuf:"bytes,2,rep,name=value_matrix,json=valueMatrix,proto3" json:"value_matrix,omitempty"`
Counts []uint32 `protobuf:"varint,3,rep,packed,name=counts,proto3" 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,proto3" json:"facet_matrix,omitempty"`
LangMatrix []*LangList `protobuf:"bytes,6,rep,name=lang_matrix,json=langMatrix,proto3" json:"lang_matrix,omitempty"`
List bool `protobuf:"varint,7,opt,name=list,proto3" json:"list,omitempty"`
VectorMetrics map[string]uint64 `` /* 189-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*Result) Descriptor
deprecated
func (*Result) GetFacetMatrix ¶
func (x *Result) GetFacetMatrix() []*FacetsList
func (*Result) GetIntersectDest ¶
func (*Result) GetLangMatrix ¶
func (*Result) GetUidMatrix ¶
func (*Result) GetValueMatrix ¶
func (*Result) GetVectorMetrics ¶
func (*Result) ProtoMessage ¶
func (*Result) ProtoMessage()
func (*Result) ProtoReflect ¶
func (x *Result) ProtoReflect() protoreflect.Message
type SchemaNode ¶
type SchemaNode struct {
Predicate string `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Index bool `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
Tokenizer []string `protobuf:"bytes,4,rep,name=tokenizer,proto3" json:"tokenizer,omitempty"`
Reverse bool `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
Count bool `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
List bool `protobuf:"varint,7,opt,name=list,proto3" json:"list,omitempty"`
Upsert bool `protobuf:"varint,8,opt,name=upsert,proto3" json:"upsert,omitempty"`
Lang bool `protobuf:"varint,9,opt,name=lang,proto3" json:"lang,omitempty"`
NoConflict bool `protobuf:"varint,10,opt,name=no_conflict,json=noConflict,proto3" json:"no_conflict,omitempty"`
Unique bool `protobuf:"varint,11,opt,name=unique,proto3" json:"unique,omitempty"`
IndexSpecs []*VectorIndexSpec `protobuf:"bytes,12,rep,name=index_specs,json=indexSpecs,proto3" json:"index_specs,omitempty"`
// contains filtered or unexported fields
}
func (*SchemaNode) Descriptor
deprecated
func (*SchemaNode) Descriptor() ([]byte, []int)
Deprecated: Use SchemaNode.ProtoReflect.Descriptor instead.
func (*SchemaNode) GetCount ¶
func (x *SchemaNode) GetCount() bool
func (*SchemaNode) GetIndex ¶
func (x *SchemaNode) GetIndex() bool
func (*SchemaNode) GetIndexSpecs ¶
func (x *SchemaNode) GetIndexSpecs() []*VectorIndexSpec
func (*SchemaNode) GetLang ¶
func (x *SchemaNode) GetLang() bool
func (*SchemaNode) GetList ¶
func (x *SchemaNode) GetList() bool
func (*SchemaNode) GetNoConflict ¶
func (x *SchemaNode) GetNoConflict() bool
func (*SchemaNode) GetPredicate ¶
func (x *SchemaNode) GetPredicate() string
func (*SchemaNode) GetReverse ¶
func (x *SchemaNode) GetReverse() bool
func (*SchemaNode) GetTokenizer ¶
func (x *SchemaNode) GetTokenizer() []string
func (*SchemaNode) GetType ¶
func (x *SchemaNode) GetType() string
func (*SchemaNode) GetUnique ¶
func (x *SchemaNode) GetUnique() bool
func (*SchemaNode) GetUpsert ¶
func (x *SchemaNode) GetUpsert() bool
func (*SchemaNode) ProtoMessage ¶
func (*SchemaNode) ProtoMessage()
func (*SchemaNode) ProtoReflect ¶
func (x *SchemaNode) ProtoReflect() protoreflect.Message
func (*SchemaNode) Reset ¶
func (x *SchemaNode) Reset()
func (*SchemaNode) String ¶
func (x *SchemaNode) String() string
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,proto3" json:"predicates,omitempty"`
// fields can be on of type, index, reverse or tokenizer
Fields []string `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
Types []string `protobuf:"bytes,4,rep,name=types,proto3" json:"types,omitempty"`
// contains filtered or unexported fields
}
Schema messages.
func (*SchemaRequest) Descriptor
deprecated
func (*SchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use SchemaRequest.ProtoReflect.Descriptor instead.
func (*SchemaRequest) GetFields ¶
func (x *SchemaRequest) GetFields() []string
func (*SchemaRequest) GetGroupId ¶
func (x *SchemaRequest) GetGroupId() uint32
func (*SchemaRequest) GetPredicates ¶
func (x *SchemaRequest) GetPredicates() []string
func (*SchemaRequest) GetTypes ¶
func (x *SchemaRequest) GetTypes() []string
func (*SchemaRequest) ProtoMessage ¶
func (*SchemaRequest) ProtoMessage()
func (*SchemaRequest) ProtoReflect ¶
func (x *SchemaRequest) ProtoReflect() protoreflect.Message
func (*SchemaRequest) Reset ¶
func (x *SchemaRequest) Reset()
func (*SchemaRequest) String ¶
func (x *SchemaRequest) String() string
type SchemaResult ¶
type SchemaResult struct {
// Deprecated: Marked as deprecated in pb.proto.
Schema []*SchemaNode `protobuf:"bytes,1,rep,name=schema,proto3" json:"schema,omitempty"`
// contains filtered or unexported fields
}
func (*SchemaResult) Descriptor
deprecated
func (*SchemaResult) Descriptor() ([]byte, []int)
Deprecated: Use SchemaResult.ProtoReflect.Descriptor instead.
func (*SchemaResult) GetSchema
deprecated
func (x *SchemaResult) GetSchema() []*SchemaNode
Deprecated: Marked as deprecated in pb.proto.
func (*SchemaResult) ProtoMessage ¶
func (*SchemaResult) ProtoMessage()
func (*SchemaResult) ProtoReflect ¶
func (x *SchemaResult) ProtoReflect() protoreflect.Message
func (*SchemaResult) Reset ¶
func (x *SchemaResult) Reset()
func (*SchemaResult) String ¶
func (x *SchemaResult) String() string
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=pb.Posting_ValType" json:"value_type,omitempty"`
Directive SchemaUpdate_Directive `protobuf:"varint,3,opt,name=directive,proto3,enum=pb.SchemaUpdate_Directive" json:"directive,omitempty"`
Tokenizer []string `protobuf:"bytes,4,rep,name=tokenizer,proto3" 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"`
Lang bool `protobuf:"varint,9,opt,name=lang,proto3" json:"lang,omitempty"`
Unique bool `protobuf:"varint,14,opt,name=unique,proto3" json:"unique,omitempty"`
// Fields required for type system.
NonNullable bool `protobuf:"varint,10,opt,name=non_nullable,json=nonNullable,proto3" json:"non_nullable,omitempty"`
NonNullableList bool `protobuf:"varint,11,opt,name=non_nullable_list,json=nonNullableList,proto3" json:"non_nullable_list,omitempty"`
// If value_type is OBJECT, then this represents an object type with a
// custom name. This field stores said name.
ObjectTypeName string `protobuf:"bytes,12,opt,name=object_type_name,json=objectTypeName,proto3" json:"object_type_name,omitempty"`
NoConflict bool `protobuf:"varint,13,opt,name=no_conflict,json=noConflict,proto3" json:"no_conflict,omitempty"`
IndexSpecs []*VectorIndexSpec `protobuf:"bytes,15,rep,name=index_specs,json=indexSpecs,proto3" json:"index_specs,omitempty"`
// contains filtered or unexported fields
}
func (*SchemaUpdate) Descriptor
deprecated
func (*SchemaUpdate) Descriptor() ([]byte, []int)
Deprecated: Use SchemaUpdate.ProtoReflect.Descriptor instead.
func (*SchemaUpdate) GetCount ¶
func (x *SchemaUpdate) GetCount() bool
func (*SchemaUpdate) GetDirective ¶
func (x *SchemaUpdate) GetDirective() SchemaUpdate_Directive
func (*SchemaUpdate) GetIndexSpecs ¶
func (x *SchemaUpdate) GetIndexSpecs() []*VectorIndexSpec
func (*SchemaUpdate) GetLang ¶
func (x *SchemaUpdate) GetLang() bool
func (*SchemaUpdate) GetList ¶
func (x *SchemaUpdate) GetList() bool
func (*SchemaUpdate) GetNoConflict ¶
func (x *SchemaUpdate) GetNoConflict() bool
func (*SchemaUpdate) GetNonNullable ¶
func (x *SchemaUpdate) GetNonNullable() bool
func (*SchemaUpdate) GetNonNullableList ¶
func (x *SchemaUpdate) GetNonNullableList() bool
func (*SchemaUpdate) GetObjectTypeName ¶
func (x *SchemaUpdate) GetObjectTypeName() string
func (*SchemaUpdate) GetPredicate ¶
func (x *SchemaUpdate) GetPredicate() string
func (*SchemaUpdate) GetTokenizer ¶
func (x *SchemaUpdate) GetTokenizer() []string
func (*SchemaUpdate) GetUnique ¶
func (x *SchemaUpdate) GetUnique() bool
func (*SchemaUpdate) GetUpsert ¶
func (x *SchemaUpdate) GetUpsert() bool
func (*SchemaUpdate) GetValueType ¶
func (x *SchemaUpdate) GetValueType() Posting_ValType
func (*SchemaUpdate) ProtoMessage ¶
func (*SchemaUpdate) ProtoMessage()
func (*SchemaUpdate) ProtoReflect ¶
func (x *SchemaUpdate) ProtoReflect() protoreflect.Message
func (*SchemaUpdate) Reset ¶
func (x *SchemaUpdate) Reset()
func (*SchemaUpdate) String ¶
func (x *SchemaUpdate) String() string
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) Descriptor ¶
func (SchemaUpdate_Directive) Descriptor() protoreflect.EnumDescriptor
func (SchemaUpdate_Directive) Enum ¶
func (x SchemaUpdate_Directive) Enum() *SchemaUpdate_Directive
func (SchemaUpdate_Directive) EnumDescriptor
deprecated
func (SchemaUpdate_Directive) EnumDescriptor() ([]byte, []int)
Deprecated: Use SchemaUpdate_Directive.Descriptor instead.
func (SchemaUpdate_Directive) Number ¶
func (x SchemaUpdate_Directive) Number() protoreflect.EnumNumber
func (SchemaUpdate_Directive) String ¶
func (x SchemaUpdate_Directive) String() string
func (SchemaUpdate_Directive) Type ¶
func (SchemaUpdate_Directive) Type() protoreflect.EnumType
type Sensitive ¶
type Sensitive string
Sensitive implements the Stringer interface to redact its contents. Use this type for sensitive info such as keys, passwords, or secrets so it doesn't leak as output such as logs.
type Snapshot ¶
type Snapshot struct {
Context *RaftContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
ReadTs uint64 `protobuf:"varint,3,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
// done is used to indicate that snapshot stream was a success.
Done bool `protobuf:"varint,4,opt,name=done,proto3" json:"done,omitempty"`
// since_ts stores the ts of the last snapshot to support diff snap updates.
SinceTs uint64 `protobuf:"varint,5,opt,name=since_ts,json=sinceTs,proto3" json:"since_ts,omitempty"`
// contains filtered or unexported fields
}
func (*Snapshot) Descriptor
deprecated
func (*Snapshot) GetContext ¶
func (x *Snapshot) GetContext() *RaftContext
func (*Snapshot) GetSinceTs ¶
func (*Snapshot) ProtoMessage ¶
func (*Snapshot) ProtoMessage()
func (*Snapshot) ProtoReflect ¶
func (x *Snapshot) ProtoReflect() protoreflect.Message
type SnapshotMeta ¶
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"`
// contains filtered or unexported fields
}
func (*SnapshotMeta) Descriptor
deprecated
func (*SnapshotMeta) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotMeta.ProtoReflect.Descriptor instead.
func (*SnapshotMeta) GetClientTs ¶
func (x *SnapshotMeta) GetClientTs() uint64
func (*SnapshotMeta) GetGroupId ¶
func (x *SnapshotMeta) GetGroupId() uint32
func (*SnapshotMeta) ProtoMessage ¶
func (*SnapshotMeta) ProtoMessage()
func (*SnapshotMeta) ProtoReflect ¶
func (x *SnapshotMeta) ProtoReflect() protoreflect.Message
func (*SnapshotMeta) Reset ¶
func (x *SnapshotMeta) Reset()
func (*SnapshotMeta) String ¶
func (x *SnapshotMeta) String() string
type SortMessage ¶
type SortMessage struct {
Order []*Order `protobuf:"bytes,1,rep,name=order,proto3" json:"order,omitempty"`
UidMatrix []*List `protobuf:"bytes,2,rep,name=uid_matrix,json=uidMatrix,proto3" json:"uid_matrix,omitempty"`
Count int32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` // Return this many elements.
Offset int32 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` // Skip this many elements.
ReadTs uint64 `protobuf:"varint,13,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
// contains filtered or unexported fields
}
func (*SortMessage) Descriptor
deprecated
func (*SortMessage) Descriptor() ([]byte, []int)
Deprecated: Use SortMessage.ProtoReflect.Descriptor instead.
func (*SortMessage) GetCount ¶
func (x *SortMessage) GetCount() int32
func (*SortMessage) GetOffset ¶
func (x *SortMessage) GetOffset() int32
func (*SortMessage) GetOrder ¶
func (x *SortMessage) GetOrder() []*Order
func (*SortMessage) GetReadTs ¶
func (x *SortMessage) GetReadTs() uint64
func (*SortMessage) GetUidMatrix ¶
func (x *SortMessage) GetUidMatrix() []*List
func (*SortMessage) ProtoMessage ¶
func (*SortMessage) ProtoMessage()
func (*SortMessage) ProtoReflect ¶
func (x *SortMessage) ProtoReflect() protoreflect.Message
func (*SortMessage) Reset ¶
func (x *SortMessage) Reset()
func (*SortMessage) String ¶
func (x *SortMessage) String() string
type SortResult ¶
type SortResult struct {
UidMatrix []*List `protobuf:"bytes,1,rep,name=uid_matrix,json=uidMatrix,proto3" json:"uid_matrix,omitempty"`
// contains filtered or unexported fields
}
func (*SortResult) Descriptor
deprecated
func (*SortResult) Descriptor() ([]byte, []int)
Deprecated: Use SortResult.ProtoReflect.Descriptor instead.
func (*SortResult) GetUidMatrix ¶
func (x *SortResult) GetUidMatrix() []*List
func (*SortResult) ProtoMessage ¶
func (*SortResult) ProtoMessage()
func (*SortResult) ProtoReflect ¶
func (x *SortResult) ProtoReflect() protoreflect.Message
func (*SortResult) Reset ¶
func (x *SortResult) Reset()
func (*SortResult) String ¶
func (x *SortResult) String() string
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,proto3" json:"args,omitempty"`
IsCount bool `protobuf:"varint,4,opt,name=isCount,proto3" json:"isCount,omitempty"`
// contains filtered or unexported fields
}
func (*SrcFunction) Descriptor
deprecated
func (*SrcFunction) Descriptor() ([]byte, []int)
Deprecated: Use SrcFunction.ProtoReflect.Descriptor instead.
func (*SrcFunction) GetArgs ¶
func (x *SrcFunction) GetArgs() []string
func (*SrcFunction) GetIsCount ¶
func (x *SrcFunction) GetIsCount() bool
func (*SrcFunction) GetName ¶
func (x *SrcFunction) GetName() string
func (*SrcFunction) ProtoMessage ¶
func (*SrcFunction) ProtoMessage()
func (*SrcFunction) ProtoReflect ¶
func (x *SrcFunction) ProtoReflect() protoreflect.Message
func (*SrcFunction) Reset ¶
func (x *SrcFunction) Reset()
func (*SrcFunction) String ¶
func (x *SrcFunction) String() string
type Status ¶
type Status struct {
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
// contains filtered or unexported fields
}
Status describes a general status response. code: 0 = success, 0 != failure.
func (*Status) Descriptor
deprecated
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type SubscriptionRequest ¶
type SubscriptionRequest struct {
Prefixes [][]byte `protobuf:"bytes,1,rep,name=prefixes,proto3" json:"prefixes,omitempty"`
Matches []*pb.Match `protobuf:"bytes,2,rep,name=matches,proto3" json:"matches,omitempty"`
// contains filtered or unexported fields
}
func (*SubscriptionRequest) Descriptor
deprecated
func (*SubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.
func (*SubscriptionRequest) GetMatches ¶
func (x *SubscriptionRequest) GetMatches() []*pb.Match
func (*SubscriptionRequest) GetPrefixes ¶
func (x *SubscriptionRequest) GetPrefixes() [][]byte
func (*SubscriptionRequest) ProtoMessage ¶
func (*SubscriptionRequest) ProtoMessage()
func (*SubscriptionRequest) ProtoReflect ¶
func (x *SubscriptionRequest) ProtoReflect() protoreflect.Message
func (*SubscriptionRequest) Reset ¶
func (x *SubscriptionRequest) Reset()
func (*SubscriptionRequest) String ¶
func (x *SubscriptionRequest) String() string
type SubscriptionResponse ¶
type SubscriptionResponse struct {
Kvs *pb.KVList `protobuf:"bytes,1,opt,name=kvs,proto3" json:"kvs,omitempty"`
// contains filtered or unexported fields
}
func (*SubscriptionResponse) Descriptor
deprecated
func (*SubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionResponse.ProtoReflect.Descriptor instead.
func (*SubscriptionResponse) GetKvs ¶
func (x *SubscriptionResponse) GetKvs() *pb.KVList
func (*SubscriptionResponse) ProtoMessage ¶
func (*SubscriptionResponse) ProtoMessage()
func (*SubscriptionResponse) ProtoReflect ¶
func (x *SubscriptionResponse) ProtoReflect() protoreflect.Message
func (*SubscriptionResponse) Reset ¶
func (x *SubscriptionResponse) Reset()
func (*SubscriptionResponse) String ¶
func (x *SubscriptionResponse) String() string
type Tablet ¶
type Tablet struct {
GroupId uint32 `protobuf:"varint,1,opt,name=groupId,proto3" json:"groupId,omitempty"` // Served by which group.
Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"` // Used while moving predicate.
OnDiskBytes int64 `protobuf:"varint,7,opt,name=on_disk_bytes,json=onDiskBytes,proto3" json:"on_disk_bytes,omitempty"`
Remove bool `protobuf:"varint,8,opt,name=remove,proto3" json:"remove,omitempty"`
ReadOnly bool `protobuf:"varint,9,opt,name=readOnly,proto3" json:"readOnly,omitempty"` // If true, do not ask zero to serve any tablets.
MoveTs uint64 `protobuf:"varint,10,opt,name=moveTs,proto3" json:"moveTs,omitempty"`
UncompressedBytes int64 `protobuf:"varint,11,opt,name=uncompressed_bytes,json=uncompressedBytes,proto3" json:"uncompressed_bytes,omitempty"` // Estimated uncompressed size of tablet in bytes
// contains filtered or unexported fields
}
func (*Tablet) Descriptor
deprecated
func (*Tablet) GetGroupId ¶
func (*Tablet) GetOnDiskBytes ¶
func (*Tablet) GetPredicate ¶
func (*Tablet) GetReadOnly ¶
func (*Tablet) GetUncompressedBytes ¶
func (*Tablet) ProtoMessage ¶
func (*Tablet) ProtoMessage()
func (*Tablet) ProtoReflect ¶
func (x *Tablet) ProtoReflect() protoreflect.Message
type TabletRequest ¶
type TabletRequest struct {
Tablets []*Tablet `protobuf:"bytes,1,rep,name=tablets,proto3" json:"tablets,omitempty"`
GroupId uint32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
// contains filtered or unexported fields
}
func (*TabletRequest) Descriptor
deprecated
func (*TabletRequest) Descriptor() ([]byte, []int)
Deprecated: Use TabletRequest.ProtoReflect.Descriptor instead.
func (*TabletRequest) GetGroupId ¶
func (x *TabletRequest) GetGroupId() uint32
func (*TabletRequest) GetTablets ¶
func (x *TabletRequest) GetTablets() []*Tablet
func (*TabletRequest) ProtoMessage ¶
func (*TabletRequest) ProtoMessage()
func (*TabletRequest) ProtoReflect ¶
func (x *TabletRequest) ProtoReflect() protoreflect.Message
func (*TabletRequest) Reset ¶
func (x *TabletRequest) Reset()
func (*TabletRequest) String ¶
func (x *TabletRequest) String() string
type TabletResponse ¶
type TabletResponse struct {
Tablets []*Tablet `protobuf:"bytes,1,rep,name=tablets,proto3" json:"tablets,omitempty"`
// contains filtered or unexported fields
}
func (*TabletResponse) Descriptor
deprecated
func (*TabletResponse) Descriptor() ([]byte, []int)
Deprecated: Use TabletResponse.ProtoReflect.Descriptor instead.
func (*TabletResponse) GetTablets ¶
func (x *TabletResponse) GetTablets() []*Tablet
func (*TabletResponse) ProtoMessage ¶
func (*TabletResponse) ProtoMessage()
func (*TabletResponse) ProtoReflect ¶
func (x *TabletResponse) ProtoReflect() protoreflect.Message
func (*TabletResponse) Reset ¶
func (x *TabletResponse) Reset()
func (*TabletResponse) String ¶
func (x *TabletResponse) String() string
type TaskStatusRequest ¶
type TaskStatusRequest struct {
TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
// contains filtered or unexported fields
}
func (*TaskStatusRequest) Descriptor
deprecated
func (*TaskStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use TaskStatusRequest.ProtoReflect.Descriptor instead.
func (*TaskStatusRequest) GetTaskId ¶
func (x *TaskStatusRequest) GetTaskId() uint64
func (*TaskStatusRequest) ProtoMessage ¶
func (*TaskStatusRequest) ProtoMessage()
func (*TaskStatusRequest) ProtoReflect ¶
func (x *TaskStatusRequest) ProtoReflect() protoreflect.Message
func (*TaskStatusRequest) Reset ¶
func (x *TaskStatusRequest) Reset()
func (*TaskStatusRequest) String ¶
func (x *TaskStatusRequest) String() string
type TaskStatusResponse ¶
type TaskStatusResponse struct {
TaskMeta uint64 `protobuf:"varint,1,opt,name=task_meta,json=taskMeta,proto3" json:"task_meta,omitempty"`
// contains filtered or unexported fields
}
func (*TaskStatusResponse) Descriptor
deprecated
func (*TaskStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaskStatusResponse.ProtoReflect.Descriptor instead.
func (*TaskStatusResponse) GetTaskMeta ¶
func (x *TaskStatusResponse) GetTaskMeta() uint64
func (*TaskStatusResponse) ProtoMessage ¶
func (*TaskStatusResponse) ProtoMessage()
func (*TaskStatusResponse) ProtoReflect ¶
func (x *TaskStatusResponse) ProtoReflect() protoreflect.Message
func (*TaskStatusResponse) Reset ¶
func (x *TaskStatusResponse) Reset()
func (*TaskStatusResponse) String ¶
func (x *TaskStatusResponse) String() string
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=pb.Posting_ValType" json:"val_type,omitempty"`
// contains filtered or unexported fields
}
func (*TaskValue) Descriptor
deprecated
func (*TaskValue) GetValType ¶
func (x *TaskValue) GetValType() Posting_ValType
func (*TaskValue) ProtoMessage ¶
func (*TaskValue) ProtoMessage()
func (*TaskValue) ProtoReflect ¶
func (x *TaskValue) ProtoReflect() protoreflect.Message
type TxnStatus ¶
type TxnStatus struct {
StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
CommitTs uint64 `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
// contains filtered or unexported fields
}
func (*TxnStatus) Descriptor
deprecated
func (*TxnStatus) GetCommitTs ¶
func (*TxnStatus) GetStartTs ¶
func (*TxnStatus) ProtoMessage ¶
func (*TxnStatus) ProtoMessage()
func (*TxnStatus) ProtoReflect ¶
func (x *TxnStatus) ProtoReflect() protoreflect.Message
type TxnTimestamps ¶
type TxnTimestamps struct {
Ts []uint64 `protobuf:"varint,1,rep,packed,name=ts,proto3" json:"ts,omitempty"`
// contains filtered or unexported fields
}
func (*TxnTimestamps) Descriptor
deprecated
func (*TxnTimestamps) Descriptor() ([]byte, []int)
Deprecated: Use TxnTimestamps.ProtoReflect.Descriptor instead.
func (*TxnTimestamps) GetTs ¶
func (x *TxnTimestamps) GetTs() []uint64
func (*TxnTimestamps) ProtoMessage ¶
func (*TxnTimestamps) ProtoMessage()
func (*TxnTimestamps) ProtoReflect ¶
func (x *TxnTimestamps) ProtoReflect() protoreflect.Message
func (*TxnTimestamps) Reset ¶
func (x *TxnTimestamps) Reset()
func (*TxnTimestamps) String ¶
func (x *TxnTimestamps) String() string
type TypeUpdate ¶
type TypeUpdate struct {
TypeName string `protobuf:"bytes,1,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
Fields []*SchemaUpdate `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
// contains filtered or unexported fields
}
func (*TypeUpdate) Descriptor
deprecated
func (*TypeUpdate) Descriptor() ([]byte, []int)
Deprecated: Use TypeUpdate.ProtoReflect.Descriptor instead.
func (*TypeUpdate) GetFields ¶
func (x *TypeUpdate) GetFields() []*SchemaUpdate
func (*TypeUpdate) GetTypeName ¶
func (x *TypeUpdate) GetTypeName() string
func (*TypeUpdate) ProtoMessage ¶
func (*TypeUpdate) ProtoMessage()
func (*TypeUpdate) ProtoReflect ¶
func (x *TypeUpdate) ProtoReflect() protoreflect.Message
func (*TypeUpdate) Reset ¶
func (x *TypeUpdate) Reset()
func (*TypeUpdate) String ¶
func (x *TypeUpdate) String() string
type UidBlock ¶
type UidBlock struct {
Base uint64 `protobuf:"varint,1,opt,name=base,proto3" json:"base,omitempty"`
// deltas contains the deltas encoded with Varints. We don't store deltas as a
// list of integers, because when the PB is brought to memory, Go would always
// use 8-bytes per integer. Instead, storing it as a byte slice is a lot
// cheaper in memory.
Deltas []byte `protobuf:"bytes,2,opt,name=deltas,proto3" json:"deltas,omitempty"`
// num_uids is the number of UIDs in the block. We are including this because
// we want to switch encoding to groupvarint encoding. Current avaialble open
// source version implements encoding and decoding for uint32. To use that, we
// create different blocks for different 32-bit MSB base uids. That is, if the
// 32 MSBs are different, we will create a new block irrespective of whether
// the block is filled with the block_size or not. Default Blocksize is 256 so
// uint32 would be sufficient.
NumUids uint32 `protobuf:"varint,3,opt,name=num_uids,json=numUids,proto3" json:"num_uids,omitempty"`
// contains filtered or unexported fields
}
func (*UidBlock) Descriptor
deprecated
func (*UidBlock) GetNumUids ¶
func (*UidBlock) ProtoMessage ¶
func (*UidBlock) ProtoMessage()
func (*UidBlock) ProtoReflect ¶
func (x *UidBlock) ProtoReflect() protoreflect.Message
type UidPack ¶
type UidPack struct {
BlockSize uint32 `protobuf:"varint,1,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
Blocks []*UidBlock `protobuf:"bytes,2,rep,name=blocks,proto3" json:"blocks,omitempty"`
AllocRef uint64 `protobuf:"varint,23,opt,name=alloc_ref,json=allocRef,proto3" json:"alloc_ref,omitempty"` // This field should be set to 0 during marshal.
// contains filtered or unexported fields
}
func (*UidPack) Descriptor
deprecated
func (*UidPack) GetAllocRef ¶
func (*UidPack) GetBlockSize ¶
func (*UidPack) ProtoMessage ¶
func (*UidPack) ProtoMessage()
func (*UidPack) ProtoReflect ¶
func (x *UidPack) ProtoReflect() protoreflect.Message
type UnimplementedRaftServer ¶
type UnimplementedRaftServer struct {
}
UnimplementedRaftServer must be embedded to have forward compatible implementations.
func (UnimplementedRaftServer) Heartbeat ¶
func (UnimplementedRaftServer) Heartbeat(*api.Payload, Raft_HeartbeatServer) error
func (UnimplementedRaftServer) IsPeer ¶
func (UnimplementedRaftServer) IsPeer(context.Context, *RaftContext) (*PeerResponse, error)
func (UnimplementedRaftServer) JoinCluster ¶
func (UnimplementedRaftServer) JoinCluster(context.Context, *RaftContext) (*api.Payload, error)
func (UnimplementedRaftServer) RaftMessage ¶
func (UnimplementedRaftServer) RaftMessage(Raft_RaftMessageServer) error
type UnimplementedWorkerServer ¶
type UnimplementedWorkerServer struct {
}
UnimplementedWorkerServer must be embedded to have forward compatible implementations.
func (UnimplementedWorkerServer) ApplyDrainmode ¶
func (UnimplementedWorkerServer) ApplyDrainmode(context.Context, *DrainModeRequest) (*Status, error)
func (UnimplementedWorkerServer) Backup ¶
func (UnimplementedWorkerServer) Backup(context.Context, *BackupRequest) (*BackupResponse, error)
func (UnimplementedWorkerServer) DeleteNamespace ¶
func (UnimplementedWorkerServer) DeleteNamespace(context.Context, *DeleteNsRequest) (*Status, error)
func (UnimplementedWorkerServer) Export ¶
func (UnimplementedWorkerServer) Export(context.Context, *ExportRequest) (*ExportResponse, error)
func (UnimplementedWorkerServer) InternalStreamPDir ¶
func (UnimplementedWorkerServer) InternalStreamPDir(Worker_InternalStreamPDirServer) error
func (UnimplementedWorkerServer) MovePredicate ¶
func (UnimplementedWorkerServer) MovePredicate(context.Context, *MovePredicatePayload) (*api.Payload, error)
func (UnimplementedWorkerServer) Mutate ¶
func (UnimplementedWorkerServer) Mutate(context.Context, *Mutations) (*api.TxnContext, error)
func (UnimplementedWorkerServer) ReceivePredicate ¶
func (UnimplementedWorkerServer) ReceivePredicate(Worker_ReceivePredicateServer) error
func (UnimplementedWorkerServer) Restore ¶
func (UnimplementedWorkerServer) Restore(context.Context, *RestoreRequest) (*Status, error)
func (UnimplementedWorkerServer) Schema ¶
func (UnimplementedWorkerServer) Schema(context.Context, *SchemaRequest) (*SchemaResult, error)
func (UnimplementedWorkerServer) Sort ¶
func (UnimplementedWorkerServer) Sort(context.Context, *SortMessage) (*SortResult, error)
func (UnimplementedWorkerServer) StreamSnapshot ¶
func (UnimplementedWorkerServer) StreamSnapshot(Worker_StreamSnapshotServer) error
func (UnimplementedWorkerServer) Subscribe ¶
func (UnimplementedWorkerServer) Subscribe(*SubscriptionRequest, Worker_SubscribeServer) error
func (UnimplementedWorkerServer) TaskStatus ¶
func (UnimplementedWorkerServer) TaskStatus(context.Context, *TaskStatusRequest) (*TaskStatusResponse, error)
func (UnimplementedWorkerServer) UpdateGraphQLSchema ¶
func (UnimplementedWorkerServer) UpdateGraphQLSchema(context.Context, *UpdateGraphQLSchemaRequest) (*UpdateGraphQLSchemaResponse, error)
type UnimplementedZeroServer ¶
type UnimplementedZeroServer struct {
}
UnimplementedZeroServer must be embedded to have forward compatible implementations.
func (UnimplementedZeroServer) AssignIds ¶
func (UnimplementedZeroServer) AssignIds(context.Context, *Num) (*AssignedIds, error)
func (UnimplementedZeroServer) CommitOrAbort ¶
func (UnimplementedZeroServer) CommitOrAbort(context.Context, *api.TxnContext) (*api.TxnContext, error)
func (UnimplementedZeroServer) Connect ¶
func (UnimplementedZeroServer) Connect(context.Context, *Member) (*ConnectionState, error)
func (UnimplementedZeroServer) DeleteNamespace ¶
func (UnimplementedZeroServer) DeleteNamespace(context.Context, *DeleteNsRequest) (*Status, error)
func (UnimplementedZeroServer) Inform ¶
func (UnimplementedZeroServer) Inform(context.Context, *TabletRequest) (*TabletResponse, error)
func (UnimplementedZeroServer) MoveTablet ¶
func (UnimplementedZeroServer) MoveTablet(context.Context, *MoveTabletRequest) (*Status, error)
func (UnimplementedZeroServer) Oracle ¶
func (UnimplementedZeroServer) Oracle(*api.Payload, Zero_OracleServer) error
func (UnimplementedZeroServer) RemoveNode ¶
func (UnimplementedZeroServer) RemoveNode(context.Context, *RemoveNodeRequest) (*Status, error)
func (UnimplementedZeroServer) ShouldServe ¶
func (UnimplementedZeroServer) StreamMembership ¶
func (UnimplementedZeroServer) StreamMembership(*api.Payload, Zero_StreamMembershipServer) error
func (UnimplementedZeroServer) Timestamps ¶
func (UnimplementedZeroServer) Timestamps(context.Context, *Num) (*AssignedIds, error)
func (UnimplementedZeroServer) TryAbort ¶
func (UnimplementedZeroServer) TryAbort(context.Context, *TxnTimestamps) (*OracleDelta, error)
func (UnimplementedZeroServer) UpdateMembership ¶
type UnsafeRaftServer ¶
type UnsafeRaftServer interface {
// contains filtered or unexported methods
}
UnsafeRaftServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RaftServer will result in compilation errors.
type UnsafeWorkerServer ¶
type UnsafeWorkerServer interface {
// contains filtered or unexported methods
}
UnsafeWorkerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServer will result in compilation errors.
type UnsafeZeroServer ¶
type UnsafeZeroServer interface {
// contains filtered or unexported methods
}
UnsafeZeroServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ZeroServer will result in compilation errors.
type UpdateGraphQLSchemaRequest ¶
type UpdateGraphQLSchemaRequest struct {
StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
GraphqlSchema string `protobuf:"bytes,2,opt,name=graphql_schema,json=graphqlSchema,proto3" json:"graphql_schema,omitempty"`
DgraphPreds []*SchemaUpdate `protobuf:"bytes,3,rep,name=dgraph_preds,json=dgraphPreds,proto3" json:"dgraph_preds,omitempty"`
DgraphTypes []*TypeUpdate `protobuf:"bytes,4,rep,name=dgraph_types,json=dgraphTypes,proto3" json:"dgraph_types,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateGraphQLSchemaRequest) Descriptor
deprecated
func (*UpdateGraphQLSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateGraphQLSchemaRequest.ProtoReflect.Descriptor instead.
func (*UpdateGraphQLSchemaRequest) GetDgraphPreds ¶
func (x *UpdateGraphQLSchemaRequest) GetDgraphPreds() []*SchemaUpdate
func (*UpdateGraphQLSchemaRequest) GetDgraphTypes ¶
func (x *UpdateGraphQLSchemaRequest) GetDgraphTypes() []*TypeUpdate
func (*UpdateGraphQLSchemaRequest) GetGraphqlSchema ¶
func (x *UpdateGraphQLSchemaRequest) GetGraphqlSchema() string
func (*UpdateGraphQLSchemaRequest) GetStartTs ¶
func (x *UpdateGraphQLSchemaRequest) GetStartTs() uint64
func (*UpdateGraphQLSchemaRequest) ProtoMessage ¶
func (*UpdateGraphQLSchemaRequest) ProtoMessage()
func (*UpdateGraphQLSchemaRequest) ProtoReflect ¶
func (x *UpdateGraphQLSchemaRequest) ProtoReflect() protoreflect.Message
func (*UpdateGraphQLSchemaRequest) Reset ¶
func (x *UpdateGraphQLSchemaRequest) Reset()
func (*UpdateGraphQLSchemaRequest) String ¶
func (x *UpdateGraphQLSchemaRequest) String() string
type UpdateGraphQLSchemaResponse ¶
type UpdateGraphQLSchemaResponse struct {
Uid uint64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateGraphQLSchemaResponse) Descriptor
deprecated
func (*UpdateGraphQLSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateGraphQLSchemaResponse.ProtoReflect.Descriptor instead.
func (*UpdateGraphQLSchemaResponse) GetUid ¶
func (x *UpdateGraphQLSchemaResponse) GetUid() uint64
func (*UpdateGraphQLSchemaResponse) ProtoMessage ¶
func (*UpdateGraphQLSchemaResponse) ProtoMessage()
func (*UpdateGraphQLSchemaResponse) ProtoReflect ¶
func (x *UpdateGraphQLSchemaResponse) ProtoReflect() protoreflect.Message
func (*UpdateGraphQLSchemaResponse) Reset ¶
func (x *UpdateGraphQLSchemaResponse) Reset()
func (*UpdateGraphQLSchemaResponse) String ¶
func (x *UpdateGraphQLSchemaResponse) String() string
type ValueList ¶
type ValueList struct {
Values []*TaskValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*ValueList) Descriptor
deprecated
func (*ValueList) ProtoMessage ¶
func (*ValueList) ProtoMessage()
func (*ValueList) ProtoReflect ¶
func (x *ValueList) ProtoReflect() protoreflect.Message
type VectorIndexSpec ¶
type VectorIndexSpec struct {
// This names the kind of Vector Index, e.g.,
//
// hnsw, lsh, hypertree, ...
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Options []*OptionPair `protobuf:"bytes,2,rep,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*VectorIndexSpec) Descriptor
deprecated
func (*VectorIndexSpec) Descriptor() ([]byte, []int)
Deprecated: Use VectorIndexSpec.ProtoReflect.Descriptor instead.
func (*VectorIndexSpec) GetName ¶
func (x *VectorIndexSpec) GetName() string
func (*VectorIndexSpec) GetOptions ¶
func (x *VectorIndexSpec) GetOptions() []*OptionPair
func (*VectorIndexSpec) ProtoMessage ¶
func (*VectorIndexSpec) ProtoMessage()
func (*VectorIndexSpec) ProtoReflect ¶
func (x *VectorIndexSpec) ProtoReflect() protoreflect.Message
func (*VectorIndexSpec) Reset ¶
func (x *VectorIndexSpec) Reset()
func (*VectorIndexSpec) String ¶
func (x *VectorIndexSpec) String() string
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)
StreamSnapshot(ctx context.Context, opts ...grpc.CallOption) (Worker_StreamSnapshotClient, error)
Sort(ctx context.Context, in *SortMessage, opts ...grpc.CallOption) (*SortResult, error)
Schema(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaResult, error)
Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (*BackupResponse, error)
Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*Status, error)
Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error)
ReceivePredicate(ctx context.Context, opts ...grpc.CallOption) (Worker_ReceivePredicateClient, error)
MovePredicate(ctx context.Context, in *MovePredicatePayload, opts ...grpc.CallOption) (*api.Payload, error)
Subscribe(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (Worker_SubscribeClient, error)
UpdateGraphQLSchema(ctx context.Context, in *UpdateGraphQLSchemaRequest, opts ...grpc.CallOption) (*UpdateGraphQLSchemaResponse, error)
DeleteNamespace(ctx context.Context, in *DeleteNsRequest, opts ...grpc.CallOption) (*Status, error)
TaskStatus(ctx context.Context, in *TaskStatusRequest, opts ...grpc.CallOption) (*TaskStatusResponse, error)
ApplyDrainmode(ctx context.Context, in *DrainModeRequest, opts ...grpc.CallOption) (*Status, error)
InternalStreamPDir(ctx context.Context, opts ...grpc.CallOption) (Worker_InternalStreamPDirClient, error)
}
WorkerClient is the client API for Worker service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewWorkerClient ¶
func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient
type WorkerServer ¶
type WorkerServer interface {
// Data serving RPCs.
Mutate(context.Context, *Mutations) (*api.TxnContext, error)
ServeTask(context.Context, *Query) (*Result, error)
StreamSnapshot(Worker_StreamSnapshotServer) error
Sort(context.Context, *SortMessage) (*SortResult, error)
Schema(context.Context, *SchemaRequest) (*SchemaResult, error)
Backup(context.Context, *BackupRequest) (*BackupResponse, error)
Restore(context.Context, *RestoreRequest) (*Status, error)
Export(context.Context, *ExportRequest) (*ExportResponse, error)
ReceivePredicate(Worker_ReceivePredicateServer) error
MovePredicate(context.Context, *MovePredicatePayload) (*api.Payload, error)
Subscribe(*SubscriptionRequest, Worker_SubscribeServer) error
UpdateGraphQLSchema(context.Context, *UpdateGraphQLSchemaRequest) (*UpdateGraphQLSchemaResponse, error)
DeleteNamespace(context.Context, *DeleteNsRequest) (*Status, error)
TaskStatus(context.Context, *TaskStatusRequest) (*TaskStatusResponse, error)
ApplyDrainmode(context.Context, *DrainModeRequest) (*Status, error)
InternalStreamPDir(Worker_InternalStreamPDirServer) error
// contains filtered or unexported methods
}
WorkerServer is the server API for Worker service. All implementations must embed UnimplementedWorkerServer for forward compatibility
type Worker_InternalStreamPDirClient ¶
type Worker_InternalStreamPDirClient interface {
Send(*api_v2.StreamPDirRequest) error
CloseAndRecv() (*api_v2.StreamPDirResponse, error)
grpc.ClientStream
}
type Worker_InternalStreamPDirServer ¶
type Worker_InternalStreamPDirServer interface {
SendAndClose(*api_v2.StreamPDirResponse) error
Recv() (*api_v2.StreamPDirRequest, error)
grpc.ServerStream
}
type Worker_SubscribeClient ¶
type Worker_SubscribeClient interface {
Recv() (*pb.KVList, error)
grpc.ClientStream
}
type Worker_SubscribeServer ¶
type Worker_SubscribeServer interface {
Send(*pb.KVList) error
grpc.ServerStream
}
type ZeroClient ¶
type ZeroClient interface {
// These 3 endpoints are for handling membership.
Connect(ctx context.Context, in *Member, opts ...grpc.CallOption) (*ConnectionState, error)
UpdateMembership(ctx context.Context, in *Group, opts ...grpc.CallOption) (*api.Payload, error)
StreamMembership(ctx context.Context, in *api.Payload, opts ...grpc.CallOption) (Zero_StreamMembershipClient, 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)
Inform(ctx context.Context, in *TabletRequest, opts ...grpc.CallOption) (*TabletResponse, error)
AssignIds(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error)
Timestamps(ctx context.Context, in *Num, opts ...grpc.CallOption) (*AssignedIds, error)
CommitOrAbort(ctx context.Context, in *api.TxnContext, opts ...grpc.CallOption) (*api.TxnContext, error)
TryAbort(ctx context.Context, in *TxnTimestamps, opts ...grpc.CallOption) (*OracleDelta, error)
DeleteNamespace(ctx context.Context, in *DeleteNsRequest, opts ...grpc.CallOption) (*Status, error)
RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*Status, error)
MoveTablet(ctx context.Context, in *MoveTabletRequest, opts ...grpc.CallOption) (*Status, error)
}
ZeroClient is the client API for Zero service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewZeroClient ¶
func NewZeroClient(cc grpc.ClientConnInterface) ZeroClient
type ZeroProposal ¶
type ZeroProposal struct {
SnapshotTs map[uint32]uint64 `` // Group ID -> Snapshot Ts.
/* 181-byte string literal not displayed */
Member *Member `protobuf:"bytes,2,opt,name=member,proto3" json:"member,omitempty"`
Tablet *Tablet `protobuf:"bytes,3,opt,name=tablet,proto3" json:"tablet,omitempty"`
MaxUID uint64 `protobuf:"varint,4,opt,name=maxUID,proto3" json:"maxUID,omitempty"`
MaxTxnTs uint64 `protobuf:"varint,5,opt,name=maxTxnTs,proto3" json:"maxTxnTs,omitempty"`
MaxNsID uint64 `protobuf:"varint,12,opt,name=maxNsID,proto3" json:"maxNsID,omitempty"`
MaxRaftId uint64 `protobuf:"varint,6,opt,name=maxRaftId,proto3" json:"maxRaftId,omitempty"`
Txn *api.TxnContext `protobuf:"bytes,7,opt,name=txn,proto3" json:"txn,omitempty"`
Cid string `protobuf:"bytes,9,opt,name=cid,proto3" json:"cid,omitempty"` // Used as unique identifier for the cluster.
Snapshot *ZeroSnapshot `protobuf:"bytes,11,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // Used to make Zeros take a snapshot.
// 12 has already been used.
DeleteNs *DeleteNsRequest `protobuf:"bytes,13,opt,name=delete_ns,json=deleteNs,proto3" json:"delete_ns,omitempty"` // Used to delete namespace.
Tablets []*Tablet `protobuf:"bytes,14,rep,name=tablets,proto3" json:"tablets,omitempty"`
// contains filtered or unexported fields
}
func (*ZeroProposal) Descriptor
deprecated
func (*ZeroProposal) Descriptor() ([]byte, []int)
Deprecated: Use ZeroProposal.ProtoReflect.Descriptor instead.
func (*ZeroProposal) GetCid ¶
func (x *ZeroProposal) GetCid() string
func (*ZeroProposal) GetDeleteNs ¶
func (x *ZeroProposal) GetDeleteNs() *DeleteNsRequest
func (*ZeroProposal) GetMaxNsID ¶
func (x *ZeroProposal) GetMaxNsID() uint64
func (*ZeroProposal) GetMaxRaftId ¶
func (x *ZeroProposal) GetMaxRaftId() uint64
func (*ZeroProposal) GetMaxTxnTs ¶
func (x *ZeroProposal) GetMaxTxnTs() uint64
func (*ZeroProposal) GetMaxUID ¶
func (x *ZeroProposal) GetMaxUID() uint64
func (*ZeroProposal) GetMember ¶
func (x *ZeroProposal) GetMember() *Member
func (*ZeroProposal) GetSnapshot ¶
func (x *ZeroProposal) GetSnapshot() *ZeroSnapshot
func (*ZeroProposal) GetSnapshotTs ¶
func (x *ZeroProposal) GetSnapshotTs() map[uint32]uint64
func (*ZeroProposal) GetTablet ¶
func (x *ZeroProposal) GetTablet() *Tablet
func (*ZeroProposal) GetTablets ¶
func (x *ZeroProposal) GetTablets() []*Tablet
func (*ZeroProposal) GetTxn ¶
func (x *ZeroProposal) GetTxn() *api.TxnContext
func (*ZeroProposal) ProtoMessage ¶
func (*ZeroProposal) ProtoMessage()
func (*ZeroProposal) ProtoReflect ¶
func (x *ZeroProposal) ProtoReflect() protoreflect.Message
func (*ZeroProposal) Reset ¶
func (x *ZeroProposal) Reset()
func (*ZeroProposal) String ¶
func (x *ZeroProposal) String() string
type ZeroServer ¶
type ZeroServer interface {
// These 3 endpoints are for handling membership.
Connect(context.Context, *Member) (*ConnectionState, error)
UpdateMembership(context.Context, *Group) (*api.Payload, error)
StreamMembership(*api.Payload, Zero_StreamMembershipServer) error
Oracle(*api.Payload, Zero_OracleServer) error
ShouldServe(context.Context, *Tablet) (*Tablet, error)
Inform(context.Context, *TabletRequest) (*TabletResponse, error)
AssignIds(context.Context, *Num) (*AssignedIds, error)
Timestamps(context.Context, *Num) (*AssignedIds, error)
CommitOrAbort(context.Context, *api.TxnContext) (*api.TxnContext, error)
TryAbort(context.Context, *TxnTimestamps) (*OracleDelta, error)
DeleteNamespace(context.Context, *DeleteNsRequest) (*Status, error)
RemoveNode(context.Context, *RemoveNodeRequest) (*Status, error)
MoveTablet(context.Context, *MoveTabletRequest) (*Status, error)
// contains filtered or unexported methods
}
ZeroServer is the server API for Zero service. All implementations must embed UnimplementedZeroServer for forward compatibility
type ZeroSnapshot ¶
type ZeroSnapshot struct {
Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
CheckpointTs uint64 `protobuf:"varint,2,opt,name=checkpoint_ts,json=checkpointTs,proto3" json:"checkpoint_ts,omitempty"`
State *MembershipState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*ZeroSnapshot) Descriptor
deprecated
func (*ZeroSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use ZeroSnapshot.ProtoReflect.Descriptor instead.
func (*ZeroSnapshot) GetCheckpointTs ¶
func (x *ZeroSnapshot) GetCheckpointTs() uint64
func (*ZeroSnapshot) GetIndex ¶
func (x *ZeroSnapshot) GetIndex() uint64
func (*ZeroSnapshot) GetState ¶
func (x *ZeroSnapshot) GetState() *MembershipState
func (*ZeroSnapshot) ProtoMessage ¶
func (*ZeroSnapshot) ProtoMessage()
func (*ZeroSnapshot) ProtoReflect ¶
func (x *ZeroSnapshot) ProtoReflect() protoreflect.Message
func (*ZeroSnapshot) Reset ¶
func (x *ZeroSnapshot) Reset()
func (*ZeroSnapshot) String ¶
func (x *ZeroSnapshot) String() string
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_StreamMembershipClient ¶
type Zero_StreamMembershipClient interface {
Recv() (*MembershipState, error)
grpc.ClientStream
}
type Zero_StreamMembershipServer ¶
type Zero_StreamMembershipServer interface {
Send(*MembershipState) error
grpc.ServerStream
}