pb

package
v25.0.0-custom-qt-impr... Latest Latest
Warning

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

Go to latest
Published: Jun 5, 2025 License: Apache-2.0 Imports: 12 Imported by: 2

Documentation

Index

Constants

View Source
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"
)
View Source
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"
)
View Source
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

View Source
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.

View Source
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.

View Source
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.

View Source
var (
	Posting_ValType_name = map[int32]string{
		0:  "DEFAULT",
		1:  "BINARY",
		2:  "INT",
		3:  "FLOAT",
		4:  "BOOL",
		5:  "DATETIME",
		6:  "GEO",
		7:  "UID",
		8:  "PASSWORD",
		9:  "STRING",
		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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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)

View Source
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)

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use BackupKey.ProtoReflect.Descriptor instead.

func (*BackupKey) GetAttr

func (x *BackupKey) GetAttr() string

func (*BackupKey) GetCount

func (x *BackupKey) GetCount() uint32

func (*BackupKey) GetNamespace

func (x *BackupKey) GetNamespace() uint64

func (*BackupKey) GetStartUid

func (x *BackupKey) GetStartUid() uint64

func (*BackupKey) GetTerm

func (x *BackupKey) GetTerm() []byte

func (*BackupKey) GetType

func (x *BackupKey) GetType() BackupKey_KeyType

func (*BackupKey) GetUid

func (x *BackupKey) GetUid() uint64

func (*BackupKey) ProtoMessage

func (*BackupKey) ProtoMessage()

func (*BackupKey) ProtoReflect

func (x *BackupKey) ProtoReflect() protoreflect.Message

func (*BackupKey) Reset

func (x *BackupKey) Reset()

func (*BackupKey) String

func (x *BackupKey) String() string

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) Enum

func (BackupKey_KeyType) EnumDescriptor deprecated

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

Deprecated: Use BackupKey_KeyType.Descriptor instead.

func (BackupKey_KeyType) Number

func (BackupKey_KeyType) String

func (x BackupKey_KeyType) String() string

func (BackupKey_KeyType) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use BulkMeta.ProtoReflect.Descriptor instead.

func (*BulkMeta) GetEdgeCount

func (x *BulkMeta) GetEdgeCount() int64

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

func (*BulkMeta) Reset

func (x *BulkMeta) Reset()

func (*BulkMeta) String

func (x *BulkMeta) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use CDCState.ProtoReflect.Descriptor instead.

func (*CDCState) GetSentTs

func (x *CDCState) GetSentTs() uint64

func (*CDCState) ProtoMessage

func (*CDCState) ProtoMessage()

func (*CDCState) ProtoReflect

func (x *CDCState) ProtoReflect() protoreflect.Message

func (*CDCState) Reset

func (x *CDCState) Reset()

func (*CDCState) String

func (x *CDCState) String() string

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) 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 (DirectedEdge_Op) String

func (x DirectedEdge_Op) String() string

func (DirectedEdge_Op) Type

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) Enum

func (DropOperation_DropOp) EnumDescriptor deprecated

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

Deprecated: Use DropOperation_DropOp.Descriptor instead.

func (DropOperation_DropOp) Number

func (DropOperation_DropOp) String

func (x DropOperation_DropOp) String() string

func (DropOperation_DropOp) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Facets.ProtoReflect.Descriptor instead.

func (*Facets) GetFacets

func (x *Facets) GetFacets() []*api.Facet

func (*Facets) ProtoMessage

func (*Facets) ProtoMessage()

func (*Facets) ProtoReflect

func (x *Facets) ProtoReflect() protoreflect.Message

func (*Facets) Reset

func (x *Facets) Reset()

func (*Facets) String

func (x *Facets) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Function.ProtoReflect.Descriptor instead.

func (*Function) GetArgs

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

func (*Function) GetKey

func (x *Function) GetKey() string

func (*Function) GetName

func (x *Function) GetName() string

func (*Function) ProtoMessage

func (*Function) ProtoMessage()

func (*Function) ProtoReflect

func (x *Function) ProtoReflect() protoreflect.Message

func (*Function) Reset

func (x *Function) Reset()

func (*Function) String

func (x *Function) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Group.ProtoReflect.Descriptor instead.

func (*Group) GetCheckpointTs

func (x *Group) GetCheckpointTs() uint64

func (*Group) GetChecksum

func (x *Group) GetChecksum() uint64

func (*Group) GetMembers

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

func (*Group) GetSnapshotTs

func (x *Group) GetSnapshotTs() uint64

func (*Group) GetTablets

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

func (*Group) ProtoMessage

func (*Group) ProtoMessage()

func (*Group) ProtoReflect

func (x *Group) ProtoReflect() protoreflect.Message

func (*Group) Reset

func (x *Group) Reset()

func (*Group) String

func (x *Group) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use KVS.ProtoReflect.Descriptor instead.

func (*KVS) GetData

func (x *KVS) GetData() []byte

func (*KVS) GetDone

func (x *KVS) GetDone() bool

func (*KVS) GetPredicates

func (x *KVS) GetPredicates() []string

func (*KVS) GetTypes

func (x *KVS) GetTypes() []string

func (*KVS) ProtoMessage

func (*KVS) ProtoMessage()

func (*KVS) ProtoReflect

func (x *KVS) ProtoReflect() protoreflect.Message

func (*KVS) Reset

func (x *KVS) Reset()

func (*KVS) String

func (x *KVS) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use LangList.ProtoReflect.Descriptor instead.

func (*LangList) GetLang

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

func (*LangList) ProtoMessage

func (*LangList) ProtoMessage()

func (*LangList) ProtoReflect

func (x *LangList) ProtoReflect() protoreflect.Message

func (*LangList) Reset

func (x *LangList) Reset()

func (*LangList) String

func (x *LangList) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use List.ProtoReflect.Descriptor instead.

func (*List) GetUids

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

func (*List) ProtoMessage

func (*List) ProtoMessage()

func (*List) ProtoReflect

func (x *List) ProtoReflect() protoreflect.Message

func (*List) Reset

func (x *List) Reset()

func (*List) String

func (x *List) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use MapHeader.ProtoReflect.Descriptor instead.

func (*MapHeader) GetPartitionKeys

func (x *MapHeader) GetPartitionKeys() [][]byte

func (*MapHeader) ProtoMessage

func (*MapHeader) ProtoMessage()

func (*MapHeader) ProtoReflect

func (x *MapHeader) ProtoReflect() protoreflect.Message

func (*MapHeader) Reset

func (x *MapHeader) Reset()

func (*MapHeader) String

func (x *MapHeader) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetAddr

func (x *Member) GetAddr() string

func (*Member) GetAmDead

func (x *Member) GetAmDead() bool

func (*Member) GetClusterInfoOnly

func (x *Member) GetClusterInfoOnly() bool

func (*Member) GetForceGroupId

func (x *Member) GetForceGroupId() bool

func (*Member) GetGroupId

func (x *Member) GetGroupId() uint32

func (*Member) GetId

func (x *Member) GetId() uint64

func (*Member) GetLastUpdate

func (x *Member) GetLastUpdate() uint64

func (*Member) GetLeader

func (x *Member) GetLeader() bool

func (*Member) GetLearner

func (x *Member) GetLearner() bool

func (*Member) ProtoMessage

func (*Member) ProtoMessage()

func (*Member) ProtoReflect

func (x *Member) ProtoReflect() protoreflect.Message

func (*Member) Reset

func (x *Member) Reset()

func (*Member) String

func (x *Member) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

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

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

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) Enum

func (Metadata_HintType) EnumDescriptor deprecated

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

Deprecated: Use Metadata_HintType.Descriptor instead.

func (Metadata_HintType) Number

func (Metadata_HintType) String

func (x Metadata_HintType) String() string

func (Metadata_HintType) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Mutations.ProtoReflect.Descriptor instead.

func (*Mutations) GetDropOp

func (x *Mutations) GetDropOp() Mutations_DropOp

func (*Mutations) GetDropValue

func (x *Mutations) GetDropValue() string

func (*Mutations) GetEdges

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

func (*Mutations) GetGroupId

func (x *Mutations) GetGroupId() uint32

func (*Mutations) GetMetadata

func (x *Mutations) GetMetadata() *Metadata

func (*Mutations) GetSchema

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

func (*Mutations) GetStartTs

func (x *Mutations) GetStartTs() uint64

func (*Mutations) GetTypes

func (x *Mutations) GetTypes() []*TypeUpdate

func (*Mutations) ProtoMessage

func (*Mutations) ProtoMessage()

func (*Mutations) ProtoReflect

func (x *Mutations) ProtoReflect() protoreflect.Message

func (*Mutations) Reset

func (x *Mutations) Reset()

func (*Mutations) String

func (x *Mutations) String() string

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) Enum

func (Mutations_DropOp) EnumDescriptor deprecated

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

Deprecated: Use Mutations_DropOp.Descriptor instead.

func (Mutations_DropOp) Number

func (Mutations_DropOp) String

func (x Mutations_DropOp) String() string

func (Mutations_DropOp) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Num.ProtoReflect.Descriptor instead.

func (*Num) GetBump

func (x *Num) GetBump() bool

func (*Num) GetForwarded

func (x *Num) GetForwarded() bool

func (*Num) GetReadOnly

func (x *Num) GetReadOnly() bool

func (*Num) GetType

func (x *Num) GetType() NumLeaseType

func (*Num) GetVal

func (x *Num) GetVal() uint64

func (*Num) ProtoMessage

func (*Num) ProtoMessage()

func (*Num) ProtoReflect

func (x *Num) ProtoReflect() protoreflect.Message

func (*Num) Reset

func (x *Num) Reset()

func (*Num) String

func (x *Num) String() string

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) Enum

func (x NumLeaseType) Enum() *NumLeaseType

func (NumLeaseType) EnumDescriptor deprecated

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

Deprecated: Use NumLeaseType.Descriptor instead.

func (NumLeaseType) Number

func (NumLeaseType) String

func (x NumLeaseType) String() string

func (NumLeaseType) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Order.ProtoReflect.Descriptor instead.

func (*Order) GetAttr

func (x *Order) GetAttr() string

func (*Order) GetDesc

func (x *Order) GetDesc() bool

func (*Order) GetLangs

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

func (*Order) ProtoMessage

func (*Order) ProtoMessage()

func (*Order) ProtoReflect

func (x *Order) ProtoReflect() protoreflect.Message

func (*Order) Reset

func (x *Order) Reset()

func (*Order) String

func (x *Order) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Posting.ProtoReflect.Descriptor instead.

func (*Posting) GetCommitTs

func (x *Posting) GetCommitTs() uint64

func (*Posting) GetFacets

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

func (*Posting) GetLangTag

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

func (*Posting) GetOp

func (x *Posting) GetOp() uint32

func (*Posting) GetPostingType

func (x *Posting) GetPostingType() Posting_PostingType

func (*Posting) GetStartTs

func (x *Posting) GetStartTs() uint64

func (*Posting) GetUid

func (x *Posting) GetUid() uint64

func (*Posting) GetValType

func (x *Posting) GetValType() Posting_ValType

func (*Posting) GetValue

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

func (*Posting) ProtoMessage

func (*Posting) ProtoMessage()

func (*Posting) ProtoReflect

func (x *Posting) ProtoReflect() protoreflect.Message

func (*Posting) Reset

func (x *Posting) Reset()

func (*Posting) String

func (x *Posting) String() string

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) Enum

func (Posting_PostingType) EnumDescriptor deprecated

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

Deprecated: Use Posting_PostingType.Descriptor instead.

func (Posting_PostingType) Number

func (Posting_PostingType) String

func (x Posting_PostingType) String() string

func (Posting_PostingType) Type

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) 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 (Posting_ValType) String

func (x Posting_ValType) String() string

func (Posting_ValType) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Proposal.ProtoReflect.Descriptor instead.

func (*Proposal) GetCdcState

func (x *Proposal) GetCdcState() *CDCState

func (*Proposal) GetCleanPredicate

func (x *Proposal) GetCleanPredicate() string

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 (x *Proposal) GetExpectedChecksum() uint64

func (*Proposal) GetIndex

func (x *Proposal) GetIndex() uint64

func (*Proposal) GetKv

func (x *Proposal) GetKv() []*pb.KV

func (*Proposal) GetMutations

func (x *Proposal) GetMutations() *Mutations

func (*Proposal) GetRestore

func (x *Proposal) GetRestore() *RestoreRequest

func (*Proposal) GetSnapshot

func (x *Proposal) GetSnapshot() *Snapshot

func (*Proposal) GetStartTs

func (x *Proposal) GetStartTs() uint64

func (*Proposal) GetState

func (x *Proposal) GetState() *MembershipState

func (*Proposal) ProtoMessage

func (*Proposal) ProtoMessage()

func (*Proposal) ProtoReflect

func (x *Proposal) ProtoReflect() protoreflect.Message

func (*Proposal) Reset

func (x *Proposal) Reset()

func (*Proposal) String

func (x *Proposal) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetAfterUid

func (x *Query) GetAfterUid() uint64

func (*Query) GetAttr

func (x *Query) GetAttr() string

func (*Query) GetCache

func (x *Query) GetCache() int32

func (*Query) GetDoCount

func (x *Query) GetDoCount() bool

func (*Query) GetExpandAll

func (x *Query) GetExpandAll() bool

func (*Query) GetFacetParam

func (x *Query) GetFacetParam() *FacetParams

func (*Query) GetFacetsFilter

func (x *Query) GetFacetsFilter() *FilterTree

func (*Query) GetFirst

func (x *Query) GetFirst() int32

func (*Query) GetLangs

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

func (*Query) GetOffset

func (x *Query) GetOffset() int32

func (*Query) GetReadTs

func (x *Query) GetReadTs() uint64

func (*Query) GetReverse

func (x *Query) GetReverse() bool

func (*Query) GetSrcFunc

func (x *Query) GetSrcFunc() *SrcFunction

func (*Query) GetUidList

func (x *Query) GetUidList() *List

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) ProtoReflect

func (x *Query) ProtoReflect() protoreflect.Message

func (*Query) Reset

func (x *Query) Reset()

func (*Query) String

func (x *Query) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RaftBatch.ProtoReflect.Descriptor instead.

func (*RaftBatch) GetContext

func (x *RaftBatch) GetContext() *RaftContext

func (*RaftBatch) GetPayload

func (x *RaftBatch) GetPayload() *api.Payload

func (*RaftBatch) ProtoMessage

func (*RaftBatch) ProtoMessage()

func (*RaftBatch) ProtoReflect

func (x *RaftBatch) ProtoReflect() protoreflect.Message

func (*RaftBatch) Reset

func (x *RaftBatch) Reset()

func (*RaftBatch) String

func (x *RaftBatch) String() string

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_RaftMessageClient interface {
	Send(*RaftBatch) error
	CloseAndRecv() (*api.Payload, error)
	grpc.ClientStream
}

type Raft_RaftMessageServer

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetCounts

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

func (*Result) GetFacetMatrix

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

func (*Result) GetIntersectDest

func (x *Result) GetIntersectDest() bool

func (*Result) GetLangMatrix

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

func (*Result) GetList

func (x *Result) GetList() bool

func (*Result) GetUidMatrix

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

func (*Result) GetValueMatrix

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

func (*Result) GetVectorMetrics

func (x *Result) GetVectorMetrics() map[string]uint64

func (*Result) ProtoMessage

func (*Result) ProtoMessage()

func (*Result) ProtoReflect

func (x *Result) ProtoReflect() protoreflect.Message

func (*Result) Reset

func (x *Result) Reset()

func (*Result) String

func (x *Result) String() string

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) Enum

func (SchemaUpdate_Directive) EnumDescriptor deprecated

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

Deprecated: Use SchemaUpdate_Directive.Descriptor instead.

func (SchemaUpdate_Directive) Number

func (SchemaUpdate_Directive) String

func (x SchemaUpdate_Directive) String() string

func (SchemaUpdate_Directive) Type

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.

func (Sensitive) String

func (Sensitive) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) GetContext

func (x *Snapshot) GetContext() *RaftContext

func (*Snapshot) GetDone

func (x *Snapshot) GetDone() bool

func (*Snapshot) GetIndex

func (x *Snapshot) GetIndex() uint64

func (*Snapshot) GetReadTs

func (x *Snapshot) GetReadTs() uint64

func (*Snapshot) GetSinceTs

func (x *Snapshot) GetSinceTs() uint64

func (*Snapshot) ProtoMessage

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect

func (x *Snapshot) ProtoReflect() protoreflect.Message

func (*Snapshot) Reset

func (x *Snapshot) Reset()

func (*Snapshot) String

func (x *Snapshot) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode

func (x *Status) GetCode() int32

func (*Status) GetMsg

func (x *Status) GetMsg() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Tablet.ProtoReflect.Descriptor instead.

func (*Tablet) GetForce

func (x *Tablet) GetForce() bool

func (*Tablet) GetGroupId

func (x *Tablet) GetGroupId() uint32

func (*Tablet) GetMoveTs

func (x *Tablet) GetMoveTs() uint64

func (*Tablet) GetOnDiskBytes

func (x *Tablet) GetOnDiskBytes() int64

func (*Tablet) GetPredicate

func (x *Tablet) GetPredicate() string

func (*Tablet) GetReadOnly

func (x *Tablet) GetReadOnly() bool

func (*Tablet) GetRemove

func (x *Tablet) GetRemove() bool

func (*Tablet) GetUncompressedBytes

func (x *Tablet) GetUncompressedBytes() int64

func (*Tablet) ProtoMessage

func (*Tablet) ProtoMessage()

func (*Tablet) ProtoReflect

func (x *Tablet) ProtoReflect() protoreflect.Message

func (*Tablet) Reset

func (x *Tablet) Reset()

func (*Tablet) String

func (x *Tablet) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TaskValue.ProtoReflect.Descriptor instead.

func (*TaskValue) GetVal

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

func (*TaskValue) GetValType

func (x *TaskValue) GetValType() Posting_ValType

func (*TaskValue) ProtoMessage

func (*TaskValue) ProtoMessage()

func (*TaskValue) ProtoReflect

func (x *TaskValue) ProtoReflect() protoreflect.Message

func (*TaskValue) Reset

func (x *TaskValue) Reset()

func (*TaskValue) String

func (x *TaskValue) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TxnStatus.ProtoReflect.Descriptor instead.

func (*TxnStatus) GetCommitTs

func (x *TxnStatus) GetCommitTs() uint64

func (*TxnStatus) GetStartTs

func (x *TxnStatus) GetStartTs() uint64

func (*TxnStatus) ProtoMessage

func (*TxnStatus) ProtoMessage()

func (*TxnStatus) ProtoReflect

func (x *TxnStatus) ProtoReflect() protoreflect.Message

func (*TxnStatus) Reset

func (x *TxnStatus) Reset()

func (*TxnStatus) String

func (x *TxnStatus) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use UidBlock.ProtoReflect.Descriptor instead.

func (*UidBlock) GetBase

func (x *UidBlock) GetBase() uint64

func (*UidBlock) GetDeltas

func (x *UidBlock) GetDeltas() []byte

func (*UidBlock) GetNumUids

func (x *UidBlock) GetNumUids() uint32

func (*UidBlock) ProtoMessage

func (*UidBlock) ProtoMessage()

func (*UidBlock) ProtoReflect

func (x *UidBlock) ProtoReflect() protoreflect.Message

func (*UidBlock) Reset

func (x *UidBlock) Reset()

func (*UidBlock) String

func (x *UidBlock) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use UidPack.ProtoReflect.Descriptor instead.

func (*UidPack) GetAllocRef

func (x *UidPack) GetAllocRef() uint64

func (*UidPack) GetBlockSize

func (x *UidPack) GetBlockSize() uint32

func (*UidPack) GetBlocks

func (x *UidPack) GetBlocks() []*UidBlock

func (*UidPack) ProtoMessage

func (*UidPack) ProtoMessage()

func (*UidPack) ProtoReflect

func (x *UidPack) ProtoReflect() protoreflect.Message

func (*UidPack) Reset

func (x *UidPack) Reset()

func (*UidPack) String

func (x *UidPack) String() string

type UnimplementedRaftServer

type UnimplementedRaftServer struct {
}

UnimplementedRaftServer must be embedded to have forward compatible implementations.

func (UnimplementedRaftServer) Heartbeat

func (UnimplementedRaftServer) IsPeer

func (UnimplementedRaftServer) JoinCluster

func (UnimplementedRaftServer) RaftMessage

type UnimplementedWorkerServer

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServer) ApplyDrainmode

func (UnimplementedWorkerServer) Backup

func (UnimplementedWorkerServer) DeleteNamespace

func (UnimplementedWorkerServer) Export

func (UnimplementedWorkerServer) InternalStreamPDir

func (UnimplementedWorkerServer) MovePredicate

func (UnimplementedWorkerServer) Mutate

func (UnimplementedWorkerServer) ReceivePredicate

func (UnimplementedWorkerServer) Restore

func (UnimplementedWorkerServer) Schema

func (UnimplementedWorkerServer) ServeTask

func (UnimplementedWorkerServer) Sort

func (UnimplementedWorkerServer) StreamSnapshot

func (UnimplementedWorkerServer) Subscribe

func (UnimplementedWorkerServer) TaskStatus

type UnimplementedZeroServer

type UnimplementedZeroServer struct {
}

UnimplementedZeroServer must be embedded to have forward compatible implementations.

func (UnimplementedZeroServer) AssignIds

func (UnimplementedZeroServer) CommitOrAbort

func (UnimplementedZeroServer) Connect

func (UnimplementedZeroServer) DeleteNamespace

func (UnimplementedZeroServer) Inform

func (UnimplementedZeroServer) MoveTablet

func (UnimplementedZeroServer) Oracle

func (UnimplementedZeroServer) RemoveNode

func (UnimplementedZeroServer) ShouldServe

func (UnimplementedZeroServer) StreamMembership

func (UnimplementedZeroServer) Timestamps

func (UnimplementedZeroServer) TryAbort

func (UnimplementedZeroServer) UpdateMembership

func (UnimplementedZeroServer) UpdateMembership(context.Context, *Group) (*api.Payload, error)

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 (*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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use ValueList.ProtoReflect.Descriptor instead.

func (*ValueList) GetValues

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

func (*ValueList) ProtoMessage

func (*ValueList) ProtoMessage()

func (*ValueList) ProtoReflect

func (x *ValueList) ProtoReflect() protoreflect.Message

func (*ValueList) Reset

func (x *ValueList) Reset()

func (*ValueList) String

func (x *ValueList) String() string

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

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_ReceivePredicateClient

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

type Worker_ReceivePredicateServer

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

type Worker_StreamSnapshotClient

type Worker_StreamSnapshotClient interface {
	Send(*Snapshot) error
	Recv() (*KVS, error)
	grpc.ClientStream
}

type Worker_StreamSnapshotServer

type Worker_StreamSnapshotServer interface {
	Send(*KVS) error
	Recv() (*Snapshot, 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
}

Jump to

Keyboard shortcuts

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