tserver

package
v0.0.0-...-c201ef6 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_FetchDataRequestPB_Offset    = uint64(0)
	Default_FetchDataRequestPB_MaxLength = int64(0)
)

Default values for FetchDataRequestPB fields.

View Source 
const (
	Default_WriteRequestPB_CacheBlocks  = bool(true)
	Default_WriteRequestPB_IncludeTrace = bool(false)
)

Default values for WriteRequestPB fields.

View Source 
const (
	Default_ReadRequestPB_CacheBlocks      = bool(true)
	Default_ReadRequestPB_IncludeTrace     = bool(false)
	Default_ReadRequestPB_ConsistencyLevel = common.YBConsistencyLevel_STRONG
)

Default values for ReadRequestPB fields.

View Source 
const (
	Default_CheckRemoteBootstrapSessionActiveRequestPB_Keepalive = bool(false)
)

Default values for CheckRemoteBootstrapSessionActiveRequestPB fields.

View Source 
const (
	Default_CreateTabletRequestPB_Colocated = bool(false)
)

Default values for CreateTabletRequestPB fields.

View Source 
const (
	Default_DeleteTabletRequestPB_DeleteType = common.TabletDataState_TABLET_DATA_TOMBSTONED
)

Default values for DeleteTabletRequestPB fields.

View Source 
const (
	Default_EndRemoteBootstrapSessionRequestPB_KeepSession = bool(false)
)

Default values for EndRemoteBootstrapSessionRequestPB fields.

View Source 
const (
	Default_EndRemoteBootstrapSessionResponsePB_SessionKept = bool(false)
)

Default values for EndRemoteBootstrapSessionResponsePB fields.

View Source 
const (
	Default_IsTabletServerReadyResponsePB_TotalTablets = int32(0)
)

Default values for IsTabletServerReadyResponsePB fields.

View Source 
const (
	Default_RemoteBootstrapErrorPB_Code = RemoteBootstrapErrorPB_UNKNOWN_ERROR
)

Default values for RemoteBootstrapErrorPB fields.

View Source 
const (
	Default_TabletServerErrorPB_Code = TabletServerErrorPB_UNKNOWN_ERROR
)

Default values for TabletServerErrorPB fields.

Variables

View Source 
var (
	TabletSnapshotOpRequestPB_Operation_name = map[int32]string{
		0: "UNKNOWN",
		1: "CREATE_ON_TABLET",
		2: "RESTORE_ON_TABLET",
		3: "DELETE_ON_TABLET",
		4: "CREATE_ON_MASTER",
		5: "DELETE_ON_MASTER",
		6: "RESTORE_SYS_CATALOG",
	}
	TabletSnapshotOpRequestPB_Operation_value = map[string]int32{
		"UNKNOWN":             0,
		"CREATE_ON_TABLET":    1,
		"RESTORE_ON_TABLET":   2,
		"DELETE_ON_TABLET":    3,
		"CREATE_ON_MASTER":    4,
		"DELETE_ON_MASTER":    5,
		"RESTORE_SYS_CATALOG": 6,
	}
)

Enum value maps for TabletSnapshotOpRequestPB_Operation.

View Source 
var (
	RemoteBootstrapErrorPB_Code_name = map[int32]string{
		1: "UNKNOWN_ERROR",
		2: "NO_SESSION",
		3: "TABLET_NOT_FOUND",
		4: "BLOCK_NOT_FOUND",
		5: "WAL_SEGMENT_NOT_FOUND",
		6: "INVALID_REMOTE_BOOTSTRAP_REQUEST",
		7: "IO_ERROR",
		8: "ROCKSDB_FILE_NOT_FOUND",
	}
	RemoteBootstrapErrorPB_Code_value = map[string]int32{
		"UNKNOWN_ERROR":                    1,
		"NO_SESSION":                       2,
		"TABLET_NOT_FOUND":                 3,
		"BLOCK_NOT_FOUND":                  4,
		"WAL_SEGMENT_NOT_FOUND":            5,
		"INVALID_REMOTE_BOOTSTRAP_REQUEST": 6,
		"IO_ERROR":                         7,
		"ROCKSDB_FILE_NOT_FOUND":           8,
	}
)

Enum value maps for RemoteBootstrapErrorPB_Code.

View Source 
var (
	DataIdPB_IdType_name = map[int32]string{
		0: "UNKNOWN",
		2: "LOG_SEGMENT",
		3: "ROCKSDB_FILE",
		4: "SNAPSHOT_FILE",
	}
	DataIdPB_IdType_value = map[string]int32{
		"UNKNOWN":       0,
		"LOG_SEGMENT":   2,
		"ROCKSDB_FILE":  3,
		"SNAPSHOT_FILE": 4,
	}
)

Enum value maps for DataIdPB_IdType.

View Source 
var (
	TabletServerErrorPB_Code_name = map[int32]string{
		1:  "UNKNOWN_ERROR",
		2:  "INVALID_SCHEMA",
		3:  "INVALID_ROW_BLOCK",
		4:  "INVALID_MUTATION",
		5:  "MISMATCHED_SCHEMA",
		6:  "TABLET_NOT_FOUND",
		7:  "SCANNER_EXPIRED",
		8:  "INVALID_SCAN_SPEC",
		9:  "INVALID_CONFIG",
		10: "TABLET_ALREADY_EXISTS",
		11: "TABLET_HAS_A_NEWER_SCHEMA",
		12: "TABLET_NOT_RUNNING",
		13: "INVALID_SNAPSHOT",
		14: "INVALID_SCAN_CALL_SEQ_ID",
		15: "NOT_THE_LEADER",
		16: "WRONG_SERVER_UUID",
		17: "CAS_FAILED",
		18: "LEADER_NOT_READY_CHANGE_CONFIG",
		19: "LEADER_NOT_READY_TO_STEP_DOWN",
		20: "ADD_CHANGE_CONFIG_ALREADY_PRESENT",
		21: "REMOVE_CHANGE_CONFIG_NOT_PRESENT",
		22: "LEADER_NEEDS_STEP_DOWN",
		23: "OPERATION_NOT_SUPPORTED",
		24: "LEADER_NOT_READY_TO_SERVE",
		25: "STALE_FOLLOWER",
		26: "ALREADY_IN_PROGRESS",
		27: "PENDING_LOCAL_BOOTSTRAPS",
		28: "TABLET_SPLIT",
	}
	TabletServerErrorPB_Code_value = map[string]int32{
		"UNKNOWN_ERROR":                     1,
		"INVALID_SCHEMA":                    2,
		"INVALID_ROW_BLOCK":                 3,
		"INVALID_MUTATION":                  4,
		"MISMATCHED_SCHEMA":                 5,
		"TABLET_NOT_FOUND":                  6,
		"SCANNER_EXPIRED":                   7,
		"INVALID_SCAN_SPEC":                 8,
		"INVALID_CONFIG":                    9,
		"TABLET_ALREADY_EXISTS":             10,
		"TABLET_HAS_A_NEWER_SCHEMA":         11,
		"TABLET_NOT_RUNNING":                12,
		"INVALID_SNAPSHOT":                  13,
		"INVALID_SCAN_CALL_SEQ_ID":          14,
		"NOT_THE_LEADER":                    15,
		"WRONG_SERVER_UUID":                 16,
		"CAS_FAILED":                        17,
		"LEADER_NOT_READY_CHANGE_CONFIG":    18,
		"LEADER_NOT_READY_TO_STEP_DOWN":     19,
		"ADD_CHANGE_CONFIG_ALREADY_PRESENT": 20,
		"REMOVE_CHANGE_CONFIG_NOT_PRESENT":  21,
		"LEADER_NEEDS_STEP_DOWN":            22,
		"OPERATION_NOT_SUPPORTED":           23,
		"LEADER_NOT_READY_TO_SERVE":         24,
		"STALE_FOLLOWER":                    25,
		"ALREADY_IN_PROGRESS":               26,
		"PENDING_LOCAL_BOOTSTRAPS":          27,
		"TABLET_SPLIT":                      28,
	}
)

Enum value maps for TabletServerErrorPB_Code.

View Source 
var (
	TSTabletManagerStatePB_name = map[int32]string{
		999: "UNKNOWN",
		0:   "MANAGER_INITIALIZING",
		1:   "MANAGER_RUNNING",
		2:   "MANAGER_QUIESCING",
		3:   "MANAGER_SHUTDOWN",
	}
	TSTabletManagerStatePB_value = map[string]int32{
		"UNKNOWN":              999,
		"MANAGER_INITIALIZING": 0,
		"MANAGER_RUNNING":      1,
		"MANAGER_QUIESCING":    2,
		"MANAGER_SHUTDOWN":     3,
	}
)

Enum value maps for TSTabletManagerStatePB.

View Source 
var (
	// optional yb.tserver.RemoteBootstrapErrorPB remote_bootstrap_error_ext = 102;
	E_RemoteBootstrapErrorPB_RemoteBootstrapErrorExt = &file_yb_tserver_remote_bootstrap_proto_extTypes[0]
)

Extension fields to rpc.ErrorStatusPB.

View Source 
var File_yb_tserver_backup_proto protoreflect.FileDescriptor
View Source 
var File_yb_tserver_remote_bootstrap_proto protoreflect.FileDescriptor
View Source 
var File_yb_tserver_tserver_admin_proto protoreflect.FileDescriptor
View Source 
var File_yb_tserver_tserver_proto protoreflect.FileDescriptor
View Source 
var File_yb_tserver_tserver_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AbortTransactionRequestPB 

type AbortTransactionRequestPB struct {
	TabletId             []byte  `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	TransactionId        []byte  `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId" json:"transaction_id,omitempty"`
	PropagatedHybridTime *uint64 `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*AbortTransactionRequestPB) Descriptor deprecated 

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

Deprecated: Use AbortTransactionRequestPB.ProtoReflect.Descriptor instead.

func (*AbortTransactionRequestPB) GetPropagatedHybridTime 

func (x *AbortTransactionRequestPB) GetPropagatedHybridTime() uint64

func (*AbortTransactionRequestPB) GetTabletId 

func (x *AbortTransactionRequestPB) GetTabletId() []byte

func (*AbortTransactionRequestPB) GetTransactionId 

func (x *AbortTransactionRequestPB) GetTransactionId() []byte

func (*AbortTransactionRequestPB) MarshalJSON 

func (m *AbortTransactionRequestPB) MarshalJSON() ([]byte, error)

func (*AbortTransactionRequestPB) ProtoMessage 

func (*AbortTransactionRequestPB) ProtoMessage()

func (*AbortTransactionRequestPB) ProtoReflect 

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

func (*AbortTransactionRequestPB) Reset 

func (x *AbortTransactionRequestPB) Reset()

func (*AbortTransactionRequestPB) String 

func (x *AbortTransactionRequestPB) String() string

func (*AbortTransactionRequestPB) UnmarshalJSON 

func (m *AbortTransactionRequestPB) UnmarshalJSON(b []byte) error

type AbortTransactionResponsePB 

type AbortTransactionResponsePB struct {

	// Error message, if any.
	Error  *TabletServerErrorPB      `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Status *common.TransactionStatus `protobuf:"varint,2,opt,name=status,enum=yb.TransactionStatus" json:"status,omitempty"`
	// For description of status_hybrid_time see comment in TransactionStatusResult.
	StatusHybridTime     *uint64 `protobuf:"fixed64,3,opt,name=status_hybrid_time,json=statusHybridTime" json:"status_hybrid_time,omitempty"`
	PropagatedHybridTime *uint64 `protobuf:"fixed64,4,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	CoordinatorSafeTime  *uint64 `protobuf:"fixed64,5,opt,name=coordinator_safe_time,json=coordinatorSafeTime" json:"coordinator_safe_time,omitempty"`
	// contains filtered or unexported fields
}

func (*AbortTransactionResponsePB) Descriptor deprecated 

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

Deprecated: Use AbortTransactionResponsePB.ProtoReflect.Descriptor instead.

func (*AbortTransactionResponsePB) GetCoordinatorSafeTime 

func (x *AbortTransactionResponsePB) GetCoordinatorSafeTime() uint64

func (*AbortTransactionResponsePB) GetError 

func (x *AbortTransactionResponsePB) GetError() *TabletServerErrorPB

func (*AbortTransactionResponsePB) GetPropagatedHybridTime 

func (x *AbortTransactionResponsePB) GetPropagatedHybridTime() uint64

func (*AbortTransactionResponsePB) GetStatus 

func (x *AbortTransactionResponsePB) GetStatus() common.TransactionStatus

func (*AbortTransactionResponsePB) GetStatusHybridTime 

func (x *AbortTransactionResponsePB) GetStatusHybridTime() uint64

func (*AbortTransactionResponsePB) MarshalJSON 

func (m *AbortTransactionResponsePB) MarshalJSON() ([]byte, error)

func (*AbortTransactionResponsePB) ProtoMessage 

func (*AbortTransactionResponsePB) ProtoMessage()

func (*AbortTransactionResponsePB) ProtoReflect 

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

func (*AbortTransactionResponsePB) Reset 

func (x *AbortTransactionResponsePB) Reset()

func (*AbortTransactionResponsePB) String 

func (x *AbortTransactionResponsePB) String() string

func (*AbortTransactionResponsePB) UnmarshalJSON 

func (m *AbortTransactionResponsePB) UnmarshalJSON(b []byte) error

type AddTableToTabletRequestPB 

type AddTableToTabletRequestPB struct {
	TabletId []byte              `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	AddTable *common.TableInfoPB `protobuf:"bytes,2,req,name=add_table,json=addTable" json:"add_table,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTableToTabletRequestPB) Descriptor deprecated 

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

Deprecated: Use AddTableToTabletRequestPB.ProtoReflect.Descriptor instead.

func (*AddTableToTabletRequestPB) GetAddTable 

func (x *AddTableToTabletRequestPB) GetAddTable() *common.TableInfoPB

func (*AddTableToTabletRequestPB) GetTabletId 

func (x *AddTableToTabletRequestPB) GetTabletId() []byte

func (*AddTableToTabletRequestPB) MarshalJSON 

func (m *AddTableToTabletRequestPB) MarshalJSON() ([]byte, error)

func (*AddTableToTabletRequestPB) ProtoMessage 

func (*AddTableToTabletRequestPB) ProtoMessage()

func (*AddTableToTabletRequestPB) ProtoReflect 

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

func (*AddTableToTabletRequestPB) Reset 

func (x *AddTableToTabletRequestPB) Reset()

func (*AddTableToTabletRequestPB) String 

func (x *AddTableToTabletRequestPB) String() string

func (*AddTableToTabletRequestPB) UnmarshalJSON 

func (m *AddTableToTabletRequestPB) UnmarshalJSON(b []byte) error

type AddTableToTabletResponsePB 

type AddTableToTabletResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTableToTabletResponsePB) Descriptor deprecated 

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

Deprecated: Use AddTableToTabletResponsePB.ProtoReflect.Descriptor instead.

func (*AddTableToTabletResponsePB) GetError 

func (x *AddTableToTabletResponsePB) GetError() *TabletServerErrorPB

func (*AddTableToTabletResponsePB) GetPropagatedHybridTime 

func (x *AddTableToTabletResponsePB) GetPropagatedHybridTime() uint64

func (*AddTableToTabletResponsePB) MarshalJSON 

func (m *AddTableToTabletResponsePB) MarshalJSON() ([]byte, error)

func (*AddTableToTabletResponsePB) ProtoMessage 

func (*AddTableToTabletResponsePB) ProtoMessage()

func (*AddTableToTabletResponsePB) ProtoReflect 

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

func (*AddTableToTabletResponsePB) Reset 

func (x *AddTableToTabletResponsePB) Reset()

func (*AddTableToTabletResponsePB) String 

func (x *AddTableToTabletResponsePB) String() string

func (*AddTableToTabletResponsePB) UnmarshalJSON 

func (m *AddTableToTabletResponsePB) UnmarshalJSON(b []byte) error

type BackfillIndexRequestPB 

type BackfillIndexRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,1,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TabletId []byte `protobuf:"bytes,2,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Indexes on the _same table_ to backfill.
	Indexes              []*common.IndexInfoPB `protobuf:"bytes,3,rep,name=indexes" json:"indexes,omitempty"`
	SchemaVersion        *uint32               `protobuf:"varint,4,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	ReadAtHybridTime     *uint64               `protobuf:"fixed64,5,opt,name=read_at_hybrid_time,json=readAtHybridTime" json:"read_at_hybrid_time,omitempty"`
	StartKey             []byte                `protobuf:"bytes,6,opt,name=start_key,json=startKey" json:"start_key,omitempty"`
	EndKey               []byte                `protobuf:"bytes,7,opt,name=end_key,json=endKey" json:"end_key,omitempty"`
	PropagatedHybridTime *uint64               `protobuf:"fixed64,8,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// Currently only used for YSQL.
	NamespaceName *string `protobuf:"bytes,9,opt,name=namespace_name,json=namespaceName" json:"namespace_name,omitempty"`
	// Indexed table ID so we can properly address a colocated table.
	IndexedTableId []byte `protobuf:"bytes,10,opt,name=indexed_table_id,json=indexedTableId" json:"indexed_table_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BackfillIndexRequestPB) Descriptor deprecated 

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

Deprecated: Use BackfillIndexRequestPB.ProtoReflect.Descriptor instead.

func (*BackfillIndexRequestPB) GetDestUuid 

func (x *BackfillIndexRequestPB) GetDestUuid() []byte

func (*BackfillIndexRequestPB) GetEndKey 

func (x *BackfillIndexRequestPB) GetEndKey() []byte

func (*BackfillIndexRequestPB) GetIndexedTableId 

func (x *BackfillIndexRequestPB) GetIndexedTableId() []byte

func (*BackfillIndexRequestPB) GetIndexes 

func (x *BackfillIndexRequestPB) GetIndexes() []*common.IndexInfoPB

func (*BackfillIndexRequestPB) GetNamespaceName 

func (x *BackfillIndexRequestPB) GetNamespaceName() string

func (*BackfillIndexRequestPB) GetPropagatedHybridTime 

func (x *BackfillIndexRequestPB) GetPropagatedHybridTime() uint64

func (*BackfillIndexRequestPB) GetReadAtHybridTime 

func (x *BackfillIndexRequestPB) GetReadAtHybridTime() uint64

func (*BackfillIndexRequestPB) GetSchemaVersion 

func (x *BackfillIndexRequestPB) GetSchemaVersion() uint32

func (*BackfillIndexRequestPB) GetStartKey 

func (x *BackfillIndexRequestPB) GetStartKey() []byte

func (*BackfillIndexRequestPB) GetTabletId 

func (x *BackfillIndexRequestPB) GetTabletId() []byte

func (*BackfillIndexRequestPB) MarshalJSON 

func (m *BackfillIndexRequestPB) MarshalJSON() ([]byte, error)

func (*BackfillIndexRequestPB) ProtoMessage 

func (*BackfillIndexRequestPB) ProtoMessage()

func (*BackfillIndexRequestPB) ProtoReflect 

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

func (*BackfillIndexRequestPB) Reset 

func (x *BackfillIndexRequestPB) Reset()

func (*BackfillIndexRequestPB) String 

func (x *BackfillIndexRequestPB) String() string

func (*BackfillIndexRequestPB) UnmarshalJSON 

func (m *BackfillIndexRequestPB) UnmarshalJSON(b []byte) error

type BackfillIndexResponsePB 

type BackfillIndexResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// If non-empty, this is used to keep track of how far along
	// the backfill has completed, so that it can be resumed.
	// Encoded as the DocKey for the next row to be backfilled.
	BackfilledUntil []byte `protobuf:"bytes,3,opt,name=backfilled_until,json=backfilledUntil" json:"backfilled_until,omitempty"`
	// In case of a partial error, list of indexes that failed.
	FailedIndexIds [][]byte `protobuf:"bytes,4,rep,name=failed_index_ids,json=failedIndexIds" json:"failed_index_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*BackfillIndexResponsePB) Descriptor deprecated 

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

Deprecated: Use BackfillIndexResponsePB.ProtoReflect.Descriptor instead.

func (*BackfillIndexResponsePB) GetBackfilledUntil 

func (x *BackfillIndexResponsePB) GetBackfilledUntil() []byte

func (*BackfillIndexResponsePB) GetError 

func (x *BackfillIndexResponsePB) GetError() *TabletServerErrorPB

func (*BackfillIndexResponsePB) GetFailedIndexIds 

func (x *BackfillIndexResponsePB) GetFailedIndexIds() [][]byte

func (*BackfillIndexResponsePB) GetPropagatedHybridTime 

func (x *BackfillIndexResponsePB) GetPropagatedHybridTime() uint64

func (*BackfillIndexResponsePB) MarshalJSON 

func (m *BackfillIndexResponsePB) MarshalJSON() ([]byte, error)

func (*BackfillIndexResponsePB) ProtoMessage 

func (*BackfillIndexResponsePB) ProtoMessage()

func (*BackfillIndexResponsePB) ProtoReflect 

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

func (*BackfillIndexResponsePB) Reset 

func (x *BackfillIndexResponsePB) Reset()

func (*BackfillIndexResponsePB) String 

func (x *BackfillIndexResponsePB) String() string

func (*BackfillIndexResponsePB) UnmarshalJSON 

func (m *BackfillIndexResponsePB) UnmarshalJSON(b []byte) error

type BeginRemoteBootstrapSessionRequestPB 

type BeginRemoteBootstrapSessionRequestPB struct {

	// permanent_uuid of the requesting peer.
	RequestorUuid []byte `protobuf:"bytes,1,req,name=requestor_uuid,json=requestorUuid" json:"requestor_uuid,omitempty"`
	// tablet_id of the tablet the requester desires to bootstrap from.
	TabletId []byte `protobuf:"bytes,2,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginRemoteBootstrapSessionRequestPB) Descriptor deprecated 

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

Deprecated: Use BeginRemoteBootstrapSessionRequestPB.ProtoReflect.Descriptor instead.

func (*BeginRemoteBootstrapSessionRequestPB) GetRequestorUuid 

func (x *BeginRemoteBootstrapSessionRequestPB) GetRequestorUuid() []byte

func (*BeginRemoteBootstrapSessionRequestPB) GetTabletId 

func (x *BeginRemoteBootstrapSessionRequestPB) GetTabletId() []byte

func (*BeginRemoteBootstrapSessionRequestPB) MarshalJSON 

func (m *BeginRemoteBootstrapSessionRequestPB) MarshalJSON() ([]byte, error)

func (*BeginRemoteBootstrapSessionRequestPB) ProtoMessage 

func (*BeginRemoteBootstrapSessionRequestPB) ProtoMessage()

func (*BeginRemoteBootstrapSessionRequestPB) ProtoReflect 

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

func (*BeginRemoteBootstrapSessionRequestPB) Reset 

func (x *BeginRemoteBootstrapSessionRequestPB) Reset()

func (*BeginRemoteBootstrapSessionRequestPB) String 

func (x *BeginRemoteBootstrapSessionRequestPB) String() string

func (*BeginRemoteBootstrapSessionRequestPB) UnmarshalJSON 

func (m *BeginRemoteBootstrapSessionRequestPB) UnmarshalJSON(b []byte) error

type BeginRemoteBootstrapSessionResponsePB 

type BeginRemoteBootstrapSessionResponsePB struct {

	// Opaque session id assigned by the server.
	// No guarantees are made as to the format of the session id.
	SessionId []byte `protobuf:"bytes,1,req,name=session_id,json=sessionId" json:"session_id,omitempty"`
	// Maximum session idle timeout between requests.
	// Learners will have to start over again if they reach this timeout.
	// A value of 0 means there is no timeout.
	SessionIdleTimeoutMillis *uint64 `` /* 131-byte string literal not displayed */
	// Active superblock at the time of the request.
	Superblock *common.RaftGroupReplicaSuperBlockPB `protobuf:"bytes,3,req,name=superblock" json:"superblock,omitempty"`
	// Identifiers for the WAL segments available for download.
	// Each WAL segment is keyed by its sequence number.
	DEPRECATEDWalSegmentSeqnos []uint64 `` /* 137-byte string literal not displayed */
	// Sequence number of first WAL segment available for download.
	FirstWalSegmentSeqno *uint64 `protobuf:"varint,6,opt,name=first_wal_segment_seqno,json=firstWalSegmentSeqno" json:"first_wal_segment_seqno,omitempty"`
	// A snapshot of the committed Consensus state at the time that the
	// remote bootstrap session was started.
	InitialCommittedCstate *common.ConsensusStatePB `protobuf:"bytes,5,req,name=initial_committed_cstate,json=initialCommittedCstate" json:"initial_committed_cstate,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginRemoteBootstrapSessionResponsePB) Descriptor deprecated 

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

Deprecated: Use BeginRemoteBootstrapSessionResponsePB.ProtoReflect.Descriptor instead.

func (*BeginRemoteBootstrapSessionResponsePB) GetDEPRECATEDWalSegmentSeqnos 

func (x *BeginRemoteBootstrapSessionResponsePB) GetDEPRECATEDWalSegmentSeqnos() []uint64

func (*BeginRemoteBootstrapSessionResponsePB) GetFirstWalSegmentSeqno 

func (x *BeginRemoteBootstrapSessionResponsePB) GetFirstWalSegmentSeqno() uint64

func (*BeginRemoteBootstrapSessionResponsePB) GetInitialCommittedCstate 

func (x *BeginRemoteBootstrapSessionResponsePB) GetInitialCommittedCstate() *common.ConsensusStatePB

func (*BeginRemoteBootstrapSessionResponsePB) GetSessionId 

func (x *BeginRemoteBootstrapSessionResponsePB) GetSessionId() []byte

func (*BeginRemoteBootstrapSessionResponsePB) GetSessionIdleTimeoutMillis 

func (x *BeginRemoteBootstrapSessionResponsePB) GetSessionIdleTimeoutMillis() uint64

func (*BeginRemoteBootstrapSessionResponsePB) GetSuperblock 

func (x *BeginRemoteBootstrapSessionResponsePB) GetSuperblock() *common.RaftGroupReplicaSuperBlockPB

func (*BeginRemoteBootstrapSessionResponsePB) MarshalJSON 

func (m *BeginRemoteBootstrapSessionResponsePB) MarshalJSON() ([]byte, error)

func (*BeginRemoteBootstrapSessionResponsePB) ProtoMessage 

func (*BeginRemoteBootstrapSessionResponsePB) ProtoMessage()

func (*BeginRemoteBootstrapSessionResponsePB) ProtoReflect 

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

func (*BeginRemoteBootstrapSessionResponsePB) Reset 

func (x *BeginRemoteBootstrapSessionResponsePB) Reset()

func (*BeginRemoteBootstrapSessionResponsePB) String 

func (x *BeginRemoteBootstrapSessionResponsePB) String() string

func (*BeginRemoteBootstrapSessionResponsePB) UnmarshalJSON 

func (m *BeginRemoteBootstrapSessionResponsePB) UnmarshalJSON(b []byte) error

type ChangeMetadataRequestPB 

type ChangeMetadataRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,5,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// TODO: Replace with the table descriptor
	// (Schema, Column IDs, Column Attributes)
	Schema               *common.SchemaPB      `protobuf:"bytes,2,opt,name=schema" json:"schema,omitempty"`
	Indexes              []*common.IndexInfoPB `protobuf:"bytes,7,rep,name=indexes" json:"indexes,omitempty"`
	SchemaVersion        *uint32               `protobuf:"varint,3,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	NewTableName         *string               `protobuf:"bytes,4,opt,name=new_table_name,json=newTableName" json:"new_table_name,omitempty"`
	PropagatedHybridTime *uint64               `protobuf:"fixed64,6,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	AddTable             *common.TableInfoPB   `protobuf:"bytes,8,opt,name=add_table,json=addTable" json:"add_table,omitempty"`
	WalRetentionSecs     *uint32               `protobuf:"varint,9,opt,name=wal_retention_secs,json=walRetentionSecs" json:"wal_retention_secs,omitempty"`
	RemoveTableId        []byte                `protobuf:"bytes,10,opt,name=remove_table_id,json=removeTableId" json:"remove_table_id,omitempty"`
	// Note that we don't use the value of this and just check has_mark_backfill_done.
	MarkBackfillDone *bool `protobuf:"varint,11,opt,name=mark_backfill_done,json=markBackfillDone" json:"mark_backfill_done,omitempty"`
	// Used for alter schema on a non-primary table (e.g. colocated user table).
	AlterTableId []byte `protobuf:"bytes,12,opt,name=alter_table_id,json=alterTableId" json:"alter_table_id,omitempty"`
	// Used to update schema of a colocated user table upon backfill completion.
	BackfillDoneTableId []byte `protobuf:"bytes,13,opt,name=backfill_done_table_id,json=backfillDoneTableId" json:"backfill_done_table_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeMetadataRequestPB) Descriptor deprecated 

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

Deprecated: Use ChangeMetadataRequestPB.ProtoReflect.Descriptor instead.

func (*ChangeMetadataRequestPB) GetAddTable 

func (x *ChangeMetadataRequestPB) GetAddTable() *common.TableInfoPB

func (*ChangeMetadataRequestPB) GetAlterTableId 

func (x *ChangeMetadataRequestPB) GetAlterTableId() []byte

func (*ChangeMetadataRequestPB) GetBackfillDoneTableId 

func (x *ChangeMetadataRequestPB) GetBackfillDoneTableId() []byte

func (*ChangeMetadataRequestPB) GetDestUuid 

func (x *ChangeMetadataRequestPB) GetDestUuid() []byte

func (*ChangeMetadataRequestPB) GetIndexes 

func (x *ChangeMetadataRequestPB) GetIndexes() []*common.IndexInfoPB

func (*ChangeMetadataRequestPB) GetMarkBackfillDone 

func (x *ChangeMetadataRequestPB) GetMarkBackfillDone() bool

func (*ChangeMetadataRequestPB) GetNewTableName 

func (x *ChangeMetadataRequestPB) GetNewTableName() string

func (*ChangeMetadataRequestPB) GetPropagatedHybridTime 

func (x *ChangeMetadataRequestPB) GetPropagatedHybridTime() uint64

func (*ChangeMetadataRequestPB) GetRemoveTableId 

func (x *ChangeMetadataRequestPB) GetRemoveTableId() []byte

func (*ChangeMetadataRequestPB) GetSchema 

func (x *ChangeMetadataRequestPB) GetSchema() *common.SchemaPB

func (*ChangeMetadataRequestPB) GetSchemaVersion 

func (x *ChangeMetadataRequestPB) GetSchemaVersion() uint32

func (*ChangeMetadataRequestPB) GetTabletId 

func (x *ChangeMetadataRequestPB) GetTabletId() []byte

func (*ChangeMetadataRequestPB) GetWalRetentionSecs 

func (x *ChangeMetadataRequestPB) GetWalRetentionSecs() uint32

func (*ChangeMetadataRequestPB) MarshalJSON 

func (m *ChangeMetadataRequestPB) MarshalJSON() ([]byte, error)

func (*ChangeMetadataRequestPB) ProtoMessage 

func (*ChangeMetadataRequestPB) ProtoMessage()

func (*ChangeMetadataRequestPB) ProtoReflect 

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

func (*ChangeMetadataRequestPB) Reset 

func (x *ChangeMetadataRequestPB) Reset()

func (*ChangeMetadataRequestPB) String 

func (x *ChangeMetadataRequestPB) String() string

func (*ChangeMetadataRequestPB) UnmarshalJSON 

func (m *ChangeMetadataRequestPB) UnmarshalJSON(b []byte) error

type ChangeMetadataResponsePB 

type ChangeMetadataResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeMetadataResponsePB) Descriptor deprecated 

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

Deprecated: Use ChangeMetadataResponsePB.ProtoReflect.Descriptor instead.

func (*ChangeMetadataResponsePB) GetError 

func (x *ChangeMetadataResponsePB) GetError() *TabletServerErrorPB

func (*ChangeMetadataResponsePB) GetPropagatedHybridTime 

func (x *ChangeMetadataResponsePB) GetPropagatedHybridTime() uint64

func (*ChangeMetadataResponsePB) MarshalJSON 

func (m *ChangeMetadataResponsePB) MarshalJSON() ([]byte, error)

func (*ChangeMetadataResponsePB) ProtoMessage 

func (*ChangeMetadataResponsePB) ProtoMessage()

func (*ChangeMetadataResponsePB) ProtoReflect 

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

func (*ChangeMetadataResponsePB) Reset 

func (x *ChangeMetadataResponsePB) Reset()

func (*ChangeMetadataResponsePB) String 

func (x *ChangeMetadataResponsePB) String() string

func (*ChangeMetadataResponsePB) UnmarshalJSON 

func (m *ChangeMetadataResponsePB) UnmarshalJSON(b []byte) error

type CheckRemoteBootstrapSessionActiveRequestPB 

type CheckRemoteBootstrapSessionActiveRequestPB struct {

	// Valid Session ID returned by a BeginRemoteBootstrapSession() RPC call.
	SessionId []byte `protobuf:"bytes,1,req,name=session_id,json=sessionId" json:"session_id,omitempty"`
	// Set keepalive to true to reset the session timeout timer.
	Keepalive *bool `protobuf:"varint,2,opt,name=keepalive,def=0" json:"keepalive,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckRemoteBootstrapSessionActiveRequestPB) Descriptor deprecated 

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

Deprecated: Use CheckRemoteBootstrapSessionActiveRequestPB.ProtoReflect.Descriptor instead.

func (*CheckRemoteBootstrapSessionActiveRequestPB) GetKeepalive 

func (x *CheckRemoteBootstrapSessionActiveRequestPB) GetKeepalive() bool

func (*CheckRemoteBootstrapSessionActiveRequestPB) GetSessionId 

func (x *CheckRemoteBootstrapSessionActiveRequestPB) GetSessionId() []byte

func (*CheckRemoteBootstrapSessionActiveRequestPB) MarshalJSON 

func (m *CheckRemoteBootstrapSessionActiveRequestPB) MarshalJSON() ([]byte, error)

func (*CheckRemoteBootstrapSessionActiveRequestPB) ProtoMessage 

func (*CheckRemoteBootstrapSessionActiveRequestPB) ProtoMessage()

func (*CheckRemoteBootstrapSessionActiveRequestPB) ProtoReflect 

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

func (*CheckRemoteBootstrapSessionActiveRequestPB) Reset 

func (x *CheckRemoteBootstrapSessionActiveRequestPB) Reset()

func (*CheckRemoteBootstrapSessionActiveRequestPB) String 

func (x *CheckRemoteBootstrapSessionActiveRequestPB) String() string

func (*CheckRemoteBootstrapSessionActiveRequestPB) UnmarshalJSON 

func (m *CheckRemoteBootstrapSessionActiveRequestPB) UnmarshalJSON(b []byte) error

type CheckRemoteBootstrapSessionActiveResponsePB 

type CheckRemoteBootstrapSessionActiveResponsePB struct {

	// Whether the given session id represents an active remote bootstrap session.
	SessionIsActive *bool `protobuf:"varint,1,req,name=session_is_active,json=sessionIsActive" json:"session_is_active,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckRemoteBootstrapSessionActiveResponsePB) Descriptor deprecated 

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

Deprecated: Use CheckRemoteBootstrapSessionActiveResponsePB.ProtoReflect.Descriptor instead.

func (*CheckRemoteBootstrapSessionActiveResponsePB) GetSessionIsActive 

func (x *CheckRemoteBootstrapSessionActiveResponsePB) GetSessionIsActive() bool

func (*CheckRemoteBootstrapSessionActiveResponsePB) MarshalJSON 

func (m *CheckRemoteBootstrapSessionActiveResponsePB) MarshalJSON() ([]byte, error)

func (*CheckRemoteBootstrapSessionActiveResponsePB) ProtoMessage 

func (*CheckRemoteBootstrapSessionActiveResponsePB) ProtoMessage()

func (*CheckRemoteBootstrapSessionActiveResponsePB) ProtoReflect 

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

func (*CheckRemoteBootstrapSessionActiveResponsePB) Reset 

func (x *CheckRemoteBootstrapSessionActiveResponsePB) Reset()

func (*CheckRemoteBootstrapSessionActiveResponsePB) String 

func (x *CheckRemoteBootstrapSessionActiveResponsePB) String() string

func (*CheckRemoteBootstrapSessionActiveResponsePB) UnmarshalJSON 

func (m *CheckRemoteBootstrapSessionActiveResponsePB) UnmarshalJSON(b []byte) error

type ChecksumRequestPB 

type ChecksumRequestPB struct {
	TabletId         []byte                     `protobuf:"bytes,6,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	ConsistencyLevel *common.YBConsistencyLevel `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChecksumRequestPB) Descriptor deprecated 

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

Deprecated: Use ChecksumRequestPB.ProtoReflect.Descriptor instead.

func (*ChecksumRequestPB) GetConsistencyLevel 

func (x *ChecksumRequestPB) GetConsistencyLevel() common.YBConsistencyLevel

func (*ChecksumRequestPB) GetTabletId 

func (x *ChecksumRequestPB) GetTabletId() []byte

func (*ChecksumRequestPB) MarshalJSON 

func (m *ChecksumRequestPB) MarshalJSON() ([]byte, error)

func (*ChecksumRequestPB) ProtoMessage 

func (*ChecksumRequestPB) ProtoMessage()

func (*ChecksumRequestPB) ProtoReflect 

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

func (*ChecksumRequestPB) Reset 

func (x *ChecksumRequestPB) Reset()

func (*ChecksumRequestPB) String 

func (x *ChecksumRequestPB) String() string

func (*ChecksumRequestPB) UnmarshalJSON 

func (m *ChecksumRequestPB) UnmarshalJSON(b []byte) error

type ChecksumResponsePB 

type ChecksumResponsePB struct {

	// Error message, if any.
	Error *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// The (possibly partial) checksum of the tablet data.
	// This checksum is only complete if 'has_more_results' is false.
	Checksum *uint64 `protobuf:"varint,2,opt,name=checksum" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*ChecksumResponsePB) Descriptor deprecated 

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

Deprecated: Use ChecksumResponsePB.ProtoReflect.Descriptor instead.

func (*ChecksumResponsePB) GetChecksum 

func (x *ChecksumResponsePB) GetChecksum() uint64

func (*ChecksumResponsePB) GetError 

func (x *ChecksumResponsePB) GetError() *TabletServerErrorPB

func (*ChecksumResponsePB) MarshalJSON 

func (m *ChecksumResponsePB) MarshalJSON() ([]byte, error)

func (*ChecksumResponsePB) ProtoMessage 

func (*ChecksumResponsePB) ProtoMessage()

func (*ChecksumResponsePB) ProtoReflect 

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

func (*ChecksumResponsePB) Reset 

func (x *ChecksumResponsePB) Reset()

func (*ChecksumResponsePB) String 

func (x *ChecksumResponsePB) String() string

func (*ChecksumResponsePB) UnmarshalJSON 

func (m *ChecksumResponsePB) UnmarshalJSON(b []byte) error

type CopartitionTableRequestPB 

type CopartitionTableRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid  []byte  `protobuf:"bytes,1,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TableId   []byte  `protobuf:"bytes,2,opt,name=table_id,json=tableId" json:"table_id,omitempty"`
	TabletId  []byte  `protobuf:"bytes,3,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	TableName *string `protobuf:"bytes,4,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CopartitionTableRequestPB) Descriptor deprecated 

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

Deprecated: Use CopartitionTableRequestPB.ProtoReflect.Descriptor instead.

func (*CopartitionTableRequestPB) GetDestUuid 

func (x *CopartitionTableRequestPB) GetDestUuid() []byte

func (*CopartitionTableRequestPB) GetTableId 

func (x *CopartitionTableRequestPB) GetTableId() []byte

func (*CopartitionTableRequestPB) GetTableName 

func (x *CopartitionTableRequestPB) GetTableName() string

func (*CopartitionTableRequestPB) GetTabletId 

func (x *CopartitionTableRequestPB) GetTabletId() []byte

func (*CopartitionTableRequestPB) MarshalJSON 

func (m *CopartitionTableRequestPB) MarshalJSON() ([]byte, error)

func (*CopartitionTableRequestPB) ProtoMessage 

func (*CopartitionTableRequestPB) ProtoMessage()

func (*CopartitionTableRequestPB) ProtoReflect 

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

func (*CopartitionTableRequestPB) Reset 

func (x *CopartitionTableRequestPB) Reset()

func (*CopartitionTableRequestPB) String 

func (x *CopartitionTableRequestPB) String() string

func (*CopartitionTableRequestPB) UnmarshalJSON 

func (m *CopartitionTableRequestPB) UnmarshalJSON(b []byte) error

type CopartitionTableResponsePB 

type CopartitionTableResponsePB struct {
	Error *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CopartitionTableResponsePB) Descriptor deprecated 

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

Deprecated: Use CopartitionTableResponsePB.ProtoReflect.Descriptor instead.

func (*CopartitionTableResponsePB) GetError 

func (x *CopartitionTableResponsePB) GetError() *TabletServerErrorPB

func (*CopartitionTableResponsePB) MarshalJSON 

func (m *CopartitionTableResponsePB) MarshalJSON() ([]byte, error)

func (*CopartitionTableResponsePB) ProtoMessage 

func (*CopartitionTableResponsePB) ProtoMessage()

func (*CopartitionTableResponsePB) ProtoReflect 

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

func (*CopartitionTableResponsePB) Reset 

func (x *CopartitionTableResponsePB) Reset()

func (*CopartitionTableResponsePB) String 

func (x *CopartitionTableResponsePB) String() string

func (*CopartitionTableResponsePB) UnmarshalJSON 

func (m *CopartitionTableResponsePB) UnmarshalJSON(b []byte) error

type CountIntentsRequestPB 

type CountIntentsRequestPB struct {
	// contains filtered or unexported fields
}

func (*CountIntentsRequestPB) Descriptor deprecated 

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

Deprecated: Use CountIntentsRequestPB.ProtoReflect.Descriptor instead.

func (*CountIntentsRequestPB) MarshalJSON 

func (m *CountIntentsRequestPB) MarshalJSON() ([]byte, error)

func (*CountIntentsRequestPB) ProtoMessage 

func (*CountIntentsRequestPB) ProtoMessage()

func (*CountIntentsRequestPB) ProtoReflect 

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

func (*CountIntentsRequestPB) Reset 

func (x *CountIntentsRequestPB) Reset()

func (*CountIntentsRequestPB) String 

func (x *CountIntentsRequestPB) String() string

func (*CountIntentsRequestPB) UnmarshalJSON 

func (m *CountIntentsRequestPB) UnmarshalJSON(b []byte) error

type CountIntentsResponsePB 

type CountIntentsResponsePB struct {
	Error      *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	NumIntents *int64               `protobuf:"varint,2,opt,name=num_intents,json=numIntents" json:"num_intents,omitempty"`
	// contains filtered or unexported fields
}

func (*CountIntentsResponsePB) Descriptor deprecated 

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

Deprecated: Use CountIntentsResponsePB.ProtoReflect.Descriptor instead.

func (*CountIntentsResponsePB) GetError 

func (x *CountIntentsResponsePB) GetError() *TabletServerErrorPB

func (*CountIntentsResponsePB) GetNumIntents 

func (x *CountIntentsResponsePB) GetNumIntents() int64

func (*CountIntentsResponsePB) MarshalJSON 

func (m *CountIntentsResponsePB) MarshalJSON() ([]byte, error)

func (*CountIntentsResponsePB) ProtoMessage 

func (*CountIntentsResponsePB) ProtoMessage()

func (*CountIntentsResponsePB) ProtoReflect 

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

func (*CountIntentsResponsePB) Reset 

func (x *CountIntentsResponsePB) Reset()

func (*CountIntentsResponsePB) String 

func (x *CountIntentsResponsePB) String() string

func (*CountIntentsResponsePB) UnmarshalJSON 

func (m *CountIntentsResponsePB) UnmarshalJSON(b []byte) error

type CreateTabletRequestPB 

type CreateTabletRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,8,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TableId  []byte `protobuf:"bytes,1,req,name=table_id,json=tableId" json:"table_id,omitempty"`
	TabletId []byte `protobuf:"bytes,2,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// DEPRECATED.
	StartKey []byte `protobuf:"bytes,3,opt,name=start_key,json=startKey" json:"start_key,omitempty"`
	// DEPRECATED.
	EndKey []byte `protobuf:"bytes,4,opt,name=end_key,json=endKey" json:"end_key,omitempty"`
	// The partition of the tablet.
	Partition     *common.PartitionPB `protobuf:"bytes,9,opt,name=partition" json:"partition,omitempty"`
	NamespaceId   []byte              `protobuf:"bytes,14,opt,name=namespace_id,json=namespaceId" json:"namespace_id,omitempty"`
	NamespaceName []byte              `protobuf:"bytes,15,opt,name=namespace_name,json=namespaceName" json:"namespace_name,omitempty"`
	TableName     *string             `protobuf:"bytes,5,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	TableType     *common.TableType   `protobuf:"varint,11,opt,name=table_type,json=tableType,enum=yb.TableType" json:"table_type,omitempty"`
	Schema        *common.SchemaPB    `protobuf:"bytes,6,req,name=schema" json:"schema,omitempty"`
	// The partition schema of the table which the tablet belongs to.
	PartitionSchema *common.PartitionSchemaPB `protobuf:"bytes,10,opt,name=partition_schema,json=partitionSchema" json:"partition_schema,omitempty"`
	// Initial consensus configuration for the tablet.
	Config *common.RaftConfigPB `protobuf:"bytes,7,req,name=config" json:"config,omitempty"`
	// For index table: information about this index.
	IndexInfo *common.IndexInfoPB `protobuf:"bytes,12,opt,name=index_info,json=indexInfo" json:"index_info,omitempty"`
	// True if the tablet is colocated.
	Colocated         *bool    `protobuf:"varint,13,opt,name=colocated,def=0" json:"colocated,omitempty"`
	SnapshotSchedules [][]byte `protobuf:"bytes,16,rep,name=snapshot_schedules,json=snapshotSchedules" json:"snapshot_schedules,omitempty"`
	// contains filtered or unexported fields
}

A create tablet request.

func (*CreateTabletRequestPB) Descriptor deprecated 

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

Deprecated: Use CreateTabletRequestPB.ProtoReflect.Descriptor instead.

func (*CreateTabletRequestPB) GetColocated 

func (x *CreateTabletRequestPB) GetColocated() bool

func (*CreateTabletRequestPB) GetConfig 

func (x *CreateTabletRequestPB) GetConfig() *common.RaftConfigPB

func (*CreateTabletRequestPB) GetDestUuid 

func (x *CreateTabletRequestPB) GetDestUuid() []byte

func (*CreateTabletRequestPB) GetEndKey 

func (x *CreateTabletRequestPB) GetEndKey() []byte

func (*CreateTabletRequestPB) GetIndexInfo 

func (x *CreateTabletRequestPB) GetIndexInfo() *common.IndexInfoPB

func (*CreateTabletRequestPB) GetNamespaceId 

func (x *CreateTabletRequestPB) GetNamespaceId() []byte

func (*CreateTabletRequestPB) GetNamespaceName 

func (x *CreateTabletRequestPB) GetNamespaceName() []byte

func (*CreateTabletRequestPB) GetPartition 

func (x *CreateTabletRequestPB) GetPartition() *common.PartitionPB

func (*CreateTabletRequestPB) GetPartitionSchema 

func (x *CreateTabletRequestPB) GetPartitionSchema() *common.PartitionSchemaPB

func (*CreateTabletRequestPB) GetSchema 

func (x *CreateTabletRequestPB) GetSchema() *common.SchemaPB

func (*CreateTabletRequestPB) GetSnapshotSchedules 

func (x *CreateTabletRequestPB) GetSnapshotSchedules() [][]byte

func (*CreateTabletRequestPB) GetStartKey 

func (x *CreateTabletRequestPB) GetStartKey() []byte

func (*CreateTabletRequestPB) GetTableId 

func (x *CreateTabletRequestPB) GetTableId() []byte

func (*CreateTabletRequestPB) GetTableName 

func (x *CreateTabletRequestPB) GetTableName() string

func (*CreateTabletRequestPB) GetTableType 

func (x *CreateTabletRequestPB) GetTableType() common.TableType

func (*CreateTabletRequestPB) GetTabletId 

func (x *CreateTabletRequestPB) GetTabletId() []byte

func (*CreateTabletRequestPB) MarshalJSON 

func (m *CreateTabletRequestPB) MarshalJSON() ([]byte, error)

func (*CreateTabletRequestPB) ProtoMessage 

func (*CreateTabletRequestPB) ProtoMessage()

func (*CreateTabletRequestPB) ProtoReflect 

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

func (*CreateTabletRequestPB) Reset 

func (x *CreateTabletRequestPB) Reset()

func (*CreateTabletRequestPB) String 

func (x *CreateTabletRequestPB) String() string

func (*CreateTabletRequestPB) UnmarshalJSON 

func (m *CreateTabletRequestPB) UnmarshalJSON(b []byte) error

type CreateTabletResponsePB 

type CreateTabletResponsePB struct {
	Error *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTabletResponsePB) Descriptor deprecated 

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

Deprecated: Use CreateTabletResponsePB.ProtoReflect.Descriptor instead.

func (*CreateTabletResponsePB) GetError 

func (x *CreateTabletResponsePB) GetError() *TabletServerErrorPB

func (*CreateTabletResponsePB) MarshalJSON 

func (m *CreateTabletResponsePB) MarshalJSON() ([]byte, error)

func (*CreateTabletResponsePB) ProtoMessage 

func (*CreateTabletResponsePB) ProtoMessage()

func (*CreateTabletResponsePB) ProtoReflect 

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

func (*CreateTabletResponsePB) Reset 

func (x *CreateTabletResponsePB) Reset()

func (*CreateTabletResponsePB) String 

func (x *CreateTabletResponsePB) String() string

func (*CreateTabletResponsePB) UnmarshalJSON 

func (m *CreateTabletResponsePB) UnmarshalJSON(b []byte) error

type DataChunkPB 

type DataChunkPB struct {

	// Offset into the complete data block or file that 'data' starts at.
	Offset *uint64 `protobuf:"varint,1,req,name=offset" json:"offset,omitempty"`
	// Actual bytes of data from the data block, starting at 'offset'.
	Data []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
	// CRC32C of the bytes contained in 'data'.
	Crc32 *uint32 `protobuf:"fixed32,3,req,name=crc32" json:"crc32,omitempty"`
	// Full length, in bytes, of the complete data block or file on the server.
	// The number of bytes returned in 'data' can certainly be less than this.
	TotalDataLength *int64 `protobuf:"varint,4,req,name=total_data_length,json=totalDataLength" json:"total_data_length,omitempty"`
	// contains filtered or unexported fields
}

A chunk of data (a slice of a block, file, etc).

func (*DataChunkPB) Descriptor deprecated 

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

Deprecated: Use DataChunkPB.ProtoReflect.Descriptor instead.

func (*DataChunkPB) GetCrc32 

func (x *DataChunkPB) GetCrc32() uint32

func (*DataChunkPB) GetData 

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

func (*DataChunkPB) GetOffset 

func (x *DataChunkPB) GetOffset() uint64

func (*DataChunkPB) GetTotalDataLength 

func (x *DataChunkPB) GetTotalDataLength() int64

func (*DataChunkPB) MarshalJSON 

func (m *DataChunkPB) MarshalJSON() ([]byte, error)

func (*DataChunkPB) ProtoMessage 

func (*DataChunkPB) ProtoMessage()

func (*DataChunkPB) ProtoReflect 

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

func (*DataChunkPB) Reset 

func (x *DataChunkPB) Reset()

func (*DataChunkPB) String 

func (x *DataChunkPB) String() string

func (*DataChunkPB) UnmarshalJSON 

func (m *DataChunkPB) UnmarshalJSON(b []byte) error

type DataIdPB 

type DataIdPB struct {

	// Indicator whether it's a block or log segment id.
	Type            *DataIdPB_IdType `protobuf:"varint,1,req,name=type,enum=yb.tserver.DataIdPB_IdType" json:"type,omitempty"`
	WalSegmentSeqno *uint64          `protobuf:"varint,3,opt,name=wal_segment_seqno,json=walSegmentSeqno" json:"wal_segment_seqno,omitempty"` // To fetch a log segment.
	FileName        *string          `protobuf:"bytes,4,opt,name=file_name,json=fileName" json:"file_name,omitempty"`                         // To fetch a RocksDB file.
	SnapshotId      []byte           `protobuf:"bytes,5,opt,name=snapshot_id,json=snapshotId" json:"snapshot_id,omitempty"`                   // To fetch a Snapshot file.
	// contains filtered or unexported fields
}

A "union" type that allows the same RPC call to fetch different types of data (data blocks or log files).

func (*DataIdPB) Descriptor deprecated 

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

Deprecated: Use DataIdPB.ProtoReflect.Descriptor instead.

func (*DataIdPB) GetFileName 

func (x *DataIdPB) GetFileName() string

func (*DataIdPB) GetSnapshotId 

func (x *DataIdPB) GetSnapshotId() []byte

func (*DataIdPB) GetType 

func (x *DataIdPB) GetType() DataIdPB_IdType

func (*DataIdPB) GetWalSegmentSeqno 

func (x *DataIdPB) GetWalSegmentSeqno() uint64

func (*DataIdPB) MarshalJSON 

func (m *DataIdPB) MarshalJSON() ([]byte, error)

func (*DataIdPB) ProtoMessage 

func (*DataIdPB) ProtoMessage()

func (*DataIdPB) ProtoReflect 

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

func (*DataIdPB) Reset 

func (x *DataIdPB) Reset()

func (*DataIdPB) String 

func (x *DataIdPB) String() string

func (*DataIdPB) UnmarshalJSON 

func (m *DataIdPB) UnmarshalJSON(b []byte) error

type DataIdPB_IdType 

type DataIdPB_IdType int32
const (
	DataIdPB_UNKNOWN       DataIdPB_IdType = 0
	DataIdPB_LOG_SEGMENT   DataIdPB_IdType = 2
	DataIdPB_ROCKSDB_FILE  DataIdPB_IdType = 3
	DataIdPB_SNAPSHOT_FILE DataIdPB_IdType = 4
)

func (DataIdPB_IdType) Descriptor 

func (DataIdPB_IdType) Descriptor() protoreflect.EnumDescriptor

func (DataIdPB_IdType) Enum 

func (x DataIdPB_IdType) Enum() *DataIdPB_IdType

func (DataIdPB_IdType) EnumDescriptor deprecated 

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

Deprecated: Use DataIdPB_IdType.Descriptor instead.

func (DataIdPB_IdType) Number 

func (x DataIdPB_IdType) Number() protoreflect.EnumNumber

func (DataIdPB_IdType) String 

func (x DataIdPB_IdType) String() string

func (DataIdPB_IdType) Type 

func (DataIdPB_IdType) Type() protoreflect.EnumType

func (*DataIdPB_IdType) UnmarshalJSON deprecated 

func (x *DataIdPB_IdType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type DeleteTabletRequestPB 

type DeleteTabletRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,4,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Reason the tablet is being deleted (for logging purposes)
	Reason *string `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	// Must be one of TABLET_DATA_DELETED (for table deletes) or
	// TABLET_DATA_TOMBSTONED (for replica retirement).
	DeleteType *common.TabletDataState `protobuf:"varint,3,opt,name=delete_type,json=deleteType,enum=yb.tablet.TabletDataState,def=3" json:"delete_type,omitempty"`
	// The highest allowed OpId index of the latest known committed config.
	// This optional parameter is here to provide an atomic (compare-and-swap)
	// DeleteTablet operation. If this parameter is specified, the DeleteTablet()
	// operation will succeed only if the committed config has an opid_index that
	// is less than or equal to this value.
	// See also the definition of RaftConfigPB.
	// Note: At the time of this writing, there is a small race between checking
	// the value of the committed config opid index and shutting down the tablet
	// for deletion. See comments in ts_tablet_manager.cc
	CasConfigOpidIndexLessOrEqual *int64 `` /* 152-byte string literal not displayed */
	// Hide tablet instead of deleting it.
	HideOnly *bool `protobuf:"varint,6,opt,name=hide_only,json=hideOnly" json:"hide_only,omitempty"`
	// contains filtered or unexported fields
}

A delete tablet request.

func (*DeleteTabletRequestPB) Descriptor deprecated 

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

Deprecated: Use DeleteTabletRequestPB.ProtoReflect.Descriptor instead.

func (*DeleteTabletRequestPB) GetCasConfigOpidIndexLessOrEqual 

func (x *DeleteTabletRequestPB) GetCasConfigOpidIndexLessOrEqual() int64

func (*DeleteTabletRequestPB) GetDeleteType 

func (x *DeleteTabletRequestPB) GetDeleteType() common.TabletDataState

func (*DeleteTabletRequestPB) GetDestUuid 

func (x *DeleteTabletRequestPB) GetDestUuid() []byte

func (*DeleteTabletRequestPB) GetHideOnly 

func (x *DeleteTabletRequestPB) GetHideOnly() bool

func (*DeleteTabletRequestPB) GetReason 

func (x *DeleteTabletRequestPB) GetReason() string

func (*DeleteTabletRequestPB) GetTabletId 

func (x *DeleteTabletRequestPB) GetTabletId() []byte

func (*DeleteTabletRequestPB) MarshalJSON 

func (m *DeleteTabletRequestPB) MarshalJSON() ([]byte, error)

func (*DeleteTabletRequestPB) ProtoMessage 

func (*DeleteTabletRequestPB) ProtoMessage()

func (*DeleteTabletRequestPB) ProtoReflect 

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

func (*DeleteTabletRequestPB) Reset 

func (x *DeleteTabletRequestPB) Reset()

func (*DeleteTabletRequestPB) String 

func (x *DeleteTabletRequestPB) String() string

func (*DeleteTabletRequestPB) UnmarshalJSON 

func (m *DeleteTabletRequestPB) UnmarshalJSON(b []byte) error

type DeleteTabletResponsePB 

type DeleteTabletResponsePB struct {
	Error *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTabletResponsePB) Descriptor deprecated 

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

Deprecated: Use DeleteTabletResponsePB.ProtoReflect.Descriptor instead.

func (*DeleteTabletResponsePB) GetError 

func (x *DeleteTabletResponsePB) GetError() *TabletServerErrorPB

func (*DeleteTabletResponsePB) MarshalJSON 

func (m *DeleteTabletResponsePB) MarshalJSON() ([]byte, error)

func (*DeleteTabletResponsePB) ProtoMessage 

func (*DeleteTabletResponsePB) ProtoMessage()

func (*DeleteTabletResponsePB) ProtoReflect 

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

func (*DeleteTabletResponsePB) Reset 

func (x *DeleteTabletResponsePB) Reset()

func (*DeleteTabletResponsePB) String 

func (x *DeleteTabletResponsePB) String() string

func (*DeleteTabletResponsePB) UnmarshalJSON 

func (m *DeleteTabletResponsePB) UnmarshalJSON(b []byte) error

type EndRemoteBootstrapSessionRequestPB 

type EndRemoteBootstrapSessionRequestPB struct {
	SessionId []byte `protobuf:"bytes,1,req,name=session_id,json=sessionId" json:"session_id,omitempty"`
	// Set to true if bootstrap is successful.
	IsSuccess *bool `protobuf:"varint,2,req,name=is_success,json=isSuccess" json:"is_success,omitempty"`
	// Client-provided error message. The server will log this error so that an
	// admin can identify when bad things are happening with remote bootstrap.
	Error *common.AppStatusPB `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	// True if we should not remove session on this request, and it will be removed by upcoming
	// RemoveRemoteBootstrapSession.
	KeepSession *bool `protobuf:"varint,4,opt,name=keep_session,json=keepSession,def=0" json:"keep_session,omitempty"`
	// contains filtered or unexported fields
}

func (*EndRemoteBootstrapSessionRequestPB) Descriptor deprecated 

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

Deprecated: Use EndRemoteBootstrapSessionRequestPB.ProtoReflect.Descriptor instead.

func (*EndRemoteBootstrapSessionRequestPB) GetError 

func (x *EndRemoteBootstrapSessionRequestPB) GetError() *common.AppStatusPB

func (*EndRemoteBootstrapSessionRequestPB) GetIsSuccess 

func (x *EndRemoteBootstrapSessionRequestPB) GetIsSuccess() bool

func (*EndRemoteBootstrapSessionRequestPB) GetKeepSession 

func (x *EndRemoteBootstrapSessionRequestPB) GetKeepSession() bool

func (*EndRemoteBootstrapSessionRequestPB) GetSessionId 

func (x *EndRemoteBootstrapSessionRequestPB) GetSessionId() []byte

func (*EndRemoteBootstrapSessionRequestPB) MarshalJSON 

func (m *EndRemoteBootstrapSessionRequestPB) MarshalJSON() ([]byte, error)

func (*EndRemoteBootstrapSessionRequestPB) ProtoMessage 

func (*EndRemoteBootstrapSessionRequestPB) ProtoMessage()

func (*EndRemoteBootstrapSessionRequestPB) ProtoReflect 

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

func (*EndRemoteBootstrapSessionRequestPB) Reset 

func (x *EndRemoteBootstrapSessionRequestPB) Reset()

func (*EndRemoteBootstrapSessionRequestPB) String 

func (x *EndRemoteBootstrapSessionRequestPB) String() string

func (*EndRemoteBootstrapSessionRequestPB) UnmarshalJSON 

func (m *EndRemoteBootstrapSessionRequestPB) UnmarshalJSON(b []byte) error

type EndRemoteBootstrapSessionResponsePB 

type EndRemoteBootstrapSessionResponsePB struct {
	SessionKept *bool `protobuf:"varint,1,opt,name=session_kept,json=sessionKept,def=0" json:"session_kept,omitempty"`
	// contains filtered or unexported fields
}

func (*EndRemoteBootstrapSessionResponsePB) Descriptor deprecated 

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

Deprecated: Use EndRemoteBootstrapSessionResponsePB.ProtoReflect.Descriptor instead.

func (*EndRemoteBootstrapSessionResponsePB) GetSessionKept 

func (x *EndRemoteBootstrapSessionResponsePB) GetSessionKept() bool

func (*EndRemoteBootstrapSessionResponsePB) MarshalJSON 

func (m *EndRemoteBootstrapSessionResponsePB) MarshalJSON() ([]byte, error)

func (*EndRemoteBootstrapSessionResponsePB) ProtoMessage 

func (*EndRemoteBootstrapSessionResponsePB) ProtoMessage()

func (*EndRemoteBootstrapSessionResponsePB) ProtoReflect 

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

func (*EndRemoteBootstrapSessionResponsePB) Reset 

func (x *EndRemoteBootstrapSessionResponsePB) Reset()

func (*EndRemoteBootstrapSessionResponsePB) String 

func (x *EndRemoteBootstrapSessionResponsePB) String() string

func (*EndRemoteBootstrapSessionResponsePB) UnmarshalJSON 

func (m *EndRemoteBootstrapSessionResponsePB) UnmarshalJSON(b []byte) error

type ExportedTabletMetadataChanges 

type ExportedTabletMetadataChanges struct {
	MetadataChanges []*ChangeMetadataRequestPB `protobuf:"bytes,1,rep,name=metadata_changes,json=metadataChanges" json:"metadata_changes,omitempty"`
	// contains filtered or unexported fields
}

This is used to export tablet metadata changes to a protobuf file to be reloaded on a new cluster startup to avoid running initdb.

func (*ExportedTabletMetadataChanges) Descriptor deprecated 

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

Deprecated: Use ExportedTabletMetadataChanges.ProtoReflect.Descriptor instead.

func (*ExportedTabletMetadataChanges) GetMetadataChanges 

func (x *ExportedTabletMetadataChanges) GetMetadataChanges() []*ChangeMetadataRequestPB

func (*ExportedTabletMetadataChanges) MarshalJSON 

func (m *ExportedTabletMetadataChanges) MarshalJSON() ([]byte, error)

func (*ExportedTabletMetadataChanges) ProtoMessage 

func (*ExportedTabletMetadataChanges) ProtoMessage()

func (*ExportedTabletMetadataChanges) ProtoReflect 

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

func (*ExportedTabletMetadataChanges) Reset 

func (x *ExportedTabletMetadataChanges) Reset()

func (*ExportedTabletMetadataChanges) String 

func (x *ExportedTabletMetadataChanges) String() string

func (*ExportedTabletMetadataChanges) UnmarshalJSON 

func (m *ExportedTabletMetadataChanges) UnmarshalJSON(b []byte) error

type FetchDataRequestPB 

type FetchDataRequestPB struct {

	// Valid Session ID returned by a BeginRemoteBootstrapSession() RPC call.
	SessionId []byte `protobuf:"bytes,1,req,name=session_id,json=sessionId" json:"session_id,omitempty"`
	// The server will use this ID to determine the key and type of data
	// that was requested.
	DataId *DataIdPB `protobuf:"bytes,2,req,name=data_id,json=dataId" json:"data_id,omitempty"`
	// Offset into data to start reading from.
	// If not specified, the server will send the data from offset 0.
	Offset *uint64 `protobuf:"varint,3,opt,name=offset,def=0" json:"offset,omitempty"`
	// Maximum length of the chunk of data to return.
	// If max_length is not specified, or if the server's max is less than the
	// requested max, the server will use its own max.
	MaxLength *int64 `protobuf:"varint,4,opt,name=max_length,json=maxLength,def=0" json:"max_length,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchDataRequestPB) Descriptor deprecated 

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

Deprecated: Use FetchDataRequestPB.ProtoReflect.Descriptor instead.

func (*FetchDataRequestPB) GetDataId 

func (x *FetchDataRequestPB) GetDataId() *DataIdPB

func (*FetchDataRequestPB) GetMaxLength 

func (x *FetchDataRequestPB) GetMaxLength() int64

func (*FetchDataRequestPB) GetOffset 

func (x *FetchDataRequestPB) GetOffset() uint64

func (*FetchDataRequestPB) GetSessionId 

func (x *FetchDataRequestPB) GetSessionId() []byte

func (*FetchDataRequestPB) MarshalJSON 

func (m *FetchDataRequestPB) MarshalJSON() ([]byte, error)

func (*FetchDataRequestPB) ProtoMessage 

func (*FetchDataRequestPB) ProtoMessage()

func (*FetchDataRequestPB) ProtoReflect 

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

func (*FetchDataRequestPB) Reset 

func (x *FetchDataRequestPB) Reset()

func (*FetchDataRequestPB) String 

func (x *FetchDataRequestPB) String() string

func (*FetchDataRequestPB) UnmarshalJSON 

func (m *FetchDataRequestPB) UnmarshalJSON(b []byte) error

type FetchDataResponsePB 

type FetchDataResponsePB struct {

	// The server will automatically release the resources (i.e. close file, free
	// read buffers) for a given data resource after the last byte is read.
	// So, per-resource, chunks are optimized to be fetched in-order.
	Chunk *DataChunkPB `protobuf:"bytes,1,req,name=chunk" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchDataResponsePB) Descriptor deprecated 

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

Deprecated: Use FetchDataResponsePB.ProtoReflect.Descriptor instead.

func (*FetchDataResponsePB) GetChunk 

func (x *FetchDataResponsePB) GetChunk() *DataChunkPB

func (*FetchDataResponsePB) MarshalJSON 

func (m *FetchDataResponsePB) MarshalJSON() ([]byte, error)

func (*FetchDataResponsePB) ProtoMessage 

func (*FetchDataResponsePB) ProtoMessage()

func (*FetchDataResponsePB) ProtoReflect 

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

func (*FetchDataResponsePB) Reset 

func (x *FetchDataResponsePB) Reset()

func (*FetchDataResponsePB) String 

func (x *FetchDataResponsePB) String() string

func (*FetchDataResponsePB) UnmarshalJSON 

func (m *FetchDataResponsePB) UnmarshalJSON(b []byte) error

type FlushTabletsRequestPB 

type FlushTabletsRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,1,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	// Tablets to flush.
	TabletIds            [][]byte `protobuf:"bytes,2,rep,name=tablet_ids,json=tabletIds" json:"tablet_ids,omitempty"`
	PropagatedHybridTime *uint64  `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// Whether we want to compact the tablets instead of flushing them.
	IsCompaction *bool `protobuf:"varint,4,opt,name=is_compaction,json=isCompaction" json:"is_compaction,omitempty"`
	// Whether we want to flush or compact all tablets in the server.
	AllTablets *bool `protobuf:"varint,5,opt,name=all_tablets,json=allTablets" json:"all_tablets,omitempty"`
	// contains filtered or unexported fields
}

TODO: rename this to FlushOrCompactTabletsRequestPB

func (*FlushTabletsRequestPB) Descriptor deprecated 

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

Deprecated: Use FlushTabletsRequestPB.ProtoReflect.Descriptor instead.

func (*FlushTabletsRequestPB) GetAllTablets 

func (x *FlushTabletsRequestPB) GetAllTablets() bool

func (*FlushTabletsRequestPB) GetDestUuid 

func (x *FlushTabletsRequestPB) GetDestUuid() []byte

func (*FlushTabletsRequestPB) GetIsCompaction 

func (x *FlushTabletsRequestPB) GetIsCompaction() bool

func (*FlushTabletsRequestPB) GetPropagatedHybridTime 

func (x *FlushTabletsRequestPB) GetPropagatedHybridTime() uint64

func (*FlushTabletsRequestPB) GetTabletIds 

func (x *FlushTabletsRequestPB) GetTabletIds() [][]byte

func (*FlushTabletsRequestPB) MarshalJSON 

func (m *FlushTabletsRequestPB) MarshalJSON() ([]byte, error)

func (*FlushTabletsRequestPB) ProtoMessage 

func (*FlushTabletsRequestPB) ProtoMessage()

func (*FlushTabletsRequestPB) ProtoReflect 

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

func (*FlushTabletsRequestPB) Reset 

func (x *FlushTabletsRequestPB) Reset()

func (*FlushTabletsRequestPB) String 

func (x *FlushTabletsRequestPB) String() string

func (*FlushTabletsRequestPB) UnmarshalJSON 

func (m *FlushTabletsRequestPB) UnmarshalJSON(b []byte) error

type FlushTabletsResponsePB 

type FlushTabletsResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	FailedTabletId       []byte               `protobuf:"bytes,2,opt,name=failed_tablet_id,json=failedTabletId" json:"failed_tablet_id,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushTabletsResponsePB) Descriptor deprecated 

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

Deprecated: Use FlushTabletsResponsePB.ProtoReflect.Descriptor instead.

func (*FlushTabletsResponsePB) GetError 

func (x *FlushTabletsResponsePB) GetError() *TabletServerErrorPB

func (*FlushTabletsResponsePB) GetFailedTabletId 

func (x *FlushTabletsResponsePB) GetFailedTabletId() []byte

func (*FlushTabletsResponsePB) GetPropagatedHybridTime 

func (x *FlushTabletsResponsePB) GetPropagatedHybridTime() uint64

func (*FlushTabletsResponsePB) MarshalJSON 

func (m *FlushTabletsResponsePB) MarshalJSON() ([]byte, error)

func (*FlushTabletsResponsePB) ProtoMessage 

func (*FlushTabletsResponsePB) ProtoMessage()

func (*FlushTabletsResponsePB) ProtoReflect 

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

func (*FlushTabletsResponsePB) Reset 

func (x *FlushTabletsResponsePB) Reset()

func (*FlushTabletsResponsePB) String 

func (x *FlushTabletsResponsePB) String() string

func (*FlushTabletsResponsePB) UnmarshalJSON 

func (m *FlushTabletsResponsePB) UnmarshalJSON(b []byte) error

type GetLogLocationRequestPB 

type GetLogLocationRequestPB struct {
	// contains filtered or unexported fields
}

func (*GetLogLocationRequestPB) Descriptor deprecated 

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

Deprecated: Use GetLogLocationRequestPB.ProtoReflect.Descriptor instead.

func (*GetLogLocationRequestPB) MarshalJSON 

func (m *GetLogLocationRequestPB) MarshalJSON() ([]byte, error)

func (*GetLogLocationRequestPB) ProtoMessage 

func (*GetLogLocationRequestPB) ProtoMessage()

func (*GetLogLocationRequestPB) ProtoReflect 

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

func (*GetLogLocationRequestPB) Reset 

func (x *GetLogLocationRequestPB) Reset()

func (*GetLogLocationRequestPB) String 

func (x *GetLogLocationRequestPB) String() string

func (*GetLogLocationRequestPB) UnmarshalJSON 

func (m *GetLogLocationRequestPB) UnmarshalJSON(b []byte) error

type GetLogLocationResponsePB 

type GetLogLocationResponsePB struct {
	LogLocation *string `protobuf:"bytes,1,opt,name=log_location,json=logLocation" json:"log_location,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogLocationResponsePB) Descriptor deprecated 

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

Deprecated: Use GetLogLocationResponsePB.ProtoReflect.Descriptor instead.

func (*GetLogLocationResponsePB) GetLogLocation 

func (x *GetLogLocationResponsePB) GetLogLocation() string

func (*GetLogLocationResponsePB) MarshalJSON 

func (m *GetLogLocationResponsePB) MarshalJSON() ([]byte, error)

func (*GetLogLocationResponsePB) ProtoMessage 

func (*GetLogLocationResponsePB) ProtoMessage()

func (*GetLogLocationResponsePB) ProtoReflect 

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

func (*GetLogLocationResponsePB) Reset 

func (x *GetLogLocationResponsePB) Reset()

func (*GetLogLocationResponsePB) String 

func (x *GetLogLocationResponsePB) String() string

func (*GetLogLocationResponsePB) UnmarshalJSON 

func (m *GetLogLocationResponsePB) UnmarshalJSON(b []byte) error

type GetMasterAddressesRequestPB 

type GetMasterAddressesRequestPB struct {
	// contains filtered or unexported fields
}

func (*GetMasterAddressesRequestPB) Descriptor deprecated 

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

Deprecated: Use GetMasterAddressesRequestPB.ProtoReflect.Descriptor instead.

func (*GetMasterAddressesRequestPB) MarshalJSON 

func (m *GetMasterAddressesRequestPB) MarshalJSON() ([]byte, error)

func (*GetMasterAddressesRequestPB) ProtoMessage 

func (*GetMasterAddressesRequestPB) ProtoMessage()

func (*GetMasterAddressesRequestPB) ProtoReflect 

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

func (*GetMasterAddressesRequestPB) Reset 

func (x *GetMasterAddressesRequestPB) Reset()

func (*GetMasterAddressesRequestPB) String 

func (x *GetMasterAddressesRequestPB) String() string

func (*GetMasterAddressesRequestPB) UnmarshalJSON 

func (m *GetMasterAddressesRequestPB) UnmarshalJSON(b []byte) error

type GetMasterAddressesResponsePB 

type GetMasterAddressesResponsePB struct {
	Error           *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	MasterAddresses *string              `protobuf:"bytes,2,opt,name=master_addresses,json=masterAddresses" json:"master_addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMasterAddressesResponsePB) Descriptor deprecated 

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

Deprecated: Use GetMasterAddressesResponsePB.ProtoReflect.Descriptor instead.

func (*GetMasterAddressesResponsePB) GetError 

func (x *GetMasterAddressesResponsePB) GetError() *TabletServerErrorPB

func (*GetMasterAddressesResponsePB) GetMasterAddresses 

func (x *GetMasterAddressesResponsePB) GetMasterAddresses() string

func (*GetMasterAddressesResponsePB) MarshalJSON 

func (m *GetMasterAddressesResponsePB) MarshalJSON() ([]byte, error)

func (*GetMasterAddressesResponsePB) ProtoMessage 

func (*GetMasterAddressesResponsePB) ProtoMessage()

func (*GetMasterAddressesResponsePB) ProtoReflect 

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

func (*GetMasterAddressesResponsePB) Reset 

func (x *GetMasterAddressesResponsePB) Reset()

func (*GetMasterAddressesResponsePB) String 

func (x *GetMasterAddressesResponsePB) String() string

func (*GetMasterAddressesResponsePB) UnmarshalJSON 

func (m *GetMasterAddressesResponsePB) UnmarshalJSON(b []byte) error

type GetSafeTimeRequestPB 

type GetSafeTimeRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid                 []byte  `protobuf:"bytes,1,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TabletId                 []byte  `protobuf:"bytes,2,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	SchemaVersion            *uint32 `protobuf:"varint,3,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	PropagatedHybridTime     *uint64 `protobuf:"fixed64,4,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	MinHybridTimeForBackfill *uint64 `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSafeTimeRequestPB) Descriptor deprecated 

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

Deprecated: Use GetSafeTimeRequestPB.ProtoReflect.Descriptor instead.

func (*GetSafeTimeRequestPB) GetDestUuid 

func (x *GetSafeTimeRequestPB) GetDestUuid() []byte

func (*GetSafeTimeRequestPB) GetMinHybridTimeForBackfill 

func (x *GetSafeTimeRequestPB) GetMinHybridTimeForBackfill() uint64

func (*GetSafeTimeRequestPB) GetPropagatedHybridTime 

func (x *GetSafeTimeRequestPB) GetPropagatedHybridTime() uint64

func (*GetSafeTimeRequestPB) GetSchemaVersion 

func (x *GetSafeTimeRequestPB) GetSchemaVersion() uint32

func (*GetSafeTimeRequestPB) GetTabletId 

func (x *GetSafeTimeRequestPB) GetTabletId() []byte

func (*GetSafeTimeRequestPB) MarshalJSON 

func (m *GetSafeTimeRequestPB) MarshalJSON() ([]byte, error)

func (*GetSafeTimeRequestPB) ProtoMessage 

func (*GetSafeTimeRequestPB) ProtoMessage()

func (*GetSafeTimeRequestPB) ProtoReflect 

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

func (*GetSafeTimeRequestPB) Reset 

func (x *GetSafeTimeRequestPB) Reset()

func (*GetSafeTimeRequestPB) String 

func (x *GetSafeTimeRequestPB) String() string

func (*GetSafeTimeRequestPB) UnmarshalJSON 

func (m *GetSafeTimeRequestPB) UnmarshalJSON(b []byte) error

type GetSafeTimeResponsePB 

type GetSafeTimeResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	SafeTime             *uint64              `protobuf:"fixed64,2,opt,name=safe_time,json=safeTime" json:"safe_time,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSafeTimeResponsePB) Descriptor deprecated 

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

Deprecated: Use GetSafeTimeResponsePB.ProtoReflect.Descriptor instead.

func (*GetSafeTimeResponsePB) GetError 

func (x *GetSafeTimeResponsePB) GetError() *TabletServerErrorPB

func (*GetSafeTimeResponsePB) GetPropagatedHybridTime 

func (x *GetSafeTimeResponsePB) GetPropagatedHybridTime() uint64

func (*GetSafeTimeResponsePB) GetSafeTime 

func (x *GetSafeTimeResponsePB) GetSafeTime() uint64

func (*GetSafeTimeResponsePB) MarshalJSON 

func (m *GetSafeTimeResponsePB) MarshalJSON() ([]byte, error)

func (*GetSafeTimeResponsePB) ProtoMessage 

func (*GetSafeTimeResponsePB) ProtoMessage()

func (*GetSafeTimeResponsePB) ProtoReflect 

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

func (*GetSafeTimeResponsePB) Reset 

func (x *GetSafeTimeResponsePB) Reset()

func (*GetSafeTimeResponsePB) String 

func (x *GetSafeTimeResponsePB) String() string

func (*GetSafeTimeResponsePB) UnmarshalJSON 

func (m *GetSafeTimeResponsePB) UnmarshalJSON(b []byte) error

type GetTabletStatusRequestPB 

type GetTabletStatusRequestPB struct {
	TabletId []byte `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// contains filtered or unexported fields
}

Tablet's status request

func (*GetTabletStatusRequestPB) Descriptor deprecated 

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

Deprecated: Use GetTabletStatusRequestPB.ProtoReflect.Descriptor instead.

func (*GetTabletStatusRequestPB) GetTabletId 

func (x *GetTabletStatusRequestPB) GetTabletId() []byte

func (*GetTabletStatusRequestPB) MarshalJSON 

func (m *GetTabletStatusRequestPB) MarshalJSON() ([]byte, error)

func (*GetTabletStatusRequestPB) ProtoMessage 

func (*GetTabletStatusRequestPB) ProtoMessage()

func (*GetTabletStatusRequestPB) ProtoReflect 

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

func (*GetTabletStatusRequestPB) Reset 

func (x *GetTabletStatusRequestPB) Reset()

func (*GetTabletStatusRequestPB) String 

func (x *GetTabletStatusRequestPB) String() string

func (*GetTabletStatusRequestPB) UnmarshalJSON 

func (m *GetTabletStatusRequestPB) UnmarshalJSON(b []byte) error

type GetTabletStatusResponsePB 

type GetTabletStatusResponsePB struct {
	Error        *TabletServerErrorPB   `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	TabletStatus *tablet.TabletStatusPB `protobuf:"bytes,2,opt,name=tablet_status,json=tabletStatus" json:"tablet_status,omitempty"`
	// contains filtered or unexported fields
}

Tablet's status response

func (*GetTabletStatusResponsePB) Descriptor deprecated 

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

Deprecated: Use GetTabletStatusResponsePB.ProtoReflect.Descriptor instead.

func (*GetTabletStatusResponsePB) GetError 

func (x *GetTabletStatusResponsePB) GetError() *TabletServerErrorPB

func (*GetTabletStatusResponsePB) GetTabletStatus 

func (x *GetTabletStatusResponsePB) GetTabletStatus() *tablet.TabletStatusPB

func (*GetTabletStatusResponsePB) MarshalJSON 

func (m *GetTabletStatusResponsePB) MarshalJSON() ([]byte, error)

func (*GetTabletStatusResponsePB) ProtoMessage 

func (*GetTabletStatusResponsePB) ProtoMessage()

func (*GetTabletStatusResponsePB) ProtoReflect 

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

func (*GetTabletStatusResponsePB) Reset 

func (x *GetTabletStatusResponsePB) Reset()

func (*GetTabletStatusResponsePB) String 

func (x *GetTabletStatusResponsePB) String() string

func (*GetTabletStatusResponsePB) UnmarshalJSON 

func (m *GetTabletStatusResponsePB) UnmarshalJSON(b []byte) error

type GetTransactionStatusAtParticipantRequestPB 

type GetTransactionStatusAtParticipantRequestPB struct {
	TabletId                     []byte  `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	TransactionId                []byte  `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId" json:"transaction_id,omitempty"`
	PropagatedHybridTime         *uint64 `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	RequiredNumReplicatedBatches *int64  `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetTransactionStatusAtParticipantRequestPB) Descriptor deprecated 

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

Deprecated: Use GetTransactionStatusAtParticipantRequestPB.ProtoReflect.Descriptor instead.

func (*GetTransactionStatusAtParticipantRequestPB) GetPropagatedHybridTime 

func (x *GetTransactionStatusAtParticipantRequestPB) GetPropagatedHybridTime() uint64

func (*GetTransactionStatusAtParticipantRequestPB) GetRequiredNumReplicatedBatches 

func (x *GetTransactionStatusAtParticipantRequestPB) GetRequiredNumReplicatedBatches() int64

func (*GetTransactionStatusAtParticipantRequestPB) GetTabletId 

func (x *GetTransactionStatusAtParticipantRequestPB) GetTabletId() []byte

func (*GetTransactionStatusAtParticipantRequestPB) GetTransactionId 

func (x *GetTransactionStatusAtParticipantRequestPB) GetTransactionId() []byte

func (*GetTransactionStatusAtParticipantRequestPB) MarshalJSON 

func (m *GetTransactionStatusAtParticipantRequestPB) MarshalJSON() ([]byte, error)

func (*GetTransactionStatusAtParticipantRequestPB) ProtoMessage 

func (*GetTransactionStatusAtParticipantRequestPB) ProtoMessage()

func (*GetTransactionStatusAtParticipantRequestPB) ProtoReflect 

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

func (*GetTransactionStatusAtParticipantRequestPB) Reset 

func (x *GetTransactionStatusAtParticipantRequestPB) Reset()

func (*GetTransactionStatusAtParticipantRequestPB) String 

func (x *GetTransactionStatusAtParticipantRequestPB) String() string

func (*GetTransactionStatusAtParticipantRequestPB) UnmarshalJSON 

func (m *GetTransactionStatusAtParticipantRequestPB) UnmarshalJSON(b []byte) error

type GetTransactionStatusAtParticipantResponsePB 

type GetTransactionStatusAtParticipantResponsePB struct {

	// Error message, if any.
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	NumReplicatedBatches *int64               `protobuf:"varint,3,opt,name=num_replicated_batches,json=numReplicatedBatches" json:"num_replicated_batches,omitempty"`
	StatusHybridTime     *uint64              `protobuf:"fixed64,4,opt,name=status_hybrid_time,json=statusHybridTime" json:"status_hybrid_time,omitempty"`
	Aborted              *bool                `protobuf:"varint,5,opt,name=aborted" json:"aborted,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionStatusAtParticipantResponsePB) Descriptor deprecated 

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

Deprecated: Use GetTransactionStatusAtParticipantResponsePB.ProtoReflect.Descriptor instead.

func (*GetTransactionStatusAtParticipantResponsePB) GetAborted 

func (x *GetTransactionStatusAtParticipantResponsePB) GetAborted() bool

func (*GetTransactionStatusAtParticipantResponsePB) GetError 

func (x *GetTransactionStatusAtParticipantResponsePB) GetError() *TabletServerErrorPB

func (*GetTransactionStatusAtParticipantResponsePB) GetNumReplicatedBatches 

func (x *GetTransactionStatusAtParticipantResponsePB) GetNumReplicatedBatches() int64

func (*GetTransactionStatusAtParticipantResponsePB) GetPropagatedHybridTime 

func (x *GetTransactionStatusAtParticipantResponsePB) GetPropagatedHybridTime() uint64

func (*GetTransactionStatusAtParticipantResponsePB) GetStatusHybridTime 

func (x *GetTransactionStatusAtParticipantResponsePB) GetStatusHybridTime() uint64

func (*GetTransactionStatusAtParticipantResponsePB) MarshalJSON 

func (m *GetTransactionStatusAtParticipantResponsePB) MarshalJSON() ([]byte, error)

func (*GetTransactionStatusAtParticipantResponsePB) ProtoMessage 

func (*GetTransactionStatusAtParticipantResponsePB) ProtoMessage()

func (*GetTransactionStatusAtParticipantResponsePB) ProtoReflect 

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

func (*GetTransactionStatusAtParticipantResponsePB) Reset 

func (x *GetTransactionStatusAtParticipantResponsePB) Reset()

func (*GetTransactionStatusAtParticipantResponsePB) String 

func (x *GetTransactionStatusAtParticipantResponsePB) String() string

func (*GetTransactionStatusAtParticipantResponsePB) UnmarshalJSON 

func (m *GetTransactionStatusAtParticipantResponsePB) UnmarshalJSON(b []byte) error

type GetTransactionStatusRequestPB 

type GetTransactionStatusRequestPB struct {
	TabletId             []byte   `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	TransactionId        [][]byte `protobuf:"bytes,2,rep,name=transaction_id,json=transactionId" json:"transaction_id,omitempty"`
	PropagatedHybridTime *uint64  `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionStatusRequestPB) Descriptor deprecated 

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

Deprecated: Use GetTransactionStatusRequestPB.ProtoReflect.Descriptor instead.

func (*GetTransactionStatusRequestPB) GetPropagatedHybridTime 

func (x *GetTransactionStatusRequestPB) GetPropagatedHybridTime() uint64

func (*GetTransactionStatusRequestPB) GetTabletId 

func (x *GetTransactionStatusRequestPB) GetTabletId() []byte

func (*GetTransactionStatusRequestPB) GetTransactionId 

func (x *GetTransactionStatusRequestPB) GetTransactionId() [][]byte

func (*GetTransactionStatusRequestPB) MarshalJSON 

func (m *GetTransactionStatusRequestPB) MarshalJSON() ([]byte, error)

func (*GetTransactionStatusRequestPB) ProtoMessage 

func (*GetTransactionStatusRequestPB) ProtoMessage()

func (*GetTransactionStatusRequestPB) ProtoReflect 

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

func (*GetTransactionStatusRequestPB) Reset 

func (x *GetTransactionStatusRequestPB) Reset()

func (*GetTransactionStatusRequestPB) String 

func (x *GetTransactionStatusRequestPB) String() string

func (*GetTransactionStatusRequestPB) UnmarshalJSON 

func (m *GetTransactionStatusRequestPB) UnmarshalJSON(b []byte) error

type GetTransactionStatusResponsePB 

type GetTransactionStatusResponsePB struct {

	// Error message, if any.
	Error *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// For backward compatibility we use multiple repeated fields instead of one field
	// with custom message.
	Status []common.TransactionStatus `protobuf:"varint,2,rep,name=status,enum=yb.TransactionStatus" json:"status,omitempty"`
	// For description of status_hybrid_time see comment in TransactionStatusResult.
	StatusHybridTime     []uint64 `protobuf:"fixed64,3,rep,name=status_hybrid_time,json=statusHybridTime" json:"status_hybrid_time,omitempty"`
	PropagatedHybridTime *uint64  `protobuf:"fixed64,4,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	NumReplicatedBatches []int64  `protobuf:"varint,5,rep,name=num_replicated_batches,json=numReplicatedBatches" json:"num_replicated_batches,omitempty"`
	// Size could be less than status size. In this case appropriates values should be interpreted
	// as invalid hybrid time.
	CoordinatorSafeTime []uint64 `protobuf:"fixed64,6,rep,name=coordinator_safe_time,json=coordinatorSafeTime" json:"coordinator_safe_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionStatusResponsePB) Descriptor deprecated 

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

Deprecated: Use GetTransactionStatusResponsePB.ProtoReflect.Descriptor instead.

func (*GetTransactionStatusResponsePB) GetCoordinatorSafeTime 

func (x *GetTransactionStatusResponsePB) GetCoordinatorSafeTime() []uint64

func (*GetTransactionStatusResponsePB) GetError 

func (x *GetTransactionStatusResponsePB) GetError() *TabletServerErrorPB

func (*GetTransactionStatusResponsePB) GetNumReplicatedBatches 

func (x *GetTransactionStatusResponsePB) GetNumReplicatedBatches() []int64

func (*GetTransactionStatusResponsePB) GetPropagatedHybridTime 

func (x *GetTransactionStatusResponsePB) GetPropagatedHybridTime() uint64

func (*GetTransactionStatusResponsePB) GetStatus 

func (x *GetTransactionStatusResponsePB) GetStatus() []common.TransactionStatus

func (*GetTransactionStatusResponsePB) GetStatusHybridTime 

func (x *GetTransactionStatusResponsePB) GetStatusHybridTime() []uint64

func (*GetTransactionStatusResponsePB) MarshalJSON 

func (m *GetTransactionStatusResponsePB) MarshalJSON() ([]byte, error)

func (*GetTransactionStatusResponsePB) ProtoMessage 

func (*GetTransactionStatusResponsePB) ProtoMessage()

func (*GetTransactionStatusResponsePB) ProtoReflect 

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

func (*GetTransactionStatusResponsePB) Reset 

func (x *GetTransactionStatusResponsePB) Reset()

func (*GetTransactionStatusResponsePB) String 

func (x *GetTransactionStatusResponsePB) String() string

func (*GetTransactionStatusResponsePB) UnmarshalJSON 

func (m *GetTransactionStatusResponsePB) UnmarshalJSON(b []byte) error

type ImportDataRequestPB 

type ImportDataRequestPB struct {
	TabletId  *string `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	SourceDir *string `protobuf:"bytes,2,opt,name=source_dir,json=sourceDir" json:"source_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportDataRequestPB) Descriptor deprecated 

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

Deprecated: Use ImportDataRequestPB.ProtoReflect.Descriptor instead.

func (*ImportDataRequestPB) GetSourceDir 

func (x *ImportDataRequestPB) GetSourceDir() string

func (*ImportDataRequestPB) GetTabletId 

func (x *ImportDataRequestPB) GetTabletId() string

func (*ImportDataRequestPB) MarshalJSON 

func (m *ImportDataRequestPB) MarshalJSON() ([]byte, error)

func (*ImportDataRequestPB) ProtoMessage 

func (*ImportDataRequestPB) ProtoMessage()

func (*ImportDataRequestPB) ProtoReflect 

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

func (*ImportDataRequestPB) Reset 

func (x *ImportDataRequestPB) Reset()

func (*ImportDataRequestPB) String 

func (x *ImportDataRequestPB) String() string

func (*ImportDataRequestPB) UnmarshalJSON 

func (m *ImportDataRequestPB) UnmarshalJSON(b []byte) error

type ImportDataResponsePB 

type ImportDataResponsePB struct {

	// Error message, if any.
	Error *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportDataResponsePB) Descriptor deprecated 

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

Deprecated: Use ImportDataResponsePB.ProtoReflect.Descriptor instead.

func (*ImportDataResponsePB) GetError 

func (x *ImportDataResponsePB) GetError() *TabletServerErrorPB

func (*ImportDataResponsePB) MarshalJSON 

func (m *ImportDataResponsePB) MarshalJSON() ([]byte, error)

func (*ImportDataResponsePB) ProtoMessage 

func (*ImportDataResponsePB) ProtoMessage()

func (*ImportDataResponsePB) ProtoReflect 

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

func (*ImportDataResponsePB) Reset 

func (x *ImportDataResponsePB) Reset()

func (*ImportDataResponsePB) String 

func (x *ImportDataResponsePB) String() string

func (*ImportDataResponsePB) UnmarshalJSON 

func (m *ImportDataResponsePB) UnmarshalJSON(b []byte) error

type IsTabletServerReadyRequestPB 

type IsTabletServerReadyRequestPB struct {
	// contains filtered or unexported fields
}

Get this tserver's notion of being ready for handling IO requests across all tablets that it owns.

func (*IsTabletServerReadyRequestPB) Descriptor deprecated 

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

Deprecated: Use IsTabletServerReadyRequestPB.ProtoReflect.Descriptor instead.

func (*IsTabletServerReadyRequestPB) MarshalJSON 

func (m *IsTabletServerReadyRequestPB) MarshalJSON() ([]byte, error)

func (*IsTabletServerReadyRequestPB) ProtoMessage 

func (*IsTabletServerReadyRequestPB) ProtoMessage()

func (*IsTabletServerReadyRequestPB) ProtoReflect 

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

func (*IsTabletServerReadyRequestPB) Reset 

func (x *IsTabletServerReadyRequestPB) Reset()

func (*IsTabletServerReadyRequestPB) String 

func (x *IsTabletServerReadyRequestPB) String() string

func (*IsTabletServerReadyRequestPB) UnmarshalJSON 

func (m *IsTabletServerReadyRequestPB) UnmarshalJSON(b []byte) error

type IsTabletServerReadyResponsePB 

type IsTabletServerReadyResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	NumTabletsNotRunning *int32               `protobuf:"varint,2,opt,name=num_tablets_not_running,json=numTabletsNotRunning" json:"num_tablets_not_running,omitempty"`
	TotalTablets         *int32               `protobuf:"varint,3,opt,name=total_tablets,json=totalTablets,def=0" json:"total_tablets,omitempty"`
	// contains filtered or unexported fields
}

When response has no errors, the tserver is deemed ready as per its tablet manager layer when the number of not running tablets is 0. Or the client can choose to timeout before that. Also returns total tablets under this tablet server.

func (*IsTabletServerReadyResponsePB) Descriptor deprecated 

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

Deprecated: Use IsTabletServerReadyResponsePB.ProtoReflect.Descriptor instead.

func (*IsTabletServerReadyResponsePB) GetError 

func (x *IsTabletServerReadyResponsePB) GetError() *TabletServerErrorPB

func (*IsTabletServerReadyResponsePB) GetNumTabletsNotRunning 

func (x *IsTabletServerReadyResponsePB) GetNumTabletsNotRunning() int32

func (*IsTabletServerReadyResponsePB) GetTotalTablets 

func (x *IsTabletServerReadyResponsePB) GetTotalTablets() int32

func (*IsTabletServerReadyResponsePB) MarshalJSON 

func (m *IsTabletServerReadyResponsePB) MarshalJSON() ([]byte, error)

func (*IsTabletServerReadyResponsePB) ProtoMessage 

func (*IsTabletServerReadyResponsePB) ProtoMessage()

func (*IsTabletServerReadyResponsePB) ProtoReflect 

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

func (*IsTabletServerReadyResponsePB) Reset 

func (x *IsTabletServerReadyResponsePB) Reset()

func (*IsTabletServerReadyResponsePB) String 

func (x *IsTabletServerReadyResponsePB) String() string

func (*IsTabletServerReadyResponsePB) UnmarshalJSON 

func (m *IsTabletServerReadyResponsePB) UnmarshalJSON(b []byte) error

type ListTabletsForTabletServerRequestPB 

type ListTabletsForTabletServerRequestPB struct {
	// contains filtered or unexported fields
}

func (*ListTabletsForTabletServerRequestPB) Descriptor deprecated 

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

Deprecated: Use ListTabletsForTabletServerRequestPB.ProtoReflect.Descriptor instead.

func (*ListTabletsForTabletServerRequestPB) MarshalJSON 

func (m *ListTabletsForTabletServerRequestPB) MarshalJSON() ([]byte, error)

func (*ListTabletsForTabletServerRequestPB) ProtoMessage 

func (*ListTabletsForTabletServerRequestPB) ProtoMessage()

func (*ListTabletsForTabletServerRequestPB) ProtoReflect 

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

func (*ListTabletsForTabletServerRequestPB) Reset 

func (x *ListTabletsForTabletServerRequestPB) Reset()

func (*ListTabletsForTabletServerRequestPB) String 

func (x *ListTabletsForTabletServerRequestPB) String() string

func (*ListTabletsForTabletServerRequestPB) UnmarshalJSON 

func (m *ListTabletsForTabletServerRequestPB) UnmarshalJSON(b []byte) error

type ListTabletsForTabletServerResponsePB 

type ListTabletsForTabletServerResponsePB struct {
	Entries []*ListTabletsForTabletServerResponsePB_Entry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTabletsForTabletServerResponsePB) Descriptor deprecated 

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

Deprecated: Use ListTabletsForTabletServerResponsePB.ProtoReflect.Descriptor instead.

func (*ListTabletsForTabletServerResponsePB) GetEntries 

func (x *ListTabletsForTabletServerResponsePB) GetEntries() []*ListTabletsForTabletServerResponsePB_Entry

func (*ListTabletsForTabletServerResponsePB) MarshalJSON 

func (m *ListTabletsForTabletServerResponsePB) MarshalJSON() ([]byte, error)

func (*ListTabletsForTabletServerResponsePB) ProtoMessage 

func (*ListTabletsForTabletServerResponsePB) ProtoMessage()

func (*ListTabletsForTabletServerResponsePB) ProtoReflect 

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

func (*ListTabletsForTabletServerResponsePB) Reset 

func (x *ListTabletsForTabletServerResponsePB) Reset()

func (*ListTabletsForTabletServerResponsePB) String 

func (x *ListTabletsForTabletServerResponsePB) String() string

func (*ListTabletsForTabletServerResponsePB) UnmarshalJSON 

func (m *ListTabletsForTabletServerResponsePB) UnmarshalJSON(b []byte) error

type ListTabletsForTabletServerResponsePB_Entry 

type ListTabletsForTabletServerResponsePB_Entry struct {
	TableName           *string                  `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	TabletId            []byte                   `protobuf:"bytes,2,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	IsLeader            *bool                    `protobuf:"varint,3,opt,name=is_leader,json=isLeader" json:"is_leader,omitempty"`
	State               *common.RaftGroupStatePB `protobuf:"varint,4,opt,name=state,enum=yb.tablet.RaftGroupStatePB" json:"state,omitempty"`
	NumSstFiles         *uint64                  `protobuf:"varint,5,opt,name=num_sst_files,json=numSstFiles" json:"num_sst_files,omitempty"`
	NumLogSegments      *uint64                  `protobuf:"varint,6,opt,name=num_log_segments,json=numLogSegments" json:"num_log_segments,omitempty"`
	NumMemtablesIntents *uint64                  `protobuf:"varint,7,opt,name=num_memtables_intents,json=numMemtablesIntents" json:"num_memtables_intents,omitempty"`
	NumMemtablesRegular *uint64                  `protobuf:"varint,8,opt,name=num_memtables_regular,json=numMemtablesRegular" json:"num_memtables_regular,omitempty"`
	// contains filtered or unexported fields
}

An entry for each tablet.

func (*ListTabletsForTabletServerResponsePB_Entry) Descriptor deprecated 

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

Deprecated: Use ListTabletsForTabletServerResponsePB_Entry.ProtoReflect.Descriptor instead.

func (*ListTabletsForTabletServerResponsePB_Entry) GetIsLeader 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetIsLeader() bool

func (*ListTabletsForTabletServerResponsePB_Entry) GetNumLogSegments 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetNumLogSegments() uint64

func (*ListTabletsForTabletServerResponsePB_Entry) GetNumMemtablesIntents 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetNumMemtablesIntents() uint64

func (*ListTabletsForTabletServerResponsePB_Entry) GetNumMemtablesRegular 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetNumMemtablesRegular() uint64

func (*ListTabletsForTabletServerResponsePB_Entry) GetNumSstFiles 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetNumSstFiles() uint64

func (*ListTabletsForTabletServerResponsePB_Entry) GetState 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetState() common.RaftGroupStatePB

func (*ListTabletsForTabletServerResponsePB_Entry) GetTableName 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetTableName() string

func (*ListTabletsForTabletServerResponsePB_Entry) GetTabletId 

func (x *ListTabletsForTabletServerResponsePB_Entry) GetTabletId() []byte

func (*ListTabletsForTabletServerResponsePB_Entry) ProtoMessage 

func (*ListTabletsForTabletServerResponsePB_Entry) ProtoMessage()

func (*ListTabletsForTabletServerResponsePB_Entry) ProtoReflect 

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

func (*ListTabletsForTabletServerResponsePB_Entry) Reset 

func (x *ListTabletsForTabletServerResponsePB_Entry) Reset()

func (*ListTabletsForTabletServerResponsePB_Entry) String 

func (x *ListTabletsForTabletServerResponsePB_Entry) String() string

type ListTabletsRequestPB 

type ListTabletsRequestPB struct {
	// contains filtered or unexported fields
}

A list tablets request

func (*ListTabletsRequestPB) Descriptor deprecated 

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

Deprecated: Use ListTabletsRequestPB.ProtoReflect.Descriptor instead.

func (*ListTabletsRequestPB) MarshalJSON 

func (m *ListTabletsRequestPB) MarshalJSON() ([]byte, error)

func (*ListTabletsRequestPB) ProtoMessage 

func (*ListTabletsRequestPB) ProtoMessage()

func (*ListTabletsRequestPB) ProtoReflect 

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

func (*ListTabletsRequestPB) Reset 

func (x *ListTabletsRequestPB) Reset()

func (*ListTabletsRequestPB) String 

func (x *ListTabletsRequestPB) String() string

func (*ListTabletsRequestPB) UnmarshalJSON 

func (m *ListTabletsRequestPB) UnmarshalJSON(b []byte) error

type ListTabletsResponsePB 

type ListTabletsResponsePB struct {
	Error           *TabletServerErrorPB                       `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	StatusAndSchema []*ListTabletsResponsePB_StatusAndSchemaPB `protobuf:"bytes,2,rep,name=status_and_schema,json=statusAndSchema" json:"status_and_schema,omitempty"`
	// contains filtered or unexported fields
}

A list tablets response

func (*ListTabletsResponsePB) Descriptor deprecated 

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

Deprecated: Use ListTabletsResponsePB.ProtoReflect.Descriptor instead.

func (*ListTabletsResponsePB) GetError 

func (x *ListTabletsResponsePB) GetError() *TabletServerErrorPB

func (*ListTabletsResponsePB) GetStatusAndSchema 

func (x *ListTabletsResponsePB) GetStatusAndSchema() []*ListTabletsResponsePB_StatusAndSchemaPB

func (*ListTabletsResponsePB) MarshalJSON 

func (m *ListTabletsResponsePB) MarshalJSON() ([]byte, error)

func (*ListTabletsResponsePB) ProtoMessage 

func (*ListTabletsResponsePB) ProtoMessage()

func (*ListTabletsResponsePB) ProtoReflect 

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

func (*ListTabletsResponsePB) Reset 

func (x *ListTabletsResponsePB) Reset()

func (*ListTabletsResponsePB) String 

func (x *ListTabletsResponsePB) String() string

func (*ListTabletsResponsePB) UnmarshalJSON 

func (m *ListTabletsResponsePB) UnmarshalJSON(b []byte) error

type ListTabletsResponsePB_StatusAndSchemaPB 

type ListTabletsResponsePB_StatusAndSchemaPB struct {
	TabletStatus    *tablet.TabletStatusPB    `protobuf:"bytes,1,req,name=tablet_status,json=tabletStatus" json:"tablet_status,omitempty"`
	Schema          *common.SchemaPB          `protobuf:"bytes,2,req,name=schema" json:"schema,omitempty"`
	PartitionSchema *common.PartitionSchemaPB `protobuf:"bytes,3,opt,name=partition_schema,json=partitionSchema" json:"partition_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTabletsResponsePB_StatusAndSchemaPB) Descriptor deprecated 

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

Deprecated: Use ListTabletsResponsePB_StatusAndSchemaPB.ProtoReflect.Descriptor instead.

func (*ListTabletsResponsePB_StatusAndSchemaPB) GetPartitionSchema 

func (x *ListTabletsResponsePB_StatusAndSchemaPB) GetPartitionSchema() *common.PartitionSchemaPB

func (*ListTabletsResponsePB_StatusAndSchemaPB) GetSchema 

func (x *ListTabletsResponsePB_StatusAndSchemaPB) GetSchema() *common.SchemaPB

func (*ListTabletsResponsePB_StatusAndSchemaPB) GetTabletStatus 

func (x *ListTabletsResponsePB_StatusAndSchemaPB) GetTabletStatus() *tablet.TabletStatusPB

func (*ListTabletsResponsePB_StatusAndSchemaPB) ProtoMessage 

func (*ListTabletsResponsePB_StatusAndSchemaPB) ProtoMessage()

func (*ListTabletsResponsePB_StatusAndSchemaPB) ProtoReflect 

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

func (*ListTabletsResponsePB_StatusAndSchemaPB) Reset 

func (x *ListTabletsResponsePB_StatusAndSchemaPB) Reset()

func (*ListTabletsResponsePB_StatusAndSchemaPB) String 

func (x *ListTabletsResponsePB_StatusAndSchemaPB) String() string

type NoOpRequestPB 

type NoOpRequestPB struct {
	TabletId []byte `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NoOpRequestPB) Descriptor deprecated 

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

Deprecated: Use NoOpRequestPB.ProtoReflect.Descriptor instead.

func (*NoOpRequestPB) GetTabletId 

func (x *NoOpRequestPB) GetTabletId() []byte

func (*NoOpRequestPB) MarshalJSON 

func (m *NoOpRequestPB) MarshalJSON() ([]byte, error)

func (*NoOpRequestPB) ProtoMessage 

func (*NoOpRequestPB) ProtoMessage()

func (*NoOpRequestPB) ProtoReflect 

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

func (*NoOpRequestPB) Reset 

func (x *NoOpRequestPB) Reset()

func (*NoOpRequestPB) String 

func (x *NoOpRequestPB) String() string

func (*NoOpRequestPB) UnmarshalJSON 

func (m *NoOpRequestPB) UnmarshalJSON(b []byte) error

type NoOpResponsePB 

type NoOpResponsePB struct {
	Error *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*NoOpResponsePB) Descriptor deprecated 

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

Deprecated: Use NoOpResponsePB.ProtoReflect.Descriptor instead.

func (*NoOpResponsePB) GetError 

func (x *NoOpResponsePB) GetError() *TabletServerErrorPB

func (*NoOpResponsePB) MarshalJSON 

func (m *NoOpResponsePB) MarshalJSON() ([]byte, error)

func (*NoOpResponsePB) ProtoMessage 

func (*NoOpResponsePB) ProtoMessage()

func (*NoOpResponsePB) ProtoReflect 

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

func (*NoOpResponsePB) Reset 

func (x *NoOpResponsePB) Reset()

func (*NoOpResponsePB) String 

func (x *NoOpResponsePB) String() string

func (*NoOpResponsePB) UnmarshalJSON 

func (m *NoOpResponsePB) UnmarshalJSON(b []byte) error

type PublishRequestPB 

type PublishRequestPB struct {
	Channel []byte `protobuf:"bytes,1,req,name=channel" json:"channel,omitempty"`
	Message []byte `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequestPB) Descriptor deprecated 

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

Deprecated: Use PublishRequestPB.ProtoReflect.Descriptor instead.

func (*PublishRequestPB) GetChannel 

func (x *PublishRequestPB) GetChannel() []byte

func (*PublishRequestPB) GetMessage 

func (x *PublishRequestPB) GetMessage() []byte

func (*PublishRequestPB) MarshalJSON 

func (m *PublishRequestPB) MarshalJSON() ([]byte, error)

func (*PublishRequestPB) ProtoMessage 

func (*PublishRequestPB) ProtoMessage()

func (*PublishRequestPB) ProtoReflect 

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

func (*PublishRequestPB) Reset 

func (x *PublishRequestPB) Reset()

func (*PublishRequestPB) String 

func (x *PublishRequestPB) String() string

func (*PublishRequestPB) UnmarshalJSON 

func (m *PublishRequestPB) UnmarshalJSON(b []byte) error

type PublishResponsePB 

type PublishResponsePB struct {
	NumClientsForwardedTo *int32 `protobuf:"varint,1,req,name=num_clients_forwarded_to,json=numClientsForwardedTo" json:"num_clients_forwarded_to,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResponsePB) Descriptor deprecated 

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

Deprecated: Use PublishResponsePB.ProtoReflect.Descriptor instead.

func (*PublishResponsePB) GetNumClientsForwardedTo 

func (x *PublishResponsePB) GetNumClientsForwardedTo() int32

func (*PublishResponsePB) MarshalJSON 

func (m *PublishResponsePB) MarshalJSON() ([]byte, error)

func (*PublishResponsePB) ProtoMessage 

func (*PublishResponsePB) ProtoMessage()

func (*PublishResponsePB) ProtoReflect 

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

func (*PublishResponsePB) Reset 

func (x *PublishResponsePB) Reset()

func (*PublishResponsePB) String 

func (x *PublishResponsePB) String() string

func (*PublishResponsePB) UnmarshalJSON 

func (m *PublishResponsePB) UnmarshalJSON(b []byte) error

type ReadRequestPB 

type ReadRequestPB struct {

	// The tablet to scan.
	TabletId   []byte                       `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	RedisBatch []*common.RedisReadRequestPB `protobuf:"bytes,2,rep,name=redis_batch,json=redisBatch" json:"redis_batch,omitempty"`
	QlBatch    []*common.QLReadRequestPB    `protobuf:"bytes,4,rep,name=ql_batch,json=qlBatch" json:"ql_batch,omitempty"`
	PgsqlBatch []*common.PgsqlReadRequestPB `protobuf:"bytes,10,rep,name=pgsql_batch,json=pgsqlBatch" json:"pgsql_batch,omitempty"`
	// Whether data blocks will be cached when read from the files or discarded after use.
	// Disable this to lower cache churn when doing large scans.
	CacheBlocks      *bool                      `protobuf:"varint,3,opt,name=cache_blocks,json=cacheBlocks,def=1" json:"cache_blocks,omitempty"`
	IncludeTrace     *bool                      `protobuf:"varint,5,opt,name=include_trace,json=includeTrace,def=0" json:"include_trace,omitempty"`
	ConsistencyLevel *common.YBConsistencyLevel `` // TODO: add hybrid_time in future
	/* 136-byte string literal not displayed */
	Transaction          *common.TransactionMetadataPB `protobuf:"bytes,7,opt,name=transaction" json:"transaction,omitempty"`
	PropagatedHybridTime *uint64                       `protobuf:"fixed64,8,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// See ReadHybridTime for explation of next two fields.
	ReadTime                  *common.ReadHybridTimePB `protobuf:"bytes,9,opt,name=read_time,json=readTime" json:"read_time,omitempty"`
	ProxyUuid                 *string                  `protobuf:"bytes,11,opt,name=proxy_uuid,json=proxyUuid" json:"proxy_uuid,omitempty"`
	DEPRECATEDMayHaveMetadata *bool                    `` /* 135-byte string literal not displayed */
	RejectionScore            *float64                 `protobuf:"fixed64,13,opt,name=rejection_score,json=rejectionScore" json:"rejection_score,omitempty"`
	BatchIdx                  *uint64                  `protobuf:"varint,14,opt,name=batch_idx,json=batchIdx" json:"batch_idx,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequestPB) Descriptor deprecated 

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

Deprecated: Use ReadRequestPB.ProtoReflect.Descriptor instead.

func (*ReadRequestPB) GetBatchIdx 

func (x *ReadRequestPB) GetBatchIdx() uint64

func (*ReadRequestPB) GetCacheBlocks 

func (x *ReadRequestPB) GetCacheBlocks() bool

func (*ReadRequestPB) GetConsistencyLevel 

func (x *ReadRequestPB) GetConsistencyLevel() common.YBConsistencyLevel

func (*ReadRequestPB) GetDEPRECATEDMayHaveMetadata 

func (x *ReadRequestPB) GetDEPRECATEDMayHaveMetadata() bool

func (*ReadRequestPB) GetIncludeTrace 

func (x *ReadRequestPB) GetIncludeTrace() bool

func (*ReadRequestPB) GetPgsqlBatch 

func (x *ReadRequestPB) GetPgsqlBatch() []*common.PgsqlReadRequestPB

func (*ReadRequestPB) GetPropagatedHybridTime 

func (x *ReadRequestPB) GetPropagatedHybridTime() uint64

func (*ReadRequestPB) GetProxyUuid 

func (x *ReadRequestPB) GetProxyUuid() string

func (*ReadRequestPB) GetQlBatch 

func (x *ReadRequestPB) GetQlBatch() []*common.QLReadRequestPB

func (*ReadRequestPB) GetReadTime 

func (x *ReadRequestPB) GetReadTime() *common.ReadHybridTimePB

func (*ReadRequestPB) GetRedisBatch 

func (x *ReadRequestPB) GetRedisBatch() []*common.RedisReadRequestPB

func (*ReadRequestPB) GetRejectionScore 

func (x *ReadRequestPB) GetRejectionScore() float64

func (*ReadRequestPB) GetTabletId 

func (x *ReadRequestPB) GetTabletId() []byte

func (*ReadRequestPB) GetTransaction 

func (x *ReadRequestPB) GetTransaction() *common.TransactionMetadataPB

func (*ReadRequestPB) MarshalJSON 

func (m *ReadRequestPB) MarshalJSON() ([]byte, error)

func (*ReadRequestPB) ProtoMessage 

func (*ReadRequestPB) ProtoMessage()

func (*ReadRequestPB) ProtoReflect 

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

func (*ReadRequestPB) Reset 

func (x *ReadRequestPB) Reset()

func (*ReadRequestPB) String 

func (x *ReadRequestPB) String() string

func (*ReadRequestPB) UnmarshalJSON 

func (m *ReadRequestPB) UnmarshalJSON(b []byte) error

type ReadResponsePB 

type ReadResponsePB struct {
	RedisBatch           []*common.RedisResponsePB `protobuf:"bytes,1,rep,name=redis_batch,json=redisBatch" json:"redis_batch,omitempty"`
	QlBatch              []*common.QLResponsePB    `protobuf:"bytes,4,rep,name=ql_batch,json=qlBatch" json:"ql_batch,omitempty"`
	PgsqlBatch           []*common.PgsqlResponsePB `protobuf:"bytes,8,rep,name=pgsql_batch,json=pgsqlBatch" json:"pgsql_batch,omitempty"`
	Error                *TabletServerErrorPB      `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	TraceBuffer          *string                   `protobuf:"bytes,5,opt,name=trace_buffer,json=traceBuffer" json:"trace_buffer,omitempty"`
	PropagatedHybridTime *uint64                   `protobuf:"fixed64,6,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// Used to report restart whether this operation requires read restart.
	RestartReadTime *common.ReadHybridTimePB `protobuf:"bytes,7,opt,name=restart_read_time,json=restartReadTime" json:"restart_read_time,omitempty"`
	// Used to report used read time when transaction asked for it.
	UsedReadTime *common.ReadHybridTimePB `protobuf:"bytes,9,opt,name=used_read_time,json=usedReadTime" json:"used_read_time,omitempty"`
	LocalLimitHt *uint64                  `protobuf:"fixed64,10,opt,name=local_limit_ht,json=localLimitHt" json:"local_limit_ht,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponsePB) Descriptor deprecated 

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

Deprecated: Use ReadResponsePB.ProtoReflect.Descriptor instead.

func (*ReadResponsePB) GetError 

func (x *ReadResponsePB) GetError() *TabletServerErrorPB

func (*ReadResponsePB) GetLocalLimitHt 

func (x *ReadResponsePB) GetLocalLimitHt() uint64

func (*ReadResponsePB) GetPgsqlBatch 

func (x *ReadResponsePB) GetPgsqlBatch() []*common.PgsqlResponsePB

func (*ReadResponsePB) GetPropagatedHybridTime 

func (x *ReadResponsePB) GetPropagatedHybridTime() uint64

func (*ReadResponsePB) GetQlBatch 

func (x *ReadResponsePB) GetQlBatch() []*common.QLResponsePB

func (*ReadResponsePB) GetRedisBatch 

func (x *ReadResponsePB) GetRedisBatch() []*common.RedisResponsePB

func (*ReadResponsePB) GetRestartReadTime 

func (x *ReadResponsePB) GetRestartReadTime() *common.ReadHybridTimePB

func (*ReadResponsePB) GetTraceBuffer 

func (x *ReadResponsePB) GetTraceBuffer() string

func (*ReadResponsePB) GetUsedReadTime 

func (x *ReadResponsePB) GetUsedReadTime() *common.ReadHybridTimePB

func (*ReadResponsePB) MarshalJSON 

func (m *ReadResponsePB) MarshalJSON() ([]byte, error)

func (*ReadResponsePB) ProtoMessage 

func (*ReadResponsePB) ProtoMessage()

func (*ReadResponsePB) ProtoReflect 

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

func (*ReadResponsePB) Reset 

func (x *ReadResponsePB) Reset()

func (*ReadResponsePB) String 

func (x *ReadResponsePB) String() string

func (*ReadResponsePB) UnmarshalJSON 

func (m *ReadResponsePB) UnmarshalJSON(b []byte) error

type RemoteBootstrapErrorPB 

type RemoteBootstrapErrorPB struct {

	// The error code.
	Code *RemoteBootstrapErrorPB_Code `protobuf:"varint,1,req,name=code,enum=yb.tserver.RemoteBootstrapErrorPB_Code,def=1" json:"code,omitempty"`
	// The Status object for the error. This will include a textual
	// message that may be more useful to present in log messages, etc,
	// though its error code is less specific.
	Status *common.AppStatusPB `protobuf:"bytes,2,req,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Remote bootstrap-specific errors use this protobuf.

func (*RemoteBootstrapErrorPB) Descriptor deprecated 

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

Deprecated: Use RemoteBootstrapErrorPB.ProtoReflect.Descriptor instead.

func (*RemoteBootstrapErrorPB) GetCode 

func (x *RemoteBootstrapErrorPB) GetCode() RemoteBootstrapErrorPB_Code

func (*RemoteBootstrapErrorPB) GetStatus 

func (x *RemoteBootstrapErrorPB) GetStatus() *common.AppStatusPB

func (*RemoteBootstrapErrorPB) MarshalJSON 

func (m *RemoteBootstrapErrorPB) MarshalJSON() ([]byte, error)

func (*RemoteBootstrapErrorPB) ProtoMessage 

func (*RemoteBootstrapErrorPB) ProtoMessage()

func (*RemoteBootstrapErrorPB) ProtoReflect 

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

func (*RemoteBootstrapErrorPB) Reset 

func (x *RemoteBootstrapErrorPB) Reset()

func (*RemoteBootstrapErrorPB) String 

func (x *RemoteBootstrapErrorPB) String() string

func (*RemoteBootstrapErrorPB) UnmarshalJSON 

func (m *RemoteBootstrapErrorPB) UnmarshalJSON(b []byte) error

type RemoteBootstrapErrorPB_Code 

type RemoteBootstrapErrorPB_Code int32
const (
	// An error which has no more specific error code.
	// The code and message in 'status' may reveal more details.
	//
	// RPCs should avoid returning this, since callers will not be
	// able to easily parse the error.
	RemoteBootstrapErrorPB_UNKNOWN_ERROR RemoteBootstrapErrorPB_Code = 1
	// The specified remote bootstrap session either never existed or has expired.
	RemoteBootstrapErrorPB_NO_SESSION RemoteBootstrapErrorPB_Code = 2
	// Unknown tablet.
	RemoteBootstrapErrorPB_TABLET_NOT_FOUND RemoteBootstrapErrorPB_Code = 3
	// Unknown data block.
	RemoteBootstrapErrorPB_BLOCK_NOT_FOUND RemoteBootstrapErrorPB_Code = 4
	// Unknown WAL segment.
	RemoteBootstrapErrorPB_WAL_SEGMENT_NOT_FOUND RemoteBootstrapErrorPB_Code = 5
	// Invalid request. Possibly missing parameters.
	RemoteBootstrapErrorPB_INVALID_REMOTE_BOOTSTRAP_REQUEST RemoteBootstrapErrorPB_Code = 6
	// Error reading or transferring data.
	RemoteBootstrapErrorPB_IO_ERROR RemoteBootstrapErrorPB_Code = 7
	// Unknown RocksDB file.
	RemoteBootstrapErrorPB_ROCKSDB_FILE_NOT_FOUND RemoteBootstrapErrorPB_Code = 8
)

func (RemoteBootstrapErrorPB_Code) Descriptor 

func (RemoteBootstrapErrorPB_Code) Descriptor() protoreflect.EnumDescriptor

func (RemoteBootstrapErrorPB_Code) Enum 

func (x RemoteBootstrapErrorPB_Code) Enum() *RemoteBootstrapErrorPB_Code

func (RemoteBootstrapErrorPB_Code) EnumDescriptor deprecated 

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

Deprecated: Use RemoteBootstrapErrorPB_Code.Descriptor instead.

func (RemoteBootstrapErrorPB_Code) Number 

func (x RemoteBootstrapErrorPB_Code) Number() protoreflect.EnumNumber

func (RemoteBootstrapErrorPB_Code) String 

func (x RemoteBootstrapErrorPB_Code) String() string

func (RemoteBootstrapErrorPB_Code) Type 

func (RemoteBootstrapErrorPB_Code) Type() protoreflect.EnumType

func (*RemoteBootstrapErrorPB_Code) UnmarshalJSON deprecated 

func (x *RemoteBootstrapErrorPB_Code) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type RemoteBootstrapService 

type RemoteBootstrapService interface {
	BeginRemoteBootstrapSession(request *BeginRemoteBootstrapSessionRequestPB) (*BeginRemoteBootstrapSessionResponsePB, error)
	CheckSessionActive(request *CheckRemoteBootstrapSessionActiveRequestPB) (*CheckRemoteBootstrapSessionActiveResponsePB, error)
	FetchData(request *FetchDataRequestPB) (*FetchDataResponsePB, error)
	EndRemoteBootstrapSession(request *EndRemoteBootstrapSessionRequestPB) (*EndRemoteBootstrapSessionResponsePB, error)
	RemoveSession(request *RemoveSessionRequestPB) (*RemoveSessionResponsePB, error)
}

type RemoteBootstrapServiceImpl 

type RemoteBootstrapServiceImpl struct {
	Log       logr.Logger
	Messenger message.Messenger
}

func (*RemoteBootstrapServiceImpl) BeginRemoteBootstrapSession 

func (s *RemoteBootstrapServiceImpl) BeginRemoteBootstrapSession(request *BeginRemoteBootstrapSessionRequestPB) (*BeginRemoteBootstrapSessionResponsePB, error)

func (*RemoteBootstrapServiceImpl) CheckSessionActive 

func (s *RemoteBootstrapServiceImpl) CheckSessionActive(request *CheckRemoteBootstrapSessionActiveRequestPB) (*CheckRemoteBootstrapSessionActiveResponsePB, error)

func (*RemoteBootstrapServiceImpl) EndRemoteBootstrapSession 

func (s *RemoteBootstrapServiceImpl) EndRemoteBootstrapSession(request *EndRemoteBootstrapSessionRequestPB) (*EndRemoteBootstrapSessionResponsePB, error)

func (*RemoteBootstrapServiceImpl) FetchData 

func (s *RemoteBootstrapServiceImpl) FetchData(request *FetchDataRequestPB) (*FetchDataResponsePB, error)

func (*RemoteBootstrapServiceImpl) RemoveSession 

func (s *RemoteBootstrapServiceImpl) RemoveSession(request *RemoveSessionRequestPB) (*RemoveSessionResponsePB, error)

type RemoveSessionRequestPB 

type RemoveSessionRequestPB struct {
	SessionId []byte `protobuf:"bytes,1,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveSessionRequestPB) Descriptor deprecated 

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

Deprecated: Use RemoveSessionRequestPB.ProtoReflect.Descriptor instead.

func (*RemoveSessionRequestPB) GetSessionId 

func (x *RemoveSessionRequestPB) GetSessionId() []byte

func (*RemoveSessionRequestPB) MarshalJSON 

func (m *RemoveSessionRequestPB) MarshalJSON() ([]byte, error)

func (*RemoveSessionRequestPB) ProtoMessage 

func (*RemoveSessionRequestPB) ProtoMessage()

func (*RemoveSessionRequestPB) ProtoReflect 

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

func (*RemoveSessionRequestPB) Reset 

func (x *RemoveSessionRequestPB) Reset()

func (*RemoveSessionRequestPB) String 

func (x *RemoveSessionRequestPB) String() string

func (*RemoveSessionRequestPB) UnmarshalJSON 

func (m *RemoveSessionRequestPB) UnmarshalJSON(b []byte) error

type RemoveSessionResponsePB 

type RemoveSessionResponsePB struct {
	// contains filtered or unexported fields
}

func (*RemoveSessionResponsePB) Descriptor deprecated 

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

Deprecated: Use RemoveSessionResponsePB.ProtoReflect.Descriptor instead.

func (*RemoveSessionResponsePB) MarshalJSON 

func (m *RemoveSessionResponsePB) MarshalJSON() ([]byte, error)

func (*RemoveSessionResponsePB) ProtoMessage 

func (*RemoveSessionResponsePB) ProtoMessage()

func (*RemoveSessionResponsePB) ProtoReflect 

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

func (*RemoveSessionResponsePB) Reset 

func (x *RemoveSessionResponsePB) Reset()

func (*RemoveSessionResponsePB) String 

func (x *RemoveSessionResponsePB) String() string

func (*RemoveSessionResponsePB) UnmarshalJSON 

func (m *RemoveSessionResponsePB) UnmarshalJSON(b []byte) error

type RemoveTableFromTabletRequestPB 

type RemoveTableFromTabletRequestPB struct {
	TabletId      []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	RemoveTableId []byte `protobuf:"bytes,2,req,name=remove_table_id,json=removeTableId" json:"remove_table_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveTableFromTabletRequestPB) Descriptor deprecated 

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

Deprecated: Use RemoveTableFromTabletRequestPB.ProtoReflect.Descriptor instead.

func (*RemoveTableFromTabletRequestPB) GetRemoveTableId 

func (x *RemoveTableFromTabletRequestPB) GetRemoveTableId() []byte

func (*RemoveTableFromTabletRequestPB) GetTabletId 

func (x *RemoveTableFromTabletRequestPB) GetTabletId() []byte

func (*RemoveTableFromTabletRequestPB) MarshalJSON 

func (m *RemoveTableFromTabletRequestPB) MarshalJSON() ([]byte, error)

func (*RemoveTableFromTabletRequestPB) ProtoMessage 

func (*RemoveTableFromTabletRequestPB) ProtoMessage()

func (*RemoveTableFromTabletRequestPB) ProtoReflect 

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

func (*RemoveTableFromTabletRequestPB) Reset 

func (x *RemoveTableFromTabletRequestPB) Reset()

func (*RemoveTableFromTabletRequestPB) String 

func (x *RemoveTableFromTabletRequestPB) String() string

func (*RemoveTableFromTabletRequestPB) UnmarshalJSON 

func (m *RemoveTableFromTabletRequestPB) UnmarshalJSON(b []byte) error

type RemoveTableFromTabletResponsePB 

type RemoveTableFromTabletResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveTableFromTabletResponsePB) Descriptor deprecated 

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

Deprecated: Use RemoveTableFromTabletResponsePB.ProtoReflect.Descriptor instead.

func (*RemoveTableFromTabletResponsePB) GetError 

func (x *RemoveTableFromTabletResponsePB) GetError() *TabletServerErrorPB

func (*RemoveTableFromTabletResponsePB) GetPropagatedHybridTime 

func (x *RemoveTableFromTabletResponsePB) GetPropagatedHybridTime() uint64

func (*RemoveTableFromTabletResponsePB) MarshalJSON 

func (m *RemoveTableFromTabletResponsePB) MarshalJSON() ([]byte, error)

func (*RemoveTableFromTabletResponsePB) ProtoMessage 

func (*RemoveTableFromTabletResponsePB) ProtoMessage()

func (*RemoveTableFromTabletResponsePB) ProtoReflect 

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

func (*RemoveTableFromTabletResponsePB) Reset 

func (x *RemoveTableFromTabletResponsePB) Reset()

func (*RemoveTableFromTabletResponsePB) String 

func (x *RemoveTableFromTabletResponsePB) String() string

func (*RemoveTableFromTabletResponsePB) UnmarshalJSON 

func (m *RemoveTableFromTabletResponsePB) UnmarshalJSON(b []byte) error

type SplitTabletRequestPB 

type SplitTabletRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid             []byte  `protobuf:"bytes,1,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	PropagatedHybridTime *uint64 `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	TabletId             []byte  `protobuf:"bytes,3,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	NewTablet1Id         []byte  `protobuf:"bytes,4,req,name=new_tablet1_id,json=newTablet1Id" json:"new_tablet1_id,omitempty"`
	NewTablet2Id         []byte  `protobuf:"bytes,5,req,name=new_tablet2_id,json=newTablet2Id" json:"new_tablet2_id,omitempty"`
	SplitPartitionKey    []byte  `protobuf:"bytes,6,req,name=split_partition_key,json=splitPartitionKey" json:"split_partition_key,omitempty"`
	SplitEncodedKey      []byte  `protobuf:"bytes,7,req,name=split_encoded_key,json=splitEncodedKey" json:"split_encoded_key,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitTabletRequestPB) Descriptor deprecated 

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

Deprecated: Use SplitTabletRequestPB.ProtoReflect.Descriptor instead.

func (*SplitTabletRequestPB) GetDestUuid 

func (x *SplitTabletRequestPB) GetDestUuid() []byte

func (*SplitTabletRequestPB) GetNewTablet1Id 

func (x *SplitTabletRequestPB) GetNewTablet1Id() []byte

func (*SplitTabletRequestPB) GetNewTablet2Id 

func (x *SplitTabletRequestPB) GetNewTablet2Id() []byte

func (*SplitTabletRequestPB) GetPropagatedHybridTime 

func (x *SplitTabletRequestPB) GetPropagatedHybridTime() uint64

func (*SplitTabletRequestPB) GetSplitEncodedKey 

func (x *SplitTabletRequestPB) GetSplitEncodedKey() []byte

func (*SplitTabletRequestPB) GetSplitPartitionKey 

func (x *SplitTabletRequestPB) GetSplitPartitionKey() []byte

func (*SplitTabletRequestPB) GetTabletId 

func (x *SplitTabletRequestPB) GetTabletId() []byte

func (*SplitTabletRequestPB) MarshalJSON 

func (m *SplitTabletRequestPB) MarshalJSON() ([]byte, error)

func (*SplitTabletRequestPB) ProtoMessage 

func (*SplitTabletRequestPB) ProtoMessage()

func (*SplitTabletRequestPB) ProtoReflect 

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

func (*SplitTabletRequestPB) Reset 

func (x *SplitTabletRequestPB) Reset()

func (*SplitTabletRequestPB) String 

func (x *SplitTabletRequestPB) String() string

func (*SplitTabletRequestPB) UnmarshalJSON 

func (m *SplitTabletRequestPB) UnmarshalJSON(b []byte) error

type SplitTabletResponsePB 

type SplitTabletResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitTabletResponsePB) Descriptor deprecated 

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

Deprecated: Use SplitTabletResponsePB.ProtoReflect.Descriptor instead.

func (*SplitTabletResponsePB) GetError 

func (x *SplitTabletResponsePB) GetError() *TabletServerErrorPB

func (*SplitTabletResponsePB) GetPropagatedHybridTime 

func (x *SplitTabletResponsePB) GetPropagatedHybridTime() uint64

func (*SplitTabletResponsePB) MarshalJSON 

func (m *SplitTabletResponsePB) MarshalJSON() ([]byte, error)

func (*SplitTabletResponsePB) ProtoMessage 

func (*SplitTabletResponsePB) ProtoMessage()

func (*SplitTabletResponsePB) ProtoReflect 

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

func (*SplitTabletResponsePB) Reset 

func (x *SplitTabletResponsePB) Reset()

func (*SplitTabletResponsePB) String 

func (x *SplitTabletResponsePB) String() string

func (*SplitTabletResponsePB) UnmarshalJSON 

func (m *SplitTabletResponsePB) UnmarshalJSON(b []byte) error

type TSTabletManagerStatePB 

type TSTabletManagerStatePB int32

Enum of the server's Tablet Manager state: currently this is only used for assertions, but this can also be sent to the master. 

const (
	TSTabletManagerStatePB_UNKNOWN TSTabletManagerStatePB = 999
	// Indicates that Tablet Manager is initializing.
	TSTabletManagerStatePB_MANAGER_INITIALIZING TSTabletManagerStatePB = 0
	// Indicates that Tablet Manager is running and can create new
	// tablets.
	TSTabletManagerStatePB_MANAGER_RUNNING TSTabletManagerStatePB = 1
	// Indicates that tablet manager is shutting down and no new tablets
	// can be created.
	TSTabletManagerStatePB_MANAGER_QUIESCING TSTabletManagerStatePB = 2
	// Tablet Manager has shutdown.
	TSTabletManagerStatePB_MANAGER_SHUTDOWN TSTabletManagerStatePB = 3
)

func (TSTabletManagerStatePB) Descriptor 

func (TSTabletManagerStatePB) Descriptor() protoreflect.EnumDescriptor

func (TSTabletManagerStatePB) Enum 

func (x TSTabletManagerStatePB) Enum() *TSTabletManagerStatePB

func (TSTabletManagerStatePB) EnumDescriptor deprecated 

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

Deprecated: Use TSTabletManagerStatePB.Descriptor instead.

func (TSTabletManagerStatePB) Number 

func (x TSTabletManagerStatePB) Number() protoreflect.EnumNumber

func (TSTabletManagerStatePB) String 

func (x TSTabletManagerStatePB) String() string

func (TSTabletManagerStatePB) Type 

func (TSTabletManagerStatePB) Type() protoreflect.EnumType

func (*TSTabletManagerStatePB) UnmarshalJSON deprecated 

func (x *TSTabletManagerStatePB) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TabletServerAdminService 

type TabletServerAdminService interface {
	CreateTablet(request *CreateTabletRequestPB) (*CreateTabletResponsePB, error)
	DeleteTablet(request *DeleteTabletRequestPB) (*DeleteTabletResponsePB, error)
	AlterSchema(request *ChangeMetadataRequestPB) (*ChangeMetadataResponsePB, error)
	GetSafeTime(request *GetSafeTimeRequestPB) (*GetSafeTimeResponsePB, error)
	BackfillIndex(request *BackfillIndexRequestPB) (*BackfillIndexResponsePB, error)
	BackfillDone(request *ChangeMetadataRequestPB) (*ChangeMetadataResponsePB, error)
	CopartitionTable(request *CopartitionTableRequestPB) (*CopartitionTableResponsePB, error)
	FlushTablets(request *FlushTabletsRequestPB) (*FlushTabletsResponsePB, error)
	CountIntents(request *CountIntentsRequestPB) (*CountIntentsResponsePB, error)
	AddTableToTablet(request *AddTableToTabletRequestPB) (*AddTableToTabletResponsePB, error)
	RemoveTableFromTablet(request *RemoveTableFromTabletRequestPB) (*RemoveTableFromTabletResponsePB, error)
	SplitTablet(request *SplitTabletRequestPB) (*SplitTabletResponsePB, error)
}

service: yb.tserver.TabletServerAdminService service: TabletServerAdminService

type TabletServerAdminServiceImpl 

type TabletServerAdminServiceImpl struct {
	Log       logr.Logger
	Messenger message.Messenger
}

func (*TabletServerAdminServiceImpl) AddTableToTablet 

func (s *TabletServerAdminServiceImpl) AddTableToTablet(request *AddTableToTabletRequestPB) (*AddTableToTabletResponsePB, error)

func (*TabletServerAdminServiceImpl) AlterSchema 

func (s *TabletServerAdminServiceImpl) AlterSchema(request *ChangeMetadataRequestPB) (*ChangeMetadataResponsePB, error)

func (*TabletServerAdminServiceImpl) BackfillDone 

func (s *TabletServerAdminServiceImpl) BackfillDone(request *ChangeMetadataRequestPB) (*ChangeMetadataResponsePB, error)

func (*TabletServerAdminServiceImpl) BackfillIndex 

func (s *TabletServerAdminServiceImpl) BackfillIndex(request *BackfillIndexRequestPB) (*BackfillIndexResponsePB, error)

func (*TabletServerAdminServiceImpl) CopartitionTable 

func (s *TabletServerAdminServiceImpl) CopartitionTable(request *CopartitionTableRequestPB) (*CopartitionTableResponsePB, error)

func (*TabletServerAdminServiceImpl) CountIntents 

func (s *TabletServerAdminServiceImpl) CountIntents(request *CountIntentsRequestPB) (*CountIntentsResponsePB, error)

func (*TabletServerAdminServiceImpl) CreateTablet 

func (s *TabletServerAdminServiceImpl) CreateTablet(request *CreateTabletRequestPB) (*CreateTabletResponsePB, error)

func (*TabletServerAdminServiceImpl) DeleteTablet 

func (s *TabletServerAdminServiceImpl) DeleteTablet(request *DeleteTabletRequestPB) (*DeleteTabletResponsePB, error)

func (*TabletServerAdminServiceImpl) FlushTablets 

func (s *TabletServerAdminServiceImpl) FlushTablets(request *FlushTabletsRequestPB) (*FlushTabletsResponsePB, error)

func (*TabletServerAdminServiceImpl) GetSafeTime 

func (s *TabletServerAdminServiceImpl) GetSafeTime(request *GetSafeTimeRequestPB) (*GetSafeTimeResponsePB, error)

func (*TabletServerAdminServiceImpl) RemoveTableFromTablet 

func (s *TabletServerAdminServiceImpl) RemoveTableFromTablet(request *RemoveTableFromTabletRequestPB) (*RemoveTableFromTabletResponsePB, error)

func (*TabletServerAdminServiceImpl) SplitTablet 

func (s *TabletServerAdminServiceImpl) SplitTablet(request *SplitTabletRequestPB) (*SplitTabletResponsePB, error)

type TabletServerBackupService 

type TabletServerBackupService interface {
	TabletSnapshotOp(request *TabletSnapshotOpRequestPB) (*TabletSnapshotOpResponsePB, error)
}

service: yb.tserver.TabletServerBackupService service: TabletServerBackupService

type TabletServerBackupServiceImpl 

type TabletServerBackupServiceImpl struct {
	Log       logr.Logger
	Messenger message.Messenger
}

func (*TabletServerBackupServiceImpl) TabletSnapshotOp 

func (s *TabletServerBackupServiceImpl) TabletSnapshotOp(request *TabletSnapshotOpRequestPB) (*TabletSnapshotOpResponsePB, error)

type TabletServerErrorPB 

type TabletServerErrorPB struct {

	// The error code.
	Code *TabletServerErrorPB_Code `protobuf:"varint,1,req,name=code,enum=yb.tserver.TabletServerErrorPB_Code,def=1" json:"code,omitempty"`
	// The Status object for the error. This will include a textual
	// message that may be more useful to present in log messages, etc,
	// though its error code is less specific.
	Status *common.AppStatusPB `protobuf:"bytes,2,req,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Tablet-server specific errors use this protobuf.

func (*TabletServerErrorPB) Descriptor deprecated 

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

Deprecated: Use TabletServerErrorPB.ProtoReflect.Descriptor instead.

func (*TabletServerErrorPB) GetCode 

func (x *TabletServerErrorPB) GetCode() TabletServerErrorPB_Code

func (*TabletServerErrorPB) GetStatus 

func (x *TabletServerErrorPB) GetStatus() *common.AppStatusPB

func (*TabletServerErrorPB) MarshalJSON 

func (m *TabletServerErrorPB) MarshalJSON() ([]byte, error)

func (*TabletServerErrorPB) ProtoMessage 

func (*TabletServerErrorPB) ProtoMessage()

func (*TabletServerErrorPB) ProtoReflect 

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

func (*TabletServerErrorPB) Reset 

func (x *TabletServerErrorPB) Reset()

func (*TabletServerErrorPB) String 

func (x *TabletServerErrorPB) String() string

func (*TabletServerErrorPB) UnmarshalJSON 

func (m *TabletServerErrorPB) UnmarshalJSON(b []byte) error

type TabletServerErrorPB_Code 

type TabletServerErrorPB_Code int32
const (
	// An error which has no more specific error code.
	// The code and message in 'status' may reveal more details.
	//
	// RPCs should avoid returning this, since callers will not be
	// able to easily parse the error.
	TabletServerErrorPB_UNKNOWN_ERROR TabletServerErrorPB_Code = 1
	// The schema provided for a request was not well-formed.
	TabletServerErrorPB_INVALID_SCHEMA TabletServerErrorPB_Code = 2
	// The row data provided for a request was not well-formed.
	TabletServerErrorPB_INVALID_ROW_BLOCK TabletServerErrorPB_Code = 3
	// The mutations or mutation keys provided for a request were
	// not well formed.
	TabletServerErrorPB_INVALID_MUTATION TabletServerErrorPB_Code = 4
	// The schema provided for a request didn't match the actual
	// schema of the tablet.
	TabletServerErrorPB_MISMATCHED_SCHEMA TabletServerErrorPB_Code = 5
	// The requested tablet_id is not currently hosted on this server.
	TabletServerErrorPB_TABLET_NOT_FOUND TabletServerErrorPB_Code = 6
	// A request was made against a scanner ID that was either never
	// created or has expired.
	TabletServerErrorPB_SCANNER_EXPIRED TabletServerErrorPB_Code = 7
	// An invalid scan was specified -- e.g the values passed for
	// predicates were incorrect sizes.
	TabletServerErrorPB_INVALID_SCAN_SPEC TabletServerErrorPB_Code = 8
	// The provided configuration was not well-formed and/or
	// had a sequence number that was below the current config.
	TabletServerErrorPB_INVALID_CONFIG TabletServerErrorPB_Code = 9
	// On a create tablet request, signals that the tablet already exists.
	TabletServerErrorPB_TABLET_ALREADY_EXISTS TabletServerErrorPB_Code = 10
	// If the tablet has a newer schema than the requested one the "alter"
	// request will be rejected with this error.
	TabletServerErrorPB_TABLET_HAS_A_NEWER_SCHEMA TabletServerErrorPB_Code = 11
	// The tablet is hosted on this server, but not in RUNNING state.
	TabletServerErrorPB_TABLET_NOT_RUNNING TabletServerErrorPB_Code = 12
	// Client requested a snapshot read but the snapshot was invalid.
	TabletServerErrorPB_INVALID_SNAPSHOT TabletServerErrorPB_Code = 13
	// An invalid scan call sequence ID was specified.
	TabletServerErrorPB_INVALID_SCAN_CALL_SEQ_ID TabletServerErrorPB_Code = 14
	// This tserver is not the leader of the consensus configuration.
	TabletServerErrorPB_NOT_THE_LEADER TabletServerErrorPB_Code = 15
	// The destination UUID in the request does not match this server.
	TabletServerErrorPB_WRONG_SERVER_UUID TabletServerErrorPB_Code = 16
	// The compare-and-swap specified by an atomic RPC operation failed.
	TabletServerErrorPB_CAS_FAILED TabletServerErrorPB_Code = 17
	// This server leader is not ready for the change configuration operation.
	TabletServerErrorPB_LEADER_NOT_READY_CHANGE_CONFIG TabletServerErrorPB_Code = 18
	// This server leader is not ready to step down.
	TabletServerErrorPB_LEADER_NOT_READY_TO_STEP_DOWN TabletServerErrorPB_Code = 19
	// Adding a peer which is already present in the current raft config.
	TabletServerErrorPB_ADD_CHANGE_CONFIG_ALREADY_PRESENT TabletServerErrorPB_Code = 20
	// Removing a peer which is not present in the current raft config.
	TabletServerErrorPB_REMOVE_CHANGE_CONFIG_NOT_PRESENT TabletServerErrorPB_Code = 21
	// Leader needs to be stepped down before calling change config. This happens
	// if the server we are trying to remove from the config is currently the leader.
	TabletServerErrorPB_LEADER_NEEDS_STEP_DOWN TabletServerErrorPB_Code = 22
	// The operation is not supported.
	TabletServerErrorPB_OPERATION_NOT_SUPPORTED TabletServerErrorPB_Code = 23
	// This tserver is the leader of the consensus configuration, but it's not ready to serve
	// requests. (That means in fact that the elected leader has not yet commited NoOp request.
	// The client must wait a bit for the end of this replica-operation.)
	TabletServerErrorPB_LEADER_NOT_READY_TO_SERVE TabletServerErrorPB_Code = 24
	// This follower hasn't heard from the leader for a specified amount of time.
	TabletServerErrorPB_STALE_FOLLOWER TabletServerErrorPB_Code = 25
	// The operation is already in progress. Used for remote bootstrap requests for now.
	TabletServerErrorPB_ALREADY_IN_PROGRESS TabletServerErrorPB_Code = 26
	// Tablet server has some tablets pending local bootstraps.
	TabletServerErrorPB_PENDING_LOCAL_BOOTSTRAPS TabletServerErrorPB_Code = 27
	// Tablet splitting has been started (after split is completed - tablet stays in this state
	// until it is deleted).
	TabletServerErrorPB_TABLET_SPLIT TabletServerErrorPB_Code = 28
)

func (TabletServerErrorPB_Code) Descriptor 

func (TabletServerErrorPB_Code) Descriptor() protoreflect.EnumDescriptor

func (TabletServerErrorPB_Code) Enum 

func (x TabletServerErrorPB_Code) Enum() *TabletServerErrorPB_Code

func (TabletServerErrorPB_Code) EnumDescriptor deprecated 

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

Deprecated: Use TabletServerErrorPB_Code.Descriptor instead.

func (TabletServerErrorPB_Code) Number 

func (x TabletServerErrorPB_Code) Number() protoreflect.EnumNumber

func (TabletServerErrorPB_Code) String 

func (x TabletServerErrorPB_Code) String() string

func (TabletServerErrorPB_Code) Type 

func (TabletServerErrorPB_Code) Type() protoreflect.EnumType

func (*TabletServerErrorPB_Code) UnmarshalJSON deprecated 

func (x *TabletServerErrorPB_Code) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TabletServerService 

type TabletServerService interface {
	Write(request *WriteRequestPB) (*WriteResponsePB, error)
	Read(request *ReadRequestPB) (*ReadResponsePB, error)
	NoOp(request *NoOpRequestPB) (*NoOpResponsePB, error)
	ListTablets(request *ListTabletsRequestPB) (*ListTabletsResponsePB, error)
	GetLogLocation(request *GetLogLocationRequestPB) (*GetLogLocationResponsePB, error)
	Checksum(request *ChecksumRequestPB) (*ChecksumResponsePB, error)
	ListTabletsForTabletServer(request *ListTabletsForTabletServerRequestPB) (*ListTabletsForTabletServerResponsePB, error)
	ImportData(request *ImportDataRequestPB) (*ImportDataResponsePB, error)
	UpdateTransaction(request *UpdateTransactionRequestPB) (*UpdateTransactionResponsePB, error)
	GetTransactionStatus(request *GetTransactionStatusRequestPB) (*GetTransactionStatusResponsePB, error)
	GetTransactionStatusAtParticipant(request *GetTransactionStatusAtParticipantRequestPB) (*GetTransactionStatusAtParticipantResponsePB, error)
	AbortTransaction(request *AbortTransactionRequestPB) (*AbortTransactionResponsePB, error)
	Truncate(request *TruncateRequestPB) (*TruncateResponsePB, error)
	GetTabletStatus(request *GetTabletStatusRequestPB) (*GetTabletStatusResponsePB, error)
	GetMasterAddresses(request *GetMasterAddressesRequestPB) (*GetMasterAddressesResponsePB, error)
	Publish(request *PublishRequestPB) (*PublishResponsePB, error)
	IsTabletServerReady(request *IsTabletServerReadyRequestPB) (*IsTabletServerReadyResponsePB, error)
	TakeTransaction(request *TakeTransactionRequestPB) (*TakeTransactionResponsePB, error)
}

service: yb.tserver.TabletServerService service: TabletServerService

type TabletServerServiceImpl 

type TabletServerServiceImpl struct {
	Log       logr.Logger
	Messenger message.Messenger
}

func (*TabletServerServiceImpl) AbortTransaction 

func (s *TabletServerServiceImpl) AbortTransaction(request *AbortTransactionRequestPB) (*AbortTransactionResponsePB, error)

func (*TabletServerServiceImpl) Checksum 

func (s *TabletServerServiceImpl) Checksum(request *ChecksumRequestPB) (*ChecksumResponsePB, error)

func (*TabletServerServiceImpl) GetLogLocation 

func (s *TabletServerServiceImpl) GetLogLocation(request *GetLogLocationRequestPB) (*GetLogLocationResponsePB, error)

func (*TabletServerServiceImpl) GetMasterAddresses 

func (s *TabletServerServiceImpl) GetMasterAddresses(request *GetMasterAddressesRequestPB) (*GetMasterAddressesResponsePB, error)

func (*TabletServerServiceImpl) GetTabletStatus 

func (s *TabletServerServiceImpl) GetTabletStatus(request *GetTabletStatusRequestPB) (*GetTabletStatusResponsePB, error)

func (*TabletServerServiceImpl) GetTransactionStatus 

func (s *TabletServerServiceImpl) GetTransactionStatus(request *GetTransactionStatusRequestPB) (*GetTransactionStatusResponsePB, error)

func (*TabletServerServiceImpl) GetTransactionStatusAtParticipant 

func (s *TabletServerServiceImpl) GetTransactionStatusAtParticipant(request *GetTransactionStatusAtParticipantRequestPB) (*GetTransactionStatusAtParticipantResponsePB, error)

func (*TabletServerServiceImpl) ImportData 

func (s *TabletServerServiceImpl) ImportData(request *ImportDataRequestPB) (*ImportDataResponsePB, error)

func (*TabletServerServiceImpl) IsTabletServerReady 

func (s *TabletServerServiceImpl) IsTabletServerReady(request *IsTabletServerReadyRequestPB) (*IsTabletServerReadyResponsePB, error)

func (*TabletServerServiceImpl) ListTablets 

func (s *TabletServerServiceImpl) ListTablets(request *ListTabletsRequestPB) (*ListTabletsResponsePB, error)

func (*TabletServerServiceImpl) ListTabletsForTabletServer 

func (s *TabletServerServiceImpl) ListTabletsForTabletServer(request *ListTabletsForTabletServerRequestPB) (*ListTabletsForTabletServerResponsePB, error)

func (*TabletServerServiceImpl) NoOp 

func (s *TabletServerServiceImpl) NoOp(request *NoOpRequestPB) (*NoOpResponsePB, error)

func (*TabletServerServiceImpl) Publish 

func (s *TabletServerServiceImpl) Publish(request *PublishRequestPB) (*PublishResponsePB, error)

func (*TabletServerServiceImpl) Read 

func (s *TabletServerServiceImpl) Read(request *ReadRequestPB) (*ReadResponsePB, error)

func (*TabletServerServiceImpl) TakeTransaction 

func (s *TabletServerServiceImpl) TakeTransaction(request *TakeTransactionRequestPB) (*TakeTransactionResponsePB, error)

func (*TabletServerServiceImpl) Truncate 

func (s *TabletServerServiceImpl) Truncate(request *TruncateRequestPB) (*TruncateResponsePB, error)

func (*TabletServerServiceImpl) UpdateTransaction 

func (s *TabletServerServiceImpl) UpdateTransaction(request *UpdateTransactionRequestPB) (*UpdateTransactionResponsePB, error)

func (*TabletServerServiceImpl) Write 

func (s *TabletServerServiceImpl) Write(request *WriteRequestPB) (*WriteResponsePB, error)

type TabletSnapshotOpRequestPB 

type TabletSnapshotOpRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid  []byte                              `protobuf:"bytes,1,opt,name=dest_uuid,json=destUuid,proto3" json:"dest_uuid,omitempty"`
	Operation TabletSnapshotOpRequestPB_Operation `protobuf:"varint,2,opt,name=operation,proto3,enum=yb.tserver.TabletSnapshotOpRequestPB_Operation" json:"operation,omitempty"`
	// In case of transactional id it is binary representation of snapshot UUID, i.e. 16 bytes.
	// Otherwise it is hexadecimal representation of snapshot UUID, i.e. 32 bytes.
	SnapshotId []byte `protobuf:"bytes,3,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	// Tablets to snapshot. In case of CREATE_ON_MASTER it contains UUIDs of all tablets of snapshot.
	// Otherwise it contains just one tablet.
	TabletId             [][]byte `protobuf:"bytes,4,rep,name=tablet_id,json=tabletId,proto3" json:"tablet_id,omitempty"`
	PropagatedHybridTime uint64   `protobuf:"fixed64,5,opt,name=propagated_hybrid_time,json=propagatedHybridTime,proto3" json:"propagated_hybrid_time,omitempty"`
	// Override the snapshot directory. Used in restoring sys catalog to avoid running initdb.
	SnapshotDirOverride string `protobuf:"bytes,6,opt,name=snapshot_dir_override,json=snapshotDirOverride,proto3" json:"snapshot_dir_override,omitempty"`
	SnapshotHybridTime  uint64 `protobuf:"fixed64,7,opt,name=snapshot_hybrid_time,json=snapshotHybridTime,proto3" json:"snapshot_hybrid_time,omitempty"`
	// Extra data assigned for this snapshot request, so instance it could contain SysRowEntries.
	ExtraData                  *anypb.Any            `protobuf:"bytes,8,opt,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"`
	Imported                   bool                  `protobuf:"varint,9,opt,name=imported,proto3" json:"imported,omitempty"`
	ScheduleId                 []byte                `protobuf:"bytes,10,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	RestorationId              []byte                `protobuf:"bytes,11,opt,name=restoration_id,json=restorationId,proto3" json:"restoration_id,omitempty"`
	SchemaVersion              uint32                `protobuf:"varint,12,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	Schema                     *common.SchemaPB      `protobuf:"bytes,13,opt,name=schema,proto3" json:"schema,omitempty"`
	Indexes                    []*common.IndexInfoPB `protobuf:"bytes,14,rep,name=indexes,proto3" json:"indexes,omitempty"`
	PreviousSnapshotHybridTime uint64                `` /* 146-byte string literal not displayed */
	Hide                       bool                  `protobuf:"varint,16,opt,name=hide,proto3" json:"hide,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletSnapshotOpRequestPB) Descriptor deprecated 

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

Deprecated: Use TabletSnapshotOpRequestPB.ProtoReflect.Descriptor instead.

func (*TabletSnapshotOpRequestPB) GetDestUuid 

func (x *TabletSnapshotOpRequestPB) GetDestUuid() []byte

func (*TabletSnapshotOpRequestPB) GetExtraData 

func (x *TabletSnapshotOpRequestPB) GetExtraData() *anypb.Any

func (*TabletSnapshotOpRequestPB) GetHide 

func (x *TabletSnapshotOpRequestPB) GetHide() bool

func (*TabletSnapshotOpRequestPB) GetImported 

func (x *TabletSnapshotOpRequestPB) GetImported() bool

func (*TabletSnapshotOpRequestPB) GetIndexes 

func (x *TabletSnapshotOpRequestPB) GetIndexes() []*common.IndexInfoPB

func (*TabletSnapshotOpRequestPB) GetOperation 

func (x *TabletSnapshotOpRequestPB) GetOperation() TabletSnapshotOpRequestPB_Operation

func (*TabletSnapshotOpRequestPB) GetPreviousSnapshotHybridTime 

func (x *TabletSnapshotOpRequestPB) GetPreviousSnapshotHybridTime() uint64

func (*TabletSnapshotOpRequestPB) GetPropagatedHybridTime 

func (x *TabletSnapshotOpRequestPB) GetPropagatedHybridTime() uint64

func (*TabletSnapshotOpRequestPB) GetRestorationId 

func (x *TabletSnapshotOpRequestPB) GetRestorationId() []byte

func (*TabletSnapshotOpRequestPB) GetScheduleId 

func (x *TabletSnapshotOpRequestPB) GetScheduleId() []byte

func (*TabletSnapshotOpRequestPB) GetSchema 

func (x *TabletSnapshotOpRequestPB) GetSchema() *common.SchemaPB

func (*TabletSnapshotOpRequestPB) GetSchemaVersion 

func (x *TabletSnapshotOpRequestPB) GetSchemaVersion() uint32

func (*TabletSnapshotOpRequestPB) GetSnapshotDirOverride 

func (x *TabletSnapshotOpRequestPB) GetSnapshotDirOverride() string

func (*TabletSnapshotOpRequestPB) GetSnapshotHybridTime 

func (x *TabletSnapshotOpRequestPB) GetSnapshotHybridTime() uint64

func (*TabletSnapshotOpRequestPB) GetSnapshotId 

func (x *TabletSnapshotOpRequestPB) GetSnapshotId() []byte

func (*TabletSnapshotOpRequestPB) GetTabletId 

func (x *TabletSnapshotOpRequestPB) GetTabletId() [][]byte

func (*TabletSnapshotOpRequestPB) MarshalJSON 

func (m *TabletSnapshotOpRequestPB) MarshalJSON() ([]byte, error)

func (*TabletSnapshotOpRequestPB) ProtoMessage 

func (*TabletSnapshotOpRequestPB) ProtoMessage()

func (*TabletSnapshotOpRequestPB) ProtoReflect 

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

func (*TabletSnapshotOpRequestPB) Reset 

func (x *TabletSnapshotOpRequestPB) Reset()

func (*TabletSnapshotOpRequestPB) String 

func (x *TabletSnapshotOpRequestPB) String() string

func (*TabletSnapshotOpRequestPB) UnmarshalJSON 

func (m *TabletSnapshotOpRequestPB) UnmarshalJSON(b []byte) error

type TabletSnapshotOpRequestPB_Operation 

type TabletSnapshotOpRequestPB_Operation int32
const (
	TabletSnapshotOpRequestPB_UNKNOWN             TabletSnapshotOpRequestPB_Operation = 0
	TabletSnapshotOpRequestPB_CREATE_ON_TABLET    TabletSnapshotOpRequestPB_Operation = 1 // Replicated at tserver, to create snapshot for a particular tablet.
	TabletSnapshotOpRequestPB_RESTORE_ON_TABLET   TabletSnapshotOpRequestPB_Operation = 2
	TabletSnapshotOpRequestPB_DELETE_ON_TABLET    TabletSnapshotOpRequestPB_Operation = 3
	TabletSnapshotOpRequestPB_CREATE_ON_MASTER    TabletSnapshotOpRequestPB_Operation = 4 // Replicated at master, while creating snapshot for multiple tablets.
	TabletSnapshotOpRequestPB_DELETE_ON_MASTER    TabletSnapshotOpRequestPB_Operation = 5
	TabletSnapshotOpRequestPB_RESTORE_SYS_CATALOG TabletSnapshotOpRequestPB_Operation = 6
)

func (TabletSnapshotOpRequestPB_Operation) Descriptor 

func (TabletSnapshotOpRequestPB_Operation) Descriptor() protoreflect.EnumDescriptor

func (TabletSnapshotOpRequestPB_Operation) Enum 

func (x TabletSnapshotOpRequestPB_Operation) Enum() *TabletSnapshotOpRequestPB_Operation

func (TabletSnapshotOpRequestPB_Operation) EnumDescriptor deprecated 

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

Deprecated: Use TabletSnapshotOpRequestPB_Operation.Descriptor instead.

func (TabletSnapshotOpRequestPB_Operation) Number 

func (x TabletSnapshotOpRequestPB_Operation) Number() protoreflect.EnumNumber

func (TabletSnapshotOpRequestPB_Operation) String 

func (x TabletSnapshotOpRequestPB_Operation) String() string

func (TabletSnapshotOpRequestPB_Operation) Type 

func (TabletSnapshotOpRequestPB_Operation) Type() protoreflect.EnumType

type TabletSnapshotOpResponsePB 

type TabletSnapshotOpResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	PropagatedHybridTime uint64               `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime,proto3" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletSnapshotOpResponsePB) Descriptor deprecated 

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

Deprecated: Use TabletSnapshotOpResponsePB.ProtoReflect.Descriptor instead.

func (*TabletSnapshotOpResponsePB) GetError 

func (x *TabletSnapshotOpResponsePB) GetError() *TabletServerErrorPB

func (*TabletSnapshotOpResponsePB) GetPropagatedHybridTime 

func (x *TabletSnapshotOpResponsePB) GetPropagatedHybridTime() uint64

func (*TabletSnapshotOpResponsePB) MarshalJSON 

func (m *TabletSnapshotOpResponsePB) MarshalJSON() ([]byte, error)

func (*TabletSnapshotOpResponsePB) ProtoMessage 

func (*TabletSnapshotOpResponsePB) ProtoMessage()

func (*TabletSnapshotOpResponsePB) ProtoReflect 

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

func (*TabletSnapshotOpResponsePB) Reset 

func (x *TabletSnapshotOpResponsePB) Reset()

func (*TabletSnapshotOpResponsePB) String 

func (x *TabletSnapshotOpResponsePB) String() string

func (*TabletSnapshotOpResponsePB) UnmarshalJSON 

func (m *TabletSnapshotOpResponsePB) UnmarshalJSON(b []byte) error

type TakeTransactionRequestPB 

type TakeTransactionRequestPB struct {
	// contains filtered or unexported fields
}

func (*TakeTransactionRequestPB) Descriptor deprecated 

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

Deprecated: Use TakeTransactionRequestPB.ProtoReflect.Descriptor instead.

func (*TakeTransactionRequestPB) MarshalJSON 

func (m *TakeTransactionRequestPB) MarshalJSON() ([]byte, error)

func (*TakeTransactionRequestPB) ProtoMessage 

func (*TakeTransactionRequestPB) ProtoMessage()

func (*TakeTransactionRequestPB) ProtoReflect 

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

func (*TakeTransactionRequestPB) Reset 

func (x *TakeTransactionRequestPB) Reset()

func (*TakeTransactionRequestPB) String 

func (x *TakeTransactionRequestPB) String() string

func (*TakeTransactionRequestPB) UnmarshalJSON 

func (m *TakeTransactionRequestPB) UnmarshalJSON(b []byte) error

type TakeTransactionResponsePB 

type TakeTransactionResponsePB struct {
	Metadata *common.TransactionMetadataPB `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*TakeTransactionResponsePB) Descriptor deprecated 

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

Deprecated: Use TakeTransactionResponsePB.ProtoReflect.Descriptor instead.

func (*TakeTransactionResponsePB) GetMetadata 

func (x *TakeTransactionResponsePB) GetMetadata() *common.TransactionMetadataPB

func (*TakeTransactionResponsePB) MarshalJSON 

func (m *TakeTransactionResponsePB) MarshalJSON() ([]byte, error)

func (*TakeTransactionResponsePB) ProtoMessage 

func (*TakeTransactionResponsePB) ProtoMessage()

func (*TakeTransactionResponsePB) ProtoReflect 

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

func (*TakeTransactionResponsePB) Reset 

func (x *TakeTransactionResponsePB) Reset()

func (*TakeTransactionResponsePB) String 

func (x *TakeTransactionResponsePB) String() string

func (*TakeTransactionResponsePB) UnmarshalJSON 

func (m *TakeTransactionResponsePB) UnmarshalJSON(b []byte) error

type TransactionStatePB 

type TransactionStatePB struct {
	TransactionId []byte                    `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId" json:"transaction_id,omitempty"`
	Status        *common.TransactionStatus `protobuf:"varint,2,opt,name=status,enum=yb.TransactionStatus" json:"status,omitempty"`
	// tablets has different meaning, depending on status:
	// COMMITTED - list of involved tablets
	// APPLYING - single entry, status tablet of this transaction
	// APPLIED - single entry, tablet that applied this transaction
	// Not used is other cases.
	Tablets [][]byte `protobuf:"bytes,3,rep,name=tablets" json:"tablets,omitempty"`
	// Relevant only in SEALED state.
	// Number of batches that should be replicated at appropriate tablet to interpret transaction as
	// committed.
	TabletBatches []int64 `protobuf:"varint,5,rep,name=tablet_batches,json=tabletBatches" json:"tablet_batches,omitempty"`
	// Relevant only in APPLYING state.
	CommitHybridTime *uint64 `protobuf:"fixed64,4,opt,name=commit_hybrid_time,json=commitHybridTime" json:"commit_hybrid_time,omitempty"`
	// Relevant only in CLEANUP and APPLYING status, true when we perform request
	// for a transaction that was previously sealed.
	Sealed *bool `protobuf:"varint,6,opt,name=sealed" json:"sealed,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionStatePB) Descriptor deprecated 

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

Deprecated: Use TransactionStatePB.ProtoReflect.Descriptor instead.

func (*TransactionStatePB) GetCommitHybridTime 

func (x *TransactionStatePB) GetCommitHybridTime() uint64

func (*TransactionStatePB) GetSealed 

func (x *TransactionStatePB) GetSealed() bool

func (*TransactionStatePB) GetStatus 

func (x *TransactionStatePB) GetStatus() common.TransactionStatus

func (*TransactionStatePB) GetTabletBatches 

func (x *TransactionStatePB) GetTabletBatches() []int64

func (*TransactionStatePB) GetTablets 

func (x *TransactionStatePB) GetTablets() [][]byte

func (*TransactionStatePB) GetTransactionId 

func (x *TransactionStatePB) GetTransactionId() []byte

func (*TransactionStatePB) MarshalJSON 

func (m *TransactionStatePB) MarshalJSON() ([]byte, error)

func (*TransactionStatePB) ProtoMessage 

func (*TransactionStatePB) ProtoMessage()

func (*TransactionStatePB) ProtoReflect 

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

func (*TransactionStatePB) Reset 

func (x *TransactionStatePB) Reset()

func (*TransactionStatePB) String 

func (x *TransactionStatePB) String() string

func (*TransactionStatePB) UnmarshalJSON 

func (m *TransactionStatePB) UnmarshalJSON(b []byte) error

type TruncateRequestPB 

type TruncateRequestPB struct {
	TabletId             []byte  `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	PropagatedHybridTime *uint64 `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

Truncate tablet request.

func (*TruncateRequestPB) Descriptor deprecated 

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

Deprecated: Use TruncateRequestPB.ProtoReflect.Descriptor instead.

func (*TruncateRequestPB) GetPropagatedHybridTime 

func (x *TruncateRequestPB) GetPropagatedHybridTime() uint64

func (*TruncateRequestPB) GetTabletId 

func (x *TruncateRequestPB) GetTabletId() []byte

func (*TruncateRequestPB) MarshalJSON 

func (m *TruncateRequestPB) MarshalJSON() ([]byte, error)

func (*TruncateRequestPB) ProtoMessage 

func (*TruncateRequestPB) ProtoMessage()

func (*TruncateRequestPB) ProtoReflect 

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

func (*TruncateRequestPB) Reset 

func (x *TruncateRequestPB) Reset()

func (*TruncateRequestPB) String 

func (x *TruncateRequestPB) String() string

func (*TruncateRequestPB) UnmarshalJSON 

func (m *TruncateRequestPB) UnmarshalJSON(b []byte) error

type TruncateResponsePB 

type TruncateResponsePB struct {
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

Truncate tablet response.

func (*TruncateResponsePB) Descriptor deprecated 

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

Deprecated: Use TruncateResponsePB.ProtoReflect.Descriptor instead.

func (*TruncateResponsePB) GetError 

func (x *TruncateResponsePB) GetError() *TabletServerErrorPB

func (*TruncateResponsePB) GetPropagatedHybridTime 

func (x *TruncateResponsePB) GetPropagatedHybridTime() uint64

func (*TruncateResponsePB) MarshalJSON 

func (m *TruncateResponsePB) MarshalJSON() ([]byte, error)

func (*TruncateResponsePB) ProtoMessage 

func (*TruncateResponsePB) ProtoMessage()

func (*TruncateResponsePB) ProtoReflect 

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

func (*TruncateResponsePB) Reset 

func (x *TruncateResponsePB) Reset()

func (*TruncateResponsePB) String 

func (x *TruncateResponsePB) String() string

func (*TruncateResponsePB) UnmarshalJSON 

func (m *TruncateResponsePB) UnmarshalJSON(b []byte) error

type UpdateTransactionRequestPB 

type UpdateTransactionRequestPB struct {
	TabletId             []byte              `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	State                *TransactionStatePB `protobuf:"bytes,2,opt,name=state" json:"state,omitempty"`
	PropagatedHybridTime *uint64             `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTransactionRequestPB) Descriptor deprecated 

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

Deprecated: Use UpdateTransactionRequestPB.ProtoReflect.Descriptor instead.

func (*UpdateTransactionRequestPB) GetPropagatedHybridTime 

func (x *UpdateTransactionRequestPB) GetPropagatedHybridTime() uint64

func (*UpdateTransactionRequestPB) GetState 

func (x *UpdateTransactionRequestPB) GetState() *TransactionStatePB

func (*UpdateTransactionRequestPB) GetTabletId 

func (x *UpdateTransactionRequestPB) GetTabletId() []byte

func (*UpdateTransactionRequestPB) MarshalJSON 

func (m *UpdateTransactionRequestPB) MarshalJSON() ([]byte, error)

func (*UpdateTransactionRequestPB) ProtoMessage 

func (*UpdateTransactionRequestPB) ProtoMessage()

func (*UpdateTransactionRequestPB) ProtoReflect 

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

func (*UpdateTransactionRequestPB) Reset 

func (x *UpdateTransactionRequestPB) Reset()

func (*UpdateTransactionRequestPB) String 

func (x *UpdateTransactionRequestPB) String() string

func (*UpdateTransactionRequestPB) UnmarshalJSON 

func (m *UpdateTransactionRequestPB) UnmarshalJSON(b []byte) error

type UpdateTransactionResponsePB 

type UpdateTransactionResponsePB struct {

	// Error message, if any.
	Error                *TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PropagatedHybridTime *uint64              `protobuf:"fixed64,2,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTransactionResponsePB) Descriptor deprecated 

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

Deprecated: Use UpdateTransactionResponsePB.ProtoReflect.Descriptor instead.

func (*UpdateTransactionResponsePB) GetError 

func (x *UpdateTransactionResponsePB) GetError() *TabletServerErrorPB

func (*UpdateTransactionResponsePB) GetPropagatedHybridTime 

func (x *UpdateTransactionResponsePB) GetPropagatedHybridTime() uint64

func (*UpdateTransactionResponsePB) MarshalJSON 

func (m *UpdateTransactionResponsePB) MarshalJSON() ([]byte, error)

func (*UpdateTransactionResponsePB) ProtoMessage 

func (*UpdateTransactionResponsePB) ProtoMessage()

func (*UpdateTransactionResponsePB) ProtoReflect 

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

func (*UpdateTransactionResponsePB) Reset 

func (x *UpdateTransactionResponsePB) Reset()

func (*UpdateTransactionResponsePB) String 

func (x *UpdateTransactionResponsePB) String() string

func (*UpdateTransactionResponsePB) UnmarshalJSON 

func (m *UpdateTransactionResponsePB) UnmarshalJSON(b []byte) error

type WriteRequestPB 

type WriteRequestPB struct {
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// When replicating RocksDB write operations through Raft for single-shard transactions,
	// we put a write batch here.
	WriteBatch *docdb.KeyValueWriteBatchPB `protobuf:"bytes,7,opt,name=write_batch,json=writeBatch" json:"write_batch,omitempty"`
	// A batch of redis operations.
	RedisWriteBatch []*common.RedisWriteRequestPB `protobuf:"bytes,8,rep,name=redis_write_batch,json=redisWriteBatch" json:"redis_write_batch,omitempty"`
	// A batch of QL operations.
	QlWriteBatch []*common.QLWriteRequestPB `protobuf:"bytes,10,rep,name=ql_write_batch,json=qlWriteBatch" json:"ql_write_batch,omitempty"`
	// A batch of Pgsql operations (Although batching is not yet supported).
	PgsqlWriteBatch []*common.PgsqlWriteRequestPB `protobuf:"bytes,13,rep,name=pgsql_write_batch,json=pgsqlWriteBatch" json:"pgsql_write_batch,omitempty"`
	// Whether data blocks will be cached when read from the files or discarded after use.
	// Disable this to lower cache churn when doing large scans.
	CacheBlocks *bool `protobuf:"varint,9,opt,name=cache_blocks,json=cacheBlocks,def=1" json:"cache_blocks,omitempty"`
	// A hybrid_time obtained by the client from a previous request.
	// TODO crypto sign this and propagate the signature along with
	// the hybrid_time.
	PropagatedHybridTime *uint64                  `protobuf:"fixed64,5,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	IncludeTrace         *bool                    `protobuf:"varint,6,opt,name=include_trace,json=includeTrace,def=0" json:"include_trace,omitempty"`
	ReadTime             *common.ReadHybridTimePB `protobuf:"bytes,12,opt,name=read_time,json=readTime" json:"read_time,omitempty"`
	// Use 2 int64 to represent UUID.
	ClientId1           *uint64  `protobuf:"fixed64,14,opt,name=client_id1,json=clientId1" json:"client_id1,omitempty"`
	ClientId2           *uint64  `protobuf:"fixed64,15,opt,name=client_id2,json=clientId2" json:"client_id2,omitempty"`
	RequestId           *int64   `protobuf:"varint,16,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	MinRunningRequestId *int64   `protobuf:"varint,17,opt,name=min_running_request_id,json=minRunningRequestId" json:"min_running_request_id,omitempty"`
	RejectionScore      *float64 `protobuf:"fixed64,18,opt,name=rejection_score,json=rejectionScore" json:"rejection_score,omitempty"`
	ExternalHybridTime  *uint64  `protobuf:"fixed64,19,opt,name=external_hybrid_time,json=externalHybridTime" json:"external_hybrid_time,omitempty"`
	BatchIdx            *uint64  `protobuf:"varint,20,opt,name=batch_idx,json=batchIdx" json:"batch_idx,omitempty"`
	// contains filtered or unexported fields
}

A batched set of insert/mutate requests.

func (*WriteRequestPB) Descriptor deprecated 

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

Deprecated: Use WriteRequestPB.ProtoReflect.Descriptor instead.

func (*WriteRequestPB) GetBatchIdx 

func (x *WriteRequestPB) GetBatchIdx() uint64

func (*WriteRequestPB) GetCacheBlocks 

func (x *WriteRequestPB) GetCacheBlocks() bool

func (*WriteRequestPB) GetClientId1 

func (x *WriteRequestPB) GetClientId1() uint64

func (*WriteRequestPB) GetClientId2 

func (x *WriteRequestPB) GetClientId2() uint64

func (*WriteRequestPB) GetExternalHybridTime 

func (x *WriteRequestPB) GetExternalHybridTime() uint64

func (*WriteRequestPB) GetIncludeTrace 

func (x *WriteRequestPB) GetIncludeTrace() bool

func (*WriteRequestPB) GetMinRunningRequestId 

func (x *WriteRequestPB) GetMinRunningRequestId() int64

func (*WriteRequestPB) GetPgsqlWriteBatch 

func (x *WriteRequestPB) GetPgsqlWriteBatch() []*common.PgsqlWriteRequestPB

func (*WriteRequestPB) GetPropagatedHybridTime 

func (x *WriteRequestPB) GetPropagatedHybridTime() uint64

func (*WriteRequestPB) GetQlWriteBatch 

func (x *WriteRequestPB) GetQlWriteBatch() []*common.QLWriteRequestPB

func (*WriteRequestPB) GetReadTime 

func (x *WriteRequestPB) GetReadTime() *common.ReadHybridTimePB

func (*WriteRequestPB) GetRedisWriteBatch 

func (x *WriteRequestPB) GetRedisWriteBatch() []*common.RedisWriteRequestPB

func (*WriteRequestPB) GetRejectionScore 

func (x *WriteRequestPB) GetRejectionScore() float64

func (*WriteRequestPB) GetRequestId 

func (x *WriteRequestPB) GetRequestId() int64

func (*WriteRequestPB) GetTabletId 

func (x *WriteRequestPB) GetTabletId() []byte

func (*WriteRequestPB) GetWriteBatch 

func (x *WriteRequestPB) GetWriteBatch() *docdb.KeyValueWriteBatchPB

func (*WriteRequestPB) MarshalJSON 

func (m *WriteRequestPB) MarshalJSON() ([]byte, error)

func (*WriteRequestPB) ProtoMessage 

func (*WriteRequestPB) ProtoMessage()

func (*WriteRequestPB) ProtoReflect 

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

func (*WriteRequestPB) Reset 

func (x *WriteRequestPB) Reset()

func (*WriteRequestPB) String 

func (x *WriteRequestPB) String() string

func (*WriteRequestPB) UnmarshalJSON 

func (m *WriteRequestPB) UnmarshalJSON(b []byte) error

type WriteResponsePB 

type WriteResponsePB struct {

	// If the entire WriteResponsePB request failed, the error status that
	// caused the failure. This type of error is triggered for
	// cases such as the tablet not being on this server, or the
	// schema not matching. If any error specific to a given row
	// occurs, this error will be recorded in per_row_errors below,
	// even if all rows failed.
	Error        *TabletServerErrorPB             `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	PerRowErrors []*WriteResponsePB_PerRowErrorPB `protobuf:"bytes,2,rep,name=per_row_errors,json=perRowErrors" json:"per_row_errors,omitempty"`
	// A batch of redis responses.
	RedisResponseBatch []*common.RedisResponsePB `protobuf:"bytes,8,rep,name=redis_response_batch,json=redisResponseBatch" json:"redis_response_batch,omitempty"`
	// A batch of QL responses.
	QlResponseBatch []*common.QLResponsePB `protobuf:"bytes,9,rep,name=ql_response_batch,json=qlResponseBatch" json:"ql_response_batch,omitempty"`
	// A batch of QL responses.
	PgsqlResponseBatch []*common.PgsqlResponsePB `protobuf:"bytes,12,rep,name=pgsql_response_batch,json=pgsqlResponseBatch" json:"pgsql_response_batch,omitempty"`
	// The hybrid_time chosen by the server for this write.
	// TODO KUDU-611 propagate hybrid_times with server signature.
	PropagatedHybridTime *uint64 `protobuf:"fixed64,3,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	TraceBuffer          *string `protobuf:"bytes,10,opt,name=trace_buffer,json=traceBuffer" json:"trace_buffer,omitempty"`
	// Used to report restart whether this operation requires read restart.
	RestartReadTime *common.ReadHybridTimePB `protobuf:"bytes,11,opt,name=restart_read_time,json=restartReadTime" json:"restart_read_time,omitempty"`
	// Used to report used read time when transaction asked for it.
	UsedReadTime *common.ReadHybridTimePB `protobuf:"bytes,13,opt,name=used_read_time,json=usedReadTime" json:"used_read_time,omitempty"`
	LocalLimitHt *uint64                  `protobuf:"fixed64,14,opt,name=local_limit_ht,json=localLimitHt" json:"local_limit_ht,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteResponsePB) Descriptor deprecated 

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

Deprecated: Use WriteResponsePB.ProtoReflect.Descriptor instead.

func (*WriteResponsePB) GetError 

func (x *WriteResponsePB) GetError() *TabletServerErrorPB

func (*WriteResponsePB) GetLocalLimitHt 

func (x *WriteResponsePB) GetLocalLimitHt() uint64

func (*WriteResponsePB) GetPerRowErrors 

func (x *WriteResponsePB) GetPerRowErrors() []*WriteResponsePB_PerRowErrorPB

func (*WriteResponsePB) GetPgsqlResponseBatch 

func (x *WriteResponsePB) GetPgsqlResponseBatch() []*common.PgsqlResponsePB

func (*WriteResponsePB) GetPropagatedHybridTime 

func (x *WriteResponsePB) GetPropagatedHybridTime() uint64

func (*WriteResponsePB) GetQlResponseBatch 

func (x *WriteResponsePB) GetQlResponseBatch() []*common.QLResponsePB

func (*WriteResponsePB) GetRedisResponseBatch 

func (x *WriteResponsePB) GetRedisResponseBatch() []*common.RedisResponsePB

func (*WriteResponsePB) GetRestartReadTime 

func (x *WriteResponsePB) GetRestartReadTime() *common.ReadHybridTimePB

func (*WriteResponsePB) GetTraceBuffer 

func (x *WriteResponsePB) GetTraceBuffer() string

func (*WriteResponsePB) GetUsedReadTime 

func (x *WriteResponsePB) GetUsedReadTime() *common.ReadHybridTimePB

func (*WriteResponsePB) MarshalJSON 

func (m *WriteResponsePB) MarshalJSON() ([]byte, error)

func (*WriteResponsePB) ProtoMessage 

func (*WriteResponsePB) ProtoMessage()

func (*WriteResponsePB) ProtoReflect 

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

func (*WriteResponsePB) Reset 

func (x *WriteResponsePB) Reset()

func (*WriteResponsePB) String 

func (x *WriteResponsePB) String() string

func (*WriteResponsePB) UnmarshalJSON 

func (m *WriteResponsePB) UnmarshalJSON(b []byte) error

type WriteResponsePB_PerRowErrorPB 

type WriteResponsePB_PerRowErrorPB struct {

	// The index of the row in the incoming batch.
	RowIndex *int32 `protobuf:"varint,1,req,name=row_index,json=rowIndex" json:"row_index,omitempty"`
	// The error that occurred.
	Error *common.AppStatusPB `protobuf:"bytes,2,req,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

If errors occurred with particular row operations, then the errors for those operations will be passed back in 'per_row_errors'.

func (*WriteResponsePB_PerRowErrorPB) Descriptor deprecated 

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

Deprecated: Use WriteResponsePB_PerRowErrorPB.ProtoReflect.Descriptor instead.

func (*WriteResponsePB_PerRowErrorPB) GetError 

func (x *WriteResponsePB_PerRowErrorPB) GetError() *common.AppStatusPB

func (*WriteResponsePB_PerRowErrorPB) GetRowIndex 

func (x *WriteResponsePB_PerRowErrorPB) GetRowIndex() int32

func (*WriteResponsePB_PerRowErrorPB) ProtoMessage 

func (*WriteResponsePB_PerRowErrorPB) ProtoMessage()

func (*WriteResponsePB_PerRowErrorPB) ProtoReflect 

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

func (*WriteResponsePB_PerRowErrorPB) Reset 

func (x *WriteResponsePB_PerRowErrorPB) Reset()

func (*WriteResponsePB_PerRowErrorPB) String 

func (x *WriteResponsePB_PerRowErrorPB) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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