proto

package
v0.0.0-...-0febee4 Latest Latest
Warning

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

Go to latest
Published: Sep 3, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Admin_GetClusterOverview_FullMethodName    = "/Admin/GetClusterOverview"
	Admin_GetRaftGroups_FullMethodName         = "/Admin/GetRaftGroups"
	Admin_GetAdapterSummary_FullMethodName     = "/Admin/GetAdapterSummary"
	Admin_GetKeyVizMatrix_FullMethodName       = "/Admin/GetKeyVizMatrix"
	Admin_GetRouteDetail_FullMethodName        = "/Admin/GetRouteDetail"
	Admin_SetAutoSplitEnabled_FullMethodName   = "/Admin/SetAutoSplitEnabled"
	Admin_BeginBackup_FullMethodName           = "/Admin/BeginBackup"
	Admin_RenewBackup_FullMethodName           = "/Admin/RenewBackup"
	Admin_EndBackup_FullMethodName             = "/Admin/EndBackup"
	Admin_ListAdaptersAndScopes_FullMethodName = "/Admin/ListAdaptersAndScopes"
	Admin_StreamBackup_FullMethodName          = "/Admin/StreamBackup"
	Admin_GetNodeVersion_FullMethodName        = "/Admin/GetNodeVersion"
	Admin_StreamEvents_FullMethodName          = "/Admin/StreamEvents"
)
View Source
const (
	Distribution_GetRoute_FullMethodName               = "/Distribution/GetRoute"
	Distribution_GetTimestamp_FullMethodName           = "/Distribution/GetTimestamp"
	Distribution_ValidateTimestamp_FullMethodName      = "/Distribution/ValidateTimestamp"
	Distribution_ListRoutes_FullMethodName             = "/Distribution/ListRoutes"
	Distribution_SplitRange_FullMethodName             = "/Distribution/SplitRange"
	Distribution_GetCatalogCapabilities_FullMethodName = "/Distribution/GetCatalogCapabilities"
	Distribution_WatchCatalog_FullMethodName           = "/Distribution/WatchCatalog"
	Distribution_StartSplitMigration_FullMethodName    = "/Distribution/StartSplitMigration"
	Distribution_GetRouteOwnership_FullMethodName      = "/Distribution/GetRouteOwnership"
	Distribution_GetIntersectingRoutes_FullMethodName  = "/Distribution/GetIntersectingRoutes"
	Distribution_GetSplitJob_FullMethodName            = "/Distribution/GetSplitJob"
	Distribution_ListSplitJobs_FullMethodName          = "/Distribution/ListSplitJobs"
	Distribution_AbandonSplitJob_FullMethodName        = "/Distribution/AbandonSplitJob"
	Distribution_RetrySplitJob_FullMethodName          = "/Distribution/RetrySplitJob"
)
View Source
const (
	EncryptionAdmin_GetCapability_FullMethodName            = "/EncryptionAdmin/GetCapability"
	EncryptionAdmin_GetSidecarState_FullMethodName          = "/EncryptionAdmin/GetSidecarState"
	EncryptionAdmin_BootstrapEncryption_FullMethodName      = "/EncryptionAdmin/BootstrapEncryption"
	EncryptionAdmin_RotateDEK_FullMethodName                = "/EncryptionAdmin/RotateDEK"
	EncryptionAdmin_RegisterEncryptionWriter_FullMethodName = "/EncryptionAdmin/RegisterEncryptionWriter"
	EncryptionAdmin_ResyncSidecar_FullMethodName            = "/EncryptionAdmin/ResyncSidecar"
	EncryptionAdmin_EnableStorageEnvelope_FullMethodName    = "/EncryptionAdmin/EnableStorageEnvelope"
	EncryptionAdmin_EnableRaftEnvelope_FullMethodName       = "/EncryptionAdmin/EnableRaftEnvelope"
)
View Source
const (
	EtcdRaft_Send_FullMethodName         = "/EtcdRaft/Send"
	EtcdRaft_SendStream_FullMethodName   = "/EtcdRaft/SendStream"
	EtcdRaft_SendSnapshot_FullMethodName = "/EtcdRaft/SendSnapshot"
)
View Source
const (
	Internal_Forward_FullMethodName              = "/Internal/Forward"
	Internal_ForwardAdminProposal_FullMethodName = "/Internal/ForwardAdminProposal"
	Internal_ForwardLeaseRead_FullMethodName     = "/Internal/ForwardLeaseRead"
	Internal_RelayPublish_FullMethodName         = "/Internal/RelayPublish"
	Internal_ExportRangeVersions_FullMethodName  = "/Internal/ExportRangeVersions"
	Internal_ImportRangeVersions_FullMethodName  = "/Internal/ImportRangeVersions"
)
View Source
const (
	RawKV_RawPut_FullMethodName            = "/RawKV/RawPut"
	RawKV_RawGet_FullMethodName            = "/RawKV/RawGet"
	RawKV_RawDelete_FullMethodName         = "/RawKV/RawDelete"
	RawKV_RawLatestCommitTS_FullMethodName = "/RawKV/RawLatestCommitTS"
	RawKV_RawScanAt_FullMethodName         = "/RawKV/RawScanAt"
)
View Source
const (
	TransactionalKV_Put_FullMethodName      = "/TransactionalKV/Put"
	TransactionalKV_Get_FullMethodName      = "/TransactionalKV/Get"
	TransactionalKV_Delete_FullMethodName   = "/TransactionalKV/Delete"
	TransactionalKV_Scan_FullMethodName     = "/TransactionalKV/Scan"
	TransactionalKV_PreWrite_FullMethodName = "/TransactionalKV/PreWrite"
	TransactionalKV_Commit_FullMethodName   = "/TransactionalKV/Commit"
	TransactionalKV_Rollback_FullMethodName = "/TransactionalKV/Rollback"
)
View Source
const (
	RaftAdmin_Status_FullMethodName             = "/RaftAdmin/Status"
	RaftAdmin_Configuration_FullMethodName      = "/RaftAdmin/Configuration"
	RaftAdmin_AddVoter_FullMethodName           = "/RaftAdmin/AddVoter"
	RaftAdmin_AddLearner_FullMethodName         = "/RaftAdmin/AddLearner"
	RaftAdmin_PromoteLearner_FullMethodName     = "/RaftAdmin/PromoteLearner"
	RaftAdmin_RemoveServer_FullMethodName       = "/RaftAdmin/RemoveServer"
	RaftAdmin_TransferLeadership_FullMethodName = "/RaftAdmin/TransferLeadership"
)
View Source
const (
	S3BlobFetch_FetchChunkBlob_FullMethodName = "/S3BlobFetch/FetchChunkBlob"
	S3BlobFetch_PushChunkBlob_FullMethodName  = "/S3BlobFetch/PushChunkBlob"
)
View Source
const (
	AdminForward_Forward_FullMethodName = "/AdminForward/Forward"
)

Variables

View Source
var (
	KeyVizSeries_name = map[int32]string{
		0: "KEYVIZ_SERIES_UNSPECIFIED",
		1: "KEYVIZ_SERIES_READS",
		2: "KEYVIZ_SERIES_WRITES",
		3: "KEYVIZ_SERIES_READ_BYTES",
		4: "KEYVIZ_SERIES_WRITE_BYTES",
	}
	KeyVizSeries_value = map[string]int32{
		"KEYVIZ_SERIES_UNSPECIFIED": 0,
		"KEYVIZ_SERIES_READS":       1,
		"KEYVIZ_SERIES_WRITES":      2,
		"KEYVIZ_SERIES_READ_BYTES":  3,
		"KEYVIZ_SERIES_WRITE_BYTES": 4,
	}
)

Enum value maps for KeyVizSeries.

View Source
var (
	SampleRole_name = map[int32]string{
		0: "SAMPLE_ROLE_UNSPECIFIED",
		1: "SAMPLE_ROLE_LEADER_WRITE",
		2: "SAMPLE_ROLE_LEADER_READ",
		3: "SAMPLE_ROLE_FOLLOWER_READ",
	}
	SampleRole_value = map[string]int32{
		"SAMPLE_ROLE_UNSPECIFIED":   0,
		"SAMPLE_ROLE_LEADER_WRITE":  1,
		"SAMPLE_ROLE_LEADER_READ":   2,
		"SAMPLE_ROLE_FOLLOWER_READ": 3,
	}
)

Enum value maps for SampleRole.

View Source
var (
	AdminOperation_name = map[int32]string{
		0: "ADMIN_OP_UNSPECIFIED",
		1: "ADMIN_OP_CREATE_TABLE",
		2: "ADMIN_OP_DELETE_TABLE",
		3: "ADMIN_OP_CREATE_BUCKET",
		4: "ADMIN_OP_DELETE_BUCKET",
		5: "ADMIN_OP_PUT_BUCKET_ACL",
	}
	AdminOperation_value = map[string]int32{
		"ADMIN_OP_UNSPECIFIED":    0,
		"ADMIN_OP_CREATE_TABLE":   1,
		"ADMIN_OP_DELETE_TABLE":   2,
		"ADMIN_OP_CREATE_BUCKET":  3,
		"ADMIN_OP_DELETE_BUCKET":  4,
		"ADMIN_OP_PUT_BUCKET_ACL": 5,
	}
)

Enum value maps for AdminOperation.

View Source
var (
	RouteState_name = map[int32]string{
		0: "ROUTE_STATE_UNSPECIFIED",
		1: "ROUTE_STATE_ACTIVE",
		2: "ROUTE_STATE_WRITE_FENCED",
		3: "ROUTE_STATE_MIGRATING_SOURCE",
		4: "ROUTE_STATE_MIGRATING_TARGET",
	}
	RouteState_value = map[string]int32{
		"ROUTE_STATE_UNSPECIFIED":      0,
		"ROUTE_STATE_ACTIVE":           1,
		"ROUTE_STATE_WRITE_FENCED":     2,
		"ROUTE_STATE_MIGRATING_SOURCE": 3,
		"ROUTE_STATE_MIGRATING_TARGET": 4,
	}
)

Enum value maps for RouteState.

View Source
var (
	SplitJobPhase_name = map[int32]string{
		0:  "SPLIT_JOB_PHASE_NONE",
		1:  "SPLIT_JOB_PHASE_PLANNED",
		2:  "SPLIT_JOB_PHASE_BACKFILL",
		3:  "SPLIT_JOB_PHASE_FENCE",
		4:  "SPLIT_JOB_PHASE_DELTA_COPY",
		5:  "SPLIT_JOB_PHASE_CUTOVER",
		6:  "SPLIT_JOB_PHASE_CLEANUP",
		7:  "SPLIT_JOB_PHASE_DONE",
		8:  "SPLIT_JOB_PHASE_FAILED",
		9:  "SPLIT_JOB_PHASE_ABANDONING",
		10: "SPLIT_JOB_PHASE_ABANDONED",
	}
	SplitJobPhase_value = map[string]int32{
		"SPLIT_JOB_PHASE_NONE":       0,
		"SPLIT_JOB_PHASE_PLANNED":    1,
		"SPLIT_JOB_PHASE_BACKFILL":   2,
		"SPLIT_JOB_PHASE_FENCE":      3,
		"SPLIT_JOB_PHASE_DELTA_COPY": 4,
		"SPLIT_JOB_PHASE_CUTOVER":    5,
		"SPLIT_JOB_PHASE_CLEANUP":    6,
		"SPLIT_JOB_PHASE_DONE":       7,
		"SPLIT_JOB_PHASE_FAILED":     8,
		"SPLIT_JOB_PHASE_ABANDONING": 9,
		"SPLIT_JOB_PHASE_ABANDONED":  10,
	}
)

Enum value maps for SplitJobPhase.

View Source
var (
	SplitJobBarrierState_name = map[int32]string{
		0: "SPLIT_JOB_BARRIER_STATE_NONE",
		1: "SPLIT_JOB_BARRIER_STATE_ARMING",
		2: "SPLIT_JOB_BARRIER_STATE_ARMED",
		3: "SPLIT_JOB_BARRIER_STATE_CLEARING",
	}
	SplitJobBarrierState_value = map[string]int32{
		"SPLIT_JOB_BARRIER_STATE_NONE":     0,
		"SPLIT_JOB_BARRIER_STATE_ARMING":   1,
		"SPLIT_JOB_BARRIER_STATE_ARMED":    2,
		"SPLIT_JOB_BARRIER_STATE_CLEARING": 3,
	}
)

Enum value maps for SplitJobBarrierState.

View Source
var (
	SplitJobExportPhase_name = map[int32]string{
		0: "SPLIT_JOB_EXPORT_PHASE_NONE",
		1: "SPLIT_JOB_EXPORT_PHASE_BACKFILL",
		2: "SPLIT_JOB_EXPORT_PHASE_DELTA_COPY",
	}
	SplitJobExportPhase_value = map[string]int32{
		"SPLIT_JOB_EXPORT_PHASE_NONE":       0,
		"SPLIT_JOB_EXPORT_PHASE_BACKFILL":   1,
		"SPLIT_JOB_EXPORT_PHASE_DELTA_COPY": 2,
	}
)

Enum value maps for SplitJobExportPhase.

View Source
var (
	CatalogDeltaMutationOp_name = map[int32]string{
		0: "CATALOG_DELTA_MUTATION_OP_UNSPECIFIED",
		1: "CATALOG_DELTA_MUTATION_OP_UPSERT",
		2: "CATALOG_DELTA_MUTATION_OP_DELETE",
	}
	CatalogDeltaMutationOp_value = map[string]int32{
		"CATALOG_DELTA_MUTATION_OP_UNSPECIFIED": 0,
		"CATALOG_DELTA_MUTATION_OP_UPSERT":      1,
		"CATALOG_DELTA_MUTATION_OP_DELETE":      2,
	}
)

Enum value maps for CatalogDeltaMutationOp.

View Source
var (
	RotateDEKRequest_Purpose_name = map[int32]string{
		0: "PURPOSE_UNSPECIFIED",
		1: "PURPOSE_STORAGE",
		2: "PURPOSE_RAFT",
	}
	RotateDEKRequest_Purpose_value = map[string]int32{
		"PURPOSE_UNSPECIFIED": 0,
		"PURPOSE_STORAGE":     1,
		"PURPOSE_RAFT":        2,
	}
)

Enum value maps for RotateDEKRequest_Purpose.

View Source
var (
	Op_name = map[int32]string{
		0: "PUT",
		1: "DEL",
		2: "DEL_PREFIX",
	}
	Op_value = map[string]int32{
		"PUT":        0,
		"DEL":        1,
		"DEL_PREFIX": 2,
	}
)

Enum value maps for Op.

View Source
var (
	Phase_name = map[int32]string{
		0: "NONE",
		1: "PREPARE",
		2: "COMMIT",
		3: "ABORT",
	}
	Phase_value = map[string]int32{
		"NONE":    0,
		"PREPARE": 1,
		"COMMIT":  2,
		"ABORT":   3,
	}
)

Enum value maps for Phase.

View Source
var (
	RaftAdminState_name = map[int32]string{
		0: "RAFT_ADMIN_STATE_UNKNOWN",
		1: "RAFT_ADMIN_STATE_FOLLOWER",
		2: "RAFT_ADMIN_STATE_CANDIDATE",
		3: "RAFT_ADMIN_STATE_LEADER",
		4: "RAFT_ADMIN_STATE_SHUTDOWN",
	}
	RaftAdminState_value = map[string]int32{
		"RAFT_ADMIN_STATE_UNKNOWN":   0,
		"RAFT_ADMIN_STATE_FOLLOWER":  1,
		"RAFT_ADMIN_STATE_CANDIDATE": 2,
		"RAFT_ADMIN_STATE_LEADER":    3,
		"RAFT_ADMIN_STATE_SHUTDOWN":  4,
	}
)

Enum value maps for RaftAdminState.

View Source
var AdminForward_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "AdminForward",
	HandlerType: (*AdminForwardServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Forward",
			Handler:    _AdminForward_Forward_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "admin_forward.proto",
}

AdminForward_ServiceDesc is the grpc.ServiceDesc for AdminForward service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var Admin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Admin",
	HandlerType: (*AdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetClusterOverview",
			Handler:    _Admin_GetClusterOverview_Handler,
		},
		{
			MethodName: "GetRaftGroups",
			Handler:    _Admin_GetRaftGroups_Handler,
		},
		{
			MethodName: "GetAdapterSummary",
			Handler:    _Admin_GetAdapterSummary_Handler,
		},
		{
			MethodName: "GetKeyVizMatrix",
			Handler:    _Admin_GetKeyVizMatrix_Handler,
		},
		{
			MethodName: "GetRouteDetail",
			Handler:    _Admin_GetRouteDetail_Handler,
		},
		{
			MethodName: "SetAutoSplitEnabled",
			Handler:    _Admin_SetAutoSplitEnabled_Handler,
		},
		{
			MethodName: "BeginBackup",
			Handler:    _Admin_BeginBackup_Handler,
		},
		{
			MethodName: "RenewBackup",
			Handler:    _Admin_RenewBackup_Handler,
		},
		{
			MethodName: "EndBackup",
			Handler:    _Admin_EndBackup_Handler,
		},
		{
			MethodName: "ListAdaptersAndScopes",
			Handler:    _Admin_ListAdaptersAndScopes_Handler,
		},
		{
			MethodName: "GetNodeVersion",
			Handler:    _Admin_GetNodeVersion_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamBackup",
			Handler:       _Admin_StreamBackup_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamEvents",
			Handler:       _Admin_StreamEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "admin.proto",
}

Admin_ServiceDesc is the grpc.ServiceDesc for Admin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var Distribution_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Distribution",
	HandlerType: (*DistributionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRoute",
			Handler:    _Distribution_GetRoute_Handler,
		},
		{
			MethodName: "GetTimestamp",
			Handler:    _Distribution_GetTimestamp_Handler,
		},
		{
			MethodName: "ValidateTimestamp",
			Handler:    _Distribution_ValidateTimestamp_Handler,
		},
		{
			MethodName: "ListRoutes",
			Handler:    _Distribution_ListRoutes_Handler,
		},
		{
			MethodName: "SplitRange",
			Handler:    _Distribution_SplitRange_Handler,
		},
		{
			MethodName: "GetCatalogCapabilities",
			Handler:    _Distribution_GetCatalogCapabilities_Handler,
		},
		{
			MethodName: "StartSplitMigration",
			Handler:    _Distribution_StartSplitMigration_Handler,
		},
		{
			MethodName: "GetRouteOwnership",
			Handler:    _Distribution_GetRouteOwnership_Handler,
		},
		{
			MethodName: "GetIntersectingRoutes",
			Handler:    _Distribution_GetIntersectingRoutes_Handler,
		},
		{
			MethodName: "GetSplitJob",
			Handler:    _Distribution_GetSplitJob_Handler,
		},
		{
			MethodName: "ListSplitJobs",
			Handler:    _Distribution_ListSplitJobs_Handler,
		},
		{
			MethodName: "AbandonSplitJob",
			Handler:    _Distribution_AbandonSplitJob_Handler,
		},
		{
			MethodName: "RetrySplitJob",
			Handler:    _Distribution_RetrySplitJob_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchCatalog",
			Handler:       _Distribution_WatchCatalog_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "distribution.proto",
}

Distribution_ServiceDesc is the grpc.ServiceDesc for Distribution service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var EncryptionAdmin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "EncryptionAdmin",
	HandlerType: (*EncryptionAdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCapability",
			Handler:    _EncryptionAdmin_GetCapability_Handler,
		},
		{
			MethodName: "GetSidecarState",
			Handler:    _EncryptionAdmin_GetSidecarState_Handler,
		},
		{
			MethodName: "BootstrapEncryption",
			Handler:    _EncryptionAdmin_BootstrapEncryption_Handler,
		},
		{
			MethodName: "RotateDEK",
			Handler:    _EncryptionAdmin_RotateDEK_Handler,
		},
		{
			MethodName: "RegisterEncryptionWriter",
			Handler:    _EncryptionAdmin_RegisterEncryptionWriter_Handler,
		},
		{
			MethodName: "ResyncSidecar",
			Handler:    _EncryptionAdmin_ResyncSidecar_Handler,
		},
		{
			MethodName: "EnableStorageEnvelope",
			Handler:    _EncryptionAdmin_EnableStorageEnvelope_Handler,
		},
		{
			MethodName: "EnableRaftEnvelope",
			Handler:    _EncryptionAdmin_EnableRaftEnvelope_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "encryption_admin.proto",
}

EncryptionAdmin_ServiceDesc is the grpc.ServiceDesc for EncryptionAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var EtcdRaft_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "EtcdRaft",
	HandlerType: (*EtcdRaftServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _EtcdRaft_Send_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendStream",
			Handler:       _EtcdRaft_SendStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "SendSnapshot",
			Handler:       _EtcdRaft_SendSnapshot_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "etcd_raft.proto",
}

EtcdRaft_ServiceDesc is the grpc.ServiceDesc for EtcdRaft service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_admin_forward_proto protoreflect.FileDescriptor
View Source
var File_admin_proto protoreflect.FileDescriptor
View Source
var File_distribution_proto protoreflect.FileDescriptor
View Source
var File_dynamodb_internal_proto protoreflect.FileDescriptor
View Source
var File_encryption_admin_proto protoreflect.FileDescriptor
View Source
var File_etcd_raft_proto protoreflect.FileDescriptor
View Source
var File_internal_proto protoreflect.FileDescriptor
View Source
var File_redis_internal_proto protoreflect.FileDescriptor
View Source
var File_service_proto protoreflect.FileDescriptor
View Source
var Internal_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Internal",
	HandlerType: (*InternalServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Forward",
			Handler:    _Internal_Forward_Handler,
		},
		{
			MethodName: "ForwardAdminProposal",
			Handler:    _Internal_ForwardAdminProposal_Handler,
		},
		{
			MethodName: "ForwardLeaseRead",
			Handler:    _Internal_ForwardLeaseRead_Handler,
		},
		{
			MethodName: "RelayPublish",
			Handler:    _Internal_RelayPublish_Handler,
		},
		{
			MethodName: "ImportRangeVersions",
			Handler:    _Internal_ImportRangeVersions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExportRangeVersions",
			Handler:       _Internal_ExportRangeVersions_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal.proto",
}

Internal_ServiceDesc is the grpc.ServiceDesc for Internal service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var RaftAdmin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "RaftAdmin",
	HandlerType: (*RaftAdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Status",
			Handler:    _RaftAdmin_Status_Handler,
		},
		{
			MethodName: "Configuration",
			Handler:    _RaftAdmin_Configuration_Handler,
		},
		{
			MethodName: "AddVoter",
			Handler:    _RaftAdmin_AddVoter_Handler,
		},
		{
			MethodName: "AddLearner",
			Handler:    _RaftAdmin_AddLearner_Handler,
		},
		{
			MethodName: "PromoteLearner",
			Handler:    _RaftAdmin_PromoteLearner_Handler,
		},
		{
			MethodName: "RemoveServer",
			Handler:    _RaftAdmin_RemoveServer_Handler,
		},
		{
			MethodName: "TransferLeadership",
			Handler:    _RaftAdmin_TransferLeadership_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

RaftAdmin_ServiceDesc is the grpc.ServiceDesc for RaftAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var RawKV_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "RawKV",
	HandlerType: (*RawKVServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RawPut",
			Handler:    _RawKV_RawPut_Handler,
		},
		{
			MethodName: "RawGet",
			Handler:    _RawKV_RawGet_Handler,
		},
		{
			MethodName: "RawDelete",
			Handler:    _RawKV_RawDelete_Handler,
		},
		{
			MethodName: "RawLatestCommitTS",
			Handler:    _RawKV_RawLatestCommitTS_Handler,
		},
		{
			MethodName: "RawScanAt",
			Handler:    _RawKV_RawScanAt_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

RawKV_ServiceDesc is the grpc.ServiceDesc for RawKV service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var S3BlobFetch_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "S3BlobFetch",
	HandlerType: (*S3BlobFetchServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FetchChunkBlob",
			Handler:       _S3BlobFetch_FetchChunkBlob_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "PushChunkBlob",
			Handler:       _S3BlobFetch_PushChunkBlob_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "service.proto",
}

S3BlobFetch_ServiceDesc is the grpc.ServiceDesc for S3BlobFetch service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var TransactionalKV_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "TransactionalKV",
	HandlerType: (*TransactionalKVServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _TransactionalKV_Put_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _TransactionalKV_Get_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _TransactionalKV_Delete_Handler,
		},
		{
			MethodName: "Scan",
			Handler:    _TransactionalKV_Scan_Handler,
		},
		{
			MethodName: "PreWrite",
			Handler:    _TransactionalKV_PreWrite_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _TransactionalKV_Commit_Handler,
		},
		{
			MethodName: "Rollback",
			Handler:    _TransactionalKV_Rollback_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

TransactionalKV_ServiceDesc is the grpc.ServiceDesc for TransactionalKV service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAdminForwardServer

func RegisterAdminForwardServer(s grpc.ServiceRegistrar, srv AdminForwardServer)

func RegisterAdminServer

func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

func RegisterDistributionServer

func RegisterDistributionServer(s grpc.ServiceRegistrar, srv DistributionServer)

func RegisterEncryptionAdminServer

func RegisterEncryptionAdminServer(s grpc.ServiceRegistrar, srv EncryptionAdminServer)

func RegisterEtcdRaftServer

func RegisterEtcdRaftServer(s grpc.ServiceRegistrar, srv EtcdRaftServer)

func RegisterInternalServer

func RegisterInternalServer(s grpc.ServiceRegistrar, srv InternalServer)

func RegisterRaftAdminServer

func RegisterRaftAdminServer(s grpc.ServiceRegistrar, srv RaftAdminServer)

func RegisterRawKVServer

func RegisterRawKVServer(s grpc.ServiceRegistrar, srv RawKVServer)

func RegisterS3BlobFetchServer

func RegisterS3BlobFetchServer(s grpc.ServiceRegistrar, srv S3BlobFetchServer)

func RegisterTransactionalKVServer

func RegisterTransactionalKVServer(s grpc.ServiceRegistrar, srv TransactionalKVServer)

Types

type AbandonSplitJobRequest

type AbandonSplitJobRequest struct {
	JobId uint64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AbandonSplitJobRequest) Descriptor deprecated

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

Deprecated: Use AbandonSplitJobRequest.ProtoReflect.Descriptor instead.

func (*AbandonSplitJobRequest) GetJobId

func (x *AbandonSplitJobRequest) GetJobId() uint64

func (*AbandonSplitJobRequest) ProtoMessage

func (*AbandonSplitJobRequest) ProtoMessage()

func (*AbandonSplitJobRequest) ProtoReflect

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

func (*AbandonSplitJobRequest) Reset

func (x *AbandonSplitJobRequest) Reset()

func (*AbandonSplitJobRequest) String

func (x *AbandonSplitJobRequest) String() string

type AbandonSplitJobResponse

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

func (*AbandonSplitJobResponse) Descriptor deprecated

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

Deprecated: Use AbandonSplitJobResponse.ProtoReflect.Descriptor instead.

func (*AbandonSplitJobResponse) ProtoMessage

func (*AbandonSplitJobResponse) ProtoMessage()

func (*AbandonSplitJobResponse) ProtoReflect

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

func (*AbandonSplitJobResponse) Reset

func (x *AbandonSplitJobResponse) Reset()

func (*AbandonSplitJobResponse) String

func (x *AbandonSplitJobResponse) String() string

type AdapterSummary

type AdapterSummary struct {
	Adapter   string  `protobuf:"bytes,1,opt,name=adapter,proto3" json:"adapter,omitempty"`
	Operation string  `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	Requests  uint64  `protobuf:"varint,3,opt,name=requests,proto3" json:"requests,omitempty"`
	InFlight  uint64  `protobuf:"varint,4,opt,name=in_flight,json=inFlight,proto3" json:"in_flight,omitempty"`
	BytesIn   uint64  `protobuf:"varint,5,opt,name=bytes_in,json=bytesIn,proto3" json:"bytes_in,omitempty"`
	BytesOut  uint64  `protobuf:"varint,6,opt,name=bytes_out,json=bytesOut,proto3" json:"bytes_out,omitempty"`
	P50Ns     float64 `protobuf:"fixed64,7,opt,name=p50_ns,json=p50Ns,proto3" json:"p50_ns,omitempty"`
	P95Ns     float64 `protobuf:"fixed64,8,opt,name=p95_ns,json=p95Ns,proto3" json:"p95_ns,omitempty"`
	P99Ns     float64 `protobuf:"fixed64,9,opt,name=p99_ns,json=p99Ns,proto3" json:"p99_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*AdapterSummary) Descriptor deprecated

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

Deprecated: Use AdapterSummary.ProtoReflect.Descriptor instead.

func (*AdapterSummary) GetAdapter

func (x *AdapterSummary) GetAdapter() string

func (*AdapterSummary) GetBytesIn

func (x *AdapterSummary) GetBytesIn() uint64

func (*AdapterSummary) GetBytesOut

func (x *AdapterSummary) GetBytesOut() uint64

func (*AdapterSummary) GetInFlight

func (x *AdapterSummary) GetInFlight() uint64

func (*AdapterSummary) GetOperation

func (x *AdapterSummary) GetOperation() string

func (*AdapterSummary) GetP50Ns

func (x *AdapterSummary) GetP50Ns() float64

func (*AdapterSummary) GetP95Ns

func (x *AdapterSummary) GetP95Ns() float64

func (*AdapterSummary) GetP99Ns

func (x *AdapterSummary) GetP99Ns() float64

func (*AdapterSummary) GetRequests

func (x *AdapterSummary) GetRequests() uint64

func (*AdapterSummary) ProtoMessage

func (*AdapterSummary) ProtoMessage()

func (*AdapterSummary) ProtoReflect

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

func (*AdapterSummary) Reset

func (x *AdapterSummary) Reset()

func (*AdapterSummary) String

func (x *AdapterSummary) String() string

type AdminClient

type AdminClient interface {
	GetClusterOverview(ctx context.Context, in *GetClusterOverviewRequest, opts ...grpc.CallOption) (*GetClusterOverviewResponse, error)
	GetRaftGroups(ctx context.Context, in *GetRaftGroupsRequest, opts ...grpc.CallOption) (*GetRaftGroupsResponse, error)
	GetAdapterSummary(ctx context.Context, in *GetAdapterSummaryRequest, opts ...grpc.CallOption) (*GetAdapterSummaryResponse, error)
	GetKeyVizMatrix(ctx context.Context, in *GetKeyVizMatrixRequest, opts ...grpc.CallOption) (*GetKeyVizMatrixResponse, error)
	GetRouteDetail(ctx context.Context, in *GetRouteDetailRequest, opts ...grpc.CallOption) (*GetRouteDetailResponse, error)
	SetAutoSplitEnabled(ctx context.Context, in *SetAutoSplitEnabledRequest, opts ...grpc.CallOption) (*SetAutoSplitEnabledResponse, error)
	BeginBackup(ctx context.Context, in *BeginBackupRequest, opts ...grpc.CallOption) (*BeginBackupResponse, error)
	RenewBackup(ctx context.Context, in *RenewBackupRequest, opts ...grpc.CallOption) (*RenewBackupResponse, error)
	EndBackup(ctx context.Context, in *EndBackupRequest, opts ...grpc.CallOption) (*EndBackupResponse, error)
	ListAdaptersAndScopes(ctx context.Context, in *ListAdaptersAndScopesRequest, opts ...grpc.CallOption) (*ListAdaptersAndScopesResponse, error)
	StreamBackup(ctx context.Context, in *StreamBackupRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[BackupKV], error)
	GetNodeVersion(ctx context.Context, in *GetNodeVersionRequest, opts ...grpc.CallOption) (*GetNodeVersionResponse, error)
	StreamEvents(ctx context.Context, in *StreamEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamEventsEvent], error)
}

AdminClient is the client API for Admin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Admin is the node-side operator gRPC service consumed by cmd/elastickv-admin. Every method requires "authorization: Bearer <token>" metadata unless the node was started with --adminInsecureNoAuth. See docs/admin_ui_key_visualizer_design.md §4 (Layer A).

func NewAdminClient

func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

type AdminForwardClient

type AdminForwardClient interface {
	// Forward dispatches an admin write operation on the leader's
	// behalf. Returns a structured response carrying the same JSON
	// payload the leader's handler would have written to the wire.
	Forward(ctx context.Context, in *AdminForwardRequest, opts ...grpc.CallOption) (*AdminForwardResponse, error)
}

AdminForwardClient is the client API for AdminForward service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

AdminForward is the SigV4-bypass RPC the admin dashboard uses to reach the Raft leader from a follower. Design Section 3.3.

The admin's HTTP layer authenticates the caller with a JWT cookie, resolves an access-key + role principal, and — if the local node is not the verified Raft leader — calls Forward over this RPC.

The leader does NOT trust the inbound principal: it re-evaluates access-key membership and role against its own access-key configuration before dispatching to the adapter (Section 3.3.1 "principal-aware internal RPC"). A follower whose configuration is mid-rolling-update can therefore not bypass the leader's view of authorisation.

AdminForward is intentionally separate from the existing `Internal.Forward` RPC, which carries SigV4 traffic and has no principal field — sharing the same RPC would force the admin path to either smuggle a principal through reserved fields or strip the SigV4-only assumptions out of the existing Forward server.

type AdminForwardRequest

type AdminForwardRequest struct {
	Principal *AdminPrincipal `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Operation AdminOperation  `protobuf:"varint,2,opt,name=operation,proto3,enum=AdminOperation" json:"operation,omitempty"`
	// payload is the JSON-encoded operation-specific request body —
	// the same bytes the SPA sent to the follower's HTTP endpoint.
	// The leader decodes this with the operation's known schema.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// forwarded_from is the follower's node id; the leader echoes it
	// into the audit log line for the operation so operators can
	// trace which follower carried the request (design Section 3.3.2
	// acceptance criteria 6).
	ForwardedFrom string `protobuf:"bytes,4,opt,name=forwarded_from,json=forwardedFrom,proto3" json:"forwarded_from,omitempty"`
	// contains filtered or unexported fields
}

func (*AdminForwardRequest) Descriptor deprecated

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

Deprecated: Use AdminForwardRequest.ProtoReflect.Descriptor instead.

func (*AdminForwardRequest) GetForwardedFrom

func (x *AdminForwardRequest) GetForwardedFrom() string

func (*AdminForwardRequest) GetOperation

func (x *AdminForwardRequest) GetOperation() AdminOperation

func (*AdminForwardRequest) GetPayload

func (x *AdminForwardRequest) GetPayload() []byte

func (*AdminForwardRequest) GetPrincipal

func (x *AdminForwardRequest) GetPrincipal() *AdminPrincipal

func (*AdminForwardRequest) ProtoMessage

func (*AdminForwardRequest) ProtoMessage()

func (*AdminForwardRequest) ProtoReflect

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

func (*AdminForwardRequest) Reset

func (x *AdminForwardRequest) Reset()

func (*AdminForwardRequest) String

func (x *AdminForwardRequest) String() string

type AdminForwardResponse

type AdminForwardResponse struct {

	// status_code is the HTTP status the leader's handler would have
	// written. The follower returns this verbatim to the SPA so the
	// failure semantics (404 vs 409 vs 400) match a leader-direct
	// call exactly.
	StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// payload is the JSON-encoded response body. Empty when
	// status_code is 204 No Content (DELETE success).
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// content_type is the response content type the leader chose; in
	// practice always "application/json; charset=utf-8" but echoed
	// explicitly so the follower does not have to guess.
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// retry_after_seconds carries a Retry-After hint the follower's
	// bridge translates back into an HTTP Retry-After header. The
	// direct HTTP path sets Retry-After: 1 on 503 leader_unavailable
	// (mid-dispatch leadership churn); without this field the same
	// response shape would lose its retry timing once forwarded —
	// clients would see 503 with no Retry-After and fall back to
	// their default backoff. Codex P2 on PR #635 flagged the gap.
	// Zero means "no Retry-After header"; the field is only meaningful
	// for status codes that traditionally carry one (typically 503).
	RetryAfterSeconds int32 `protobuf:"varint,4,opt,name=retry_after_seconds,json=retryAfterSeconds,proto3" json:"retry_after_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*AdminForwardResponse) Descriptor deprecated

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

Deprecated: Use AdminForwardResponse.ProtoReflect.Descriptor instead.

func (*AdminForwardResponse) GetContentType

func (x *AdminForwardResponse) GetContentType() string

func (*AdminForwardResponse) GetPayload

func (x *AdminForwardResponse) GetPayload() []byte

func (*AdminForwardResponse) GetRetryAfterSeconds

func (x *AdminForwardResponse) GetRetryAfterSeconds() int32

func (*AdminForwardResponse) GetStatusCode

func (x *AdminForwardResponse) GetStatusCode() int32

func (*AdminForwardResponse) ProtoMessage

func (*AdminForwardResponse) ProtoMessage()

func (*AdminForwardResponse) ProtoReflect

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

func (*AdminForwardResponse) Reset

func (x *AdminForwardResponse) Reset()

func (*AdminForwardResponse) String

func (x *AdminForwardResponse) String() string

type AdminForwardServer

type AdminForwardServer interface {
	// Forward dispatches an admin write operation on the leader's
	// behalf. Returns a structured response carrying the same JSON
	// payload the leader's handler would have written to the wire.
	Forward(context.Context, *AdminForwardRequest) (*AdminForwardResponse, error)
	// contains filtered or unexported methods
}

AdminForwardServer is the server API for AdminForward service. All implementations must embed UnimplementedAdminForwardServer for forward compatibility.

AdminForward is the SigV4-bypass RPC the admin dashboard uses to reach the Raft leader from a follower. Design Section 3.3.

The admin's HTTP layer authenticates the caller with a JWT cookie, resolves an access-key + role principal, and — if the local node is not the verified Raft leader — calls Forward over this RPC.

The leader does NOT trust the inbound principal: it re-evaluates access-key membership and role against its own access-key configuration before dispatching to the adapter (Section 3.3.1 "principal-aware internal RPC"). A follower whose configuration is mid-rolling-update can therefore not bypass the leader's view of authorisation.

AdminForward is intentionally separate from the existing `Internal.Forward` RPC, which carries SigV4 traffic and has no principal field — sharing the same RPC would force the admin path to either smuggle a principal through reserved fields or strip the SigV4-only assumptions out of the existing Forward server.

type AdminOperation

type AdminOperation int32

AdminOperation enumerates the operations the dashboard can issue. Adding a new operation requires both ends of the cluster to understand it; mismatches are caught by the version compatibility flag (`admin.leader_forward_v2`) before the call goes out.

const (
	AdminOperation_ADMIN_OP_UNSPECIFIED  AdminOperation = 0
	AdminOperation_ADMIN_OP_CREATE_TABLE AdminOperation = 1
	AdminOperation_ADMIN_OP_DELETE_TABLE AdminOperation = 2
	// S3 bucket admin operations (P2 slice 2b). New values appended
	// after the Dynamo block so the wire-format integers for the
	// existing operations stay stable.
	AdminOperation_ADMIN_OP_CREATE_BUCKET  AdminOperation = 3
	AdminOperation_ADMIN_OP_DELETE_BUCKET  AdminOperation = 4
	AdminOperation_ADMIN_OP_PUT_BUCKET_ACL AdminOperation = 5
)

func (AdminOperation) Descriptor

func (AdminOperation) Enum

func (x AdminOperation) Enum() *AdminOperation

func (AdminOperation) EnumDescriptor deprecated

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

Deprecated: Use AdminOperation.Descriptor instead.

func (AdminOperation) Number

func (AdminOperation) String

func (x AdminOperation) String() string

func (AdminOperation) Type

type AdminPrincipal

type AdminPrincipal struct {
	AccessKey string `protobuf:"bytes,1,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	Role      string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"` // "read_only" | "full"
	// contains filtered or unexported fields
}

AdminPrincipal captures the access-key + role the follower resolved from the inbound JWT. The leader re-validates this against its own access-key map before acting on it; the follower could be operating with a stale role assignment.

func (*AdminPrincipal) Descriptor deprecated

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

Deprecated: Use AdminPrincipal.ProtoReflect.Descriptor instead.

func (*AdminPrincipal) GetAccessKey

func (x *AdminPrincipal) GetAccessKey() string

func (*AdminPrincipal) GetRole

func (x *AdminPrincipal) GetRole() string

func (*AdminPrincipal) ProtoMessage

func (*AdminPrincipal) ProtoMessage()

func (*AdminPrincipal) ProtoReflect

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

func (*AdminPrincipal) Reset

func (x *AdminPrincipal) Reset()

func (*AdminPrincipal) String

func (x *AdminPrincipal) String() string

type AdminServer

AdminServer is the server API for Admin service. All implementations must embed UnimplementedAdminServer for forward compatibility.

Admin is the node-side operator gRPC service consumed by cmd/elastickv-admin. Every method requires "authorization: Bearer <token>" metadata unless the node was started with --adminInsecureNoAuth. See docs/admin_ui_key_visualizer_design.md §4 (Layer A).

type Admin_StreamBackupClient

type Admin_StreamBackupClient = grpc.ServerStreamingClient[BackupKV]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Admin_StreamBackupServer

type Admin_StreamBackupServer = grpc.ServerStreamingServer[BackupKV]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Admin_StreamEventsClient

type Admin_StreamEventsClient = grpc.ServerStreamingClient[StreamEventsEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Admin_StreamEventsServer

type Admin_StreamEventsServer = grpc.ServerStreamingServer[StreamEventsEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type BackupExpectedKeys

type BackupExpectedKeys struct {
	Adapter             string `protobuf:"bytes,1,opt,name=adapter,proto3" json:"adapter,omitempty"`
	Scope               string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	KeyCount            uint64 `protobuf:"varint,3,opt,name=key_count,json=keyCount,proto3" json:"key_count,omitempty"`
	AppliedIndexAtCount uint64 `protobuf:"varint,4,opt,name=applied_index_at_count,json=appliedIndexAtCount,proto3" json:"applied_index_at_count,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupExpectedKeys) Descriptor deprecated

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

Deprecated: Use BackupExpectedKeys.ProtoReflect.Descriptor instead.

func (*BackupExpectedKeys) GetAdapter

func (x *BackupExpectedKeys) GetAdapter() string

func (*BackupExpectedKeys) GetAppliedIndexAtCount

func (x *BackupExpectedKeys) GetAppliedIndexAtCount() uint64

func (*BackupExpectedKeys) GetKeyCount

func (x *BackupExpectedKeys) GetKeyCount() uint64

func (*BackupExpectedKeys) GetScope

func (x *BackupExpectedKeys) GetScope() string

func (*BackupExpectedKeys) ProtoMessage

func (*BackupExpectedKeys) ProtoMessage()

func (*BackupExpectedKeys) ProtoReflect

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

func (*BackupExpectedKeys) Reset

func (x *BackupExpectedKeys) Reset()

func (*BackupExpectedKeys) String

func (x *BackupExpectedKeys) String() string

type BackupKV

type BackupKV struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupKV) Descriptor deprecated

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

Deprecated: Use BackupKV.ProtoReflect.Descriptor instead.

func (*BackupKV) GetKey

func (x *BackupKV) GetKey() []byte

func (*BackupKV) GetValue

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

func (*BackupKV) ProtoMessage

func (*BackupKV) ProtoMessage()

func (*BackupKV) ProtoReflect

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

func (*BackupKV) Reset

func (x *BackupKV) Reset()

func (*BackupKV) String

func (x *BackupKV) String() string

type BackupScope

type BackupScope struct {
	Adapter string `protobuf:"bytes,1,opt,name=adapter,proto3" json:"adapter,omitempty"`
	Scope   string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupScope) Descriptor deprecated

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

Deprecated: Use BackupScope.ProtoReflect.Descriptor instead.

func (*BackupScope) GetAdapter

func (x *BackupScope) GetAdapter() string

func (*BackupScope) GetScope

func (x *BackupScope) GetScope() string

func (*BackupScope) ProtoMessage

func (*BackupScope) ProtoMessage()

func (*BackupScope) ProtoReflect

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

func (*BackupScope) Reset

func (x *BackupScope) Reset()

func (*BackupScope) String

func (x *BackupScope) String() string

type BackupShardApplied

type BackupShardApplied struct {
	RaftGroupId  uint64 `protobuf:"varint,1,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	AppliedIndex uint64 `protobuf:"varint,2,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupShardApplied) Descriptor deprecated

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

Deprecated: Use BackupShardApplied.ProtoReflect.Descriptor instead.

func (*BackupShardApplied) GetAppliedIndex

func (x *BackupShardApplied) GetAppliedIndex() uint64

func (*BackupShardApplied) GetRaftGroupId

func (x *BackupShardApplied) GetRaftGroupId() uint64

func (*BackupShardApplied) ProtoMessage

func (*BackupShardApplied) ProtoMessage()

func (*BackupShardApplied) ProtoReflect

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

func (*BackupShardApplied) Reset

func (x *BackupShardApplied) Reset()

func (*BackupShardApplied) String

func (x *BackupShardApplied) String() string

type BeginBackupRequest

type BeginBackupRequest struct {
	TtlMs uint64 `protobuf:"varint,1,opt,name=ttl_ms,json=ttlMs,proto3" json:"ttl_ms,omitempty"`
	// Empty means all adapters. Non-empty lets the server build the
	// expected-key baseline only for adapters the producer will emit.
	Adapters []string `protobuf:"bytes,2,rep,name=adapters,proto3" json:"adapters,omitempty"`
	// Empty means every scope in the selected adapters. Non-empty narrows the
	// expected-key baseline to the exact adapter/scope pairs requested by the
	// producer.
	Scopes []*BackupScope `protobuf:"bytes,3,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginBackupRequest) Descriptor deprecated

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

Deprecated: Use BeginBackupRequest.ProtoReflect.Descriptor instead.

func (*BeginBackupRequest) GetAdapters

func (x *BeginBackupRequest) GetAdapters() []string

func (*BeginBackupRequest) GetScopes

func (x *BeginBackupRequest) GetScopes() []*BackupScope

func (*BeginBackupRequest) GetTtlMs

func (x *BeginBackupRequest) GetTtlMs() uint64

func (*BeginBackupRequest) ProtoMessage

func (*BeginBackupRequest) ProtoMessage()

func (*BeginBackupRequest) ProtoReflect

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

func (*BeginBackupRequest) Reset

func (x *BeginBackupRequest) Reset()

func (*BeginBackupRequest) String

func (x *BeginBackupRequest) String() string

type BeginBackupResponse

type BeginBackupResponse struct {
	ReadTs              uint64                `protobuf:"varint,1,opt,name=read_ts,json=readTs,proto3" json:"read_ts,omitempty"`
	PinToken            []byte                `protobuf:"bytes,2,opt,name=pin_token,json=pinToken,proto3" json:"pin_token,omitempty"`
	TtlMsEffective      uint64                `protobuf:"varint,3,opt,name=ttl_ms_effective,json=ttlMsEffective,proto3" json:"ttl_ms_effective,omitempty"`
	Shards              []*BackupShardApplied `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"`
	ExpectedKeys        []*BackupExpectedKeys `protobuf:"bytes,5,rep,name=expected_keys,json=expectedKeys,proto3" json:"expected_keys,omitempty"`
	MaxActiveBackupPins uint32                `protobuf:"varint,6,opt,name=max_active_backup_pins,json=maxActiveBackupPins,proto3" json:"max_active_backup_pins,omitempty"`
	// backup_protocol_version echoes the serving node's capability level so a
	// producer can tell whether its adapters/scopes filter was honored. A v1
	// server leaves this unset, which is how the client detects that its scoped
	// request was silently ignored instead of accepting a broader baseline.
	BackupProtocolVersion uint32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BeginBackupResponse) Descriptor deprecated

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

Deprecated: Use BeginBackupResponse.ProtoReflect.Descriptor instead.

func (*BeginBackupResponse) GetBackupProtocolVersion

func (x *BeginBackupResponse) GetBackupProtocolVersion() uint32

func (*BeginBackupResponse) GetExpectedKeys

func (x *BeginBackupResponse) GetExpectedKeys() []*BackupExpectedKeys

func (*BeginBackupResponse) GetMaxActiveBackupPins

func (x *BeginBackupResponse) GetMaxActiveBackupPins() uint32

func (*BeginBackupResponse) GetPinToken

func (x *BeginBackupResponse) GetPinToken() []byte

func (*BeginBackupResponse) GetReadTs

func (x *BeginBackupResponse) GetReadTs() uint64

func (*BeginBackupResponse) GetShards

func (x *BeginBackupResponse) GetShards() []*BackupShardApplied

func (*BeginBackupResponse) GetTtlMsEffective

func (x *BeginBackupResponse) GetTtlMsEffective() uint64

func (*BeginBackupResponse) ProtoMessage

func (*BeginBackupResponse) ProtoMessage()

func (*BeginBackupResponse) ProtoReflect

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

func (*BeginBackupResponse) Reset

func (x *BeginBackupResponse) Reset()

func (*BeginBackupResponse) String

func (x *BeginBackupResponse) String() string

type BootstrapEncryptionRequest

type BootstrapEncryptionRequest struct {
	WrappedStorageDek []byte                 `protobuf:"bytes,1,opt,name=wrapped_storage_dek,json=wrappedStorageDek,proto3" json:"wrapped_storage_dek,omitempty"`
	WrappedRaftDek    []byte                 `protobuf:"bytes,2,opt,name=wrapped_raft_dek,json=wrappedRaftDek,proto3" json:"wrapped_raft_dek,omitempty"`
	StorageDekId      uint32                 `protobuf:"varint,3,opt,name=storage_dek_id,json=storageDekId,proto3" json:"storage_dek_id,omitempty"`
	RaftDekId         uint32                 `protobuf:"varint,4,opt,name=raft_dek_id,json=raftDekId,proto3" json:"raft_dek_id,omitempty"`
	WriterBatch       []*WriterRegistryEntry `protobuf:"bytes,5,rep,name=writer_batch,json=writerBatch,proto3" json:"writer_batch,omitempty"`
	// contains filtered or unexported fields
}

BootstrapEncryptionRequest carries the freshly-generated wrapped DEKs and the writer-registry batch the leader gathered from every member's GetCapability response. The server validates each local_epoch is in range before composing the §11.3 0x04 OpBootstrap body.

func (*BootstrapEncryptionRequest) Descriptor deprecated

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

Deprecated: Use BootstrapEncryptionRequest.ProtoReflect.Descriptor instead.

func (*BootstrapEncryptionRequest) GetRaftDekId

func (x *BootstrapEncryptionRequest) GetRaftDekId() uint32

func (*BootstrapEncryptionRequest) GetStorageDekId

func (x *BootstrapEncryptionRequest) GetStorageDekId() uint32

func (*BootstrapEncryptionRequest) GetWrappedRaftDek

func (x *BootstrapEncryptionRequest) GetWrappedRaftDek() []byte

func (*BootstrapEncryptionRequest) GetWrappedStorageDek

func (x *BootstrapEncryptionRequest) GetWrappedStorageDek() []byte

func (*BootstrapEncryptionRequest) GetWriterBatch

func (x *BootstrapEncryptionRequest) GetWriterBatch() []*WriterRegistryEntry

func (*BootstrapEncryptionRequest) ProtoMessage

func (*BootstrapEncryptionRequest) ProtoMessage()

func (*BootstrapEncryptionRequest) ProtoReflect

func (*BootstrapEncryptionRequest) Reset

func (x *BootstrapEncryptionRequest) Reset()

func (*BootstrapEncryptionRequest) String

func (x *BootstrapEncryptionRequest) String() string

type BootstrapEncryptionResponse

type BootstrapEncryptionResponse struct {
	AppliedIndex uint64 `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	// contains filtered or unexported fields
}

func (*BootstrapEncryptionResponse) Descriptor deprecated

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

Deprecated: Use BootstrapEncryptionResponse.ProtoReflect.Descriptor instead.

func (*BootstrapEncryptionResponse) GetAppliedIndex

func (x *BootstrapEncryptionResponse) GetAppliedIndex() uint64

func (*BootstrapEncryptionResponse) ProtoMessage

func (*BootstrapEncryptionResponse) ProtoMessage()

func (*BootstrapEncryptionResponse) ProtoReflect

func (*BootstrapEncryptionResponse) Reset

func (x *BootstrapEncryptionResponse) Reset()

func (*BootstrapEncryptionResponse) String

func (x *BootstrapEncryptionResponse) String() string

type CapabilityReport

type CapabilityReport struct {
	EncryptionCapable bool   `protobuf:"varint,1,opt,name=encryption_capable,json=encryptionCapable,proto3" json:"encryption_capable,omitempty"`
	BuildSha          string `protobuf:"bytes,2,opt,name=build_sha,json=buildSha,proto3" json:"build_sha,omitempty"`
	SidecarPresent    bool   `protobuf:"varint,3,opt,name=sidecar_present,json=sidecarPresent,proto3" json:"sidecar_present,omitempty"`
	FullNodeId        uint64 `protobuf:"varint,4,opt,name=full_node_id,json=fullNodeId,proto3" json:"full_node_id,omitempty"`
	LocalEpoch        uint32 `protobuf:"varint,5,opt,name=local_epoch,json=localEpoch,proto3" json:"local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// Old binaries omit this field and therefore decode as false. Writers must
	// keep emitting V1 envelopes until every voter and learner reports true.
	StorageEnvelopeV2Capable bool `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

CapabilityReport mirrors §6.1 admin.go's CapabilityReport. Served on every node regardless of leadership state. A node that has never run with --encryption-enabled returns encryption_capable=false with local_epoch=0 and full_node_id=0, and the cutover command refuses with ErrCapabilityCheckFailed so the empty epoch never reaches the writer registry.

func (*CapabilityReport) Descriptor deprecated

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

Deprecated: Use CapabilityReport.ProtoReflect.Descriptor instead.

func (*CapabilityReport) GetBuildSha

func (x *CapabilityReport) GetBuildSha() string

func (*CapabilityReport) GetEncryptionCapable

func (x *CapabilityReport) GetEncryptionCapable() bool

func (*CapabilityReport) GetFullNodeId

func (x *CapabilityReport) GetFullNodeId() uint64

func (*CapabilityReport) GetLocalEpoch

func (x *CapabilityReport) GetLocalEpoch() uint32

func (*CapabilityReport) GetSidecarPresent

func (x *CapabilityReport) GetSidecarPresent() bool

func (*CapabilityReport) GetStorageEnvelopeV2Capable

func (x *CapabilityReport) GetStorageEnvelopeV2Capable() bool

func (*CapabilityReport) ProtoMessage

func (*CapabilityReport) ProtoMessage()

func (*CapabilityReport) ProtoReflect

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

func (*CapabilityReport) Reset

func (x *CapabilityReport) Reset()

func (*CapabilityReport) String

func (x *CapabilityReport) String() string

type CapabilityVerdict

type CapabilityVerdict struct {
	FullNodeId        uint64 `protobuf:"varint,1,opt,name=full_node_id,json=fullNodeId,proto3" json:"full_node_id,omitempty"`
	EncryptionCapable bool   `protobuf:"varint,2,opt,name=encryption_capable,json=encryptionCapable,proto3" json:"encryption_capable,omitempty"`
	BuildSha          string `protobuf:"bytes,3,opt,name=build_sha,json=buildSha,proto3" json:"build_sha,omitempty"`
	SidecarPresent    bool   `protobuf:"varint,4,opt,name=sidecar_present,json=sidecarPresent,proto3" json:"sidecar_present,omitempty"`
	// contains filtered or unexported fields
}

CapabilityVerdict is one row of the §4 fan-out summary the cutover RPC returns. full_node_id is the route member the leader probed; the remaining fields mirror the corresponding member's CapabilityReport. A cluster where any verdict has encryption_capable=false MUST NOT reach the propose step; the summary in the response is the post-hoc record for operators.

func (*CapabilityVerdict) Descriptor deprecated

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

Deprecated: Use CapabilityVerdict.ProtoReflect.Descriptor instead.

func (*CapabilityVerdict) GetBuildSha

func (x *CapabilityVerdict) GetBuildSha() string

func (*CapabilityVerdict) GetEncryptionCapable

func (x *CapabilityVerdict) GetEncryptionCapable() bool

func (*CapabilityVerdict) GetFullNodeId

func (x *CapabilityVerdict) GetFullNodeId() uint64

func (*CapabilityVerdict) GetSidecarPresent

func (x *CapabilityVerdict) GetSidecarPresent() bool

func (*CapabilityVerdict) ProtoMessage

func (*CapabilityVerdict) ProtoMessage()

func (*CapabilityVerdict) ProtoReflect

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

func (*CapabilityVerdict) Reset

func (x *CapabilityVerdict) Reset()

func (*CapabilityVerdict) String

func (x *CapabilityVerdict) String() string

type CatalogCapabilitiesRequest

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

func (*CatalogCapabilitiesRequest) Descriptor deprecated

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

Deprecated: Use CatalogCapabilitiesRequest.ProtoReflect.Descriptor instead.

func (*CatalogCapabilitiesRequest) ProtoMessage

func (*CatalogCapabilitiesRequest) ProtoMessage()

func (*CatalogCapabilitiesRequest) ProtoReflect

func (*CatalogCapabilitiesRequest) Reset

func (x *CatalogCapabilitiesRequest) Reset()

func (*CatalogCapabilitiesRequest) String

func (x *CatalogCapabilitiesRequest) String() string

type CatalogCapabilitiesResponse

type CatalogCapabilitiesResponse struct {
	SupportedProtocolVersions []uint32 `` /* 146-byte string literal not displayed */
	CurrentVersion            uint64   `protobuf:"varint,2,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	OldestDeltaVersion        uint64   `protobuf:"varint,3,opt,name=oldest_delta_version,json=oldestDeltaVersion,proto3" json:"oldest_delta_version,omitempty"`
	MaxBatchSize              uint32   `protobuf:"varint,4,opt,name=max_batch_size,json=maxBatchSize,proto3" json:"max_batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogCapabilitiesResponse) Descriptor deprecated

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

Deprecated: Use CatalogCapabilitiesResponse.ProtoReflect.Descriptor instead.

func (*CatalogCapabilitiesResponse) GetCurrentVersion

func (x *CatalogCapabilitiesResponse) GetCurrentVersion() uint64

func (*CatalogCapabilitiesResponse) GetMaxBatchSize

func (x *CatalogCapabilitiesResponse) GetMaxBatchSize() uint32

func (*CatalogCapabilitiesResponse) GetOldestDeltaVersion

func (x *CatalogCapabilitiesResponse) GetOldestDeltaVersion() uint64

func (*CatalogCapabilitiesResponse) GetSupportedProtocolVersions

func (x *CatalogCapabilitiesResponse) GetSupportedProtocolVersions() []uint32

func (*CatalogCapabilitiesResponse) ProtoMessage

func (*CatalogCapabilitiesResponse) ProtoMessage()

func (*CatalogCapabilitiesResponse) ProtoReflect

func (*CatalogCapabilitiesResponse) Reset

func (x *CatalogCapabilitiesResponse) Reset()

func (*CatalogCapabilitiesResponse) String

func (x *CatalogCapabilitiesResponse) String() string

type CatalogDeltaMutation

type CatalogDeltaMutation struct {
	Op      CatalogDeltaMutationOp `protobuf:"varint,1,opt,name=op,proto3,enum=CatalogDeltaMutationOp" json:"op,omitempty"`
	RouteId uint64                 `protobuf:"varint,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	Route   *RouteDescriptor       `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogDeltaMutation) Descriptor deprecated

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

Deprecated: Use CatalogDeltaMutation.ProtoReflect.Descriptor instead.

func (*CatalogDeltaMutation) GetOp

func (*CatalogDeltaMutation) GetRoute

func (x *CatalogDeltaMutation) GetRoute() *RouteDescriptor

func (*CatalogDeltaMutation) GetRouteId

func (x *CatalogDeltaMutation) GetRouteId() uint64

func (*CatalogDeltaMutation) ProtoMessage

func (*CatalogDeltaMutation) ProtoMessage()

func (*CatalogDeltaMutation) ProtoReflect

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

func (*CatalogDeltaMutation) Reset

func (x *CatalogDeltaMutation) Reset()

func (*CatalogDeltaMutation) String

func (x *CatalogDeltaMutation) String() string

type CatalogDeltaMutationOp

type CatalogDeltaMutationOp int32
const (
	CatalogDeltaMutationOp_CATALOG_DELTA_MUTATION_OP_UNSPECIFIED CatalogDeltaMutationOp = 0
	CatalogDeltaMutationOp_CATALOG_DELTA_MUTATION_OP_UPSERT      CatalogDeltaMutationOp = 1
	CatalogDeltaMutationOp_CATALOG_DELTA_MUTATION_OP_DELETE      CatalogDeltaMutationOp = 2
)

func (CatalogDeltaMutationOp) Descriptor

func (CatalogDeltaMutationOp) Enum

func (CatalogDeltaMutationOp) EnumDescriptor deprecated

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

Deprecated: Use CatalogDeltaMutationOp.Descriptor instead.

func (CatalogDeltaMutationOp) Number

func (CatalogDeltaMutationOp) String

func (x CatalogDeltaMutationOp) String() string

func (CatalogDeltaMutationOp) Type

type CatalogDeltaRecord

type CatalogDeltaRecord struct {
	PreviousVersion uint64                  `protobuf:"varint,1,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	Version         uint64                  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Mutations       []*CatalogDeltaMutation `protobuf:"bytes,3,rep,name=mutations,proto3" json:"mutations,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogDeltaRecord) Descriptor deprecated

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

Deprecated: Use CatalogDeltaRecord.ProtoReflect.Descriptor instead.

func (*CatalogDeltaRecord) GetMutations

func (x *CatalogDeltaRecord) GetMutations() []*CatalogDeltaMutation

func (*CatalogDeltaRecord) GetPreviousVersion

func (x *CatalogDeltaRecord) GetPreviousVersion() uint64

func (*CatalogDeltaRecord) GetVersion

func (x *CatalogDeltaRecord) GetVersion() uint64

func (*CatalogDeltaRecord) ProtoMessage

func (*CatalogDeltaRecord) ProtoMessage()

func (*CatalogDeltaRecord) ProtoReflect

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

func (*CatalogDeltaRecord) Reset

func (x *CatalogDeltaRecord) Reset()

func (*CatalogDeltaRecord) String

func (x *CatalogDeltaRecord) String() string

type CatalogSnapshotReset

type CatalogSnapshotReset struct {
	Version uint64             `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Routes  []*RouteDescriptor `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogSnapshotReset) Descriptor deprecated

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

Deprecated: Use CatalogSnapshotReset.ProtoReflect.Descriptor instead.

func (*CatalogSnapshotReset) GetRoutes

func (x *CatalogSnapshotReset) GetRoutes() []*RouteDescriptor

func (*CatalogSnapshotReset) GetVersion

func (x *CatalogSnapshotReset) GetVersion() uint64

func (*CatalogSnapshotReset) ProtoMessage

func (*CatalogSnapshotReset) ProtoMessage()

func (*CatalogSnapshotReset) ProtoReflect

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

func (*CatalogSnapshotReset) Reset

func (x *CatalogSnapshotReset) Reset()

func (*CatalogSnapshotReset) String

func (x *CatalogSnapshotReset) String() string

type CatalogWatchEvent

type CatalogWatchEvent struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*CatalogWatchEvent_Snapshot
	//	*CatalogWatchEvent_Delta
	Payload isCatalogWatchEvent_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*CatalogWatchEvent) Descriptor deprecated

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

Deprecated: Use CatalogWatchEvent.ProtoReflect.Descriptor instead.

func (*CatalogWatchEvent) GetDelta

func (x *CatalogWatchEvent) GetDelta() *CatalogDeltaRecord

func (*CatalogWatchEvent) GetPayload

func (x *CatalogWatchEvent) GetPayload() isCatalogWatchEvent_Payload

func (*CatalogWatchEvent) GetSnapshot

func (x *CatalogWatchEvent) GetSnapshot() *CatalogSnapshotReset

func (*CatalogWatchEvent) ProtoMessage

func (*CatalogWatchEvent) ProtoMessage()

func (*CatalogWatchEvent) ProtoReflect

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

func (*CatalogWatchEvent) Reset

func (x *CatalogWatchEvent) Reset()

func (*CatalogWatchEvent) String

func (x *CatalogWatchEvent) String() string

type CatalogWatchEvent_Delta

type CatalogWatchEvent_Delta struct {
	Delta *CatalogDeltaRecord `protobuf:"bytes,2,opt,name=delta,proto3,oneof"`
}

type CatalogWatchEvent_Snapshot

type CatalogWatchEvent_Snapshot struct {
	Snapshot *CatalogSnapshotReset `protobuf:"bytes,1,opt,name=snapshot,proto3,oneof"`
}

type CatalogWatchRequest

type CatalogWatchRequest struct {
	ProtocolVersion uint32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	AfterVersion    uint64 `protobuf:"varint,2,opt,name=after_version,json=afterVersion,proto3" json:"after_version,omitempty"`
	MaxBatchSize    uint32 `protobuf:"varint,3,opt,name=max_batch_size,json=maxBatchSize,proto3" json:"max_batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogWatchRequest) Descriptor deprecated

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

Deprecated: Use CatalogWatchRequest.ProtoReflect.Descriptor instead.

func (*CatalogWatchRequest) GetAfterVersion

func (x *CatalogWatchRequest) GetAfterVersion() uint64

func (*CatalogWatchRequest) GetMaxBatchSize

func (x *CatalogWatchRequest) GetMaxBatchSize() uint32

func (*CatalogWatchRequest) GetProtocolVersion

func (x *CatalogWatchRequest) GetProtocolVersion() uint32

func (*CatalogWatchRequest) ProtoMessage

func (*CatalogWatchRequest) ProtoMessage()

func (*CatalogWatchRequest) ProtoReflect

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

func (*CatalogWatchRequest) Reset

func (x *CatalogWatchRequest) Reset()

func (*CatalogWatchRequest) String

func (x *CatalogWatchRequest) String() string

type CommitRequest

type CommitRequest struct {

	// start_ts is the timestamp of prewrite request.
	StartTs uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Keys    [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitRequest) Descriptor deprecated

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

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetKeys

func (x *CommitRequest) GetKeys() [][]byte

func (*CommitRequest) GetStartTs

func (x *CommitRequest) GetStartTs() uint64

func (*CommitRequest) ProtoMessage

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect

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

func (*CommitRequest) Reset

func (x *CommitRequest) Reset()

func (*CommitRequest) String

func (x *CommitRequest) String() string

type CommitResponse

type CommitResponse struct {
	CommitIndex uint64      `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool        `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Errors      []*KeyError `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitResponse) Descriptor deprecated

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

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) GetCommitIndex

func (x *CommitResponse) GetCommitIndex() uint64

func (*CommitResponse) GetErrors

func (x *CommitResponse) GetErrors() []*KeyError

func (*CommitResponse) GetSuccess

func (x *CommitResponse) GetSuccess() bool

func (*CommitResponse) ProtoMessage

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect

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

func (*CommitResponse) Reset

func (x *CommitResponse) Reset()

func (*CommitResponse) String

func (x *CommitResponse) String() string

type DeleteRequest

type DeleteRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey

func (x *DeleteRequest) GetKey() []byte

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

type DeleteResponse

type DeleteResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetCommitIndex

func (x *DeleteResponse) GetCommitIndex() uint64

func (*DeleteResponse) GetSuccess

func (x *DeleteResponse) GetSuccess() bool

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect

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

func (*DeleteResponse) Reset

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String

func (x *DeleteResponse) String() string

type DistributionClient

type DistributionClient interface {
	GetRoute(ctx context.Context, in *GetRouteRequest, opts ...grpc.CallOption) (*GetRouteResponse, error)
	GetTimestamp(ctx context.Context, in *GetTimestampRequest, opts ...grpc.CallOption) (*GetTimestampResponse, error)
	ValidateTimestamp(ctx context.Context, in *ValidateTimestampRequest, opts ...grpc.CallOption) (*ValidateTimestampResponse, error)
	ListRoutes(ctx context.Context, in *ListRoutesRequest, opts ...grpc.CallOption) (*ListRoutesResponse, error)
	SplitRange(ctx context.Context, in *SplitRangeRequest, opts ...grpc.CallOption) (*SplitRangeResponse, error)
	GetCatalogCapabilities(ctx context.Context, in *CatalogCapabilitiesRequest, opts ...grpc.CallOption) (*CatalogCapabilitiesResponse, error)
	WatchCatalog(ctx context.Context, in *CatalogWatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CatalogWatchEvent], error)
	StartSplitMigration(ctx context.Context, in *StartSplitMigrationRequest, opts ...grpc.CallOption) (*StartSplitMigrationResponse, error)
	GetRouteOwnership(ctx context.Context, in *GetRouteOwnershipRequest, opts ...grpc.CallOption) (*GetRouteOwnershipResponse, error)
	GetIntersectingRoutes(ctx context.Context, in *GetIntersectingRoutesRequest, opts ...grpc.CallOption) (*GetIntersectingRoutesResponse, error)
	GetSplitJob(ctx context.Context, in *GetSplitJobRequest, opts ...grpc.CallOption) (*GetSplitJobResponse, error)
	ListSplitJobs(ctx context.Context, in *ListSplitJobsRequest, opts ...grpc.CallOption) (*ListSplitJobsResponse, error)
	AbandonSplitJob(ctx context.Context, in *AbandonSplitJobRequest, opts ...grpc.CallOption) (*AbandonSplitJobResponse, error)
	RetrySplitJob(ctx context.Context, in *RetrySplitJobRequest, opts ...grpc.CallOption) (*RetrySplitJobResponse, error)
}

DistributionClient is the client API for Distribution service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type DistributionServer

DistributionServer is the server API for Distribution service. All implementations must embed UnimplementedDistributionServer for forward compatibility.

type Distribution_WatchCatalogClient

type Distribution_WatchCatalogClient = grpc.ServerStreamingClient[CatalogWatchEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Distribution_WatchCatalogServer

type Distribution_WatchCatalogServer = grpc.ServerStreamingServer[CatalogWatchEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DynamoAttributeValue

type DynamoAttributeValue struct {

	// Types that are valid to be assigned to Value:
	//
	//	*DynamoAttributeValue_S
	//	*DynamoAttributeValue_N
	//	*DynamoAttributeValue_B
	//	*DynamoAttributeValue_BoolValue
	//	*DynamoAttributeValue_NullValue
	//	*DynamoAttributeValue_Ss
	//	*DynamoAttributeValue_Ns
	//	*DynamoAttributeValue_Bs
	//	*DynamoAttributeValue_L
	//	*DynamoAttributeValue_M
	Value isDynamoAttributeValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*DynamoAttributeValue) Descriptor deprecated

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

Deprecated: Use DynamoAttributeValue.ProtoReflect.Descriptor instead.

func (*DynamoAttributeValue) GetB

func (x *DynamoAttributeValue) GetB() []byte

func (*DynamoAttributeValue) GetBoolValue

func (x *DynamoAttributeValue) GetBoolValue() bool

func (*DynamoAttributeValue) GetBs

func (*DynamoAttributeValue) GetL

func (*DynamoAttributeValue) GetM

func (*DynamoAttributeValue) GetN

func (x *DynamoAttributeValue) GetN() string

func (*DynamoAttributeValue) GetNs

func (*DynamoAttributeValue) GetNullValue

func (x *DynamoAttributeValue) GetNullValue() bool

func (*DynamoAttributeValue) GetS

func (x *DynamoAttributeValue) GetS() string

func (*DynamoAttributeValue) GetSs

func (*DynamoAttributeValue) GetValue

func (x *DynamoAttributeValue) GetValue() isDynamoAttributeValue_Value

func (*DynamoAttributeValue) ProtoMessage

func (*DynamoAttributeValue) ProtoMessage()

func (*DynamoAttributeValue) ProtoReflect

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

func (*DynamoAttributeValue) Reset

func (x *DynamoAttributeValue) Reset()

func (*DynamoAttributeValue) String

func (x *DynamoAttributeValue) String() string

type DynamoAttributeValueList

type DynamoAttributeValueList struct {
	Values []*DynamoAttributeValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoAttributeValueList) Descriptor deprecated

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

Deprecated: Use DynamoAttributeValueList.ProtoReflect.Descriptor instead.

func (*DynamoAttributeValueList) GetValues

func (*DynamoAttributeValueList) ProtoMessage

func (*DynamoAttributeValueList) ProtoMessage()

func (*DynamoAttributeValueList) ProtoReflect

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

func (*DynamoAttributeValueList) Reset

func (x *DynamoAttributeValueList) Reset()

func (*DynamoAttributeValueList) String

func (x *DynamoAttributeValueList) String() string

type DynamoAttributeValueMap

type DynamoAttributeValueMap struct {
	Values map[string]*DynamoAttributeValue `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DynamoAttributeValueMap) Descriptor deprecated

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

Deprecated: Use DynamoAttributeValueMap.ProtoReflect.Descriptor instead.

func (*DynamoAttributeValueMap) GetValues

func (*DynamoAttributeValueMap) ProtoMessage

func (*DynamoAttributeValueMap) ProtoMessage()

func (*DynamoAttributeValueMap) ProtoReflect

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

func (*DynamoAttributeValueMap) Reset

func (x *DynamoAttributeValueMap) Reset()

func (*DynamoAttributeValueMap) String

func (x *DynamoAttributeValueMap) String() string

type DynamoAttributeValue_B

type DynamoAttributeValue_B struct {
	B []byte `protobuf:"bytes,3,opt,name=b,proto3,oneof"`
}

type DynamoAttributeValue_BoolValue

type DynamoAttributeValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type DynamoAttributeValue_Bs

type DynamoAttributeValue_Bs struct {
	Bs *DynamoBinarySet `protobuf:"bytes,8,opt,name=bs,proto3,oneof"`
}

type DynamoAttributeValue_L

type DynamoAttributeValue_L struct {
	L *DynamoAttributeValueList `protobuf:"bytes,9,opt,name=l,proto3,oneof"`
}

type DynamoAttributeValue_M

type DynamoAttributeValue_M struct {
	M *DynamoAttributeValueMap `protobuf:"bytes,10,opt,name=m,proto3,oneof"`
}

type DynamoAttributeValue_N

type DynamoAttributeValue_N struct {
	N string `protobuf:"bytes,2,opt,name=n,proto3,oneof"`
}

type DynamoAttributeValue_Ns

type DynamoAttributeValue_Ns struct {
	Ns *DynamoNumberSet `protobuf:"bytes,7,opt,name=ns,proto3,oneof"`
}

type DynamoAttributeValue_NullValue

type DynamoAttributeValue_NullValue struct {
	NullValue bool `protobuf:"varint,5,opt,name=null_value,json=nullValue,proto3,oneof"`
}

type DynamoAttributeValue_S

type DynamoAttributeValue_S struct {
	S string `protobuf:"bytes,1,opt,name=s,proto3,oneof"`
}

type DynamoAttributeValue_Ss

type DynamoAttributeValue_Ss struct {
	Ss *DynamoStringSet `protobuf:"bytes,6,opt,name=ss,proto3,oneof"`
}

type DynamoBinarySet

type DynamoBinarySet struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoBinarySet) Descriptor deprecated

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

Deprecated: Use DynamoBinarySet.ProtoReflect.Descriptor instead.

func (*DynamoBinarySet) GetValues

func (x *DynamoBinarySet) GetValues() [][]byte

func (*DynamoBinarySet) ProtoMessage

func (*DynamoBinarySet) ProtoMessage()

func (*DynamoBinarySet) ProtoReflect

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

func (*DynamoBinarySet) Reset

func (x *DynamoBinarySet) Reset()

func (*DynamoBinarySet) String

func (x *DynamoBinarySet) String() string

type DynamoGSIProjection

type DynamoGSIProjection struct {
	ProjectionType   string   `protobuf:"bytes,1,opt,name=projection_type,json=projectionType,proto3" json:"projection_type,omitempty"`
	NonKeyAttributes []string `protobuf:"bytes,2,rep,name=non_key_attributes,json=nonKeyAttributes,proto3" json:"non_key_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoGSIProjection) Descriptor deprecated

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

Deprecated: Use DynamoGSIProjection.ProtoReflect.Descriptor instead.

func (*DynamoGSIProjection) GetNonKeyAttributes

func (x *DynamoGSIProjection) GetNonKeyAttributes() []string

func (*DynamoGSIProjection) GetProjectionType

func (x *DynamoGSIProjection) GetProjectionType() string

func (*DynamoGSIProjection) ProtoMessage

func (*DynamoGSIProjection) ProtoMessage()

func (*DynamoGSIProjection) ProtoReflect

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

func (*DynamoGSIProjection) Reset

func (x *DynamoGSIProjection) Reset()

func (*DynamoGSIProjection) String

func (x *DynamoGSIProjection) String() string

type DynamoGlobalSecondaryIndex

type DynamoGlobalSecondaryIndex struct {
	KeySchema  *DynamoKeySchema     `protobuf:"bytes,1,opt,name=key_schema,json=keySchema,proto3" json:"key_schema,omitempty"`
	Projection *DynamoGSIProjection `protobuf:"bytes,2,opt,name=projection,proto3" json:"projection,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoGlobalSecondaryIndex) Descriptor deprecated

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

Deprecated: Use DynamoGlobalSecondaryIndex.ProtoReflect.Descriptor instead.

func (*DynamoGlobalSecondaryIndex) GetKeySchema

func (x *DynamoGlobalSecondaryIndex) GetKeySchema() *DynamoKeySchema

func (*DynamoGlobalSecondaryIndex) GetProjection

func (x *DynamoGlobalSecondaryIndex) GetProjection() *DynamoGSIProjection

func (*DynamoGlobalSecondaryIndex) ProtoMessage

func (*DynamoGlobalSecondaryIndex) ProtoMessage()

func (*DynamoGlobalSecondaryIndex) ProtoReflect

func (*DynamoGlobalSecondaryIndex) Reset

func (x *DynamoGlobalSecondaryIndex) Reset()

func (*DynamoGlobalSecondaryIndex) String

func (x *DynamoGlobalSecondaryIndex) String() string

type DynamoItem

type DynamoItem struct {
	Attributes map[string]*DynamoAttributeValue `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DynamoItem) Descriptor deprecated

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

Deprecated: Use DynamoItem.ProtoReflect.Descriptor instead.

func (*DynamoItem) GetAttributes

func (x *DynamoItem) GetAttributes() map[string]*DynamoAttributeValue

func (*DynamoItem) ProtoMessage

func (*DynamoItem) ProtoMessage()

func (*DynamoItem) ProtoReflect

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

func (*DynamoItem) Reset

func (x *DynamoItem) Reset()

func (*DynamoItem) String

func (x *DynamoItem) String() string

type DynamoKeySchema

type DynamoKeySchema struct {
	HashKey  string `protobuf:"bytes,1,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
	RangeKey string `protobuf:"bytes,2,opt,name=range_key,json=rangeKey,proto3" json:"range_key,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoKeySchema) Descriptor deprecated

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

Deprecated: Use DynamoKeySchema.ProtoReflect.Descriptor instead.

func (*DynamoKeySchema) GetHashKey

func (x *DynamoKeySchema) GetHashKey() string

func (*DynamoKeySchema) GetRangeKey

func (x *DynamoKeySchema) GetRangeKey() string

func (*DynamoKeySchema) ProtoMessage

func (*DynamoKeySchema) ProtoMessage()

func (*DynamoKeySchema) ProtoReflect

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

func (*DynamoKeySchema) Reset

func (x *DynamoKeySchema) Reset()

func (*DynamoKeySchema) String

func (x *DynamoKeySchema) String() string

type DynamoNumberSet

type DynamoNumberSet struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoNumberSet) Descriptor deprecated

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

Deprecated: Use DynamoNumberSet.ProtoReflect.Descriptor instead.

func (*DynamoNumberSet) GetValues

func (x *DynamoNumberSet) GetValues() []string

func (*DynamoNumberSet) ProtoMessage

func (*DynamoNumberSet) ProtoMessage()

func (*DynamoNumberSet) ProtoReflect

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

func (*DynamoNumberSet) Reset

func (x *DynamoNumberSet) Reset()

func (*DynamoNumberSet) String

func (x *DynamoNumberSet) String() string

type DynamoStringSet

type DynamoStringSet struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoStringSet) Descriptor deprecated

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

Deprecated: Use DynamoStringSet.ProtoReflect.Descriptor instead.

func (*DynamoStringSet) GetValues

func (x *DynamoStringSet) GetValues() []string

func (*DynamoStringSet) ProtoMessage

func (*DynamoStringSet) ProtoMessage()

func (*DynamoStringSet) ProtoReflect

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

func (*DynamoStringSet) Reset

func (x *DynamoStringSet) Reset()

func (*DynamoStringSet) String

func (x *DynamoStringSet) String() string

type DynamoTableSchema

type DynamoTableSchema struct {
	TableName               string                                 `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	AttributeDefinitions    map[string]string                      `` /* 195-byte string literal not displayed */
	PrimaryKey              *DynamoKeySchema                       `protobuf:"bytes,3,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	GlobalSecondaryIndexes  map[string]*DynamoGlobalSecondaryIndex `` /* 203-byte string literal not displayed */
	KeyEncodingVersion      uint64                                 `protobuf:"varint,5,opt,name=key_encoding_version,json=keyEncodingVersion,proto3" json:"key_encoding_version,omitempty"`
	MigratingFromGeneration uint64                                 `` /* 133-byte string literal not displayed */
	Generation              uint64                                 `protobuf:"varint,7,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamoTableSchema) Descriptor deprecated

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

Deprecated: Use DynamoTableSchema.ProtoReflect.Descriptor instead.

func (*DynamoTableSchema) GetAttributeDefinitions

func (x *DynamoTableSchema) GetAttributeDefinitions() map[string]string

func (*DynamoTableSchema) GetGeneration

func (x *DynamoTableSchema) GetGeneration() uint64

func (*DynamoTableSchema) GetGlobalSecondaryIndexes

func (x *DynamoTableSchema) GetGlobalSecondaryIndexes() map[string]*DynamoGlobalSecondaryIndex

func (*DynamoTableSchema) GetKeyEncodingVersion

func (x *DynamoTableSchema) GetKeyEncodingVersion() uint64

func (*DynamoTableSchema) GetMigratingFromGeneration

func (x *DynamoTableSchema) GetMigratingFromGeneration() uint64

func (*DynamoTableSchema) GetPrimaryKey

func (x *DynamoTableSchema) GetPrimaryKey() *DynamoKeySchema

func (*DynamoTableSchema) GetTableName

func (x *DynamoTableSchema) GetTableName() string

func (*DynamoTableSchema) ProtoMessage

func (*DynamoTableSchema) ProtoMessage()

func (*DynamoTableSchema) ProtoReflect

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

func (*DynamoTableSchema) Reset

func (x *DynamoTableSchema) Reset()

func (*DynamoTableSchema) String

func (x *DynamoTableSchema) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type EnableRaftEnvelopeRequest

type EnableRaftEnvelopeRequest struct {
	ProposerNodeId     uint64 `protobuf:"varint,1,opt,name=proposer_node_id,json=proposerNodeId,proto3" json:"proposer_node_id,omitempty"`
	ProposerLocalEpoch uint32 `protobuf:"varint,2,opt,name=proposer_local_epoch,json=proposerLocalEpoch,proto3" json:"proposer_local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// contains filtered or unexported fields
}

EnableRaftEnvelopeRequest proposes the Stage 6E Phase 2 cutover from cleartext Raft proposals to §4.2-envelope Raft proposals. Defined in the 6E design doc §3.1; the server composes a RotationPayload with SubTag = RotateSubEnableRaftEnvelope (0x05) and routes it through the default Raft group's leader as a §11.3 0x05 OpRotation entry. Structural mirror of EnableStorageEnvelopeRequest; the difference is the target Purpose (PurposeRaft) and the source DEK slot (sidecar.Active.Raft).

proposer_node_id MUST be non-zero (the §6.1 "not-capable" sentinel is rejected at the server boundary, matching the existing RotateDEK / BootstrapEncryption / EnableStorageEnvelope posture).

proposer_local_epoch carries the §4.1 16-bit nonce field as uint32 (proto3 has no uint16); values above 0xFFFF are rejected at the server boundary before any Raft proposal is composed. ApplyRotation re-validates at apply time (defense-in-depth).

func (*EnableRaftEnvelopeRequest) Descriptor deprecated

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

Deprecated: Use EnableRaftEnvelopeRequest.ProtoReflect.Descriptor instead.

func (*EnableRaftEnvelopeRequest) GetProposerLocalEpoch

func (x *EnableRaftEnvelopeRequest) GetProposerLocalEpoch() uint32

func (*EnableRaftEnvelopeRequest) GetProposerNodeId

func (x *EnableRaftEnvelopeRequest) GetProposerNodeId() uint64

func (*EnableRaftEnvelopeRequest) ProtoMessage

func (*EnableRaftEnvelopeRequest) ProtoMessage()

func (*EnableRaftEnvelopeRequest) ProtoReflect

func (*EnableRaftEnvelopeRequest) Reset

func (x *EnableRaftEnvelopeRequest) Reset()

func (*EnableRaftEnvelopeRequest) String

func (x *EnableRaftEnvelopeRequest) String() string

type EnableRaftEnvelopeResponse

type EnableRaftEnvelopeResponse struct {
	AppliedIndex      uint64               `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	CapabilitySummary []*CapabilityVerdict `protobuf:"bytes,2,rep,name=capability_summary,json=capabilitySummary,proto3" json:"capability_summary,omitempty"`
	WasAlreadyActive  bool                 `protobuf:"varint,3,opt,name=was_already_active,json=wasAlreadyActive,proto3" json:"was_already_active,omitempty"`
	// contains filtered or unexported fields
}

EnableRaftEnvelopeResponse reports the outcome of a raft-envelope cutover proposal. Structural mirror of EnableStorageEnvelopeResponse with one rename to match the raft variant's sole "Phase-2 active" sentinel:

  • was_already_active reflects sidecar.RaftEnvelopeCutoverIndex != 0 on the precheck (the raft variant has no separate bool flag — non-zero cutover index IS the active sentinel).

On a fresh cutover (was_already_active == false), applied_index is the Raft index of the entry the leader just proposed and waited to apply. On a retried call, applied_index is the recorded sidecar.RaftEnvelopeCutoverIndex from the ORIGINAL cutover — stable across arbitrary subsequent encryption-relevant Raft activity.

capability_summary records which (full_node_id) members were probed during the pre-flight gate and what they reported. Empty on idempotent retries; the membership view of the original cutover is not retained.

func (*EnableRaftEnvelopeResponse) Descriptor deprecated

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

Deprecated: Use EnableRaftEnvelopeResponse.ProtoReflect.Descriptor instead.

func (*EnableRaftEnvelopeResponse) GetAppliedIndex

func (x *EnableRaftEnvelopeResponse) GetAppliedIndex() uint64

func (*EnableRaftEnvelopeResponse) GetCapabilitySummary

func (x *EnableRaftEnvelopeResponse) GetCapabilitySummary() []*CapabilityVerdict

func (*EnableRaftEnvelopeResponse) GetWasAlreadyActive

func (x *EnableRaftEnvelopeResponse) GetWasAlreadyActive() bool

func (*EnableRaftEnvelopeResponse) ProtoMessage

func (*EnableRaftEnvelopeResponse) ProtoMessage()

func (*EnableRaftEnvelopeResponse) ProtoReflect

func (*EnableRaftEnvelopeResponse) Reset

func (x *EnableRaftEnvelopeResponse) Reset()

func (*EnableRaftEnvelopeResponse) String

func (x *EnableRaftEnvelopeResponse) String() string

type EnableStorageEnvelopeRequest

type EnableStorageEnvelopeRequest struct {
	ProposerNodeId     uint64 `protobuf:"varint,1,opt,name=proposer_node_id,json=proposerNodeId,proto3" json:"proposer_node_id,omitempty"`
	ProposerLocalEpoch uint32 `protobuf:"varint,2,opt,name=proposer_local_epoch,json=proposerLocalEpoch,proto3" json:"proposer_local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// contains filtered or unexported fields
}

EnableStorageEnvelopeRequest proposes the §7.1 Phase 1 cutover that flips the cluster from cleartext storage writes to §4.1 envelope writes. Defined in the 6D design doc §3.1; the server composes a RotationPayload with SubTag = RotateSubEnableStorageEnvelope (0x04) and routes it through the default Raft group's leader as a §11.3 0x05 OpRotation entry.

proposer_node_id MUST be non-zero (the §6.1 "not-capable" sentinel is rejected at the server boundary, matching the existing RotateDEK / BootstrapEncryption posture).

proposer_local_epoch carries the §4.1 16-bit nonce field as uint32 (proto3 has no uint16); values above 0xFFFF are rejected at the server boundary before any Raft proposal is composed. ApplyRotation re-validates at apply time (defense-in-depth).

func (*EnableStorageEnvelopeRequest) Descriptor deprecated

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

Deprecated: Use EnableStorageEnvelopeRequest.ProtoReflect.Descriptor instead.

func (*EnableStorageEnvelopeRequest) GetProposerLocalEpoch

func (x *EnableStorageEnvelopeRequest) GetProposerLocalEpoch() uint32

func (*EnableStorageEnvelopeRequest) GetProposerNodeId

func (x *EnableStorageEnvelopeRequest) GetProposerNodeId() uint64

func (*EnableStorageEnvelopeRequest) ProtoMessage

func (*EnableStorageEnvelopeRequest) ProtoMessage()

func (*EnableStorageEnvelopeRequest) ProtoReflect

func (*EnableStorageEnvelopeRequest) Reset

func (x *EnableStorageEnvelopeRequest) Reset()

func (*EnableStorageEnvelopeRequest) String

type EnableStorageEnvelopeResponse

type EnableStorageEnvelopeResponse struct {
	AppliedIndex        uint64               `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	CapabilitySummary   []*CapabilityVerdict `protobuf:"bytes,2,rep,name=capability_summary,json=capabilitySummary,proto3" json:"capability_summary,omitempty"`
	CutoverIndexUnknown bool                 `protobuf:"varint,3,opt,name=cutover_index_unknown,json=cutoverIndexUnknown,proto3" json:"cutover_index_unknown,omitempty"`
	WasAlreadyActive    bool                 `protobuf:"varint,4,opt,name=was_already_active,json=wasAlreadyActive,proto3" json:"was_already_active,omitempty"`
	// contains filtered or unexported fields
}

EnableStorageEnvelopeResponse reports the outcome of a cutover proposal. The §6.4 idempotency contract is encoded as an OK status with `was_already_active = true` (NOT AlreadyExists, since unary gRPC drops the response body on non-OK status; the applied_index must be reachable on the success path).

On a fresh cutover (was_already_active == false), applied_index is the Raft index of the entry the leader just proposed and waited to apply. On a retried call, applied_index is the recorded sidecar.StorageEnvelopeCutoverIndex from the ORIGINAL cutover (§6.4) — stable across arbitrary subsequent encryption-relevant Raft activity.

capability_summary records which (full_node_id) members were probed during the pre-flight gate and what they reported. Empty on idempotent retries (was_already_active=true); the membership view of the original cutover is not retained.

cutover_index_unknown is the §6.4 defensive fallback: it only fires if a sidecar reports StorageEnvelopeActive=true with StorageEnvelopeCutoverIndex=0 (operationally impossible under normal apply, but hedged against future schema rollback). On healthy clusters this stays false. The field is only meaningful when was_already_active=true.

func (*EnableStorageEnvelopeResponse) Descriptor deprecated

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

Deprecated: Use EnableStorageEnvelopeResponse.ProtoReflect.Descriptor instead.

func (*EnableStorageEnvelopeResponse) GetAppliedIndex

func (x *EnableStorageEnvelopeResponse) GetAppliedIndex() uint64

func (*EnableStorageEnvelopeResponse) GetCapabilitySummary

func (x *EnableStorageEnvelopeResponse) GetCapabilitySummary() []*CapabilityVerdict

func (*EnableStorageEnvelopeResponse) GetCutoverIndexUnknown

func (x *EnableStorageEnvelopeResponse) GetCutoverIndexUnknown() bool

func (*EnableStorageEnvelopeResponse) GetWasAlreadyActive

func (x *EnableStorageEnvelopeResponse) GetWasAlreadyActive() bool

func (*EnableStorageEnvelopeResponse) ProtoMessage

func (*EnableStorageEnvelopeResponse) ProtoMessage()

func (*EnableStorageEnvelopeResponse) ProtoReflect

func (*EnableStorageEnvelopeResponse) Reset

func (x *EnableStorageEnvelopeResponse) Reset()

func (*EnableStorageEnvelopeResponse) String

type EncryptionAdminClient

type EncryptionAdminClient interface {
	GetCapability(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*CapabilityReport, error)
	GetSidecarState(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SidecarStateReport, error)
	BootstrapEncryption(ctx context.Context, in *BootstrapEncryptionRequest, opts ...grpc.CallOption) (*BootstrapEncryptionResponse, error)
	RotateDEK(ctx context.Context, in *RotateDEKRequest, opts ...grpc.CallOption) (*RotateDEKResponse, error)
	RegisterEncryptionWriter(ctx context.Context, in *RegisterEncryptionWriterRequest, opts ...grpc.CallOption) (*RegisterEncryptionWriterResponse, error)
	ResyncSidecar(ctx context.Context, in *ResyncSidecarRequest, opts ...grpc.CallOption) (*ResyncSidecarResponse, error)
	EnableStorageEnvelope(ctx context.Context, in *EnableStorageEnvelopeRequest, opts ...grpc.CallOption) (*EnableStorageEnvelopeResponse, error)
	EnableRaftEnvelope(ctx context.Context, in *EnableRaftEnvelopeRequest, opts ...grpc.CallOption) (*EnableRaftEnvelopeResponse, error)
}

EncryptionAdminClient is the client API for EncryptionAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

EncryptionAdmin is the operator-facing control plane for the data-at-rest encryption feature described in docs/design/2026_04_29_partial_data_at_rest_encryption.md. The service is split into two groups:

  1. Read-only, leaderless probes (GetCapability, GetSidecarState, ResyncSidecar). Safe to call on any member including learners; each returns the responding node's local view. The §5.6 / §7.1 cutover paths fan GetCapability out across every member of every Raft group to drive the pre-flight capability check and to collect the (full_node_id, local_epoch) batch that goes into the bootstrap-encryption Raft entry. GetSidecarState and ResyncSidecar share the §5.5 sidecar-recovery role: a follower whose sidecar fell behind a Raft-log compaction window calls either RPC against the leader and rewrites its local keys.json from the response. ResyncSidecar is addressed at the leader because the recovery flow only consults the leader's record; GetSidecarState answers from any node and is the broader observability surface.

  2. Mutating RPCs that propose FSM-internal entries through the default Raft group's leader (BootstrapEncryption, RotateDEK, RegisterEncryptionWriter). They route to the leader; followers return FailedPrecondition with the currently-known leader so the operator's CLI can retry against the right node.

Wire-format notes:

  • local_epoch is the §4.1 16-bit nonce field carried as uint32 (proto3 has no uint16). Every decode site MUST validate value <= 0xFFFF; values above 0xFFFF return ErrLocalEpochOutOfRange. The mutating RPCs that accept a writer-registry batch (BootstrapEncryption) MUST apply the same check at the server boundary before the batch is forwarded into the Raft proposal.
  • wrapped_dek payloads are sidecar-format bytes (DEK wrapped under the current KEK) and are leakage-safe: an RPC response that exposes them is no worse than reading the on-disk sidecar.

type EncryptionAdminServer

EncryptionAdminServer is the server API for EncryptionAdmin service. All implementations must embed UnimplementedEncryptionAdminServer for forward compatibility.

EncryptionAdmin is the operator-facing control plane for the data-at-rest encryption feature described in docs/design/2026_04_29_partial_data_at_rest_encryption.md. The service is split into two groups:

  1. Read-only, leaderless probes (GetCapability, GetSidecarState, ResyncSidecar). Safe to call on any member including learners; each returns the responding node's local view. The §5.6 / §7.1 cutover paths fan GetCapability out across every member of every Raft group to drive the pre-flight capability check and to collect the (full_node_id, local_epoch) batch that goes into the bootstrap-encryption Raft entry. GetSidecarState and ResyncSidecar share the §5.5 sidecar-recovery role: a follower whose sidecar fell behind a Raft-log compaction window calls either RPC against the leader and rewrites its local keys.json from the response. ResyncSidecar is addressed at the leader because the recovery flow only consults the leader's record; GetSidecarState answers from any node and is the broader observability surface.

  2. Mutating RPCs that propose FSM-internal entries through the default Raft group's leader (BootstrapEncryption, RotateDEK, RegisterEncryptionWriter). They route to the leader; followers return FailedPrecondition with the currently-known leader so the operator's CLI can retry against the right node.

Wire-format notes:

  • local_epoch is the §4.1 16-bit nonce field carried as uint32 (proto3 has no uint16). Every decode site MUST validate value <= 0xFFFF; values above 0xFFFF return ErrLocalEpochOutOfRange. The mutating RPCs that accept a writer-registry batch (BootstrapEncryption) MUST apply the same check at the server boundary before the batch is forwarded into the Raft proposal.
  • wrapped_dek payloads are sidecar-format bytes (DEK wrapped under the current KEK) and are leakage-safe: an RPC response that exposes them is no worse than reading the on-disk sidecar.

type EndBackupRequest

type EndBackupRequest struct {
	PinToken []byte `protobuf:"bytes,1,opt,name=pin_token,json=pinToken,proto3" json:"pin_token,omitempty"`
	// contains filtered or unexported fields
}

func (*EndBackupRequest) Descriptor deprecated

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

Deprecated: Use EndBackupRequest.ProtoReflect.Descriptor instead.

func (*EndBackupRequest) GetPinToken

func (x *EndBackupRequest) GetPinToken() []byte

func (*EndBackupRequest) ProtoMessage

func (*EndBackupRequest) ProtoMessage()

func (*EndBackupRequest) ProtoReflect

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

func (*EndBackupRequest) Reset

func (x *EndBackupRequest) Reset()

func (*EndBackupRequest) String

func (x *EndBackupRequest) String() string

type EndBackupResponse

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

func (*EndBackupResponse) Descriptor deprecated

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

Deprecated: Use EndBackupResponse.ProtoReflect.Descriptor instead.

func (*EndBackupResponse) ProtoMessage

func (*EndBackupResponse) ProtoMessage()

func (*EndBackupResponse) ProtoReflect

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

func (*EndBackupResponse) Reset

func (x *EndBackupResponse) Reset()

func (*EndBackupResponse) String

func (x *EndBackupResponse) String() string

type EtcdRaftAck

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

func (*EtcdRaftAck) Descriptor deprecated

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

Deprecated: Use EtcdRaftAck.ProtoReflect.Descriptor instead.

func (*EtcdRaftAck) ProtoMessage

func (*EtcdRaftAck) ProtoMessage()

func (*EtcdRaftAck) ProtoReflect

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

func (*EtcdRaftAck) Reset

func (x *EtcdRaftAck) Reset()

func (*EtcdRaftAck) String

func (x *EtcdRaftAck) String() string

type EtcdRaftClient

EtcdRaftClient is the client API for EtcdRaft service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEtcdRaftClient

func NewEtcdRaftClient(cc grpc.ClientConnInterface) EtcdRaftClient

type EtcdRaftMessage

type EtcdRaftMessage struct {
	Message []byte `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*EtcdRaftMessage) Descriptor deprecated

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

Deprecated: Use EtcdRaftMessage.ProtoReflect.Descriptor instead.

func (*EtcdRaftMessage) GetMessage

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

func (*EtcdRaftMessage) ProtoMessage

func (*EtcdRaftMessage) ProtoMessage()

func (*EtcdRaftMessage) ProtoReflect

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

func (*EtcdRaftMessage) Reset

func (x *EtcdRaftMessage) Reset()

func (*EtcdRaftMessage) String

func (x *EtcdRaftMessage) String() string

type EtcdRaftServer

type EtcdRaftServer interface {
	Send(context.Context, *EtcdRaftMessage) (*EtcdRaftAck, error)
	SendStream(grpc.ClientStreamingServer[EtcdRaftMessage, EtcdRaftAck]) error
	SendSnapshot(grpc.ClientStreamingServer[EtcdRaftSnapshotChunk, EtcdRaftAck]) error
	// contains filtered or unexported methods
}

EtcdRaftServer is the server API for EtcdRaft service. All implementations must embed UnimplementedEtcdRaftServer for forward compatibility.

type EtcdRaftSnapshotChunk

type EtcdRaftSnapshotChunk struct {
	Metadata []byte `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Chunk    []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Final    bool   `protobuf:"varint,3,opt,name=final,proto3" json:"final,omitempty"`
	// contains filtered or unexported fields
}

func (*EtcdRaftSnapshotChunk) Descriptor deprecated

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

Deprecated: Use EtcdRaftSnapshotChunk.ProtoReflect.Descriptor instead.

func (*EtcdRaftSnapshotChunk) GetChunk

func (x *EtcdRaftSnapshotChunk) GetChunk() []byte

func (*EtcdRaftSnapshotChunk) GetFinal

func (x *EtcdRaftSnapshotChunk) GetFinal() bool

func (*EtcdRaftSnapshotChunk) GetMetadata

func (x *EtcdRaftSnapshotChunk) GetMetadata() []byte

func (*EtcdRaftSnapshotChunk) ProtoMessage

func (*EtcdRaftSnapshotChunk) ProtoMessage()

func (*EtcdRaftSnapshotChunk) ProtoReflect

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

func (*EtcdRaftSnapshotChunk) Reset

func (x *EtcdRaftSnapshotChunk) Reset()

func (*EtcdRaftSnapshotChunk) String

func (x *EtcdRaftSnapshotChunk) String() string

type EtcdRaft_SendSnapshotClient

type EtcdRaft_SendSnapshotClient = grpc.ClientStreamingClient[EtcdRaftSnapshotChunk, EtcdRaftAck]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EtcdRaft_SendSnapshotServer

type EtcdRaft_SendSnapshotServer = grpc.ClientStreamingServer[EtcdRaftSnapshotChunk, EtcdRaftAck]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EtcdRaft_SendStreamClient

type EtcdRaft_SendStreamClient = grpc.ClientStreamingClient[EtcdRaftMessage, EtcdRaftAck]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EtcdRaft_SendStreamServer

type EtcdRaft_SendStreamServer = grpc.ClientStreamingServer[EtcdRaftMessage, EtcdRaftAck]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ExportRangeVersionsRequest

type ExportRangeVersionsRequest struct {
	RangeStart      []byte `protobuf:"bytes,1,opt,name=range_start,json=rangeStart,proto3" json:"range_start,omitempty"`
	RangeEnd        []byte `protobuf:"bytes,2,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	MaxCommitTs     uint64 `protobuf:"varint,3,opt,name=max_commit_ts,json=maxCommitTs,proto3" json:"max_commit_ts,omitempty"`
	MinCommitTs     uint64 `protobuf:"varint,4,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
	Cursor          []byte `protobuf:"bytes,5,opt,name=cursor,proto3" json:"cursor,omitempty"`
	ChunkBytes      uint32 `protobuf:"varint,6,opt,name=chunk_bytes,json=chunkBytes,proto3" json:"chunk_bytes,omitempty"`
	RouteStart      []byte `protobuf:"bytes,7,opt,name=route_start,json=routeStart,proto3" json:"route_start,omitempty"`
	RouteEnd        []byte `protobuf:"bytes,8,opt,name=route_end,json=routeEnd,proto3" json:"route_end,omitempty"`
	MaxScannedBytes uint64 `protobuf:"varint,9,opt,name=max_scanned_bytes,json=maxScannedBytes,proto3" json:"max_scanned_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportRangeVersionsRequest) Descriptor deprecated

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

Deprecated: Use ExportRangeVersionsRequest.ProtoReflect.Descriptor instead.

func (*ExportRangeVersionsRequest) GetChunkBytes

func (x *ExportRangeVersionsRequest) GetChunkBytes() uint32

func (*ExportRangeVersionsRequest) GetCursor

func (x *ExportRangeVersionsRequest) GetCursor() []byte

func (*ExportRangeVersionsRequest) GetMaxCommitTs

func (x *ExportRangeVersionsRequest) GetMaxCommitTs() uint64

func (*ExportRangeVersionsRequest) GetMaxScannedBytes

func (x *ExportRangeVersionsRequest) GetMaxScannedBytes() uint64

func (*ExportRangeVersionsRequest) GetMinCommitTs

func (x *ExportRangeVersionsRequest) GetMinCommitTs() uint64

func (*ExportRangeVersionsRequest) GetRangeEnd

func (x *ExportRangeVersionsRequest) GetRangeEnd() []byte

func (*ExportRangeVersionsRequest) GetRangeStart

func (x *ExportRangeVersionsRequest) GetRangeStart() []byte

func (*ExportRangeVersionsRequest) GetRouteEnd

func (x *ExportRangeVersionsRequest) GetRouteEnd() []byte

func (*ExportRangeVersionsRequest) GetRouteStart

func (x *ExportRangeVersionsRequest) GetRouteStart() []byte

func (*ExportRangeVersionsRequest) ProtoMessage

func (*ExportRangeVersionsRequest) ProtoMessage()

func (*ExportRangeVersionsRequest) ProtoReflect

func (*ExportRangeVersionsRequest) Reset

func (x *ExportRangeVersionsRequest) Reset()

func (*ExportRangeVersionsRequest) String

func (x *ExportRangeVersionsRequest) String() string

type ExportRangeVersionsResponse

type ExportRangeVersionsResponse struct {
	Versions   []*MVCCVersion `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	NextCursor []byte         `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	Done       bool           `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportRangeVersionsResponse) Descriptor deprecated

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

Deprecated: Use ExportRangeVersionsResponse.ProtoReflect.Descriptor instead.

func (*ExportRangeVersionsResponse) GetDone

func (x *ExportRangeVersionsResponse) GetDone() bool

func (*ExportRangeVersionsResponse) GetNextCursor

func (x *ExportRangeVersionsResponse) GetNextCursor() []byte

func (*ExportRangeVersionsResponse) GetVersions

func (x *ExportRangeVersionsResponse) GetVersions() []*MVCCVersion

func (*ExportRangeVersionsResponse) ProtoMessage

func (*ExportRangeVersionsResponse) ProtoMessage()

func (*ExportRangeVersionsResponse) ProtoReflect

func (*ExportRangeVersionsResponse) Reset

func (x *ExportRangeVersionsResponse) Reset()

func (*ExportRangeVersionsResponse) String

func (x *ExportRangeVersionsResponse) String() string

type FetchChunkBlobRequest

type FetchChunkBlobRequest struct {
	ContentSha256 []byte `protobuf:"bytes,1,opt,name=content_sha256,json=contentSha256,proto3" json:"content_sha256,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchChunkBlobRequest) Descriptor deprecated

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

Deprecated: Use FetchChunkBlobRequest.ProtoReflect.Descriptor instead.

func (*FetchChunkBlobRequest) GetContentSha256

func (x *FetchChunkBlobRequest) GetContentSha256() []byte

func (*FetchChunkBlobRequest) ProtoMessage

func (*FetchChunkBlobRequest) ProtoMessage()

func (*FetchChunkBlobRequest) ProtoReflect

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

func (*FetchChunkBlobRequest) Reset

func (x *FetchChunkBlobRequest) Reset()

func (*FetchChunkBlobRequest) String

func (x *FetchChunkBlobRequest) String() string

type FetchChunkBlobResponse

type FetchChunkBlobResponse struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Eof     bool   `protobuf:"varint,2,opt,name=eof,proto3" json:"eof,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchChunkBlobResponse) Descriptor deprecated

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

Deprecated: Use FetchChunkBlobResponse.ProtoReflect.Descriptor instead.

func (*FetchChunkBlobResponse) GetEof

func (x *FetchChunkBlobResponse) GetEof() bool

func (*FetchChunkBlobResponse) GetPayload

func (x *FetchChunkBlobResponse) GetPayload() []byte

func (*FetchChunkBlobResponse) ProtoMessage

func (*FetchChunkBlobResponse) ProtoMessage()

func (*FetchChunkBlobResponse) ProtoReflect

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

func (*FetchChunkBlobResponse) Reset

func (x *FetchChunkBlobResponse) Reset()

func (*FetchChunkBlobResponse) String

func (x *FetchChunkBlobResponse) String() string

type ForwardAdminProposalRequest

type ForwardAdminProposalRequest struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardAdminProposalRequest) Descriptor deprecated

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

Deprecated: Use ForwardAdminProposalRequest.ProtoReflect.Descriptor instead.

func (*ForwardAdminProposalRequest) GetPayload

func (x *ForwardAdminProposalRequest) GetPayload() []byte

func (*ForwardAdminProposalRequest) ProtoMessage

func (*ForwardAdminProposalRequest) ProtoMessage()

func (*ForwardAdminProposalRequest) ProtoReflect

func (*ForwardAdminProposalRequest) Reset

func (x *ForwardAdminProposalRequest) Reset()

func (*ForwardAdminProposalRequest) String

func (x *ForwardAdminProposalRequest) String() string

type ForwardAdminProposalResponse

type ForwardAdminProposalResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardAdminProposalResponse) Descriptor deprecated

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

Deprecated: Use ForwardAdminProposalResponse.ProtoReflect.Descriptor instead.

func (*ForwardAdminProposalResponse) GetCommitIndex

func (x *ForwardAdminProposalResponse) GetCommitIndex() uint64

func (*ForwardAdminProposalResponse) ProtoMessage

func (*ForwardAdminProposalResponse) ProtoMessage()

func (*ForwardAdminProposalResponse) ProtoReflect

func (*ForwardAdminProposalResponse) Reset

func (x *ForwardAdminProposalResponse) Reset()

func (*ForwardAdminProposalResponse) String

type ForwardLeaseReadRequest

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

func (*ForwardLeaseReadRequest) Descriptor deprecated

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

Deprecated: Use ForwardLeaseReadRequest.ProtoReflect.Descriptor instead.

func (*ForwardLeaseReadRequest) ProtoMessage

func (*ForwardLeaseReadRequest) ProtoMessage()

func (*ForwardLeaseReadRequest) ProtoReflect

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

func (*ForwardLeaseReadRequest) Reset

func (x *ForwardLeaseReadRequest) Reset()

func (*ForwardLeaseReadRequest) String

func (x *ForwardLeaseReadRequest) String() string

type ForwardLeaseReadResponse

type ForwardLeaseReadResponse struct {
	AppliedIndex uint64 `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	LastCommitTs uint64 `protobuf:"varint,2,opt,name=last_commit_ts,json=lastCommitTs,proto3" json:"last_commit_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardLeaseReadResponse) Descriptor deprecated

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

Deprecated: Use ForwardLeaseReadResponse.ProtoReflect.Descriptor instead.

func (*ForwardLeaseReadResponse) GetAppliedIndex

func (x *ForwardLeaseReadResponse) GetAppliedIndex() uint64

func (*ForwardLeaseReadResponse) GetLastCommitTs

func (x *ForwardLeaseReadResponse) GetLastCommitTs() uint64

func (*ForwardLeaseReadResponse) ProtoMessage

func (*ForwardLeaseReadResponse) ProtoMessage()

func (*ForwardLeaseReadResponse) ProtoReflect

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

func (*ForwardLeaseReadResponse) Reset

func (x *ForwardLeaseReadResponse) Reset()

func (*ForwardLeaseReadResponse) String

func (x *ForwardLeaseReadResponse) String() string

type ForwardRequest

type ForwardRequest struct {
	IsTxn    bool       `protobuf:"varint,1,opt,name=is_txn,json=isTxn,proto3" json:"is_txn,omitempty"`
	Requests []*Request `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardRequest) Descriptor deprecated

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

Deprecated: Use ForwardRequest.ProtoReflect.Descriptor instead.

func (*ForwardRequest) GetIsTxn

func (x *ForwardRequest) GetIsTxn() bool

func (*ForwardRequest) GetRequests

func (x *ForwardRequest) GetRequests() []*Request

func (*ForwardRequest) ProtoMessage

func (*ForwardRequest) ProtoMessage()

func (*ForwardRequest) ProtoReflect

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

func (*ForwardRequest) Reset

func (x *ForwardRequest) Reset()

func (*ForwardRequest) String

func (x *ForwardRequest) String() string

type ForwardResponse

type ForwardResponse struct {
	Success     bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	CommitIndex uint64 `protobuf:"varint,2,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	CommitTs    uint64 `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	// contains filtered or unexported fields
}

for internal leader redirect

func (*ForwardResponse) Descriptor deprecated

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

Deprecated: Use ForwardResponse.ProtoReflect.Descriptor instead.

func (*ForwardResponse) GetCommitIndex

func (x *ForwardResponse) GetCommitIndex() uint64

func (*ForwardResponse) GetCommitTs

func (x *ForwardResponse) GetCommitTs() uint64

func (*ForwardResponse) GetSuccess

func (x *ForwardResponse) GetSuccess() bool

func (*ForwardResponse) ProtoMessage

func (*ForwardResponse) ProtoMessage()

func (*ForwardResponse) ProtoReflect

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

func (*ForwardResponse) Reset

func (x *ForwardResponse) Reset()

func (*ForwardResponse) String

func (x *ForwardResponse) String() string

type GetAdapterSummaryRequest

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

func (*GetAdapterSummaryRequest) Descriptor deprecated

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

Deprecated: Use GetAdapterSummaryRequest.ProtoReflect.Descriptor instead.

func (*GetAdapterSummaryRequest) ProtoMessage

func (*GetAdapterSummaryRequest) ProtoMessage()

func (*GetAdapterSummaryRequest) ProtoReflect

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

func (*GetAdapterSummaryRequest) Reset

func (x *GetAdapterSummaryRequest) Reset()

func (*GetAdapterSummaryRequest) String

func (x *GetAdapterSummaryRequest) String() string

type GetAdapterSummaryResponse

type GetAdapterSummaryResponse struct {
	Summaries []*AdapterSummary `protobuf:"bytes,1,rep,name=summaries,proto3" json:"summaries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAdapterSummaryResponse) Descriptor deprecated

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

Deprecated: Use GetAdapterSummaryResponse.ProtoReflect.Descriptor instead.

func (*GetAdapterSummaryResponse) GetSummaries

func (x *GetAdapterSummaryResponse) GetSummaries() []*AdapterSummary

func (*GetAdapterSummaryResponse) ProtoMessage

func (*GetAdapterSummaryResponse) ProtoMessage()

func (*GetAdapterSummaryResponse) ProtoReflect

func (*GetAdapterSummaryResponse) Reset

func (x *GetAdapterSummaryResponse) Reset()

func (*GetAdapterSummaryResponse) String

func (x *GetAdapterSummaryResponse) String() string

type GetClusterOverviewRequest

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

func (*GetClusterOverviewRequest) Descriptor deprecated

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

Deprecated: Use GetClusterOverviewRequest.ProtoReflect.Descriptor instead.

func (*GetClusterOverviewRequest) ProtoMessage

func (*GetClusterOverviewRequest) ProtoMessage()

func (*GetClusterOverviewRequest) ProtoReflect

func (*GetClusterOverviewRequest) Reset

func (x *GetClusterOverviewRequest) Reset()

func (*GetClusterOverviewRequest) String

func (x *GetClusterOverviewRequest) String() string

type GetClusterOverviewResponse

type GetClusterOverviewResponse struct {
	Self         *NodeIdentity   `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"`
	Members      []*NodeIdentity `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
	GroupLeaders []*GroupLeader  `protobuf:"bytes,3,rep,name=group_leaders,json=groupLeaders,proto3" json:"group_leaders,omitempty"`
	AggregateQps uint64          `protobuf:"varint,4,opt,name=aggregate_qps,json=aggregateQps,proto3" json:"aggregate_qps,omitempty"`
	Capabilities map[string]bool `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetClusterOverviewResponse) Descriptor deprecated

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

Deprecated: Use GetClusterOverviewResponse.ProtoReflect.Descriptor instead.

func (*GetClusterOverviewResponse) GetAggregateQps

func (x *GetClusterOverviewResponse) GetAggregateQps() uint64

func (*GetClusterOverviewResponse) GetCapabilities

func (x *GetClusterOverviewResponse) GetCapabilities() map[string]bool

func (*GetClusterOverviewResponse) GetGroupLeaders

func (x *GetClusterOverviewResponse) GetGroupLeaders() []*GroupLeader

func (*GetClusterOverviewResponse) GetMembers

func (x *GetClusterOverviewResponse) GetMembers() []*NodeIdentity

func (*GetClusterOverviewResponse) GetSelf

func (*GetClusterOverviewResponse) ProtoMessage

func (*GetClusterOverviewResponse) ProtoMessage()

func (*GetClusterOverviewResponse) ProtoReflect

func (*GetClusterOverviewResponse) Reset

func (x *GetClusterOverviewResponse) Reset()

func (*GetClusterOverviewResponse) String

func (x *GetClusterOverviewResponse) String() string

type GetIntersectingRoutesRequest

type GetIntersectingRoutesRequest struct {
	Start          []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End            []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	CatalogVersion uint64 `protobuf:"varint,3,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIntersectingRoutesRequest) Descriptor deprecated

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

Deprecated: Use GetIntersectingRoutesRequest.ProtoReflect.Descriptor instead.

func (*GetIntersectingRoutesRequest) GetCatalogVersion

func (x *GetIntersectingRoutesRequest) GetCatalogVersion() uint64

func (*GetIntersectingRoutesRequest) GetEnd

func (x *GetIntersectingRoutesRequest) GetEnd() []byte

func (*GetIntersectingRoutesRequest) GetStart

func (x *GetIntersectingRoutesRequest) GetStart() []byte

func (*GetIntersectingRoutesRequest) ProtoMessage

func (*GetIntersectingRoutesRequest) ProtoMessage()

func (*GetIntersectingRoutesRequest) ProtoReflect

func (*GetIntersectingRoutesRequest) Reset

func (x *GetIntersectingRoutesRequest) Reset()

func (*GetIntersectingRoutesRequest) String

type GetIntersectingRoutesResponse

type GetIntersectingRoutesResponse struct {
	Routes         []*RouteDescriptor `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	CatalogVersion uint64             `protobuf:"varint,2,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIntersectingRoutesResponse) Descriptor deprecated

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

Deprecated: Use GetIntersectingRoutesResponse.ProtoReflect.Descriptor instead.

func (*GetIntersectingRoutesResponse) GetCatalogVersion

func (x *GetIntersectingRoutesResponse) GetCatalogVersion() uint64

func (*GetIntersectingRoutesResponse) GetRoutes

func (*GetIntersectingRoutesResponse) ProtoMessage

func (*GetIntersectingRoutesResponse) ProtoMessage()

func (*GetIntersectingRoutesResponse) ProtoReflect

func (*GetIntersectingRoutesResponse) Reset

func (x *GetIntersectingRoutesResponse) Reset()

func (*GetIntersectingRoutesResponse) String

type GetKeyVizMatrixRequest

type GetKeyVizMatrixRequest struct {
	Series     KeyVizSeries `protobuf:"varint,1,opt,name=series,proto3,enum=KeyVizSeries" json:"series,omitempty"`
	FromUnixMs int64        `protobuf:"varint,2,opt,name=from_unix_ms,json=fromUnixMs,proto3" json:"from_unix_ms,omitempty"`
	ToUnixMs   int64        `protobuf:"varint,3,opt,name=to_unix_ms,json=toUnixMs,proto3" json:"to_unix_ms,omitempty"`
	Rows       uint32       `protobuf:"varint,4,opt,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyVizMatrixRequest) Descriptor deprecated

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

Deprecated: Use GetKeyVizMatrixRequest.ProtoReflect.Descriptor instead.

func (*GetKeyVizMatrixRequest) GetFromUnixMs

func (x *GetKeyVizMatrixRequest) GetFromUnixMs() int64

func (*GetKeyVizMatrixRequest) GetRows

func (x *GetKeyVizMatrixRequest) GetRows() uint32

func (*GetKeyVizMatrixRequest) GetSeries

func (x *GetKeyVizMatrixRequest) GetSeries() KeyVizSeries

func (*GetKeyVizMatrixRequest) GetToUnixMs

func (x *GetKeyVizMatrixRequest) GetToUnixMs() int64

func (*GetKeyVizMatrixRequest) ProtoMessage

func (*GetKeyVizMatrixRequest) ProtoMessage()

func (*GetKeyVizMatrixRequest) ProtoReflect

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

func (*GetKeyVizMatrixRequest) Reset

func (x *GetKeyVizMatrixRequest) Reset()

func (*GetKeyVizMatrixRequest) String

func (x *GetKeyVizMatrixRequest) String() string

type GetKeyVizMatrixResponse

type GetKeyVizMatrixResponse struct {
	ColumnUnixMs []int64      `protobuf:"varint,1,rep,packed,name=column_unix_ms,json=columnUnixMs,proto3" json:"column_unix_ms,omitempty"`
	Rows         []*KeyVizRow `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyVizMatrixResponse) Descriptor deprecated

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

Deprecated: Use GetKeyVizMatrixResponse.ProtoReflect.Descriptor instead.

func (*GetKeyVizMatrixResponse) GetColumnUnixMs

func (x *GetKeyVizMatrixResponse) GetColumnUnixMs() []int64

func (*GetKeyVizMatrixResponse) GetRows

func (x *GetKeyVizMatrixResponse) GetRows() []*KeyVizRow

func (*GetKeyVizMatrixResponse) ProtoMessage

func (*GetKeyVizMatrixResponse) ProtoMessage()

func (*GetKeyVizMatrixResponse) ProtoReflect

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

func (*GetKeyVizMatrixResponse) Reset

func (x *GetKeyVizMatrixResponse) Reset()

func (*GetKeyVizMatrixResponse) String

func (x *GetKeyVizMatrixResponse) String() string

type GetNodeVersionRequest

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

func (*GetNodeVersionRequest) Descriptor deprecated

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

Deprecated: Use GetNodeVersionRequest.ProtoReflect.Descriptor instead.

func (*GetNodeVersionRequest) ProtoMessage

func (*GetNodeVersionRequest) ProtoMessage()

func (*GetNodeVersionRequest) ProtoReflect

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

func (*GetNodeVersionRequest) Reset

func (x *GetNodeVersionRequest) Reset()

func (*GetNodeVersionRequest) String

func (x *GetNodeVersionRequest) String() string

type GetNodeVersionResponse

type GetNodeVersionResponse struct {
	NodeVersion string `protobuf:"bytes,1,opt,name=node_version,json=nodeVersion,proto3" json:"node_version,omitempty"`
	// backup_protocol_version is a capability gate, not a release-version
	// comparison. Zero means the node cannot safely apply live-backup FSM
	// entries; version 1 supports reservation, pin, renew, release and stream.
	BackupProtocolVersion uint32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetNodeVersionResponse) Descriptor deprecated

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

Deprecated: Use GetNodeVersionResponse.ProtoReflect.Descriptor instead.

func (*GetNodeVersionResponse) GetBackupProtocolVersion

func (x *GetNodeVersionResponse) GetBackupProtocolVersion() uint32

func (*GetNodeVersionResponse) GetNodeVersion

func (x *GetNodeVersionResponse) GetNodeVersion() string

func (*GetNodeVersionResponse) ProtoMessage

func (*GetNodeVersionResponse) ProtoMessage()

func (*GetNodeVersionResponse) ProtoReflect

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

func (*GetNodeVersionResponse) Reset

func (x *GetNodeVersionResponse) Reset()

func (*GetNodeVersionResponse) String

func (x *GetNodeVersionResponse) String() string

type GetRaftGroupsRequest

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

func (*GetRaftGroupsRequest) Descriptor deprecated

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

Deprecated: Use GetRaftGroupsRequest.ProtoReflect.Descriptor instead.

func (*GetRaftGroupsRequest) ProtoMessage

func (*GetRaftGroupsRequest) ProtoMessage()

func (*GetRaftGroupsRequest) ProtoReflect

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

func (*GetRaftGroupsRequest) Reset

func (x *GetRaftGroupsRequest) Reset()

func (*GetRaftGroupsRequest) String

func (x *GetRaftGroupsRequest) String() string

type GetRaftGroupsResponse

type GetRaftGroupsResponse struct {
	Groups []*RaftGroupState `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRaftGroupsResponse) Descriptor deprecated

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

Deprecated: Use GetRaftGroupsResponse.ProtoReflect.Descriptor instead.

func (*GetRaftGroupsResponse) GetGroups

func (x *GetRaftGroupsResponse) GetGroups() []*RaftGroupState

func (*GetRaftGroupsResponse) ProtoMessage

func (*GetRaftGroupsResponse) ProtoMessage()

func (*GetRaftGroupsResponse) ProtoReflect

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

func (*GetRaftGroupsResponse) Reset

func (x *GetRaftGroupsResponse) Reset()

func (*GetRaftGroupsResponse) String

func (x *GetRaftGroupsResponse) String() string

type GetRequest

type GetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey

func (x *GetRequest) GetKey() []byte

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

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

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {
	ReadAtIndex uint64 `protobuf:"varint,1,opt,name=read_at_index,json=readAtIndex,proto3" json:"read_at_index,omitempty"`
	Value       []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetReadAtIndex

func (x *GetResponse) GetReadAtIndex() uint64

func (*GetResponse) GetValue

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

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

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

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type GetRouteDetailRequest

type GetRouteDetailRequest struct {

	// Either a concrete route:<routeID> or a virtual:<id> emitted in a previous
	// GetKeyVizMatrix response.
	BucketId   string `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	FromUnixMs int64  `protobuf:"varint,2,opt,name=from_unix_ms,json=fromUnixMs,proto3" json:"from_unix_ms,omitempty"`
	ToUnixMs   int64  `protobuf:"varint,3,opt,name=to_unix_ms,json=toUnixMs,proto3" json:"to_unix_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRouteDetailRequest) Descriptor deprecated

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

Deprecated: Use GetRouteDetailRequest.ProtoReflect.Descriptor instead.

func (*GetRouteDetailRequest) GetBucketId

func (x *GetRouteDetailRequest) GetBucketId() string

func (*GetRouteDetailRequest) GetFromUnixMs

func (x *GetRouteDetailRequest) GetFromUnixMs() int64

func (*GetRouteDetailRequest) GetToUnixMs

func (x *GetRouteDetailRequest) GetToUnixMs() int64

func (*GetRouteDetailRequest) ProtoMessage

func (*GetRouteDetailRequest) ProtoMessage()

func (*GetRouteDetailRequest) ProtoReflect

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

func (*GetRouteDetailRequest) Reset

func (x *GetRouteDetailRequest) Reset()

func (*GetRouteDetailRequest) String

func (x *GetRouteDetailRequest) String() string

type GetRouteDetailResponse

type GetRouteDetailResponse struct {
	Row        *KeyVizRow        `protobuf:"bytes,1,opt,name=row,proto3" json:"row,omitempty"`
	PerAdapter []*AdapterSummary `protobuf:"bytes,2,rep,name=per_adapter,json=perAdapter,proto3" json:"per_adapter,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRouteDetailResponse) Descriptor deprecated

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

Deprecated: Use GetRouteDetailResponse.ProtoReflect.Descriptor instead.

func (*GetRouteDetailResponse) GetPerAdapter

func (x *GetRouteDetailResponse) GetPerAdapter() []*AdapterSummary

func (*GetRouteDetailResponse) GetRow

func (x *GetRouteDetailResponse) GetRow() *KeyVizRow

func (*GetRouteDetailResponse) ProtoMessage

func (*GetRouteDetailResponse) ProtoMessage()

func (*GetRouteDetailResponse) ProtoReflect

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

func (*GetRouteDetailResponse) Reset

func (x *GetRouteDetailResponse) Reset()

func (*GetRouteDetailResponse) String

func (x *GetRouteDetailResponse) String() string

type GetRouteOwnershipRequest

type GetRouteOwnershipRequest struct {
	Key            []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	CatalogVersion uint64 `protobuf:"varint,2,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRouteOwnershipRequest) Descriptor deprecated

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

Deprecated: Use GetRouteOwnershipRequest.ProtoReflect.Descriptor instead.

func (*GetRouteOwnershipRequest) GetCatalogVersion

func (x *GetRouteOwnershipRequest) GetCatalogVersion() uint64

func (*GetRouteOwnershipRequest) GetKey

func (x *GetRouteOwnershipRequest) GetKey() []byte

func (*GetRouteOwnershipRequest) ProtoMessage

func (*GetRouteOwnershipRequest) ProtoMessage()

func (*GetRouteOwnershipRequest) ProtoReflect

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

func (*GetRouteOwnershipRequest) Reset

func (x *GetRouteOwnershipRequest) Reset()

func (*GetRouteOwnershipRequest) String

func (x *GetRouteOwnershipRequest) String() string

type GetRouteOwnershipResponse

type GetRouteOwnershipResponse struct {
	Route          *RouteDescriptor `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"`
	CatalogVersion uint64           `protobuf:"varint,2,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	Found          bool             `protobuf:"varint,3,opt,name=found,proto3" json:"found,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRouteOwnershipResponse) Descriptor deprecated

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

Deprecated: Use GetRouteOwnershipResponse.ProtoReflect.Descriptor instead.

func (*GetRouteOwnershipResponse) GetCatalogVersion

func (x *GetRouteOwnershipResponse) GetCatalogVersion() uint64

func (*GetRouteOwnershipResponse) GetFound

func (x *GetRouteOwnershipResponse) GetFound() bool

func (*GetRouteOwnershipResponse) GetRoute

func (*GetRouteOwnershipResponse) ProtoMessage

func (*GetRouteOwnershipResponse) ProtoMessage()

func (*GetRouteOwnershipResponse) ProtoReflect

func (*GetRouteOwnershipResponse) Reset

func (x *GetRouteOwnershipResponse) Reset()

func (*GetRouteOwnershipResponse) String

func (x *GetRouteOwnershipResponse) String() string

type GetRouteRequest

type GetRouteRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRouteRequest) Descriptor deprecated

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

Deprecated: Use GetRouteRequest.ProtoReflect.Descriptor instead.

func (*GetRouteRequest) GetKey

func (x *GetRouteRequest) GetKey() []byte

func (*GetRouteRequest) ProtoMessage

func (*GetRouteRequest) ProtoMessage()

func (*GetRouteRequest) ProtoReflect

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

func (*GetRouteRequest) Reset

func (x *GetRouteRequest) Reset()

func (*GetRouteRequest) String

func (x *GetRouteRequest) String() string

type GetRouteResponse

type GetRouteResponse struct {

	// start is inclusive and end is exclusive. A missing end denotes an
	// unbounded range extending to positive infinity.
	Start       []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End         []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	RaftGroupId uint64 `protobuf:"varint,3,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRouteResponse) Descriptor deprecated

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

Deprecated: Use GetRouteResponse.ProtoReflect.Descriptor instead.

func (*GetRouteResponse) GetEnd

func (x *GetRouteResponse) GetEnd() []byte

func (*GetRouteResponse) GetRaftGroupId

func (x *GetRouteResponse) GetRaftGroupId() uint64

func (*GetRouteResponse) GetStart

func (x *GetRouteResponse) GetStart() []byte

func (*GetRouteResponse) ProtoMessage

func (*GetRouteResponse) ProtoMessage()

func (*GetRouteResponse) ProtoReflect

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

func (*GetRouteResponse) Reset

func (x *GetRouteResponse) Reset()

func (*GetRouteResponse) String

func (x *GetRouteResponse) String() string

type GetSplitJobRequest

type GetSplitJobRequest struct {
	JobId uint64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSplitJobRequest) Descriptor deprecated

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

Deprecated: Use GetSplitJobRequest.ProtoReflect.Descriptor instead.

func (*GetSplitJobRequest) GetJobId

func (x *GetSplitJobRequest) GetJobId() uint64

func (*GetSplitJobRequest) ProtoMessage

func (*GetSplitJobRequest) ProtoMessage()

func (*GetSplitJobRequest) ProtoReflect

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

func (*GetSplitJobRequest) Reset

func (x *GetSplitJobRequest) Reset()

func (*GetSplitJobRequest) String

func (x *GetSplitJobRequest) String() string

type GetSplitJobResponse

type GetSplitJobResponse struct {
	Job *SplitJob `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSplitJobResponse) Descriptor deprecated

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

Deprecated: Use GetSplitJobResponse.ProtoReflect.Descriptor instead.

func (*GetSplitJobResponse) GetJob

func (x *GetSplitJobResponse) GetJob() *SplitJob

func (*GetSplitJobResponse) ProtoMessage

func (*GetSplitJobResponse) ProtoMessage()

func (*GetSplitJobResponse) ProtoReflect

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

func (*GetSplitJobResponse) Reset

func (x *GetSplitJobResponse) Reset()

func (*GetSplitJobResponse) String

func (x *GetSplitJobResponse) String() string

type GetTimestampRequest

type GetTimestampRequest struct {

	// Count requests a consecutive timestamp window and defaults to one.
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// MinTimestamp requires the returned window base to be strictly greater
	// than this value. It lets commit timestamp callers preserve startTS <
	// commitTS across a follower-to-TSO-leader RPC.
	MinTimestamp uint64 `protobuf:"varint,2,opt,name=min_timestamp,json=minTimestamp,proto3" json:"min_timestamp,omitempty"`
	// ActivateCutover durably switches the dedicated TSO group into production
	// issuance. Once committed, shadow clients return TSO timestamps instead of
	// legacy HLC candidates, so a rolling cutover cannot reintroduce them.
	ActivateCutover bool `protobuf:"varint,3,opt,name=activate_cutover,json=activateCutover,proto3" json:"activate_cutover,omitempty"`
	// ActivatePhaseD closes the legacy compatibility window after every member
	// understands the M7 FSM entry. It requires ActivateCutover and is one-way.
	ActivatePhaseD bool `protobuf:"varint,4,opt,name=activate_phase_d,json=activatePhaseD,proto3" json:"activate_phase_d,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimestampRequest) Descriptor deprecated

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

Deprecated: Use GetTimestampRequest.ProtoReflect.Descriptor instead.

func (*GetTimestampRequest) GetActivateCutover

func (x *GetTimestampRequest) GetActivateCutover() bool

func (*GetTimestampRequest) GetActivatePhaseD

func (x *GetTimestampRequest) GetActivatePhaseD() bool

func (*GetTimestampRequest) GetCount

func (x *GetTimestampRequest) GetCount() uint32

func (*GetTimestampRequest) GetMinTimestamp

func (x *GetTimestampRequest) GetMinTimestamp() uint64

func (*GetTimestampRequest) ProtoMessage

func (*GetTimestampRequest) ProtoMessage()

func (*GetTimestampRequest) ProtoReflect

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

func (*GetTimestampRequest) Reset

func (x *GetTimestampRequest) Reset()

func (*GetTimestampRequest) String

func (x *GetTimestampRequest) String() string

type GetTimestampResponse

type GetTimestampResponse struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// CommittedByDedicatedTSO distinguishes a durable TSO window from the
	// legacy catalog timestamp response during rolling upgrades.
	CommittedByDedicatedTso bool `` /* 135-byte string literal not displayed */
	// Count echoes the number of consecutive timestamps reserved at timestamp.
	Count uint32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// PreviousAllocationFloor is the highest timestamp already reserved before
	// this request. Shadow validation uses it to reject legacy candidates that
	// overlap any earlier dedicated or shadow reservation.
	PreviousAllocationFloor uint64 `` /* 133-byte string literal not displayed */
	// CutoverActive reports the durable group-0 cutover marker after applying
	// this request. Shadow nodes switch to the returned TSO timestamp when true.
	CutoverActive bool `protobuf:"varint,5,opt,name=cutover_active,json=cutoverActive,proto3" json:"cutover_active,omitempty"`
	// PhaseDActive reports that legacy per-shard issuance has been retired.
	PhaseDActive bool `protobuf:"varint,6,opt,name=phase_d_active,json=phaseDActive,proto3" json:"phase_d_active,omitempty"`
	// PhaseDFloor is the allocation floor captured by the Phase-D marker.
	PhaseDFloor uint64 `protobuf:"varint,7,opt,name=phase_d_floor,json=phaseDFloor,proto3" json:"phase_d_floor,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimestampResponse) Descriptor deprecated

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

Deprecated: Use GetTimestampResponse.ProtoReflect.Descriptor instead.

func (*GetTimestampResponse) GetCommittedByDedicatedTso

func (x *GetTimestampResponse) GetCommittedByDedicatedTso() bool

func (*GetTimestampResponse) GetCount

func (x *GetTimestampResponse) GetCount() uint32

func (*GetTimestampResponse) GetCutoverActive

func (x *GetTimestampResponse) GetCutoverActive() bool

func (*GetTimestampResponse) GetPhaseDActive

func (x *GetTimestampResponse) GetPhaseDActive() bool

func (*GetTimestampResponse) GetPhaseDFloor

func (x *GetTimestampResponse) GetPhaseDFloor() uint64

func (*GetTimestampResponse) GetPreviousAllocationFloor

func (x *GetTimestampResponse) GetPreviousAllocationFloor() uint64

func (*GetTimestampResponse) GetTimestamp

func (x *GetTimestampResponse) GetTimestamp() uint64

func (*GetTimestampResponse) ProtoMessage

func (*GetTimestampResponse) ProtoMessage()

func (*GetTimestampResponse) ProtoReflect

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

func (*GetTimestampResponse) Reset

func (x *GetTimestampResponse) Reset()

func (*GetTimestampResponse) String

func (x *GetTimestampResponse) String() string

type GroupLeader

type GroupLeader struct {
	RaftGroupId  uint64 `protobuf:"varint,1,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	LeaderNodeId string `protobuf:"bytes,2,opt,name=leader_node_id,json=leaderNodeId,proto3" json:"leader_node_id,omitempty"`
	LeaderTerm   uint64 `protobuf:"varint,3,opt,name=leader_term,json=leaderTerm,proto3" json:"leader_term,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupLeader) Descriptor deprecated

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

Deprecated: Use GroupLeader.ProtoReflect.Descriptor instead.

func (*GroupLeader) GetLeaderNodeId

func (x *GroupLeader) GetLeaderNodeId() string

func (*GroupLeader) GetLeaderTerm

func (x *GroupLeader) GetLeaderTerm() uint64

func (*GroupLeader) GetRaftGroupId

func (x *GroupLeader) GetRaftGroupId() uint64

func (*GroupLeader) ProtoMessage

func (*GroupLeader) ProtoMessage()

func (*GroupLeader) ProtoReflect

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

func (*GroupLeader) Reset

func (x *GroupLeader) Reset()

func (*GroupLeader) String

func (x *GroupLeader) String() string

type ImportRangeVersionsRequest

type ImportRangeVersionsRequest struct {
	JobId     uint64         `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Versions  []*MVCCVersion `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	Cursor    []byte         `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	BracketId uint64         `protobuf:"varint,4,opt,name=bracket_id,json=bracketId,proto3" json:"bracket_id,omitempty"`
	BatchSeq  uint64         `protobuf:"varint,5,opt,name=batch_seq,json=batchSeq,proto3" json:"batch_seq,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportRangeVersionsRequest) Descriptor deprecated

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

Deprecated: Use ImportRangeVersionsRequest.ProtoReflect.Descriptor instead.

func (*ImportRangeVersionsRequest) GetBatchSeq

func (x *ImportRangeVersionsRequest) GetBatchSeq() uint64

func (*ImportRangeVersionsRequest) GetBracketId

func (x *ImportRangeVersionsRequest) GetBracketId() uint64

func (*ImportRangeVersionsRequest) GetCursor

func (x *ImportRangeVersionsRequest) GetCursor() []byte

func (*ImportRangeVersionsRequest) GetJobId

func (x *ImportRangeVersionsRequest) GetJobId() uint64

func (*ImportRangeVersionsRequest) GetVersions

func (x *ImportRangeVersionsRequest) GetVersions() []*MVCCVersion

func (*ImportRangeVersionsRequest) ProtoMessage

func (*ImportRangeVersionsRequest) ProtoMessage()

func (*ImportRangeVersionsRequest) ProtoReflect

func (*ImportRangeVersionsRequest) Reset

func (x *ImportRangeVersionsRequest) Reset()

func (*ImportRangeVersionsRequest) String

func (x *ImportRangeVersionsRequest) String() string

type ImportRangeVersionsResponse

type ImportRangeVersionsResponse struct {
	AckedCursor []byte `protobuf:"bytes,1,opt,name=acked_cursor,json=ackedCursor,proto3" json:"acked_cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportRangeVersionsResponse) Descriptor deprecated

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

Deprecated: Use ImportRangeVersionsResponse.ProtoReflect.Descriptor instead.

func (*ImportRangeVersionsResponse) GetAckedCursor

func (x *ImportRangeVersionsResponse) GetAckedCursor() []byte

func (*ImportRangeVersionsResponse) ProtoMessage

func (*ImportRangeVersionsResponse) ProtoMessage()

func (*ImportRangeVersionsResponse) ProtoReflect

func (*ImportRangeVersionsResponse) Reset

func (x *ImportRangeVersionsResponse) Reset()

func (*ImportRangeVersionsResponse) String

func (x *ImportRangeVersionsResponse) String() string

type InternalClient

type InternalClient interface {
	// for internal leader redirect only
	Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*ForwardResponse, error)
	ForwardAdminProposal(ctx context.Context, in *ForwardAdminProposalRequest, opts ...grpc.CallOption) (*ForwardAdminProposalResponse, error)
	ForwardLeaseRead(ctx context.Context, in *ForwardLeaseReadRequest, opts ...grpc.CallOption) (*ForwardLeaseReadResponse, error)
	RelayPublish(ctx context.Context, in *RelayPublishRequest, opts ...grpc.CallOption) (*RelayPublishResponse, error)
	ExportRangeVersions(ctx context.Context, in *ExportRangeVersionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExportRangeVersionsResponse], error)
	ImportRangeVersions(ctx context.Context, in *ImportRangeVersionsRequest, opts ...grpc.CallOption) (*ImportRangeVersionsResponse, error)
}

InternalClient is the client API for Internal service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewInternalClient

func NewInternalClient(cc grpc.ClientConnInterface) InternalClient

type InternalServer

type InternalServer interface {
	// for internal leader redirect only
	Forward(context.Context, *ForwardRequest) (*ForwardResponse, error)
	ForwardAdminProposal(context.Context, *ForwardAdminProposalRequest) (*ForwardAdminProposalResponse, error)
	ForwardLeaseRead(context.Context, *ForwardLeaseReadRequest) (*ForwardLeaseReadResponse, error)
	RelayPublish(context.Context, *RelayPublishRequest) (*RelayPublishResponse, error)
	ExportRangeVersions(*ExportRangeVersionsRequest, grpc.ServerStreamingServer[ExportRangeVersionsResponse]) error
	ImportRangeVersions(context.Context, *ImportRangeVersionsRequest) (*ImportRangeVersionsResponse, error)
	// contains filtered or unexported methods
}

InternalServer is the server API for Internal service. All implementations must embed UnimplementedInternalServer for forward compatibility.

type Internal_ExportRangeVersionsClient

type Internal_ExportRangeVersionsClient = grpc.ServerStreamingClient[ExportRangeVersionsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Internal_ExportRangeVersionsServer

type Internal_ExportRangeVersionsServer = grpc.ServerStreamingServer[ExportRangeVersionsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KeyError

type KeyError struct {
	Message   string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Retryable bool   `protobuf:"varint,2,opt,name=retryable,proto3" json:"retryable,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyError) Descriptor deprecated

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

Deprecated: Use KeyError.ProtoReflect.Descriptor instead.

func (*KeyError) GetMessage

func (x *KeyError) GetMessage() string

func (*KeyError) GetRetryable

func (x *KeyError) GetRetryable() bool

func (*KeyError) ProtoMessage

func (*KeyError) ProtoMessage()

func (*KeyError) ProtoReflect

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

func (*KeyError) Reset

func (x *KeyError) Reset()

func (*KeyError) String

func (x *KeyError) String() string

type KeyVizColumn

type KeyVizColumn struct {
	ColumnUnixMs int64        `protobuf:"varint,1,opt,name=column_unix_ms,json=columnUnixMs,proto3" json:"column_unix_ms,omitempty"`
	Series       KeyVizSeries `protobuf:"varint,2,opt,name=series,proto3,enum=KeyVizSeries" json:"series,omitempty"`
	Rows         []*KeyVizRow `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyVizColumn) Descriptor deprecated

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

Deprecated: Use KeyVizColumn.ProtoReflect.Descriptor instead.

func (*KeyVizColumn) GetColumnUnixMs

func (x *KeyVizColumn) GetColumnUnixMs() int64

func (*KeyVizColumn) GetRows

func (x *KeyVizColumn) GetRows() []*KeyVizRow

func (*KeyVizColumn) GetSeries

func (x *KeyVizColumn) GetSeries() KeyVizSeries

func (*KeyVizColumn) ProtoMessage

func (*KeyVizColumn) ProtoMessage()

func (*KeyVizColumn) ProtoReflect

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

func (*KeyVizColumn) Reset

func (x *KeyVizColumn) Reset()

func (*KeyVizColumn) String

func (x *KeyVizColumn) String() string

type KeyVizRow

type KeyVizRow struct {

	// bucket_id is "route:<routeID>", "route:<routeID>:<label>", or
	// "virtual:<lineageID-or-hash>".
	BucketId string `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	Start    []byte `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End      []byte `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// label is the per-adapter KeyViz label; empty for legacy and virtual rows.
	Label             string       `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	Aggregate         bool         `protobuf:"varint,5,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	RouteIds          []uint64     `protobuf:"varint,6,rep,packed,name=route_ids,json=routeIds,proto3" json:"route_ids,omitempty"`
	RouteIdsTruncated bool         `protobuf:"varint,7,opt,name=route_ids_truncated,json=routeIdsTruncated,proto3" json:"route_ids_truncated,omitempty"`
	RouteCount        uint64       `protobuf:"varint,8,opt,name=route_count,json=routeCount,proto3" json:"route_count,omitempty"`
	SampleRoles       []SampleRole `protobuf:"varint,9,rep,packed,name=sample_roles,json=sampleRoles,proto3,enum=SampleRole" json:"sample_roles,omitempty"`
	LineageId         string       `protobuf:"bytes,10,opt,name=lineage_id,json=lineageId,proto3" json:"lineage_id,omitempty"`
	// values[j] is the series value at time column j.
	Values []uint64 `protobuf:"varint,11,rep,packed,name=values,proto3" json:"values,omitempty"`
	// soft_columns[j] is true when the j-th column missed the estimator SLO.
	SoftColumns []bool `protobuf:"varint,12,rep,packed,name=soft_columns,json=softColumns,proto3" json:"soft_columns,omitempty"`
	// raft_group_ids[j] and leader_terms[j] carry the route's Raft
	// identity at the time column j was flushed. Phase 2-C+ fan-out
	// uses (bucket_id, raft_group_id, leader_term, column) as the
	// dedupe key, so writes from a leader and the previous leader of
	// the same group can be summed across terms instead of
	// conservatively max-merged. Per-cell representation (parallel to
	// values[] and soft_columns[]) is required because leadership can
	// flip within the requested window; a single row-level scalar
	// would only capture the first column's identity and cause
	// incorrect dedupe for later columns (Gemini HIGH on PR #720).
	// Zero values mean "term not tracked" (single-group legacy
	// deployments, virtual aggregate buckets, or nodes that have not
	// yet wired the leader-term publisher) — the aggregator falls
	// back to the legacy max-merge for those cells.
	//
	// Both slices are either empty (legacy server, no per-column
	// identity to share — older clients reading the response can
	// treat empty as "all zeros") or `len(raft_group_ids) ==
	// len(leader_terms) == len(values)`. The server never emits a
	// partial-length slice.
	RaftGroupIds []uint64 `protobuf:"varint,13,rep,packed,name=raft_group_ids,json=raftGroupIds,proto3" json:"raft_group_ids,omitempty"`
	LeaderTerms  []uint64 `protobuf:"varint,14,rep,packed,name=leader_terms,json=leaderTerms,proto3" json:"leader_terms,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyVizRow) Descriptor deprecated

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

Deprecated: Use KeyVizRow.ProtoReflect.Descriptor instead.

func (*KeyVizRow) GetAggregate

func (x *KeyVizRow) GetAggregate() bool

func (*KeyVizRow) GetBucketId

func (x *KeyVizRow) GetBucketId() string

func (*KeyVizRow) GetEnd

func (x *KeyVizRow) GetEnd() []byte

func (*KeyVizRow) GetLabel

func (x *KeyVizRow) GetLabel() string

func (*KeyVizRow) GetLeaderTerms

func (x *KeyVizRow) GetLeaderTerms() []uint64

func (*KeyVizRow) GetLineageId

func (x *KeyVizRow) GetLineageId() string

func (*KeyVizRow) GetRaftGroupIds

func (x *KeyVizRow) GetRaftGroupIds() []uint64

func (*KeyVizRow) GetRouteCount

func (x *KeyVizRow) GetRouteCount() uint64

func (*KeyVizRow) GetRouteIds

func (x *KeyVizRow) GetRouteIds() []uint64

func (*KeyVizRow) GetRouteIdsTruncated

func (x *KeyVizRow) GetRouteIdsTruncated() bool

func (*KeyVizRow) GetSampleRoles

func (x *KeyVizRow) GetSampleRoles() []SampleRole

func (*KeyVizRow) GetSoftColumns

func (x *KeyVizRow) GetSoftColumns() []bool

func (*KeyVizRow) GetStart

func (x *KeyVizRow) GetStart() []byte

func (*KeyVizRow) GetValues

func (x *KeyVizRow) GetValues() []uint64

func (*KeyVizRow) ProtoMessage

func (*KeyVizRow) ProtoMessage()

func (*KeyVizRow) ProtoReflect

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

func (*KeyVizRow) Reset

func (x *KeyVizRow) Reset()

func (*KeyVizRow) String

func (x *KeyVizRow) String() string

type KeyVizSeries

type KeyVizSeries int32
const (
	KeyVizSeries_KEYVIZ_SERIES_UNSPECIFIED KeyVizSeries = 0
	KeyVizSeries_KEYVIZ_SERIES_READS       KeyVizSeries = 1
	KeyVizSeries_KEYVIZ_SERIES_WRITES      KeyVizSeries = 2
	KeyVizSeries_KEYVIZ_SERIES_READ_BYTES  KeyVizSeries = 3
	KeyVizSeries_KEYVIZ_SERIES_WRITE_BYTES KeyVizSeries = 4
)

func (KeyVizSeries) Descriptor

func (KeyVizSeries) Enum

func (x KeyVizSeries) Enum() *KeyVizSeries

func (KeyVizSeries) EnumDescriptor deprecated

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

Deprecated: Use KeyVizSeries.Descriptor instead.

func (KeyVizSeries) Number

func (KeyVizSeries) String

func (x KeyVizSeries) String() string

func (KeyVizSeries) Type

type Kv

type Kv struct {
	Error *KeyError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Key   []byte    `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Kv) Descriptor deprecated

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

Deprecated: Use Kv.ProtoReflect.Descriptor instead.

func (*Kv) GetError

func (x *Kv) GetError() *KeyError

func (*Kv) GetKey

func (x *Kv) GetKey() []byte

func (*Kv) GetValue

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

func (*Kv) ProtoMessage

func (*Kv) ProtoMessage()

func (*Kv) ProtoReflect

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

func (*Kv) Reset

func (x *Kv) Reset()

func (*Kv) String

func (x *Kv) String() string

type ListAdaptersAndScopesRequest

type ListAdaptersAndScopesRequest struct {
	PinToken []byte `protobuf:"bytes,1,opt,name=pin_token,json=pinToken,proto3" json:"pin_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAdaptersAndScopesRequest) Descriptor deprecated

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

Deprecated: Use ListAdaptersAndScopesRequest.ProtoReflect.Descriptor instead.

func (*ListAdaptersAndScopesRequest) GetPinToken

func (x *ListAdaptersAndScopesRequest) GetPinToken() []byte

func (*ListAdaptersAndScopesRequest) ProtoMessage

func (*ListAdaptersAndScopesRequest) ProtoMessage()

func (*ListAdaptersAndScopesRequest) ProtoReflect

func (*ListAdaptersAndScopesRequest) Reset

func (x *ListAdaptersAndScopesRequest) Reset()

func (*ListAdaptersAndScopesRequest) String

type ListAdaptersAndScopesResponse

type ListAdaptersAndScopesResponse struct {
	Scopes []*BackupScope `protobuf:"bytes,1,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAdaptersAndScopesResponse) Descriptor deprecated

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

Deprecated: Use ListAdaptersAndScopesResponse.ProtoReflect.Descriptor instead.

func (*ListAdaptersAndScopesResponse) GetScopes

func (x *ListAdaptersAndScopesResponse) GetScopes() []*BackupScope

func (*ListAdaptersAndScopesResponse) ProtoMessage

func (*ListAdaptersAndScopesResponse) ProtoMessage()

func (*ListAdaptersAndScopesResponse) ProtoReflect

func (*ListAdaptersAndScopesResponse) Reset

func (x *ListAdaptersAndScopesResponse) Reset()

func (*ListAdaptersAndScopesResponse) String

type ListRoutesRequest

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

func (*ListRoutesRequest) Descriptor deprecated

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

Deprecated: Use ListRoutesRequest.ProtoReflect.Descriptor instead.

func (*ListRoutesRequest) ProtoMessage

func (*ListRoutesRequest) ProtoMessage()

func (*ListRoutesRequest) ProtoReflect

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

func (*ListRoutesRequest) Reset

func (x *ListRoutesRequest) Reset()

func (*ListRoutesRequest) String

func (x *ListRoutesRequest) String() string

type ListRoutesResponse

type ListRoutesResponse struct {
	CatalogVersion uint64             `protobuf:"varint,1,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	Routes         []*RouteDescriptor `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRoutesResponse) Descriptor deprecated

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

Deprecated: Use ListRoutesResponse.ProtoReflect.Descriptor instead.

func (*ListRoutesResponse) GetCatalogVersion

func (x *ListRoutesResponse) GetCatalogVersion() uint64

func (*ListRoutesResponse) GetRoutes

func (x *ListRoutesResponse) GetRoutes() []*RouteDescriptor

func (*ListRoutesResponse) ProtoMessage

func (*ListRoutesResponse) ProtoMessage()

func (*ListRoutesResponse) ProtoReflect

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

func (*ListRoutesResponse) Reset

func (x *ListRoutesResponse) Reset()

func (*ListRoutesResponse) String

func (x *ListRoutesResponse) String() string

type ListSplitJobsRequest

type ListSplitJobsRequest struct {
	SinceTerminalAtMs uint64 `protobuf:"varint,1,opt,name=since_terminal_at_ms,json=sinceTerminalAtMs,proto3" json:"since_terminal_at_ms,omitempty"`
	Phase             string `protobuf:"bytes,2,opt,name=phase,proto3" json:"phase,omitempty"`
	PageCursor        []byte `protobuf:"bytes,3,opt,name=page_cursor,json=pageCursor,proto3" json:"page_cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSplitJobsRequest) Descriptor deprecated

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

Deprecated: Use ListSplitJobsRequest.ProtoReflect.Descriptor instead.

func (*ListSplitJobsRequest) GetPageCursor

func (x *ListSplitJobsRequest) GetPageCursor() []byte

func (*ListSplitJobsRequest) GetPhase

func (x *ListSplitJobsRequest) GetPhase() string

func (*ListSplitJobsRequest) GetSinceTerminalAtMs

func (x *ListSplitJobsRequest) GetSinceTerminalAtMs() uint64

func (*ListSplitJobsRequest) ProtoMessage

func (*ListSplitJobsRequest) ProtoMessage()

func (*ListSplitJobsRequest) ProtoReflect

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

func (*ListSplitJobsRequest) Reset

func (x *ListSplitJobsRequest) Reset()

func (*ListSplitJobsRequest) String

func (x *ListSplitJobsRequest) String() string

type ListSplitJobsResponse

type ListSplitJobsResponse struct {
	Jobs           []*SplitJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	NextPageCursor []byte      `protobuf:"bytes,2,opt,name=next_page_cursor,json=nextPageCursor,proto3" json:"next_page_cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSplitJobsResponse) Descriptor deprecated

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

Deprecated: Use ListSplitJobsResponse.ProtoReflect.Descriptor instead.

func (*ListSplitJobsResponse) GetJobs

func (x *ListSplitJobsResponse) GetJobs() []*SplitJob

func (*ListSplitJobsResponse) GetNextPageCursor

func (x *ListSplitJobsResponse) GetNextPageCursor() []byte

func (*ListSplitJobsResponse) ProtoMessage

func (*ListSplitJobsResponse) ProtoMessage()

func (*ListSplitJobsResponse) ProtoReflect

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

func (*ListSplitJobsResponse) Reset

func (x *ListSplitJobsResponse) Reset()

func (*ListSplitJobsResponse) String

func (x *ListSplitJobsResponse) String() string

type MVCCVersion

type MVCCVersion struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	CommitTs  uint64 `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	Tombstone bool   `protobuf:"varint,3,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	Value     []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	KeyFamily uint32 `protobuf:"varint,5,opt,name=key_family,json=keyFamily,proto3" json:"key_family,omitempty"`
	ExpireAt  uint64 `protobuf:"varint,6,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	// contains filtered or unexported fields
}

func (*MVCCVersion) Descriptor deprecated

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

Deprecated: Use MVCCVersion.ProtoReflect.Descriptor instead.

func (*MVCCVersion) GetCommitTs

func (x *MVCCVersion) GetCommitTs() uint64

func (*MVCCVersion) GetExpireAt

func (x *MVCCVersion) GetExpireAt() uint64

func (*MVCCVersion) GetKey

func (x *MVCCVersion) GetKey() []byte

func (*MVCCVersion) GetKeyFamily

func (x *MVCCVersion) GetKeyFamily() uint32

func (*MVCCVersion) GetTombstone

func (x *MVCCVersion) GetTombstone() bool

func (*MVCCVersion) GetValue

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

func (*MVCCVersion) ProtoMessage

func (*MVCCVersion) ProtoMessage()

func (*MVCCVersion) ProtoReflect

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

func (*MVCCVersion) Reset

func (x *MVCCVersion) Reset()

func (*MVCCVersion) String

func (x *MVCCVersion) String() string

type Mutation

type Mutation struct {
	Op    Op     `protobuf:"varint,1,opt,name=op,proto3,enum=Op" json:"op,omitempty"`
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// commit_ts_value_offset, when non-zero, asks the committing leader to write
	// the resolved transaction commit timestamp into value[offset:offset+8] as a
	// big-endian uint64 before the request is committed. This is used for values
	// that durably embed their own creation timestamp but still need leader-side
	// timestamp allocation after redirect/retry.
	CommitTsValueOffset uint64 `protobuf:"varint,4,opt,name=commit_ts_value_offset,json=commitTsValueOffset,proto3" json:"commit_ts_value_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation) Descriptor deprecated

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

Deprecated: Use Mutation.ProtoReflect.Descriptor instead.

func (*Mutation) GetCommitTsValueOffset

func (x *Mutation) GetCommitTsValueOffset() uint64

func (*Mutation) GetKey

func (x *Mutation) GetKey() []byte

func (*Mutation) GetOp

func (x *Mutation) GetOp() Op

func (*Mutation) GetValue

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

func (*Mutation) ProtoMessage

func (*Mutation) ProtoMessage()

func (*Mutation) ProtoReflect

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

func (*Mutation) Reset

func (x *Mutation) Reset()

func (*Mutation) String

func (x *Mutation) String() string

type NodeIdentity

type NodeIdentity struct {
	NodeId      string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	GrpcAddress string `protobuf:"bytes,2,opt,name=grpc_address,json=grpcAddress,proto3" json:"grpc_address,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeIdentity) Descriptor deprecated

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

Deprecated: Use NodeIdentity.ProtoReflect.Descriptor instead.

func (*NodeIdentity) GetGrpcAddress

func (x *NodeIdentity) GetGrpcAddress() string

func (*NodeIdentity) GetNodeId

func (x *NodeIdentity) GetNodeId() string

func (*NodeIdentity) ProtoMessage

func (*NodeIdentity) ProtoMessage()

func (*NodeIdentity) ProtoReflect

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

func (*NodeIdentity) Reset

func (x *NodeIdentity) Reset()

func (*NodeIdentity) String

func (x *NodeIdentity) String() string

type Op

type Op int32

internal.proto is node to node communication message in raft replication.

const (
	Op_PUT Op = 0
	Op_DEL Op = 1
	// DEL_PREFIX deletes all visible keys matching the prefix stored in `key`.
	// An empty key means "all keys". Transaction-internal keys (!txn|) are
	// always excluded.  This operation is applied locally by the FSM on each
	// node, so the Raft log contains only a single mutation regardless of how
	// many keys are deleted.
	Op_DEL_PREFIX Op = 2
)

func (Op) Descriptor

func (Op) Descriptor() protoreflect.EnumDescriptor

func (Op) Enum

func (x Op) Enum() *Op

func (Op) EnumDescriptor deprecated

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

Deprecated: Use Op.Descriptor instead.

func (Op) Number

func (x Op) Number() protoreflect.EnumNumber

func (Op) String

func (x Op) String() string

func (Op) Type

func (Op) Type() protoreflect.EnumType

type Phase

type Phase int32
const (
	Phase_NONE    Phase = 0
	Phase_PREPARE Phase = 1
	Phase_COMMIT  Phase = 2
	Phase_ABORT   Phase = 3
)

func (Phase) Descriptor

func (Phase) Descriptor() protoreflect.EnumDescriptor

func (Phase) Enum

func (x Phase) Enum() *Phase

func (Phase) EnumDescriptor deprecated

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

Deprecated: Use Phase.Descriptor instead.

func (Phase) Number

func (x Phase) Number() protoreflect.EnumNumber

func (Phase) String

func (x Phase) String() string

func (Phase) Type

func (Phase) Type() protoreflect.EnumType

type PreCommitResponse

type PreCommitResponse struct {
	Errors []*KeyError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*PreCommitResponse) Descriptor deprecated

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

Deprecated: Use PreCommitResponse.ProtoReflect.Descriptor instead.

func (*PreCommitResponse) GetErrors

func (x *PreCommitResponse) GetErrors() []*KeyError

func (*PreCommitResponse) ProtoMessage

func (*PreCommitResponse) ProtoMessage()

func (*PreCommitResponse) ProtoReflect

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

func (*PreCommitResponse) Reset

func (x *PreCommitResponse) Reset()

func (*PreCommitResponse) String

func (x *PreCommitResponse) String() string

type PreWriteRequest

type PreWriteRequest struct {

	// mutations is the list of mutations to apply atomically.
	Mutations []*Kv `protobuf:"bytes,2,rep,name=mutations,proto3" json:"mutations,omitempty"`
	// start_ts is the timestamp of the transaction.
	StartTs uint64 `protobuf:"varint,3,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// lock_ttl is the TTL of the lock in milliseconds.
	LockTtl uint64 `protobuf:"varint,4,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*PreWriteRequest) Descriptor deprecated

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

Deprecated: Use PreWriteRequest.ProtoReflect.Descriptor instead.

func (*PreWriteRequest) GetLockTtl

func (x *PreWriteRequest) GetLockTtl() uint64

func (*PreWriteRequest) GetMutations

func (x *PreWriteRequest) GetMutations() []*Kv

func (*PreWriteRequest) GetStartTs

func (x *PreWriteRequest) GetStartTs() uint64

func (*PreWriteRequest) ProtoMessage

func (*PreWriteRequest) ProtoMessage()

func (*PreWriteRequest) ProtoReflect

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

func (*PreWriteRequest) Reset

func (x *PreWriteRequest) Reset()

func (*PreWriteRequest) String

func (x *PreWriteRequest) String() string

type PushChunkBlobRequest

type PushChunkBlobRequest struct {
	ContentSha256 []byte `protobuf:"bytes,1,opt,name=content_sha256,json=contentSha256,proto3" json:"content_sha256,omitempty"`
	Payload       []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Eof           bool   `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"`
	CommitTs      uint64 `protobuf:"varint,4,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*PushChunkBlobRequest) Descriptor deprecated

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

Deprecated: Use PushChunkBlobRequest.ProtoReflect.Descriptor instead.

func (*PushChunkBlobRequest) GetCommitTs

func (x *PushChunkBlobRequest) GetCommitTs() uint64

func (*PushChunkBlobRequest) GetContentSha256

func (x *PushChunkBlobRequest) GetContentSha256() []byte

func (*PushChunkBlobRequest) GetEof

func (x *PushChunkBlobRequest) GetEof() bool

func (*PushChunkBlobRequest) GetPayload

func (x *PushChunkBlobRequest) GetPayload() []byte

func (*PushChunkBlobRequest) ProtoMessage

func (*PushChunkBlobRequest) ProtoMessage()

func (*PushChunkBlobRequest) ProtoReflect

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

func (*PushChunkBlobRequest) Reset

func (x *PushChunkBlobRequest) Reset()

func (*PushChunkBlobRequest) String

func (x *PushChunkBlobRequest) String() string

type PushChunkBlobResponse

type PushChunkBlobResponse struct {
	Durable bool `protobuf:"varint,1,opt,name=durable,proto3" json:"durable,omitempty"`
	// contains filtered or unexported fields
}

func (*PushChunkBlobResponse) Descriptor deprecated

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

Deprecated: Use PushChunkBlobResponse.ProtoReflect.Descriptor instead.

func (*PushChunkBlobResponse) GetDurable

func (x *PushChunkBlobResponse) GetDurable() bool

func (*PushChunkBlobResponse) ProtoMessage

func (*PushChunkBlobResponse) ProtoMessage()

func (*PushChunkBlobResponse) ProtoReflect

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

func (*PushChunkBlobResponse) Reset

func (x *PushChunkBlobResponse) Reset()

func (*PushChunkBlobResponse) String

func (x *PushChunkBlobResponse) String() string

type PutRequest

type PutRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetValue

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

func (*PutRequest) ProtoMessage

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect

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

func (*PutRequest) Reset

func (x *PutRequest) Reset()

func (*PutRequest) String

func (x *PutRequest) String() string

type PutResponse

type PutResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetCommitIndex

func (x *PutResponse) GetCommitIndex() uint64

func (*PutResponse) GetSuccess

func (x *PutResponse) GetSuccess() bool

func (*PutResponse) ProtoMessage

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect

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

func (*PutResponse) Reset

func (x *PutResponse) Reset()

func (*PutResponse) String

func (x *PutResponse) String() string

type RaftAdminAddLearnerRequest

type RaftAdminAddLearnerRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,3,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminAddLearnerRequest) Descriptor deprecated

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

Deprecated: Use RaftAdminAddLearnerRequest.ProtoReflect.Descriptor instead.

func (*RaftAdminAddLearnerRequest) GetAddress

func (x *RaftAdminAddLearnerRequest) GetAddress() string

func (*RaftAdminAddLearnerRequest) GetId

func (*RaftAdminAddLearnerRequest) GetPreviousIndex

func (x *RaftAdminAddLearnerRequest) GetPreviousIndex() uint64

func (*RaftAdminAddLearnerRequest) ProtoMessage

func (*RaftAdminAddLearnerRequest) ProtoMessage()

func (*RaftAdminAddLearnerRequest) ProtoReflect

func (*RaftAdminAddLearnerRequest) Reset

func (x *RaftAdminAddLearnerRequest) Reset()

func (*RaftAdminAddLearnerRequest) String

func (x *RaftAdminAddLearnerRequest) String() string

type RaftAdminAddVoterRequest

type RaftAdminAddVoterRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,3,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminAddVoterRequest) Descriptor deprecated

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

Deprecated: Use RaftAdminAddVoterRequest.ProtoReflect.Descriptor instead.

func (*RaftAdminAddVoterRequest) GetAddress

func (x *RaftAdminAddVoterRequest) GetAddress() string

func (*RaftAdminAddVoterRequest) GetId

func (x *RaftAdminAddVoterRequest) GetId() string

func (*RaftAdminAddVoterRequest) GetPreviousIndex

func (x *RaftAdminAddVoterRequest) GetPreviousIndex() uint64

func (*RaftAdminAddVoterRequest) ProtoMessage

func (*RaftAdminAddVoterRequest) ProtoMessage()

func (*RaftAdminAddVoterRequest) ProtoReflect

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

func (*RaftAdminAddVoterRequest) Reset

func (x *RaftAdminAddVoterRequest) Reset()

func (*RaftAdminAddVoterRequest) String

func (x *RaftAdminAddVoterRequest) String() string

type RaftAdminConfigurationChangeResponse

type RaftAdminConfigurationChangeResponse struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminConfigurationChangeResponse) Descriptor deprecated

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

Deprecated: Use RaftAdminConfigurationChangeResponse.ProtoReflect.Descriptor instead.

func (*RaftAdminConfigurationChangeResponse) GetIndex

func (*RaftAdminConfigurationChangeResponse) ProtoMessage

func (*RaftAdminConfigurationChangeResponse) ProtoMessage()

func (*RaftAdminConfigurationChangeResponse) ProtoReflect

func (*RaftAdminConfigurationChangeResponse) Reset

func (*RaftAdminConfigurationChangeResponse) String

type RaftAdminConfigurationRequest

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

func (*RaftAdminConfigurationRequest) Descriptor deprecated

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

Deprecated: Use RaftAdminConfigurationRequest.ProtoReflect.Descriptor instead.

func (*RaftAdminConfigurationRequest) ProtoMessage

func (*RaftAdminConfigurationRequest) ProtoMessage()

func (*RaftAdminConfigurationRequest) ProtoReflect

func (*RaftAdminConfigurationRequest) Reset

func (x *RaftAdminConfigurationRequest) Reset()

func (*RaftAdminConfigurationRequest) String

type RaftAdminConfigurationResponse

type RaftAdminConfigurationResponse struct {
	Servers []*RaftAdminMember `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminConfigurationResponse) Descriptor deprecated

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

Deprecated: Use RaftAdminConfigurationResponse.ProtoReflect.Descriptor instead.

func (*RaftAdminConfigurationResponse) GetServers

func (*RaftAdminConfigurationResponse) ProtoMessage

func (*RaftAdminConfigurationResponse) ProtoMessage()

func (*RaftAdminConfigurationResponse) ProtoReflect

func (*RaftAdminConfigurationResponse) Reset

func (x *RaftAdminConfigurationResponse) Reset()

func (*RaftAdminConfigurationResponse) String

type RaftAdminMember

type RaftAdminMember struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address  string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Suffrage string `protobuf:"bytes,3,opt,name=suffrage,proto3" json:"suffrage,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminMember) Descriptor deprecated

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

Deprecated: Use RaftAdminMember.ProtoReflect.Descriptor instead.

func (*RaftAdminMember) GetAddress

func (x *RaftAdminMember) GetAddress() string

func (*RaftAdminMember) GetId

func (x *RaftAdminMember) GetId() string

func (*RaftAdminMember) GetSuffrage

func (x *RaftAdminMember) GetSuffrage() string

func (*RaftAdminMember) ProtoMessage

func (*RaftAdminMember) ProtoMessage()

func (*RaftAdminMember) ProtoReflect

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

func (*RaftAdminMember) Reset

func (x *RaftAdminMember) Reset()

func (*RaftAdminMember) String

func (x *RaftAdminMember) String() string

type RaftAdminPromoteLearnerRequest

type RaftAdminPromoteLearnerRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,2,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// min_applied_index is the catch-up precondition: the learner's
	// leader-side Progress.Match must be >= min_applied_index for the
	// promote conf change to be proposed. The server REJECTS
	// min_applied_index == 0 unless skip_min_applied_check is also
	// set, so an operator who copy-pastes a script that omits the
	// catch-up check gets a clean FailedPrecondition instead of a
	// silent quorum stall. See learner runbook step 5.
	MinAppliedIndex uint64 `protobuf:"varint,3,opt,name=min_applied_index,json=minAppliedIndex,proto3" json:"min_applied_index,omitempty"`
	// skip_min_applied_check explicitly opts out of the catch-up
	// precondition. Strongly discouraged in production -- only set
	// when promoting a learner that the operator has independently
	// confirmed is up to date (e.g., bootstrap-time scaffolding).
	SkipMinAppliedCheck bool `protobuf:"varint,4,opt,name=skip_min_applied_check,json=skipMinAppliedCheck,proto3" json:"skip_min_applied_check,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminPromoteLearnerRequest) Descriptor deprecated

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

Deprecated: Use RaftAdminPromoteLearnerRequest.ProtoReflect.Descriptor instead.

func (*RaftAdminPromoteLearnerRequest) GetId

func (*RaftAdminPromoteLearnerRequest) GetMinAppliedIndex

func (x *RaftAdminPromoteLearnerRequest) GetMinAppliedIndex() uint64

func (*RaftAdminPromoteLearnerRequest) GetPreviousIndex

func (x *RaftAdminPromoteLearnerRequest) GetPreviousIndex() uint64

func (*RaftAdminPromoteLearnerRequest) GetSkipMinAppliedCheck

func (x *RaftAdminPromoteLearnerRequest) GetSkipMinAppliedCheck() bool

func (*RaftAdminPromoteLearnerRequest) ProtoMessage

func (*RaftAdminPromoteLearnerRequest) ProtoMessage()

func (*RaftAdminPromoteLearnerRequest) ProtoReflect

func (*RaftAdminPromoteLearnerRequest) Reset

func (x *RaftAdminPromoteLearnerRequest) Reset()

func (*RaftAdminPromoteLearnerRequest) String

type RaftAdminRemoveServerRequest

type RaftAdminRemoveServerRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,2,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminRemoveServerRequest) Descriptor deprecated

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

Deprecated: Use RaftAdminRemoveServerRequest.ProtoReflect.Descriptor instead.

func (*RaftAdminRemoveServerRequest) GetId

func (*RaftAdminRemoveServerRequest) GetPreviousIndex

func (x *RaftAdminRemoveServerRequest) GetPreviousIndex() uint64

func (*RaftAdminRemoveServerRequest) ProtoMessage

func (*RaftAdminRemoveServerRequest) ProtoMessage()

func (*RaftAdminRemoveServerRequest) ProtoReflect

func (*RaftAdminRemoveServerRequest) Reset

func (x *RaftAdminRemoveServerRequest) Reset()

func (*RaftAdminRemoveServerRequest) String

type RaftAdminServer

RaftAdminServer is the server API for RaftAdmin service. All implementations must embed UnimplementedRaftAdminServer for forward compatibility.

type RaftAdminState

type RaftAdminState int32
const (
	RaftAdminState_RAFT_ADMIN_STATE_UNKNOWN   RaftAdminState = 0
	RaftAdminState_RAFT_ADMIN_STATE_FOLLOWER  RaftAdminState = 1
	RaftAdminState_RAFT_ADMIN_STATE_CANDIDATE RaftAdminState = 2
	RaftAdminState_RAFT_ADMIN_STATE_LEADER    RaftAdminState = 3
	RaftAdminState_RAFT_ADMIN_STATE_SHUTDOWN  RaftAdminState = 4
)

func (RaftAdminState) Descriptor

func (RaftAdminState) Enum

func (x RaftAdminState) Enum() *RaftAdminState

func (RaftAdminState) EnumDescriptor deprecated

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

Deprecated: Use RaftAdminState.Descriptor instead.

func (RaftAdminState) Number

func (RaftAdminState) String

func (x RaftAdminState) String() string

func (RaftAdminState) Type

type RaftAdminStatusRequest

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

func (*RaftAdminStatusRequest) Descriptor deprecated

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

Deprecated: Use RaftAdminStatusRequest.ProtoReflect.Descriptor instead.

func (*RaftAdminStatusRequest) ProtoMessage

func (*RaftAdminStatusRequest) ProtoMessage()

func (*RaftAdminStatusRequest) ProtoReflect

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

func (*RaftAdminStatusRequest) Reset

func (x *RaftAdminStatusRequest) Reset()

func (*RaftAdminStatusRequest) String

func (x *RaftAdminStatusRequest) String() string

type RaftAdminStatusResponse

type RaftAdminStatusResponse struct {
	State              RaftAdminState `protobuf:"varint,1,opt,name=state,proto3,enum=RaftAdminState" json:"state,omitempty"`
	LeaderId           string         `protobuf:"bytes,2,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	LeaderAddress      string         `protobuf:"bytes,3,opt,name=leader_address,json=leaderAddress,proto3" json:"leader_address,omitempty"`
	Term               uint64         `protobuf:"varint,4,opt,name=term,proto3" json:"term,omitempty"`
	CommitIndex        uint64         `protobuf:"varint,5,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	AppliedIndex       uint64         `protobuf:"varint,6,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	LastLogIndex       uint64         `protobuf:"varint,7,opt,name=last_log_index,json=lastLogIndex,proto3" json:"last_log_index,omitempty"`
	LastSnapshotIndex  uint64         `protobuf:"varint,8,opt,name=last_snapshot_index,json=lastSnapshotIndex,proto3" json:"last_snapshot_index,omitempty"`
	FsmPending         uint64         `protobuf:"varint,9,opt,name=fsm_pending,json=fsmPending,proto3" json:"fsm_pending,omitempty"`
	NumPeers           uint64         `protobuf:"varint,10,opt,name=num_peers,json=numPeers,proto3" json:"num_peers,omitempty"`
	LastContactNanos   int64          `protobuf:"varint,11,opt,name=last_contact_nanos,json=lastContactNanos,proto3" json:"last_contact_nanos,omitempty"`
	ConfigurationIndex uint64         `protobuf:"varint,12,opt,name=configuration_index,json=configurationIndex,proto3" json:"configuration_index,omitempty"`
	PendingConfChange  bool           `protobuf:"varint,13,opt,name=pending_conf_change,json=pendingConfChange,proto3" json:"pending_conf_change,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminStatusResponse) Descriptor deprecated

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

Deprecated: Use RaftAdminStatusResponse.ProtoReflect.Descriptor instead.

func (*RaftAdminStatusResponse) GetAppliedIndex

func (x *RaftAdminStatusResponse) GetAppliedIndex() uint64

func (*RaftAdminStatusResponse) GetCommitIndex

func (x *RaftAdminStatusResponse) GetCommitIndex() uint64

func (*RaftAdminStatusResponse) GetConfigurationIndex

func (x *RaftAdminStatusResponse) GetConfigurationIndex() uint64

func (*RaftAdminStatusResponse) GetFsmPending

func (x *RaftAdminStatusResponse) GetFsmPending() uint64

func (*RaftAdminStatusResponse) GetLastContactNanos

func (x *RaftAdminStatusResponse) GetLastContactNanos() int64

func (*RaftAdminStatusResponse) GetLastLogIndex

func (x *RaftAdminStatusResponse) GetLastLogIndex() uint64

func (*RaftAdminStatusResponse) GetLastSnapshotIndex

func (x *RaftAdminStatusResponse) GetLastSnapshotIndex() uint64

func (*RaftAdminStatusResponse) GetLeaderAddress

func (x *RaftAdminStatusResponse) GetLeaderAddress() string

func (*RaftAdminStatusResponse) GetLeaderId

func (x *RaftAdminStatusResponse) GetLeaderId() string

func (*RaftAdminStatusResponse) GetNumPeers

func (x *RaftAdminStatusResponse) GetNumPeers() uint64

func (*RaftAdminStatusResponse) GetPendingConfChange

func (x *RaftAdminStatusResponse) GetPendingConfChange() bool

func (*RaftAdminStatusResponse) GetState

func (*RaftAdminStatusResponse) GetTerm

func (x *RaftAdminStatusResponse) GetTerm() uint64

func (*RaftAdminStatusResponse) ProtoMessage

func (*RaftAdminStatusResponse) ProtoMessage()

func (*RaftAdminStatusResponse) ProtoReflect

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

func (*RaftAdminStatusResponse) Reset

func (x *RaftAdminStatusResponse) Reset()

func (*RaftAdminStatusResponse) String

func (x *RaftAdminStatusResponse) String() string

type RaftAdminTransferLeadershipRequest

type RaftAdminTransferLeadershipRequest struct {
	TargetId         string            `protobuf:"bytes,1,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	TargetAddress    string            `protobuf:"bytes,2,opt,name=target_address,json=targetAddress,proto3" json:"target_address,omitempty"`
	Gated            bool              `protobuf:"varint,3,opt,name=gated,proto3" json:"gated,omitempty"`
	MaxLag           uint64            `protobuf:"varint,4,opt,name=max_lag,json=maxLag,proto3" json:"max_lag,omitempty"`
	TargetCandidates []*TransferTarget `protobuf:"bytes,5,rep,name=target_candidates,json=targetCandidates,proto3" json:"target_candidates,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAdminTransferLeadershipRequest) Descriptor deprecated

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

Deprecated: Use RaftAdminTransferLeadershipRequest.ProtoReflect.Descriptor instead.

func (*RaftAdminTransferLeadershipRequest) GetGated

func (*RaftAdminTransferLeadershipRequest) GetMaxLag

func (*RaftAdminTransferLeadershipRequest) GetTargetAddress

func (x *RaftAdminTransferLeadershipRequest) GetTargetAddress() string

func (*RaftAdminTransferLeadershipRequest) GetTargetCandidates

func (x *RaftAdminTransferLeadershipRequest) GetTargetCandidates() []*TransferTarget

func (*RaftAdminTransferLeadershipRequest) GetTargetId

func (x *RaftAdminTransferLeadershipRequest) GetTargetId() string

func (*RaftAdminTransferLeadershipRequest) ProtoMessage

func (*RaftAdminTransferLeadershipRequest) ProtoMessage()

func (*RaftAdminTransferLeadershipRequest) ProtoReflect

func (*RaftAdminTransferLeadershipRequest) Reset

func (*RaftAdminTransferLeadershipRequest) String

type RaftAdminTransferLeadershipResponse

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

func (*RaftAdminTransferLeadershipResponse) Descriptor deprecated

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

Deprecated: Use RaftAdminTransferLeadershipResponse.ProtoReflect.Descriptor instead.

func (*RaftAdminTransferLeadershipResponse) ProtoMessage

func (*RaftAdminTransferLeadershipResponse) ProtoMessage()

func (*RaftAdminTransferLeadershipResponse) ProtoReflect

func (*RaftAdminTransferLeadershipResponse) Reset

func (*RaftAdminTransferLeadershipResponse) String

type RaftCommand

type RaftCommand struct {
	Requests []*Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftCommand) Descriptor deprecated

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

Deprecated: Use RaftCommand.ProtoReflect.Descriptor instead.

func (*RaftCommand) GetRequests

func (x *RaftCommand) GetRequests() []*Request

func (*RaftCommand) ProtoMessage

func (*RaftCommand) ProtoMessage()

func (*RaftCommand) ProtoReflect

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

func (*RaftCommand) Reset

func (x *RaftCommand) Reset()

func (*RaftCommand) String

func (x *RaftCommand) String() string

type RaftGroupState

type RaftGroupState struct {
	RaftGroupId  uint64 `protobuf:"varint,1,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	LeaderNodeId string `protobuf:"bytes,2,opt,name=leader_node_id,json=leaderNodeId,proto3" json:"leader_node_id,omitempty"`
	LeaderTerm   uint64 `protobuf:"varint,3,opt,name=leader_term,json=leaderTerm,proto3" json:"leader_term,omitempty"`
	CommitIndex  uint64 `protobuf:"varint,4,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	AppliedIndex uint64 `protobuf:"varint,5,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	// last_contact_unix_ms is the unix-ms timestamp of the most recent leader
	// contact observed on this node. Zero means "unknown" (for example, the
	// engine is a follower that has never heard from a leader); UIs should
	// render that case as "unknown" rather than "contacted at epoch".
	LastContactUnixMs int64 `protobuf:"varint,6,opt,name=last_contact_unix_ms,json=lastContactUnixMs,proto3" json:"last_contact_unix_ms,omitempty"`
	// leader_node_version is populated asynchronously from the leader's Admin
	// GetNodeVersion RPC. Empty means unknown/unreachable/cache miss.
	LeaderNodeVersion string `protobuf:"bytes,7,opt,name=leader_node_version,json=leaderNodeVersion,proto3" json:"leader_node_version,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftGroupState) Descriptor deprecated

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

Deprecated: Use RaftGroupState.ProtoReflect.Descriptor instead.

func (*RaftGroupState) GetAppliedIndex

func (x *RaftGroupState) GetAppliedIndex() uint64

func (*RaftGroupState) GetCommitIndex

func (x *RaftGroupState) GetCommitIndex() uint64

func (*RaftGroupState) GetLastContactUnixMs

func (x *RaftGroupState) GetLastContactUnixMs() int64

func (*RaftGroupState) GetLeaderNodeId

func (x *RaftGroupState) GetLeaderNodeId() string

func (*RaftGroupState) GetLeaderNodeVersion

func (x *RaftGroupState) GetLeaderNodeVersion() string

func (*RaftGroupState) GetLeaderTerm

func (x *RaftGroupState) GetLeaderTerm() uint64

func (*RaftGroupState) GetRaftGroupId

func (x *RaftGroupState) GetRaftGroupId() uint64

func (*RaftGroupState) ProtoMessage

func (*RaftGroupState) ProtoMessage()

func (*RaftGroupState) ProtoReflect

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

func (*RaftGroupState) Reset

func (x *RaftGroupState) Reset()

func (*RaftGroupState) String

func (x *RaftGroupState) String() string

type RawDeleteRequest

type RawDeleteRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*RawDeleteRequest) Descriptor deprecated

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

Deprecated: Use RawDeleteRequest.ProtoReflect.Descriptor instead.

func (*RawDeleteRequest) GetKey

func (x *RawDeleteRequest) GetKey() []byte

func (*RawDeleteRequest) ProtoMessage

func (*RawDeleteRequest) ProtoMessage()

func (*RawDeleteRequest) ProtoReflect

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

func (*RawDeleteRequest) Reset

func (x *RawDeleteRequest) Reset()

func (*RawDeleteRequest) String

func (x *RawDeleteRequest) String() string

type RawDeleteResponse

type RawDeleteResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*RawDeleteResponse) Descriptor deprecated

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

Deprecated: Use RawDeleteResponse.ProtoReflect.Descriptor instead.

func (*RawDeleteResponse) GetCommitIndex

func (x *RawDeleteResponse) GetCommitIndex() uint64

func (*RawDeleteResponse) GetSuccess

func (x *RawDeleteResponse) GetSuccess() bool

func (*RawDeleteResponse) ProtoMessage

func (*RawDeleteResponse) ProtoMessage()

func (*RawDeleteResponse) ProtoReflect

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

func (*RawDeleteResponse) Reset

func (x *RawDeleteResponse) Reset()

func (*RawDeleteResponse) String

func (x *RawDeleteResponse) String() string

type RawGetRequest

type RawGetRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ts               uint64 `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`                                                       // optional read timestamp; if zero, server uses current HLC
	GroupId          uint64 `protobuf:"varint,4,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`                              // optional explicit Raft group for non-range-owned keyspaces
	ReadRouteVersion uint64 `protobuf:"varint,5,opt,name=read_route_version,json=readRouteVersion,proto3" json:"read_route_version,omitempty"` // stamped by server-side routing for migration read fences
	// contains filtered or unexported fields
}

func (*RawGetRequest) Descriptor deprecated

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

Deprecated: Use RawGetRequest.ProtoReflect.Descriptor instead.

func (*RawGetRequest) GetGroupId

func (x *RawGetRequest) GetGroupId() uint64

func (*RawGetRequest) GetKey

func (x *RawGetRequest) GetKey() []byte

func (*RawGetRequest) GetReadRouteVersion

func (x *RawGetRequest) GetReadRouteVersion() uint64

func (*RawGetRequest) GetTs

func (x *RawGetRequest) GetTs() uint64

func (*RawGetRequest) ProtoMessage

func (*RawGetRequest) ProtoMessage()

func (*RawGetRequest) ProtoReflect

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

func (*RawGetRequest) Reset

func (x *RawGetRequest) Reset()

func (*RawGetRequest) String

func (x *RawGetRequest) String() string

type RawGetResponse

type RawGetResponse struct {
	ReadAtIndex uint64 `protobuf:"varint,1,opt,name=read_at_index,json=readAtIndex,proto3" json:"read_at_index,omitempty"`
	Value       []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Exists      bool   `protobuf:"varint,3,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*RawGetResponse) Descriptor deprecated

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

Deprecated: Use RawGetResponse.ProtoReflect.Descriptor instead.

func (*RawGetResponse) GetExists

func (x *RawGetResponse) GetExists() bool

func (*RawGetResponse) GetReadAtIndex

func (x *RawGetResponse) GetReadAtIndex() uint64

func (*RawGetResponse) GetValue

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

func (*RawGetResponse) ProtoMessage

func (*RawGetResponse) ProtoMessage()

func (*RawGetResponse) ProtoReflect

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

func (*RawGetResponse) Reset

func (x *RawGetResponse) Reset()

func (*RawGetResponse) String

func (x *RawGetResponse) String() string

type RawKVClient

type RawKVClient interface {
	RawPut(ctx context.Context, in *RawPutRequest, opts ...grpc.CallOption) (*RawPutResponse, error)
	RawGet(ctx context.Context, in *RawGetRequest, opts ...grpc.CallOption) (*RawGetResponse, error)
	RawDelete(ctx context.Context, in *RawDeleteRequest, opts ...grpc.CallOption) (*RawDeleteResponse, error)
	RawLatestCommitTS(ctx context.Context, in *RawLatestCommitTSRequest, opts ...grpc.CallOption) (*RawLatestCommitTSResponse, error)
	RawScanAt(ctx context.Context, in *RawScanAtRequest, opts ...grpc.CallOption) (*RawScanAtResponse, error)
}

RawKVClient is the client API for RawKV service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRawKVClient

func NewRawKVClient(cc grpc.ClientConnInterface) RawKVClient

type RawKVPair

type RawKVPair struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RawKVPair) Descriptor deprecated

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

Deprecated: Use RawKVPair.ProtoReflect.Descriptor instead.

func (*RawKVPair) GetKey

func (x *RawKVPair) GetKey() []byte

func (*RawKVPair) GetValue

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

func (*RawKVPair) ProtoMessage

func (*RawKVPair) ProtoMessage()

func (*RawKVPair) ProtoReflect

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

func (*RawKVPair) Reset

func (x *RawKVPair) Reset()

func (*RawKVPair) String

func (x *RawKVPair) String() string

type RawKVServer

type RawKVServer interface {
	RawPut(context.Context, *RawPutRequest) (*RawPutResponse, error)
	RawGet(context.Context, *RawGetRequest) (*RawGetResponse, error)
	RawDelete(context.Context, *RawDeleteRequest) (*RawDeleteResponse, error)
	RawLatestCommitTS(context.Context, *RawLatestCommitTSRequest) (*RawLatestCommitTSResponse, error)
	RawScanAt(context.Context, *RawScanAtRequest) (*RawScanAtResponse, error)
	// contains filtered or unexported methods
}

RawKVServer is the server API for RawKV service. All implementations must embed UnimplementedRawKVServer for forward compatibility.

type RawLatestCommitTSRequest

type RawLatestCommitTSRequest struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ReadRouteVersion uint64 `protobuf:"varint,2,opt,name=read_route_version,json=readRouteVersion,proto3" json:"read_route_version,omitempty"` // stamped by server-side routing for migration read fences
	// group_id carries both uses: the explicit Raft group for route-specific
	// probes, and the explicit group a leader-fenced watermark read names.
	GroupId uint64 `protobuf:"varint,3,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// When non-zero, also answer whether the key has any committed version at or
	// below this timestamp. Comparing only `ts` cannot tell a tombstone at or
	// before the read timestamp apart from a newer version above it.
	VersionVisibleAtTs uint64 `protobuf:"varint,4,opt,name=version_visible_at_ts,json=versionVisibleAtTs,proto3" json:"version_visible_at_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*RawLatestCommitTSRequest) Descriptor deprecated

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

Deprecated: Use RawLatestCommitTSRequest.ProtoReflect.Descriptor instead.

func (*RawLatestCommitTSRequest) GetGroupId

func (x *RawLatestCommitTSRequest) GetGroupId() uint64

func (*RawLatestCommitTSRequest) GetKey

func (x *RawLatestCommitTSRequest) GetKey() []byte

func (*RawLatestCommitTSRequest) GetReadRouteVersion

func (x *RawLatestCommitTSRequest) GetReadRouteVersion() uint64

func (*RawLatestCommitTSRequest) GetVersionVisibleAtTs

func (x *RawLatestCommitTSRequest) GetVersionVisibleAtTs() uint64

func (*RawLatestCommitTSRequest) ProtoMessage

func (*RawLatestCommitTSRequest) ProtoMessage()

func (*RawLatestCommitTSRequest) ProtoReflect

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

func (*RawLatestCommitTSRequest) Reset

func (x *RawLatestCommitTSRequest) Reset()

func (*RawLatestCommitTSRequest) String

func (x *RawLatestCommitTSRequest) String() string

type RawLatestCommitTSResponse

type RawLatestCommitTSResponse struct {
	Ts     uint64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Exists bool   `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// Answer to version_visible_at_ts. Only meaningful when
	// version_visible_supported is set; a server that predates the probe leaves
	// both unset and the caller falls back to comparing `ts`.
	VersionVisible          bool `protobuf:"varint,3,opt,name=version_visible,json=versionVisible,proto3" json:"version_visible,omitempty"`
	VersionVisibleSupported bool `` /* 133-byte string literal not displayed */
	// 3 and 4 were taken by the version probe on main while this branch was
	// open, so the watermark fields moved up rather than reusing those tags.
	GroupId      uint64 `protobuf:"varint,5,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`                // echoes an explicit group watermark request
	LeaderFenced bool   `protobuf:"varint,6,opt,name=leader_fenced,json=leaderFenced,proto3" json:"leader_fenced,omitempty"` // true only after that group's leader ReadIndex fence
	// contains filtered or unexported fields
}

func (*RawLatestCommitTSResponse) Descriptor deprecated

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

Deprecated: Use RawLatestCommitTSResponse.ProtoReflect.Descriptor instead.

func (*RawLatestCommitTSResponse) GetExists

func (x *RawLatestCommitTSResponse) GetExists() bool

func (*RawLatestCommitTSResponse) GetGroupId

func (x *RawLatestCommitTSResponse) GetGroupId() uint64

func (*RawLatestCommitTSResponse) GetLeaderFenced

func (x *RawLatestCommitTSResponse) GetLeaderFenced() bool

func (*RawLatestCommitTSResponse) GetTs

func (x *RawLatestCommitTSResponse) GetTs() uint64

func (*RawLatestCommitTSResponse) GetVersionVisible

func (x *RawLatestCommitTSResponse) GetVersionVisible() bool

func (*RawLatestCommitTSResponse) GetVersionVisibleSupported

func (x *RawLatestCommitTSResponse) GetVersionVisibleSupported() bool

func (*RawLatestCommitTSResponse) ProtoMessage

func (*RawLatestCommitTSResponse) ProtoMessage()

func (*RawLatestCommitTSResponse) ProtoReflect

func (*RawLatestCommitTSResponse) Reset

func (x *RawLatestCommitTSResponse) Reset()

func (*RawLatestCommitTSResponse) String

func (x *RawLatestCommitTSResponse) String() string

type RawPutRequest

type RawPutRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RawPutRequest) Descriptor deprecated

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

Deprecated: Use RawPutRequest.ProtoReflect.Descriptor instead.

func (*RawPutRequest) GetKey

func (x *RawPutRequest) GetKey() []byte

func (*RawPutRequest) GetValue

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

func (*RawPutRequest) ProtoMessage

func (*RawPutRequest) ProtoMessage()

func (*RawPutRequest) ProtoReflect

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

func (*RawPutRequest) Reset

func (x *RawPutRequest) Reset()

func (*RawPutRequest) String

func (x *RawPutRequest) String() string

type RawPutResponse

type RawPutResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*RawPutResponse) Descriptor deprecated

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

Deprecated: Use RawPutResponse.ProtoReflect.Descriptor instead.

func (*RawPutResponse) GetCommitIndex

func (x *RawPutResponse) GetCommitIndex() uint64

func (*RawPutResponse) GetSuccess

func (x *RawPutResponse) GetSuccess() bool

func (*RawPutResponse) ProtoMessage

func (*RawPutResponse) ProtoMessage()

func (*RawPutResponse) ProtoReflect

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

func (*RawPutResponse) Reset

func (x *RawPutResponse) Reset()

func (*RawPutResponse) String

func (x *RawPutResponse) String() string

type RawScanAtRequest

type RawScanAtRequest struct {
	StartKey           []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey             []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Limit              int64  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` // validated against host int size; large values may be rejected
	Ts                 uint64 `protobuf:"varint,4,opt,name=ts,proto3" json:"ts,omitempty"`       // optional read timestamp; if zero, server uses current HLC
	Reverse            bool   `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
	GroupId            uint64 `protobuf:"varint,6,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`                                     // optional explicit Raft group for non-range-owned keyspaces
	KeysOnly           bool   `protobuf:"varint,7,opt,name=keys_only,json=keysOnly,proto3" json:"keys_only,omitempty"`                                  // when true, response kv entries omit values
	ReadRouteVersion   uint64 `protobuf:"varint,8,opt,name=read_route_version,json=readRouteVersion,proto3" json:"read_route_version,omitempty"`        // stamped by server-side routing for migration read fences
	RouteStart         []byte `protobuf:"bytes,9,opt,name=route_start,json=routeStart,proto3" json:"route_start,omitempty"`                             // route-key-normalized inclusive start, when already known
	RouteEnd           []byte `protobuf:"bytes,10,opt,name=route_end,json=routeEnd,proto3" json:"route_end,omitempty"`                                  // route-key-normalized exclusive end; empty means +infinity
	RouteBoundsPresent bool   `protobuf:"varint,11,opt,name=route_bounds_present,json=routeBoundsPresent,proto3" json:"route_bounds_present,omitempty"` // true when route_start/route_end were supplied, including ["", +infinity)
	// contains filtered or unexported fields
}

func (*RawScanAtRequest) Descriptor deprecated

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

Deprecated: Use RawScanAtRequest.ProtoReflect.Descriptor instead.

func (*RawScanAtRequest) GetEndKey

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

func (*RawScanAtRequest) GetGroupId

func (x *RawScanAtRequest) GetGroupId() uint64

func (*RawScanAtRequest) GetKeysOnly

func (x *RawScanAtRequest) GetKeysOnly() bool

func (*RawScanAtRequest) GetLimit

func (x *RawScanAtRequest) GetLimit() int64

func (*RawScanAtRequest) GetReadRouteVersion

func (x *RawScanAtRequest) GetReadRouteVersion() uint64

func (*RawScanAtRequest) GetReverse

func (x *RawScanAtRequest) GetReverse() bool

func (*RawScanAtRequest) GetRouteBoundsPresent

func (x *RawScanAtRequest) GetRouteBoundsPresent() bool

func (*RawScanAtRequest) GetRouteEnd

func (x *RawScanAtRequest) GetRouteEnd() []byte

func (*RawScanAtRequest) GetRouteStart

func (x *RawScanAtRequest) GetRouteStart() []byte

func (*RawScanAtRequest) GetStartKey

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

func (*RawScanAtRequest) GetTs

func (x *RawScanAtRequest) GetTs() uint64

func (*RawScanAtRequest) ProtoMessage

func (*RawScanAtRequest) ProtoMessage()

func (*RawScanAtRequest) ProtoReflect

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

func (*RawScanAtRequest) Reset

func (x *RawScanAtRequest) Reset()

func (*RawScanAtRequest) String

func (x *RawScanAtRequest) String() string

type RawScanAtResponse

type RawScanAtResponse struct {
	Kv []*RawKVPair `protobuf:"bytes,1,rep,name=kv,proto3" json:"kv,omitempty"`
	// contains filtered or unexported fields
}

func (*RawScanAtResponse) Descriptor deprecated

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

Deprecated: Use RawScanAtResponse.ProtoReflect.Descriptor instead.

func (*RawScanAtResponse) GetKv

func (x *RawScanAtResponse) GetKv() []*RawKVPair

func (*RawScanAtResponse) ProtoMessage

func (*RawScanAtResponse) ProtoMessage()

func (*RawScanAtResponse) ProtoReflect

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

func (*RawScanAtResponse) Reset

func (x *RawScanAtResponse) Reset()

func (*RawScanAtResponse) String

func (x *RawScanAtResponse) String() string

type RedisHashValue

type RedisHashValue struct {
	Entries map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RedisHashValue) Descriptor deprecated

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

Deprecated: Use RedisHashValue.ProtoReflect.Descriptor instead.

func (*RedisHashValue) GetEntries

func (x *RedisHashValue) GetEntries() map[string]string

func (*RedisHashValue) ProtoMessage

func (*RedisHashValue) ProtoMessage()

func (*RedisHashValue) ProtoReflect

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

func (*RedisHashValue) Reset

func (x *RedisHashValue) Reset()

func (*RedisHashValue) String

func (x *RedisHashValue) String() string

type RedisSetValue

type RedisSetValue struct {
	Members []string `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisSetValue) Descriptor deprecated

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

Deprecated: Use RedisSetValue.ProtoReflect.Descriptor instead.

func (*RedisSetValue) GetMembers

func (x *RedisSetValue) GetMembers() []string

func (*RedisSetValue) ProtoMessage

func (*RedisSetValue) ProtoMessage()

func (*RedisSetValue) ProtoReflect

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

func (*RedisSetValue) Reset

func (x *RedisSetValue) Reset()

func (*RedisSetValue) String

func (x *RedisSetValue) String() string

type RedisStreamEntry

type RedisStreamEntry struct {
	Id     string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisStreamEntry) Descriptor deprecated

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

Deprecated: Use RedisStreamEntry.ProtoReflect.Descriptor instead.

func (*RedisStreamEntry) GetFields

func (x *RedisStreamEntry) GetFields() []string

func (*RedisStreamEntry) GetId

func (x *RedisStreamEntry) GetId() string

func (*RedisStreamEntry) ProtoMessage

func (*RedisStreamEntry) ProtoMessage()

func (*RedisStreamEntry) ProtoReflect

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

func (*RedisStreamEntry) Reset

func (x *RedisStreamEntry) Reset()

func (*RedisStreamEntry) String

func (x *RedisStreamEntry) String() string

type RedisStreamValue

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

func (*RedisStreamValue) Descriptor deprecated

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

Deprecated: Use RedisStreamValue.ProtoReflect.Descriptor instead.

func (*RedisStreamValue) GetEntries

func (x *RedisStreamValue) GetEntries() []*RedisStreamEntry

func (*RedisStreamValue) ProtoMessage

func (*RedisStreamValue) ProtoMessage()

func (*RedisStreamValue) ProtoReflect

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

func (*RedisStreamValue) Reset

func (x *RedisStreamValue) Reset()

func (*RedisStreamValue) String

func (x *RedisStreamValue) String() string

type RedisZSetEntry

type RedisZSetEntry struct {
	Member string  `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	Score  float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisZSetEntry) Descriptor deprecated

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

Deprecated: Use RedisZSetEntry.ProtoReflect.Descriptor instead.

func (*RedisZSetEntry) GetMember

func (x *RedisZSetEntry) GetMember() string

func (*RedisZSetEntry) GetScore

func (x *RedisZSetEntry) GetScore() float64

func (*RedisZSetEntry) ProtoMessage

func (*RedisZSetEntry) ProtoMessage()

func (*RedisZSetEntry) ProtoReflect

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

func (*RedisZSetEntry) Reset

func (x *RedisZSetEntry) Reset()

func (*RedisZSetEntry) String

func (x *RedisZSetEntry) String() string

type RedisZSetValue

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

func (*RedisZSetValue) Descriptor deprecated

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

Deprecated: Use RedisZSetValue.ProtoReflect.Descriptor instead.

func (*RedisZSetValue) GetEntries

func (x *RedisZSetValue) GetEntries() []*RedisZSetEntry

func (*RedisZSetValue) ProtoMessage

func (*RedisZSetValue) ProtoMessage()

func (*RedisZSetValue) ProtoReflect

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

func (*RedisZSetValue) Reset

func (x *RedisZSetValue) Reset()

func (*RedisZSetValue) String

func (x *RedisZSetValue) String() string

type RegisterEncryptionWriterRequest

type RegisterEncryptionWriterRequest struct {
	DekId   uint32                 `protobuf:"varint,1,opt,name=dek_id,json=dekId,proto3" json:"dek_id,omitempty"`
	Writers []*WriterRegistryEntry `protobuf:"bytes,2,rep,name=writers,proto3" json:"writers,omitempty"`
	// contains filtered or unexported fields
}

RegisterEncryptionWriterRequest proposes a §11.3 0x03 OpRegistration entry for the calling node. Used by nodes that joined the cluster after bootstrap (§5.6 step 4).

func (*RegisterEncryptionWriterRequest) Descriptor deprecated

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

Deprecated: Use RegisterEncryptionWriterRequest.ProtoReflect.Descriptor instead.

func (*RegisterEncryptionWriterRequest) GetDekId

func (*RegisterEncryptionWriterRequest) GetWriters

func (*RegisterEncryptionWriterRequest) ProtoMessage

func (*RegisterEncryptionWriterRequest) ProtoMessage()

func (*RegisterEncryptionWriterRequest) ProtoReflect

func (*RegisterEncryptionWriterRequest) Reset

func (*RegisterEncryptionWriterRequest) String

type RegisterEncryptionWriterResponse

type RegisterEncryptionWriterResponse struct {
	AppliedIndex uint64 `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterEncryptionWriterResponse) Descriptor deprecated

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

Deprecated: Use RegisterEncryptionWriterResponse.ProtoReflect.Descriptor instead.

func (*RegisterEncryptionWriterResponse) GetAppliedIndex

func (x *RegisterEncryptionWriterResponse) GetAppliedIndex() uint64

func (*RegisterEncryptionWriterResponse) ProtoMessage

func (*RegisterEncryptionWriterResponse) ProtoMessage()

func (*RegisterEncryptionWriterResponse) ProtoReflect

func (*RegisterEncryptionWriterResponse) Reset

func (*RegisterEncryptionWriterResponse) String

type RelayPublishRequest

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

func (*RelayPublishRequest) Descriptor deprecated

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

Deprecated: Use RelayPublishRequest.ProtoReflect.Descriptor instead.

func (*RelayPublishRequest) GetChannel

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

func (*RelayPublishRequest) GetMessage

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

func (*RelayPublishRequest) ProtoMessage

func (*RelayPublishRequest) ProtoMessage()

func (*RelayPublishRequest) ProtoReflect

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

func (*RelayPublishRequest) Reset

func (x *RelayPublishRequest) Reset()

func (*RelayPublishRequest) String

func (x *RelayPublishRequest) String() string

type RelayPublishResponse

type RelayPublishResponse struct {
	Subscribers int64 `protobuf:"varint,1,opt,name=subscribers,proto3" json:"subscribers,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayPublishResponse) Descriptor deprecated

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

Deprecated: Use RelayPublishResponse.ProtoReflect.Descriptor instead.

func (*RelayPublishResponse) GetSubscribers

func (x *RelayPublishResponse) GetSubscribers() int64

func (*RelayPublishResponse) ProtoMessage

func (*RelayPublishResponse) ProtoMessage()

func (*RelayPublishResponse) ProtoReflect

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

func (*RelayPublishResponse) Reset

func (x *RelayPublishResponse) Reset()

func (*RelayPublishResponse) String

func (x *RelayPublishResponse) String() string

type RenewBackupRequest

type RenewBackupRequest struct {
	PinToken []byte `protobuf:"bytes,1,opt,name=pin_token,json=pinToken,proto3" json:"pin_token,omitempty"`
	TtlMs    uint64 `protobuf:"varint,2,opt,name=ttl_ms,json=ttlMs,proto3" json:"ttl_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*RenewBackupRequest) Descriptor deprecated

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

Deprecated: Use RenewBackupRequest.ProtoReflect.Descriptor instead.

func (*RenewBackupRequest) GetPinToken

func (x *RenewBackupRequest) GetPinToken() []byte

func (*RenewBackupRequest) GetTtlMs

func (x *RenewBackupRequest) GetTtlMs() uint64

func (*RenewBackupRequest) ProtoMessage

func (*RenewBackupRequest) ProtoMessage()

func (*RenewBackupRequest) ProtoReflect

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

func (*RenewBackupRequest) Reset

func (x *RenewBackupRequest) Reset()

func (*RenewBackupRequest) String

func (x *RenewBackupRequest) String() string

type RenewBackupResponse

type RenewBackupResponse struct {
	TtlMsEffective uint64 `protobuf:"varint,1,opt,name=ttl_ms_effective,json=ttlMsEffective,proto3" json:"ttl_ms_effective,omitempty"`
	// Replaces the request token and carries the newly committed hard deadline.
	PinToken []byte `protobuf:"bytes,2,opt,name=pin_token,json=pinToken,proto3" json:"pin_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RenewBackupResponse) Descriptor deprecated

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

Deprecated: Use RenewBackupResponse.ProtoReflect.Descriptor instead.

func (*RenewBackupResponse) GetPinToken

func (x *RenewBackupResponse) GetPinToken() []byte

func (*RenewBackupResponse) GetTtlMsEffective

func (x *RenewBackupResponse) GetTtlMsEffective() uint64

func (*RenewBackupResponse) ProtoMessage

func (*RenewBackupResponse) ProtoMessage()

func (*RenewBackupResponse) ProtoReflect

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

func (*RenewBackupResponse) Reset

func (x *RenewBackupResponse) Reset()

func (*RenewBackupResponse) String

func (x *RenewBackupResponse) String() string

type Request

type Request struct {
	IsTxn     bool        `protobuf:"varint,1,opt,name=is_txn,json=isTxn,proto3" json:"is_txn,omitempty"`
	Phase     Phase       `protobuf:"varint,2,opt,name=phase,proto3,enum=Phase" json:"phase,omitempty"`
	Ts        uint64      `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	Mutations []*Mutation `protobuf:"bytes,4,rep,name=mutations,proto3" json:"mutations,omitempty"`
	// read_keys carries the transaction's read set so that the FSM can validate
	// read-write conflicts atomically with the commit. Each entry is a storage
	// key that was read during the transaction; the FSM checks that none of them
	// were written after ts (the transaction's start timestamp).
	ReadKeys [][]byte `protobuf:"bytes,5,rep,name=read_keys,json=readKeys,proto3" json:"read_keys,omitempty"`
	// observed_route_version is the durable catalog version the
	// transaction's read set was captured at (set on BeginTxn from
	// distribution.Engine.Version()). Zero means "unpinned" (legacy
	// callers + read-only paths). M3 of the Composed-1 design
	// (docs/design/2026_05_29_implemented_composed1_cross_group_commit_guard.md)
	// will gate the FSM apply path on it; M1 (this field's introduction)
	// is plumbing only — the FSM ignores the value, so all existing
	// callers see no behaviour change.
	ObservedRouteVersion uint64 `protobuf:"varint,6,opt,name=observed_route_version,json=observedRouteVersion,proto3" json:"observed_route_version,omitempty"`
	// write_fence_bypass_keys carries point keys whose target group was resolved
	// outside the byte-route catalog, either by a partition resolver or an
	// explicit maintenance pin. The FSM skips byte-route write-fence and owner
	// checks only for those exact point mutations; prefixes and unmarked keys
	// still fail closed.
	WriteFenceBypassKeys [][]byte `protobuf:"bytes,7,rep,name=write_fence_bypass_keys,json=writeFenceBypassKeys,proto3" json:"write_fence_bypass_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetIsTxn

func (x *Request) GetIsTxn() bool

func (*Request) GetMutations

func (x *Request) GetMutations() []*Mutation

func (*Request) GetObservedRouteVersion

func (x *Request) GetObservedRouteVersion() uint64

func (*Request) GetPhase

func (x *Request) GetPhase() Phase

func (*Request) GetReadKeys

func (x *Request) GetReadKeys() [][]byte

func (*Request) GetTs

func (x *Request) GetTs() uint64

func (*Request) GetWriteFenceBypassKeys

func (x *Request) GetWriteFenceBypassKeys() [][]byte

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type ResyncSidecarRequest

type ResyncSidecarRequest struct {
	CallerFullNodeId uint64 `protobuf:"varint,1,opt,name=caller_full_node_id,json=callerFullNodeId,proto3" json:"caller_full_node_id,omitempty"`
	// contains filtered or unexported fields
}

ResyncSidecarRequest is the §5.5 follower-repair RPC. The caller asks the leader to ship its current wrapped DEK set so the follower can rewrite its sidecar. Read-only on the leader (no Raft proposal is involved).

func (*ResyncSidecarRequest) Descriptor deprecated

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

Deprecated: Use ResyncSidecarRequest.ProtoReflect.Descriptor instead.

func (*ResyncSidecarRequest) GetCallerFullNodeId

func (x *ResyncSidecarRequest) GetCallerFullNodeId() uint64

func (*ResyncSidecarRequest) ProtoMessage

func (*ResyncSidecarRequest) ProtoMessage()

func (*ResyncSidecarRequest) ProtoReflect

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

func (*ResyncSidecarRequest) Reset

func (x *ResyncSidecarRequest) Reset()

func (*ResyncSidecarRequest) String

func (x *ResyncSidecarRequest) String() string

type ResyncSidecarResponse

type ResyncSidecarResponse struct {
	WrappedDeksById          map[uint32][]byte `` /* 185-byte string literal not displayed */
	ActiveStorageId          uint32            `protobuf:"varint,2,opt,name=active_storage_id,json=activeStorageId,proto3" json:"active_storage_id,omitempty"`
	ActiveRaftId             uint32            `protobuf:"varint,3,opt,name=active_raft_id,json=activeRaftId,proto3" json:"active_raft_id,omitempty"`
	LeaderLatestAppliedIndex uint64            `` /* 138-byte string literal not displayed */
	// writer_registry_for_caller carries the leader's recorded
	// (dek_id, last_seen_local_epoch) for the calling node so the
	// follower can re-derive its §4.1 local_epoch monotonically.
	// Values MUST be <= 0xFFFF and the decode site MUST enforce
	// that bound. Missing rows are omitted; an empty map means the
	// leader has no recorded local_epoch for this caller under the
	// returned DEKs.
	WriterRegistryForCaller map[uint32]uint32 `` /* 210-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResyncSidecarResponse) Descriptor deprecated

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

Deprecated: Use ResyncSidecarResponse.ProtoReflect.Descriptor instead.

func (*ResyncSidecarResponse) GetActiveRaftId

func (x *ResyncSidecarResponse) GetActiveRaftId() uint32

func (*ResyncSidecarResponse) GetActiveStorageId

func (x *ResyncSidecarResponse) GetActiveStorageId() uint32

func (*ResyncSidecarResponse) GetLeaderLatestAppliedIndex

func (x *ResyncSidecarResponse) GetLeaderLatestAppliedIndex() uint64

func (*ResyncSidecarResponse) GetWrappedDeksById

func (x *ResyncSidecarResponse) GetWrappedDeksById() map[uint32][]byte

func (*ResyncSidecarResponse) GetWriterRegistryForCaller

func (x *ResyncSidecarResponse) GetWriterRegistryForCaller() map[uint32]uint32

func (*ResyncSidecarResponse) ProtoMessage

func (*ResyncSidecarResponse) ProtoMessage()

func (*ResyncSidecarResponse) ProtoReflect

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

func (*ResyncSidecarResponse) Reset

func (x *ResyncSidecarResponse) Reset()

func (*ResyncSidecarResponse) String

func (x *ResyncSidecarResponse) String() string

type RetrySplitJobRequest

type RetrySplitJobRequest struct {
	JobId uint64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrySplitJobRequest) Descriptor deprecated

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

Deprecated: Use RetrySplitJobRequest.ProtoReflect.Descriptor instead.

func (*RetrySplitJobRequest) GetJobId

func (x *RetrySplitJobRequest) GetJobId() uint64

func (*RetrySplitJobRequest) ProtoMessage

func (*RetrySplitJobRequest) ProtoMessage()

func (*RetrySplitJobRequest) ProtoReflect

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

func (*RetrySplitJobRequest) Reset

func (x *RetrySplitJobRequest) Reset()

func (*RetrySplitJobRequest) String

func (x *RetrySplitJobRequest) String() string

type RetrySplitJobResponse

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

func (*RetrySplitJobResponse) Descriptor deprecated

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

Deprecated: Use RetrySplitJobResponse.ProtoReflect.Descriptor instead.

func (*RetrySplitJobResponse) ProtoMessage

func (*RetrySplitJobResponse) ProtoMessage()

func (*RetrySplitJobResponse) ProtoReflect

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

func (*RetrySplitJobResponse) Reset

func (x *RetrySplitJobResponse) Reset()

func (*RetrySplitJobResponse) String

func (x *RetrySplitJobResponse) String() string

type RollbackRequest

type RollbackRequest struct {
	StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*RollbackRequest) Descriptor deprecated

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

Deprecated: Use RollbackRequest.ProtoReflect.Descriptor instead.

func (*RollbackRequest) GetStartTs

func (x *RollbackRequest) GetStartTs() uint64

func (*RollbackRequest) ProtoMessage

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) ProtoReflect

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

func (*RollbackRequest) Reset

func (x *RollbackRequest) Reset()

func (*RollbackRequest) String

func (x *RollbackRequest) String() string

type RollbackResponse

type RollbackResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*RollbackResponse) Descriptor deprecated

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

Deprecated: Use RollbackResponse.ProtoReflect.Descriptor instead.

func (*RollbackResponse) GetSuccess

func (x *RollbackResponse) GetSuccess() bool

func (*RollbackResponse) ProtoMessage

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) ProtoReflect

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

func (*RollbackResponse) Reset

func (x *RollbackResponse) Reset()

func (*RollbackResponse) String

func (x *RollbackResponse) String() string

type RotateDEKRequest

type RotateDEKRequest struct {
	Purpose            RotateDEKRequest_Purpose `protobuf:"varint,1,opt,name=purpose,proto3,enum=RotateDEKRequest_Purpose" json:"purpose,omitempty"`
	WrappedNewDek      []byte                   `protobuf:"bytes,2,opt,name=wrapped_new_dek,json=wrappedNewDek,proto3" json:"wrapped_new_dek,omitempty"`
	NewDekId           uint32                   `protobuf:"varint,3,opt,name=new_dek_id,json=newDekId,proto3" json:"new_dek_id,omitempty"`
	ProposerNodeId     uint64                   `protobuf:"varint,4,opt,name=proposer_node_id,json=proposerNodeId,proto3" json:"proposer_node_id,omitempty"`             // proposer registration payload, §5.2
	ProposerLocalEpoch uint32                   `protobuf:"varint,5,opt,name=proposer_local_epoch,json=proposerLocalEpoch,proto3" json:"proposer_local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// contains filtered or unexported fields
}

RotateDEKRequest proposes a §5.2 rotation as a §11.3 0x05 OpRotation entry. purpose distinguishes the two key purposes; the storage rotation appends a new storage DEK and shifts active_storage_id, and the raft rotation does the same for raft.

func (*RotateDEKRequest) Descriptor deprecated

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

Deprecated: Use RotateDEKRequest.ProtoReflect.Descriptor instead.

func (*RotateDEKRequest) GetNewDekId

func (x *RotateDEKRequest) GetNewDekId() uint32

func (*RotateDEKRequest) GetProposerLocalEpoch

func (x *RotateDEKRequest) GetProposerLocalEpoch() uint32

func (*RotateDEKRequest) GetProposerNodeId

func (x *RotateDEKRequest) GetProposerNodeId() uint64

func (*RotateDEKRequest) GetPurpose

func (*RotateDEKRequest) GetWrappedNewDek

func (x *RotateDEKRequest) GetWrappedNewDek() []byte

func (*RotateDEKRequest) ProtoMessage

func (*RotateDEKRequest) ProtoMessage()

func (*RotateDEKRequest) ProtoReflect

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

func (*RotateDEKRequest) Reset

func (x *RotateDEKRequest) Reset()

func (*RotateDEKRequest) String

func (x *RotateDEKRequest) String() string

type RotateDEKRequest_Purpose

type RotateDEKRequest_Purpose int32
const (
	RotateDEKRequest_PURPOSE_UNSPECIFIED RotateDEKRequest_Purpose = 0
	RotateDEKRequest_PURPOSE_STORAGE     RotateDEKRequest_Purpose = 1
	RotateDEKRequest_PURPOSE_RAFT        RotateDEKRequest_Purpose = 2
)

func (RotateDEKRequest_Purpose) Descriptor

func (RotateDEKRequest_Purpose) Enum

func (RotateDEKRequest_Purpose) EnumDescriptor deprecated

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

Deprecated: Use RotateDEKRequest_Purpose.Descriptor instead.

func (RotateDEKRequest_Purpose) Number

func (RotateDEKRequest_Purpose) String

func (x RotateDEKRequest_Purpose) String() string

func (RotateDEKRequest_Purpose) Type

type RotateDEKResponse

type RotateDEKResponse struct {
	AppliedIndex uint64 `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	// contains filtered or unexported fields
}

func (*RotateDEKResponse) Descriptor deprecated

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

Deprecated: Use RotateDEKResponse.ProtoReflect.Descriptor instead.

func (*RotateDEKResponse) GetAppliedIndex

func (x *RotateDEKResponse) GetAppliedIndex() uint64

func (*RotateDEKResponse) ProtoMessage

func (*RotateDEKResponse) ProtoMessage()

func (*RotateDEKResponse) ProtoReflect

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

func (*RotateDEKResponse) Reset

func (x *RotateDEKResponse) Reset()

func (*RotateDEKResponse) String

func (x *RotateDEKResponse) String() string

type RouteDescriptor

type RouteDescriptor struct {
	RouteId                uint64     `protobuf:"varint,1,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	Start                  []byte     `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End                    []byte     `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	RaftGroupId            uint64     `protobuf:"varint,4,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	State                  RouteState `protobuf:"varint,5,opt,name=state,proto3,enum=RouteState" json:"state,omitempty"`
	ParentRouteId          uint64     `protobuf:"varint,6,opt,name=parent_route_id,json=parentRouteId,proto3" json:"parent_route_id,omitempty"`
	SplitAtHlc             uint64     `protobuf:"varint,7,opt,name=split_at_hlc,json=splitAtHlc,proto3" json:"split_at_hlc,omitempty"`
	StagedVisibilityActive bool       `` /* 130-byte string literal not displayed */
	MigrationJobId         uint64     `protobuf:"varint,9,opt,name=migration_job_id,json=migrationJobId,proto3" json:"migration_job_id,omitempty"`
	MinWriteTsExclusive    uint64     `protobuf:"varint,10,opt,name=min_write_ts_exclusive,json=minWriteTsExclusive,proto3" json:"min_write_ts_exclusive,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteDescriptor) Descriptor deprecated

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

Deprecated: Use RouteDescriptor.ProtoReflect.Descriptor instead.

func (*RouteDescriptor) GetEnd

func (x *RouteDescriptor) GetEnd() []byte

func (*RouteDescriptor) GetMigrationJobId

func (x *RouteDescriptor) GetMigrationJobId() uint64

func (*RouteDescriptor) GetMinWriteTsExclusive

func (x *RouteDescriptor) GetMinWriteTsExclusive() uint64

func (*RouteDescriptor) GetParentRouteId

func (x *RouteDescriptor) GetParentRouteId() uint64

func (*RouteDescriptor) GetRaftGroupId

func (x *RouteDescriptor) GetRaftGroupId() uint64

func (*RouteDescriptor) GetRouteId

func (x *RouteDescriptor) GetRouteId() uint64

func (*RouteDescriptor) GetSplitAtHlc

func (x *RouteDescriptor) GetSplitAtHlc() uint64

func (*RouteDescriptor) GetStagedVisibilityActive

func (x *RouteDescriptor) GetStagedVisibilityActive() bool

func (*RouteDescriptor) GetStart

func (x *RouteDescriptor) GetStart() []byte

func (*RouteDescriptor) GetState

func (x *RouteDescriptor) GetState() RouteState

func (*RouteDescriptor) ProtoMessage

func (*RouteDescriptor) ProtoMessage()

func (*RouteDescriptor) ProtoReflect

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

func (*RouteDescriptor) Reset

func (x *RouteDescriptor) Reset()

func (*RouteDescriptor) String

func (x *RouteDescriptor) String() string

type RouteState

type RouteState int32
const (
	RouteState_ROUTE_STATE_UNSPECIFIED      RouteState = 0
	RouteState_ROUTE_STATE_ACTIVE           RouteState = 1
	RouteState_ROUTE_STATE_WRITE_FENCED     RouteState = 2
	RouteState_ROUTE_STATE_MIGRATING_SOURCE RouteState = 3
	RouteState_ROUTE_STATE_MIGRATING_TARGET RouteState = 4
)

func (RouteState) Descriptor

func (RouteState) Descriptor() protoreflect.EnumDescriptor

func (RouteState) Enum

func (x RouteState) Enum() *RouteState

func (RouteState) EnumDescriptor deprecated

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

Deprecated: Use RouteState.Descriptor instead.

func (RouteState) Number

func (x RouteState) Number() protoreflect.EnumNumber

func (RouteState) String

func (x RouteState) String() string

func (RouteState) Type

type RouteTransition

type RouteTransition struct {
	ParentRouteId uint64   `protobuf:"varint,1,opt,name=parent_route_id,json=parentRouteId,proto3" json:"parent_route_id,omitempty"`
	ChildRouteIds []uint64 `protobuf:"varint,2,rep,packed,name=child_route_ids,json=childRouteIds,proto3" json:"child_route_ids,omitempty"`
	LineageId     string   `protobuf:"bytes,3,opt,name=lineage_id,json=lineageId,proto3" json:"lineage_id,omitempty"`
	UnixMs        int64    `protobuf:"varint,4,opt,name=unix_ms,json=unixMs,proto3" json:"unix_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteTransition) Descriptor deprecated

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

Deprecated: Use RouteTransition.ProtoReflect.Descriptor instead.

func (*RouteTransition) GetChildRouteIds

func (x *RouteTransition) GetChildRouteIds() []uint64

func (*RouteTransition) GetLineageId

func (x *RouteTransition) GetLineageId() string

func (*RouteTransition) GetParentRouteId

func (x *RouteTransition) GetParentRouteId() uint64

func (*RouteTransition) GetUnixMs

func (x *RouteTransition) GetUnixMs() int64

func (*RouteTransition) ProtoMessage

func (*RouteTransition) ProtoMessage()

func (*RouteTransition) ProtoReflect

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

func (*RouteTransition) Reset

func (x *RouteTransition) Reset()

func (*RouteTransition) String

func (x *RouteTransition) String() string

type S3BlobFetchClient

S3BlobFetchClient is the client API for S3BlobFetch service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type S3BlobFetchServer

type S3BlobFetchServer interface {
	FetchChunkBlob(*FetchChunkBlobRequest, grpc.ServerStreamingServer[FetchChunkBlobResponse]) error
	PushChunkBlob(grpc.ClientStreamingServer[PushChunkBlobRequest, PushChunkBlobResponse]) error
	// contains filtered or unexported methods
}

S3BlobFetchServer is the server API for S3BlobFetch service. All implementations must embed UnimplementedS3BlobFetchServer for forward compatibility.

type S3BlobFetch_FetchChunkBlobClient

type S3BlobFetch_FetchChunkBlobClient = grpc.ServerStreamingClient[FetchChunkBlobResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type S3BlobFetch_FetchChunkBlobServer

type S3BlobFetch_FetchChunkBlobServer = grpc.ServerStreamingServer[FetchChunkBlobResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type S3BlobFetch_PushChunkBlobClient

type S3BlobFetch_PushChunkBlobClient = grpc.ClientStreamingClient[PushChunkBlobRequest, PushChunkBlobResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type S3BlobFetch_PushChunkBlobServer

type S3BlobFetch_PushChunkBlobServer = grpc.ClientStreamingServer[PushChunkBlobRequest, PushChunkBlobResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SampleRole

type SampleRole int32
const (
	SampleRole_SAMPLE_ROLE_UNSPECIFIED   SampleRole = 0
	SampleRole_SAMPLE_ROLE_LEADER_WRITE  SampleRole = 1
	SampleRole_SAMPLE_ROLE_LEADER_READ   SampleRole = 2
	SampleRole_SAMPLE_ROLE_FOLLOWER_READ SampleRole = 3
)

func (SampleRole) Descriptor

func (SampleRole) Descriptor() protoreflect.EnumDescriptor

func (SampleRole) Enum

func (x SampleRole) Enum() *SampleRole

func (SampleRole) EnumDescriptor deprecated

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

Deprecated: Use SampleRole.Descriptor instead.

func (SampleRole) Number

func (x SampleRole) Number() protoreflect.EnumNumber

func (SampleRole) String

func (x SampleRole) String() string

func (SampleRole) Type

type ScanRequest

type ScanRequest struct {
	StartKey []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Limit    uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanRequest) Descriptor deprecated

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

Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.

func (*ScanRequest) GetEndKey

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

func (*ScanRequest) GetLimit

func (x *ScanRequest) GetLimit() uint64

func (*ScanRequest) GetStartKey

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

func (*ScanRequest) ProtoMessage

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) ProtoReflect

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

func (*ScanRequest) Reset

func (x *ScanRequest) Reset()

func (*ScanRequest) String

func (x *ScanRequest) String() string

type ScanResponse

type ScanResponse struct {
	Kv []*Kv `protobuf:"bytes,1,rep,name=kv,proto3" json:"kv,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanResponse) Descriptor deprecated

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

Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.

func (*ScanResponse) GetKv

func (x *ScanResponse) GetKv() []*Kv

func (*ScanResponse) ProtoMessage

func (*ScanResponse) ProtoMessage()

func (*ScanResponse) ProtoReflect

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

func (*ScanResponse) Reset

func (x *ScanResponse) Reset()

func (*ScanResponse) String

func (x *ScanResponse) String() string

type SetAutoSplitEnabledRequest

type SetAutoSplitEnabledRequest struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAutoSplitEnabledRequest) Descriptor deprecated

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

Deprecated: Use SetAutoSplitEnabledRequest.ProtoReflect.Descriptor instead.

func (*SetAutoSplitEnabledRequest) GetEnabled

func (x *SetAutoSplitEnabledRequest) GetEnabled() bool

func (*SetAutoSplitEnabledRequest) ProtoMessage

func (*SetAutoSplitEnabledRequest) ProtoMessage()

func (*SetAutoSplitEnabledRequest) ProtoReflect

func (*SetAutoSplitEnabledRequest) Reset

func (x *SetAutoSplitEnabledRequest) Reset()

func (*SetAutoSplitEnabledRequest) String

func (x *SetAutoSplitEnabledRequest) String() string

type SetAutoSplitEnabledResponse

type SetAutoSplitEnabledResponse struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAutoSplitEnabledResponse) Descriptor deprecated

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

Deprecated: Use SetAutoSplitEnabledResponse.ProtoReflect.Descriptor instead.

func (*SetAutoSplitEnabledResponse) GetEnabled

func (x *SetAutoSplitEnabledResponse) GetEnabled() bool

func (*SetAutoSplitEnabledResponse) ProtoMessage

func (*SetAutoSplitEnabledResponse) ProtoMessage()

func (*SetAutoSplitEnabledResponse) ProtoReflect

func (*SetAutoSplitEnabledResponse) Reset

func (x *SetAutoSplitEnabledResponse) Reset()

func (*SetAutoSplitEnabledResponse) String

func (x *SetAutoSplitEnabledResponse) String() string

type SidecarStateReport

type SidecarStateReport struct {
	WrappedDeksById          map[uint32][]byte `` /* 185-byte string literal not displayed */
	ActiveStorageId          uint32            `protobuf:"varint,2,opt,name=active_storage_id,json=activeStorageId,proto3" json:"active_storage_id,omitempty"`
	ActiveRaftId             uint32            `protobuf:"varint,3,opt,name=active_raft_id,json=activeRaftId,proto3" json:"active_raft_id,omitempty"`
	StorageEnvelopeActive    bool              `` /* 127-byte string literal not displayed */
	RaftEnvelopeCutoverIndex uint64            `` /* 138-byte string literal not displayed */
	LatestAppliedIndex       uint64            `protobuf:"varint,6,opt,name=latest_applied_index,json=latestAppliedIndex,proto3" json:"latest_applied_index,omitempty"`
	WriterRegistryForCaller  map[uint32]uint32 `` // values MUST be <= 0xFFFF.
	/* 210-byte string literal not displayed */
	// contains filtered or unexported fields
}

SidecarStateReport is the §5.5 compaction-fallback RPC. Served on every node but the cutover-recovery flow only consults the leader's response. wrapped_deks_by_id covers every unretired DEK. Because this request is Empty, writer_registry_for_caller is the server's local-node projection; caller-specific follower repair uses ResyncSidecarRequest.caller_full_node_id.

func (*SidecarStateReport) Descriptor deprecated

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

Deprecated: Use SidecarStateReport.ProtoReflect.Descriptor instead.

func (*SidecarStateReport) GetActiveRaftId

func (x *SidecarStateReport) GetActiveRaftId() uint32

func (*SidecarStateReport) GetActiveStorageId

func (x *SidecarStateReport) GetActiveStorageId() uint32

func (*SidecarStateReport) GetLatestAppliedIndex

func (x *SidecarStateReport) GetLatestAppliedIndex() uint64

func (*SidecarStateReport) GetRaftEnvelopeCutoverIndex

func (x *SidecarStateReport) GetRaftEnvelopeCutoverIndex() uint64

func (*SidecarStateReport) GetStorageEnvelopeActive

func (x *SidecarStateReport) GetStorageEnvelopeActive() bool

func (*SidecarStateReport) GetWrappedDeksById

func (x *SidecarStateReport) GetWrappedDeksById() map[uint32][]byte

func (*SidecarStateReport) GetWriterRegistryForCaller

func (x *SidecarStateReport) GetWriterRegistryForCaller() map[uint32]uint32

func (*SidecarStateReport) ProtoMessage

func (*SidecarStateReport) ProtoMessage()

func (*SidecarStateReport) ProtoReflect

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

func (*SidecarStateReport) Reset

func (x *SidecarStateReport) Reset()

func (*SidecarStateReport) String

func (x *SidecarStateReport) String() string

type SplitJob

type SplitJob struct {
	JobId                            uint64                     `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	SourceRouteId                    uint64                     `protobuf:"varint,2,opt,name=source_route_id,json=sourceRouteId,proto3" json:"source_route_id,omitempty"`
	SplitKey                         []byte                     `protobuf:"bytes,3,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	TargetGroupId                    uint64                     `protobuf:"varint,4,opt,name=target_group_id,json=targetGroupId,proto3" json:"target_group_id,omitempty"`
	Phase                            SplitJobPhase              `protobuf:"varint,5,opt,name=phase,proto3,enum=SplitJobPhase" json:"phase,omitempty"`
	RetryPhase                       SplitJobPhase              `protobuf:"varint,6,opt,name=retry_phase,json=retryPhase,proto3,enum=SplitJobPhase" json:"retry_phase,omitempty"`
	AbandonFromPhase                 SplitJobPhase              `` /* 131-byte string literal not displayed */
	SnapshotTs                       uint64                     `protobuf:"varint,8,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,omitempty"`
	SnapshotMinAdmittedTs            uint64                     `` /* 129-byte string literal not displayed */
	WriteTrackerArmed                bool                       `protobuf:"varint,10,opt,name=write_tracker_armed,json=writeTrackerArmed,proto3" json:"write_tracker_armed,omitempty"`
	DeltaFloor                       uint64                     `protobuf:"varint,11,opt,name=delta_floor,json=deltaFloor,proto3" json:"delta_floor,omitempty"`
	PostFenceDrainCompleted          bool                       `` /* 136-byte string literal not displayed */
	FenceTs                          uint64                     `protobuf:"varint,13,opt,name=fence_ts,json=fenceTs,proto3" json:"fence_ts,omitempty"`
	CutoverVersion                   uint64                     `protobuf:"varint,14,opt,name=cutover_version,json=cutoverVersion,proto3" json:"cutover_version,omitempty"`
	CutoverReadFenceState            SplitJobBarrierState       `` /* 156-byte string literal not displayed */
	TargetStagedReadinessState       SplitJobBarrierState       `` /* 171-byte string literal not displayed */
	SourceCutoverReadFenceAckCursor  []byte                     `` /* 163-byte string literal not displayed */
	TargetStagedReadinessAckCursor   []byte                     `` /* 158-byte string literal not displayed */
	Cursor                           []byte                     `protobuf:"bytes,19,opt,name=cursor,proto3" json:"cursor,omitempty"`
	MaxImportedTs                    uint64                     `protobuf:"varint,20,opt,name=max_imported_ts,json=maxImportedTs,proto3" json:"max_imported_ts,omitempty"`
	TargetPromotionDone              bool                       `protobuf:"varint,21,opt,name=target_promotion_done,json=targetPromotionDone,proto3" json:"target_promotion_done,omitempty"`
	PromotionCompletedTs             uint64                     `protobuf:"varint,22,opt,name=promotion_completed_ts,json=promotionCompletedTs,proto3" json:"promotion_completed_ts,omitempty"`
	FenceCatalogVersion              uint64                     `protobuf:"varint,23,opt,name=fence_catalog_version,json=fenceCatalogVersion,proto3" json:"fence_catalog_version,omitempty"`
	FenceAckCursor                   []byte                     `protobuf:"bytes,24,opt,name=fence_ack_cursor,json=fenceAckCursor,proto3" json:"fence_ack_cursor,omitempty"`
	SourceCutoverAckCursor           []byte                     `` /* 132-byte string literal not displayed */
	SourceReadDrainCursor            []byte                     `` /* 129-byte string literal not displayed */
	TargetClearedDescriptorAckCursor []byte                     `` /* 164-byte string literal not displayed */
	BracketProgress                  []*SplitJobBracketProgress `protobuf:"bytes,28,rep,name=bracket_progress,json=bracketProgress,proto3" json:"bracket_progress,omitempty"`
	SourceRetentionPinTs             uint64                     `` /* 127-byte string literal not displayed */
	LastError                        string                     `protobuf:"bytes,30,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	StartedAtMs                      int64                      `protobuf:"varint,31,opt,name=started_at_ms,json=startedAtMs,proto3" json:"started_at_ms,omitempty"`
	UpdatedAtMs                      int64                      `protobuf:"varint,32,opt,name=updated_at_ms,json=updatedAtMs,proto3" json:"updated_at_ms,omitempty"`
	TerminalAtMs                     int64                      `protobuf:"varint,33,opt,name=terminal_at_ms,json=terminalAtMs,proto3" json:"terminal_at_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitJob) Descriptor deprecated

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

Deprecated: Use SplitJob.ProtoReflect.Descriptor instead.

func (*SplitJob) GetAbandonFromPhase

func (x *SplitJob) GetAbandonFromPhase() SplitJobPhase

func (*SplitJob) GetBracketProgress

func (x *SplitJob) GetBracketProgress() []*SplitJobBracketProgress

func (*SplitJob) GetCursor

func (x *SplitJob) GetCursor() []byte

func (*SplitJob) GetCutoverReadFenceState

func (x *SplitJob) GetCutoverReadFenceState() SplitJobBarrierState

func (*SplitJob) GetCutoverVersion

func (x *SplitJob) GetCutoverVersion() uint64

func (*SplitJob) GetDeltaFloor

func (x *SplitJob) GetDeltaFloor() uint64

func (*SplitJob) GetFenceAckCursor

func (x *SplitJob) GetFenceAckCursor() []byte

func (*SplitJob) GetFenceCatalogVersion

func (x *SplitJob) GetFenceCatalogVersion() uint64

func (*SplitJob) GetFenceTs

func (x *SplitJob) GetFenceTs() uint64

func (*SplitJob) GetJobId

func (x *SplitJob) GetJobId() uint64

func (*SplitJob) GetLastError

func (x *SplitJob) GetLastError() string

func (*SplitJob) GetMaxImportedTs

func (x *SplitJob) GetMaxImportedTs() uint64

func (*SplitJob) GetPhase

func (x *SplitJob) GetPhase() SplitJobPhase

func (*SplitJob) GetPostFenceDrainCompleted

func (x *SplitJob) GetPostFenceDrainCompleted() bool

func (*SplitJob) GetPromotionCompletedTs

func (x *SplitJob) GetPromotionCompletedTs() uint64

func (*SplitJob) GetRetryPhase

func (x *SplitJob) GetRetryPhase() SplitJobPhase

func (*SplitJob) GetSnapshotMinAdmittedTs

func (x *SplitJob) GetSnapshotMinAdmittedTs() uint64

func (*SplitJob) GetSnapshotTs

func (x *SplitJob) GetSnapshotTs() uint64

func (*SplitJob) GetSourceCutoverAckCursor

func (x *SplitJob) GetSourceCutoverAckCursor() []byte

func (*SplitJob) GetSourceCutoverReadFenceAckCursor

func (x *SplitJob) GetSourceCutoverReadFenceAckCursor() []byte

func (*SplitJob) GetSourceReadDrainCursor

func (x *SplitJob) GetSourceReadDrainCursor() []byte

func (*SplitJob) GetSourceRetentionPinTs

func (x *SplitJob) GetSourceRetentionPinTs() uint64

func (*SplitJob) GetSourceRouteId

func (x *SplitJob) GetSourceRouteId() uint64

func (*SplitJob) GetSplitKey

func (x *SplitJob) GetSplitKey() []byte

func (*SplitJob) GetStartedAtMs

func (x *SplitJob) GetStartedAtMs() int64

func (*SplitJob) GetTargetClearedDescriptorAckCursor

func (x *SplitJob) GetTargetClearedDescriptorAckCursor() []byte

func (*SplitJob) GetTargetGroupId

func (x *SplitJob) GetTargetGroupId() uint64

func (*SplitJob) GetTargetPromotionDone

func (x *SplitJob) GetTargetPromotionDone() bool

func (*SplitJob) GetTargetStagedReadinessAckCursor

func (x *SplitJob) GetTargetStagedReadinessAckCursor() []byte

func (*SplitJob) GetTargetStagedReadinessState

func (x *SplitJob) GetTargetStagedReadinessState() SplitJobBarrierState

func (*SplitJob) GetTerminalAtMs

func (x *SplitJob) GetTerminalAtMs() int64

func (*SplitJob) GetUpdatedAtMs

func (x *SplitJob) GetUpdatedAtMs() int64

func (*SplitJob) GetWriteTrackerArmed

func (x *SplitJob) GetWriteTrackerArmed() bool

func (*SplitJob) ProtoMessage

func (*SplitJob) ProtoMessage()

func (*SplitJob) ProtoReflect

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

func (*SplitJob) Reset

func (x *SplitJob) Reset()

func (*SplitJob) String

func (x *SplitJob) String() string

type SplitJobBarrierState

type SplitJobBarrierState int32
const (
	SplitJobBarrierState_SPLIT_JOB_BARRIER_STATE_NONE     SplitJobBarrierState = 0
	SplitJobBarrierState_SPLIT_JOB_BARRIER_STATE_ARMING   SplitJobBarrierState = 1
	SplitJobBarrierState_SPLIT_JOB_BARRIER_STATE_ARMED    SplitJobBarrierState = 2
	SplitJobBarrierState_SPLIT_JOB_BARRIER_STATE_CLEARING SplitJobBarrierState = 3
)

func (SplitJobBarrierState) Descriptor

func (SplitJobBarrierState) Enum

func (SplitJobBarrierState) EnumDescriptor deprecated

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

Deprecated: Use SplitJobBarrierState.Descriptor instead.

func (SplitJobBarrierState) Number

func (SplitJobBarrierState) String

func (x SplitJobBarrierState) String() string

func (SplitJobBarrierState) Type

type SplitJobBracketProgress

type SplitJobBracketProgress struct {
	BracketId         uint64              `protobuf:"varint,1,opt,name=bracket_id,json=bracketId,proto3" json:"bracket_id,omitempty"`
	Family            uint32              `protobuf:"varint,2,opt,name=family,proto3" json:"family,omitempty"`
	ExportPhase       SplitJobExportPhase `protobuf:"varint,3,opt,name=export_phase,json=exportPhase,proto3,enum=SplitJobExportPhase" json:"export_phase,omitempty"`
	Cursor            []byte              `protobuf:"bytes,4,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Done              bool                `protobuf:"varint,5,opt,name=done,proto3" json:"done,omitempty"`
	ScannedBytes      uint64              `protobuf:"varint,6,opt,name=scanned_bytes,json=scannedBytes,proto3" json:"scanned_bytes,omitempty"`
	AcceptedRows      uint64              `protobuf:"varint,7,opt,name=accepted_rows,json=acceptedRows,proto3" json:"accepted_rows,omitempty"`
	LastAckedBatchSeq uint64              `protobuf:"varint,8,opt,name=last_acked_batch_seq,json=lastAckedBatchSeq,proto3" json:"last_acked_batch_seq,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitJobBracketProgress) Descriptor deprecated

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

Deprecated: Use SplitJobBracketProgress.ProtoReflect.Descriptor instead.

func (*SplitJobBracketProgress) GetAcceptedRows

func (x *SplitJobBracketProgress) GetAcceptedRows() uint64

func (*SplitJobBracketProgress) GetBracketId

func (x *SplitJobBracketProgress) GetBracketId() uint64

func (*SplitJobBracketProgress) GetCursor

func (x *SplitJobBracketProgress) GetCursor() []byte

func (*SplitJobBracketProgress) GetDone

func (x *SplitJobBracketProgress) GetDone() bool

func (*SplitJobBracketProgress) GetExportPhase

func (x *SplitJobBracketProgress) GetExportPhase() SplitJobExportPhase

func (*SplitJobBracketProgress) GetFamily

func (x *SplitJobBracketProgress) GetFamily() uint32

func (*SplitJobBracketProgress) GetLastAckedBatchSeq

func (x *SplitJobBracketProgress) GetLastAckedBatchSeq() uint64

func (*SplitJobBracketProgress) GetScannedBytes

func (x *SplitJobBracketProgress) GetScannedBytes() uint64

func (*SplitJobBracketProgress) ProtoMessage

func (*SplitJobBracketProgress) ProtoMessage()

func (*SplitJobBracketProgress) ProtoReflect

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

func (*SplitJobBracketProgress) Reset

func (x *SplitJobBracketProgress) Reset()

func (*SplitJobBracketProgress) String

func (x *SplitJobBracketProgress) String() string

type SplitJobExportPhase

type SplitJobExportPhase int32
const (
	SplitJobExportPhase_SPLIT_JOB_EXPORT_PHASE_NONE       SplitJobExportPhase = 0
	SplitJobExportPhase_SPLIT_JOB_EXPORT_PHASE_BACKFILL   SplitJobExportPhase = 1
	SplitJobExportPhase_SPLIT_JOB_EXPORT_PHASE_DELTA_COPY SplitJobExportPhase = 2
)

func (SplitJobExportPhase) Descriptor

func (SplitJobExportPhase) Enum

func (SplitJobExportPhase) EnumDescriptor deprecated

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

Deprecated: Use SplitJobExportPhase.Descriptor instead.

func (SplitJobExportPhase) Number

func (SplitJobExportPhase) String

func (x SplitJobExportPhase) String() string

func (SplitJobExportPhase) Type

type SplitJobPhase

type SplitJobPhase int32
const (
	SplitJobPhase_SPLIT_JOB_PHASE_NONE       SplitJobPhase = 0
	SplitJobPhase_SPLIT_JOB_PHASE_PLANNED    SplitJobPhase = 1
	SplitJobPhase_SPLIT_JOB_PHASE_BACKFILL   SplitJobPhase = 2
	SplitJobPhase_SPLIT_JOB_PHASE_FENCE      SplitJobPhase = 3
	SplitJobPhase_SPLIT_JOB_PHASE_DELTA_COPY SplitJobPhase = 4
	SplitJobPhase_SPLIT_JOB_PHASE_CUTOVER    SplitJobPhase = 5
	SplitJobPhase_SPLIT_JOB_PHASE_CLEANUP    SplitJobPhase = 6
	SplitJobPhase_SPLIT_JOB_PHASE_DONE       SplitJobPhase = 7
	SplitJobPhase_SPLIT_JOB_PHASE_FAILED     SplitJobPhase = 8
	SplitJobPhase_SPLIT_JOB_PHASE_ABANDONING SplitJobPhase = 9
	SplitJobPhase_SPLIT_JOB_PHASE_ABANDONED  SplitJobPhase = 10
)

func (SplitJobPhase) Descriptor

func (SplitJobPhase) Enum

func (x SplitJobPhase) Enum() *SplitJobPhase

func (SplitJobPhase) EnumDescriptor deprecated

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

Deprecated: Use SplitJobPhase.Descriptor instead.

func (SplitJobPhase) Number

func (SplitJobPhase) String

func (x SplitJobPhase) String() string

func (SplitJobPhase) Type

type SplitRangeRequest

type SplitRangeRequest struct {
	ExpectedCatalogVersion uint64 `` /* 130-byte string literal not displayed */
	RouteId                uint64 `protobuf:"varint,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	SplitKey               []byte `protobuf:"bytes,3,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitRangeRequest) Descriptor deprecated

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

Deprecated: Use SplitRangeRequest.ProtoReflect.Descriptor instead.

func (*SplitRangeRequest) GetExpectedCatalogVersion

func (x *SplitRangeRequest) GetExpectedCatalogVersion() uint64

func (*SplitRangeRequest) GetRouteId

func (x *SplitRangeRequest) GetRouteId() uint64

func (*SplitRangeRequest) GetSplitKey

func (x *SplitRangeRequest) GetSplitKey() []byte

func (*SplitRangeRequest) ProtoMessage

func (*SplitRangeRequest) ProtoMessage()

func (*SplitRangeRequest) ProtoReflect

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

func (*SplitRangeRequest) Reset

func (x *SplitRangeRequest) Reset()

func (*SplitRangeRequest) String

func (x *SplitRangeRequest) String() string

type SplitRangeResponse

type SplitRangeResponse struct {
	CatalogVersion uint64           `protobuf:"varint,1,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	Left           *RouteDescriptor `protobuf:"bytes,2,opt,name=left,proto3" json:"left,omitempty"`
	Right          *RouteDescriptor `protobuf:"bytes,3,opt,name=right,proto3" json:"right,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitRangeResponse) Descriptor deprecated

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

Deprecated: Use SplitRangeResponse.ProtoReflect.Descriptor instead.

func (*SplitRangeResponse) GetCatalogVersion

func (x *SplitRangeResponse) GetCatalogVersion() uint64

func (*SplitRangeResponse) GetLeft

func (x *SplitRangeResponse) GetLeft() *RouteDescriptor

func (*SplitRangeResponse) GetRight

func (x *SplitRangeResponse) GetRight() *RouteDescriptor

func (*SplitRangeResponse) ProtoMessage

func (*SplitRangeResponse) ProtoMessage()

func (*SplitRangeResponse) ProtoReflect

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

func (*SplitRangeResponse) Reset

func (x *SplitRangeResponse) Reset()

func (*SplitRangeResponse) String

func (x *SplitRangeResponse) String() string

type StartSplitMigrationRequest

type StartSplitMigrationRequest struct {
	ExpectedCatalogVersion uint64            `` /* 130-byte string literal not displayed */
	RouteId                uint64            `protobuf:"varint,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	SplitKey               []byte            `protobuf:"bytes,3,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	TargetGroupId          uint64            `protobuf:"varint,4,opt,name=target_group_id,json=targetGroupId,proto3" json:"target_group_id,omitempty"`
	Options                map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartSplitMigrationRequest) Descriptor deprecated

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

Deprecated: Use StartSplitMigrationRequest.ProtoReflect.Descriptor instead.

func (*StartSplitMigrationRequest) GetExpectedCatalogVersion

func (x *StartSplitMigrationRequest) GetExpectedCatalogVersion() uint64

func (*StartSplitMigrationRequest) GetOptions

func (x *StartSplitMigrationRequest) GetOptions() map[string]string

func (*StartSplitMigrationRequest) GetRouteId

func (x *StartSplitMigrationRequest) GetRouteId() uint64

func (*StartSplitMigrationRequest) GetSplitKey

func (x *StartSplitMigrationRequest) GetSplitKey() []byte

func (*StartSplitMigrationRequest) GetTargetGroupId

func (x *StartSplitMigrationRequest) GetTargetGroupId() uint64

func (*StartSplitMigrationRequest) ProtoMessage

func (*StartSplitMigrationRequest) ProtoMessage()

func (*StartSplitMigrationRequest) ProtoReflect

func (*StartSplitMigrationRequest) Reset

func (x *StartSplitMigrationRequest) Reset()

func (*StartSplitMigrationRequest) String

func (x *StartSplitMigrationRequest) String() string

type StartSplitMigrationResponse

type StartSplitMigrationResponse struct {
	CatalogVersion uint64 `protobuf:"varint,1,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	JobId          uint64 `protobuf:"varint,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartSplitMigrationResponse) Descriptor deprecated

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

Deprecated: Use StartSplitMigrationResponse.ProtoReflect.Descriptor instead.

func (*StartSplitMigrationResponse) GetCatalogVersion

func (x *StartSplitMigrationResponse) GetCatalogVersion() uint64

func (*StartSplitMigrationResponse) GetJobId

func (x *StartSplitMigrationResponse) GetJobId() uint64

func (*StartSplitMigrationResponse) ProtoMessage

func (*StartSplitMigrationResponse) ProtoMessage()

func (*StartSplitMigrationResponse) ProtoReflect

func (*StartSplitMigrationResponse) Reset

func (x *StartSplitMigrationResponse) Reset()

func (*StartSplitMigrationResponse) String

func (x *StartSplitMigrationResponse) String() string

type StreamBackupRequest

type StreamBackupRequest struct {
	PinToken []byte `protobuf:"bytes,1,opt,name=pin_token,json=pinToken,proto3" json:"pin_token,omitempty"`
	// Empty means every scope present at read_ts. Otherwise only the exact
	// adapter/scope pairs are emitted.
	Scopes []*BackupScope `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamBackupRequest) Descriptor deprecated

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

Deprecated: Use StreamBackupRequest.ProtoReflect.Descriptor instead.

func (*StreamBackupRequest) GetPinToken

func (x *StreamBackupRequest) GetPinToken() []byte

func (*StreamBackupRequest) GetScopes

func (x *StreamBackupRequest) GetScopes() []*BackupScope

func (*StreamBackupRequest) ProtoMessage

func (*StreamBackupRequest) ProtoMessage()

func (*StreamBackupRequest) ProtoReflect

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

func (*StreamBackupRequest) Reset

func (x *StreamBackupRequest) Reset()

func (*StreamBackupRequest) String

func (x *StreamBackupRequest) String() string

type StreamEventsEvent

type StreamEventsEvent struct {

	// Types that are valid to be assigned to Event:
	//
	//	*StreamEventsEvent_RouteTransition
	//	*StreamEventsEvent_KeyvizColumn
	Event isStreamEventsEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*StreamEventsEvent) Descriptor deprecated

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

Deprecated: Use StreamEventsEvent.ProtoReflect.Descriptor instead.

func (*StreamEventsEvent) GetEvent

func (x *StreamEventsEvent) GetEvent() isStreamEventsEvent_Event

func (*StreamEventsEvent) GetKeyvizColumn

func (x *StreamEventsEvent) GetKeyvizColumn() *KeyVizColumn

func (*StreamEventsEvent) GetRouteTransition

func (x *StreamEventsEvent) GetRouteTransition() *RouteTransition

func (*StreamEventsEvent) ProtoMessage

func (*StreamEventsEvent) ProtoMessage()

func (*StreamEventsEvent) ProtoReflect

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

func (*StreamEventsEvent) Reset

func (x *StreamEventsEvent) Reset()

func (*StreamEventsEvent) String

func (x *StreamEventsEvent) String() string

type StreamEventsEvent_KeyvizColumn

type StreamEventsEvent_KeyvizColumn struct {
	KeyvizColumn *KeyVizColumn `protobuf:"bytes,2,opt,name=keyviz_column,json=keyvizColumn,proto3,oneof"`
}

type StreamEventsEvent_RouteTransition

type StreamEventsEvent_RouteTransition struct {
	RouteTransition *RouteTransition `protobuf:"bytes,1,opt,name=route_transition,json=routeTransition,proto3,oneof"`
}

type StreamEventsRequest

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

func (*StreamEventsRequest) Descriptor deprecated

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

Deprecated: Use StreamEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamEventsRequest) ProtoMessage

func (*StreamEventsRequest) ProtoMessage()

func (*StreamEventsRequest) ProtoReflect

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

func (*StreamEventsRequest) Reset

func (x *StreamEventsRequest) Reset()

func (*StreamEventsRequest) String

func (x *StreamEventsRequest) String() string

type TransactionalKVClient

type TransactionalKVClient interface {
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error)
	PreWrite(ctx context.Context, in *PreWriteRequest, opts ...grpc.CallOption) (*PreCommitResponse, error)
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error)
}

TransactionalKVClient is the client API for TransactionalKV service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type TransactionalKVServer

type TransactionalKVServer interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Scan(context.Context, *ScanRequest) (*ScanResponse, error)
	PreWrite(context.Context, *PreWriteRequest) (*PreCommitResponse, error)
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error)
	// contains filtered or unexported methods
}

TransactionalKVServer is the server API for TransactionalKV service. All implementations must embed UnimplementedTransactionalKVServer for forward compatibility.

type TransferTarget

type TransferTarget struct {
	TargetId      string `protobuf:"bytes,1,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	TargetAddress string `protobuf:"bytes,2,opt,name=target_address,json=targetAddress,proto3" json:"target_address,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferTarget) Descriptor deprecated

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

Deprecated: Use TransferTarget.ProtoReflect.Descriptor instead.

func (*TransferTarget) GetTargetAddress

func (x *TransferTarget) GetTargetAddress() string

func (*TransferTarget) GetTargetId

func (x *TransferTarget) GetTargetId() string

func (*TransferTarget) ProtoMessage

func (*TransferTarget) ProtoMessage()

func (*TransferTarget) ProtoReflect

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

func (*TransferTarget) Reset

func (x *TransferTarget) Reset()

func (*TransferTarget) String

func (x *TransferTarget) String() string

type UnimplementedAdminForwardServer

type UnimplementedAdminForwardServer struct{}

UnimplementedAdminForwardServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAdminForwardServer) Forward

type UnimplementedAdminServer

type UnimplementedAdminServer struct{}

UnimplementedAdminServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAdminServer) BeginBackup

func (UnimplementedAdminServer) EndBackup

func (UnimplementedAdminServer) GetKeyVizMatrix

func (UnimplementedAdminServer) GetNodeVersion

func (UnimplementedAdminServer) GetRaftGroups

func (UnimplementedAdminServer) GetRouteDetail

func (UnimplementedAdminServer) RenewBackup

func (UnimplementedAdminServer) StreamBackup

type UnimplementedDistributionServer

type UnimplementedDistributionServer struct{}

UnimplementedDistributionServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDistributionServer) AbandonSplitJob

func (UnimplementedDistributionServer) GetCatalogCapabilities

func (UnimplementedDistributionServer) GetRoute

func (UnimplementedDistributionServer) GetRouteOwnership

func (UnimplementedDistributionServer) GetSplitJob

func (UnimplementedDistributionServer) GetTimestamp

func (UnimplementedDistributionServer) ListRoutes

func (UnimplementedDistributionServer) ListSplitJobs

func (UnimplementedDistributionServer) RetrySplitJob

func (UnimplementedDistributionServer) SplitRange

func (UnimplementedDistributionServer) ValidateTimestamp

type UnimplementedEncryptionAdminServer

type UnimplementedEncryptionAdminServer struct{}

UnimplementedEncryptionAdminServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEncryptionAdminServer) BootstrapEncryption

func (UnimplementedEncryptionAdminServer) EnableRaftEnvelope

func (UnimplementedEncryptionAdminServer) GetCapability

func (UnimplementedEncryptionAdminServer) GetSidecarState

func (UnimplementedEncryptionAdminServer) ResyncSidecar

func (UnimplementedEncryptionAdminServer) RotateDEK

type UnimplementedEtcdRaftServer

type UnimplementedEtcdRaftServer struct{}

UnimplementedEtcdRaftServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEtcdRaftServer) Send

func (UnimplementedEtcdRaftServer) SendStream

type UnimplementedInternalServer

type UnimplementedInternalServer struct{}

UnimplementedInternalServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedInternalServer) Forward

func (UnimplementedInternalServer) ForwardLeaseRead

func (UnimplementedInternalServer) RelayPublish

type UnimplementedRaftAdminServer

type UnimplementedRaftAdminServer struct{}

UnimplementedRaftAdminServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

type UnimplementedRawKVServer

type UnimplementedRawKVServer struct{}

UnimplementedRawKVServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRawKVServer) RawDelete

func (UnimplementedRawKVServer) RawGet

func (UnimplementedRawKVServer) RawPut

func (UnimplementedRawKVServer) RawScanAt

type UnimplementedS3BlobFetchServer

type UnimplementedS3BlobFetchServer struct{}

UnimplementedS3BlobFetchServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

type UnimplementedTransactionalKVServer

type UnimplementedTransactionalKVServer struct{}

UnimplementedTransactionalKVServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTransactionalKVServer) Commit

func (UnimplementedTransactionalKVServer) Delete

func (UnimplementedTransactionalKVServer) Get

func (UnimplementedTransactionalKVServer) PreWrite

func (UnimplementedTransactionalKVServer) Put

func (UnimplementedTransactionalKVServer) Rollback

func (UnimplementedTransactionalKVServer) Scan

type UnsafeAdminForwardServer

type UnsafeAdminForwardServer interface {
	// contains filtered or unexported methods
}

UnsafeAdminForwardServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminForwardServer will result in compilation errors.

type UnsafeAdminServer

type UnsafeAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServer will result in compilation errors.

type UnsafeDistributionServer

type UnsafeDistributionServer interface {
	// contains filtered or unexported methods
}

UnsafeDistributionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DistributionServer will result in compilation errors.

type UnsafeEncryptionAdminServer

type UnsafeEncryptionAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeEncryptionAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EncryptionAdminServer will result in compilation errors.

type UnsafeEtcdRaftServer

type UnsafeEtcdRaftServer interface {
	// contains filtered or unexported methods
}

UnsafeEtcdRaftServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EtcdRaftServer will result in compilation errors.

type UnsafeInternalServer

type UnsafeInternalServer interface {
	// contains filtered or unexported methods
}

UnsafeInternalServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InternalServer will result in compilation errors.

type UnsafeRaftAdminServer

type UnsafeRaftAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeRaftAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RaftAdminServer will result in compilation errors.

type UnsafeRawKVServer

type UnsafeRawKVServer interface {
	// contains filtered or unexported methods
}

UnsafeRawKVServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RawKVServer will result in compilation errors.

type UnsafeS3BlobFetchServer

type UnsafeS3BlobFetchServer interface {
	// contains filtered or unexported methods
}

UnsafeS3BlobFetchServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to S3BlobFetchServer will result in compilation errors.

type UnsafeTransactionalKVServer

type UnsafeTransactionalKVServer interface {
	// contains filtered or unexported methods
}

UnsafeTransactionalKVServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransactionalKVServer will result in compilation errors.

type ValidateTimestampRequest

type ValidateTimestampRequest struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateTimestampRequest) Descriptor deprecated

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

Deprecated: Use ValidateTimestampRequest.ProtoReflect.Descriptor instead.

func (*ValidateTimestampRequest) GetTimestamp

func (x *ValidateTimestampRequest) GetTimestamp() uint64

func (*ValidateTimestampRequest) ProtoMessage

func (*ValidateTimestampRequest) ProtoMessage()

func (*ValidateTimestampRequest) ProtoReflect

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

func (*ValidateTimestampRequest) Reset

func (x *ValidateTimestampRequest) Reset()

func (*ValidateTimestampRequest) String

func (x *ValidateTimestampRequest) String() string

type ValidateTimestampResponse

type ValidateTimestampResponse struct {
	Valid           bool   `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	PhaseDActive    bool   `protobuf:"varint,2,opt,name=phase_d_active,json=phaseDActive,proto3" json:"phase_d_active,omitempty"`
	PhaseDFloor     uint64 `protobuf:"varint,3,opt,name=phase_d_floor,json=phaseDFloor,proto3" json:"phase_d_floor,omitempty"`
	AllocationFloor uint64 `protobuf:"varint,4,opt,name=allocation_floor,json=allocationFloor,proto3" json:"allocation_floor,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateTimestampResponse) Descriptor deprecated

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

Deprecated: Use ValidateTimestampResponse.ProtoReflect.Descriptor instead.

func (*ValidateTimestampResponse) GetAllocationFloor

func (x *ValidateTimestampResponse) GetAllocationFloor() uint64

func (*ValidateTimestampResponse) GetPhaseDActive

func (x *ValidateTimestampResponse) GetPhaseDActive() bool

func (*ValidateTimestampResponse) GetPhaseDFloor

func (x *ValidateTimestampResponse) GetPhaseDFloor() uint64

func (*ValidateTimestampResponse) GetValid

func (x *ValidateTimestampResponse) GetValid() bool

func (*ValidateTimestampResponse) ProtoMessage

func (*ValidateTimestampResponse) ProtoMessage()

func (*ValidateTimestampResponse) ProtoReflect

func (*ValidateTimestampResponse) Reset

func (x *ValidateTimestampResponse) Reset()

func (*ValidateTimestampResponse) String

func (x *ValidateTimestampResponse) String() string

type WriterRegistryEntry

type WriterRegistryEntry struct {
	FullNodeId uint64 `protobuf:"varint,1,opt,name=full_node_id,json=fullNodeId,proto3" json:"full_node_id,omitempty"`
	LocalEpoch uint32 `protobuf:"varint,2,opt,name=local_epoch,json=localEpoch,proto3" json:"local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// contains filtered or unexported fields
}

WriterRegistryEntry is the per-member input the leader collects during the §5.6 step 1a batch. The two uint32 fields cover the 64-bit full_node_id and the 16-bit local_epoch (carried as uint32; <= 0xFFFF validated at the server boundary).

func (*WriterRegistryEntry) Descriptor deprecated

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

Deprecated: Use WriterRegistryEntry.ProtoReflect.Descriptor instead.

func (*WriterRegistryEntry) GetFullNodeId

func (x *WriterRegistryEntry) GetFullNodeId() uint64

func (*WriterRegistryEntry) GetLocalEpoch

func (x *WriterRegistryEntry) GetLocalEpoch() uint32

func (*WriterRegistryEntry) ProtoMessage

func (*WriterRegistryEntry) ProtoMessage()

func (*WriterRegistryEntry) ProtoReflect

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

func (*WriterRegistryEntry) Reset

func (x *WriterRegistryEntry) Reset()

func (*WriterRegistryEntry) String

func (x *WriterRegistryEntry) String() string

Jump to

Keyboard shortcuts

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