Documentation
¶
Overview ¶
Package types contains generated FDB FlatBuffers message types.
These types are generated by cmd/fdb-schema-extract from FDB C++ headers. Run `just generate-wire-types` to regenerate.
Arena fields ¶
Several types have an `Arena []byte` field (e.g. CommitTransactionRequest, GetKeyValuesRequest, TenantInfo). In C++, Arena is a region allocator for zero-copy deserialization: StringRef fields (keys, values) point directly into the received network buffer, and the Arena keeps that buffer alive. When the message is done being processed, the Arena frees everything at once.
Arena has NO wire representation. C++ scalar_traits<Arena>::size = 0 and save() is a no-op. It appears in C++ serialize() signatures only to enforce a compile-time ordering constraint (fb_must_appear_last). On deserialize, Arena::load() calls context.addArena() to transfer buffer ownership.
In Go, the GC handles buffer lifetime automatically — []byte slices that reference the buffer keep it alive. Arena fields are read from the wire (always empty) but never written during serialization. This is correct behavior, not a bug.
Index ¶
- Constants
- Variables
- func MarshalErrorOrInlineError(code uint16, penalty float64) []byte
- func MarshalErrorOrValueGetKeyValuesReply(reply *GetKeyValuesReply) []byte
- type ClientDBInfo
- type CommitID
- type CommitProxyInterface
- type CommitTransactionRef
- type CommitTransactionRequest
- type Endpoint
- type Error
- type ErrorOrError
- type GetKeyReply
- type GetKeyRequest
- type GetKeyServerLocationsReply
- type GetKeyServerLocationsRequest
- type GetKeyValuesReply
- type GetKeyValuesRequest
- type GetReadVersionReply
- type GetReadVersionRequest
- type GetValueReply
- type GetValueRequest
- type GrvProxyInterface
- type IPAddress
- type KeyRangeRef
- type KeySelectorRef
- type KeyValueRef
- type LocationPair
- type MutationRef
- type NetworkAddress
- type NetworkAddressList
- type OpenDatabaseCoordRequest
- type ReadOptions
- type ReplyPromise
- type SpanContext
- type SplitRangeReply
- type SplitRangeRequest
- type StorageMetrics
- type StorageServerInterface
- type TenantInfo
- type TenantMapEntry
- type VoidReply
- type WaitMetricsRequest
- type WatchValueReply
- type WatchValueRequest
Constants ¶
const ( ClientDBInfoSlotGrvProxies = 0 ClientDBInfoSlotCommitProxies = 1 ClientDBInfoSlotId = 2 ClientDBInfoSlotForward = 3 ClientDBInfoSlotHistory = 5 ClientDBInfoSlotTenantMode = 6 ClientDBInfoSlotEncryptKeyProxy = 7 ClientDBInfoSlotClusterId = 9 ClientDBInfoSlotClusterType = 10 ClientDBInfoSlotMetaclusterName = 11 )
const ( CommitIDSlotVersion = 0 CommitIDSlotTxnBatchId = 1 CommitIDSlotMetadataVersion = 2 CommitIDSlotConflictingKRIndices = 4 )
const ( CommitProxyInterfaceSlotProcessId = 0 CommitProxyInterfaceSlotProvisional = 2 CommitProxyInterfaceSlotCommit = 3 )
const ( CommitProxyInterfaceFileID uint32 = 8954922 CommitProxyInterfaceMaxAlign = 4 )
const ( CommitTransactionRefSlotReadConflictRanges = 0 CommitTransactionRefSlotWriteConflictRanges = 1 CommitTransactionRefSlotMutations = 2 CommitTransactionRefSlotReadSnapshot = 3 CommitTransactionRefSlotReport_conflicting_keys = 4 CommitTransactionRefSlotLock_aware = 5 CommitTransactionRefSlotRead_conflict_ranges_disabled = 6 CommitTransactionRefSlotWrite_conflict_ranges_disabled = 8 )
const ( CommitTransactionRequestSlotTransaction = 0 CommitTransactionRequestSlotReply = 1 CommitTransactionRequestSlotFlags = 2 CommitTransactionRequestSlotDebugID = 3 CommitTransactionRequestSlotCommitCostEstimation = 5 CommitTransactionRequestSlotTagSet = 7 CommitTransactionRequestSlotSpanContext = 9 CommitTransactionRequestSlotTenantInfo = 10 CommitTransactionRequestSlotIdempotencyId = 11 CommitTransactionRequestSlotArena = 12 )
const ( EndpointSlotAddresses = 0 EndpointSlotToken = 1 )
const ( GetKeyReplySlotPenalty = 0 GetKeyReplySlotError = 1 GetKeyReplySlotSel = 3 GetKeyReplySlotCached = 4 )
const ( GetKeyRequestSlotSel = 0 GetKeyRequestSlotVersion = 1 GetKeyRequestSlotTags = 2 GetKeyRequestSlotReply = 4 GetKeyRequestSlotSpanContext = 5 GetKeyRequestSlotTenantInfo = 6 GetKeyRequestSlotOptions = 7 GetKeyRequestSlotSsLatestCommitVersions = 9 GetKeyRequestSlotField_10 = 10 )
const ( GetKeyServerLocationsReplySlotResults = 0 GetKeyServerLocationsReplySlotResultsTssMapping = 1 GetKeyServerLocationsReplySlotResultsTagMapping = 2 GetKeyServerLocationsReplySlotArena = 3 )
const ( GetKeyServerLocationsRequestSlotBegin = 0 GetKeyServerLocationsRequestSlotEnd = 1 GetKeyServerLocationsRequestSlotLimit = 3 GetKeyServerLocationsRequestSlotReverse = 4 GetKeyServerLocationsRequestSlotReply = 5 GetKeyServerLocationsRequestSlotSpanContext = 6 GetKeyServerLocationsRequestSlotTenant = 7 GetKeyServerLocationsRequestSlotMinTenantVersion = 8 GetKeyServerLocationsRequestSlotArena = 9 )
const ( GetKeyValuesReplySlotPenalty = 0 GetKeyValuesReplySlotError = 1 GetKeyValuesReplySlotData = 3 GetKeyValuesReplySlotVersion = 4 GetKeyValuesReplySlotMore = 5 GetKeyValuesReplySlotCached = 6 GetKeyValuesReplySlotArena = 7 )
const ( GetKeyValuesRequestSlotBegin = 0 GetKeyValuesRequestSlotEnd = 1 GetKeyValuesRequestSlotVersion = 2 GetKeyValuesRequestSlotLimit = 3 GetKeyValuesRequestSlotLimitBytes = 4 GetKeyValuesRequestSlotTags = 5 GetKeyValuesRequestSlotReply = 7 GetKeyValuesRequestSlotSpanContext = 8 GetKeyValuesRequestSlotTenantInfo = 9 GetKeyValuesRequestSlotOptions = 10 GetKeyValuesRequestSlotSsLatestCommitVersions = 12 GetKeyValuesRequestSlotArena = 13 )
const ( GetReadVersionReplySlotProcessBusyTime = 0 GetReadVersionReplySlotVersion = 1 GetReadVersionReplySlotLocked = 2 GetReadVersionReplySlotMetadataVersion = 3 GetReadVersionReplySlotTagThrottleInfo = 5 GetReadVersionReplySlotMidShardSize = 6 GetReadVersionReplySlotRkDefaultThrottled = 7 GetReadVersionReplySlotRkBatchThrottled = 8 GetReadVersionReplySlotSsVersionVectorDelta = 9 GetReadVersionReplySlotProxyId = 10 GetReadVersionReplySlotProxyTagThrottledDuration = 11 )
const ( GetReadVersionRequestSlotTransactionCount = 0 GetReadVersionRequestSlotFlags = 1 GetReadVersionRequestSlotTags = 2 GetReadVersionRequestSlotDebugID = 3 GetReadVersionRequestSlotReply = 5 GetReadVersionRequestSlotSpanContext = 6 GetReadVersionRequestSlotMaxVersion = 7 )
const ( GetValueReplySlotPenalty = 0 GetValueReplySlotError = 1 GetValueReplySlotValue = 3 GetValueReplySlotCached = 5 )
const ( GetValueRequestSlotKey = 0 GetValueRequestSlotVersion = 1 GetValueRequestSlotTags = 2 GetValueRequestSlotReply = 4 GetValueRequestSlotSpanContext = 5 GetValueRequestSlotTenantInfo = 6 GetValueRequestSlotOptions = 7 GetValueRequestSlotSsLatestCommitVersions = 9 )
const ( GrvProxyInterfaceSlotProcessId = 0 GrvProxyInterfaceSlotProvisional = 2 GrvProxyInterfaceSlotGetConsistentReadVersion = 3 )
const ( GrvProxyInterfaceFileID uint32 = 8743216 GrvProxyInterfaceMaxAlign = 4 )
const ( KeyRangeRefSlotBegin = 0 KeyRangeRefSlotEnd = 1 )
const ( KeySelectorRefSlotKey = 0 KeySelectorRefSlotOrEqual = 1 KeySelectorRefSlotOffset = 2 )
const ( KeyValueRefSlotKey = 0 KeyValueRefSlotValue = 1 )
const ( LocationPairSlotKeyRange = 0 LocationPairSlotServers = 1 )
const ( MutationRefSlotMutType = 0 MutationRefSlotParam1 = 1 MutationRefSlotParam2 = 2 )
const ( NetworkAddressSlotIp = 0 NetworkAddressSlotPort = 1 NetworkAddressSlotFlags = 2 NetworkAddressSlotFromHostname = 3 )
const ( NetworkAddressListSlotAddress = 0 NetworkAddressListSlotSecondaryAddress = 1 )
const ( OpenDatabaseCoordRequestSlotIssues = 0 OpenDatabaseCoordRequestSlotSupportedVersions = 1 OpenDatabaseCoordRequestSlotTraceLogGroup = 2 OpenDatabaseCoordRequestSlotKnownClientInfoID = 3 OpenDatabaseCoordRequestSlotClusterKey = 4 OpenDatabaseCoordRequestSlotCoordinators = 5 OpenDatabaseCoordRequestSlotReply = 6 OpenDatabaseCoordRequestSlotHostnames = 7 OpenDatabaseCoordRequestSlotInternal = 8 )
const ( ReadOptionsSlotType = 0 ReadOptionsSlotCacheResult = 1 ReadOptionsSlotDebugID = 2 ReadOptionsSlotConsistencyCheckStartVersion = 4 ReadOptionsSlotLockAware = 6 )
const ( SpanContextSlotTraceID = 0 SpanContextSlotSpanID = 1 SpanContextSlotFlags = 2 )
const ( SplitRangeRequestSlotKeys = 0 SplitRangeRequestSlotChunkSize = 1 SplitRangeRequestSlotReply = 2 SplitRangeRequestSlotTenantInfo = 3 SplitRangeRequestSlotField_4 = 4 )
const ( StorageMetricsSlotBytes = 0 StorageMetricsSlotBytesWrittenPerKSecond = 1 StorageMetricsSlotIosPerKSecond = 2 StorageMetricsSlotBytesReadPerKSecond = 3 StorageMetricsSlotOpsReadPerKSecond = 4 )
const ( StorageServerInterfaceSlotWatchValue = 0 StorageServerInterfaceSlotField_1 = 1 StorageServerInterfaceSlotField_2 = 2 StorageServerInterfaceSlotField_3 = 3 StorageServerInterfaceSlotField_5 = 5 )
const ( StorageServerInterfaceFileID uint32 = 15302073 StorageServerInterfaceMaxAlign = 8 )
const ( TenantInfoSlotTenantId = 0 TenantInfoSlotToken = 1 TenantInfoSlotArena = 3 )
const ( TenantMapEntrySlotId = 0 TenantMapEntrySlotTenantName = 1 TenantMapEntrySlotTenantLockState = 2 TenantMapEntrySlotTenantLockId = 3 TenantMapEntrySlotTenantGroup = 5 TenantMapEntrySlotConfigurationSequenceNum = 7 )
const ( WaitMetricsRequestSlotKeys = 0 WaitMetricsRequestSlotMin = 1 WaitMetricsRequestSlotMax = 2 WaitMetricsRequestSlotReply = 3 WaitMetricsRequestSlotTenantInfo = 4 WaitMetricsRequestSlotMinVersion = 5 WaitMetricsRequestSlotField_6 = 6 )
const ( WatchValueReplySlotVersion = 0 WatchValueReplySlotCached = 1 )
const ( WatchValueRequestSlotKey = 0 WatchValueRequestSlotValue = 1 WatchValueRequestSlotVersion = 3 WatchValueRequestSlotTags = 4 WatchValueRequestSlotDebugID = 6 WatchValueRequestSlotReply = 8 WatchValueRequestSlotSpanContext = 9 WatchValueRequestSlotTenantInfo = 10 )
const ClientDBInfoFileID uint32 = 5355080
const ClientDBInfoMaxAlign = 8
const CommitIDFileID uint32 = 14254927
const CommitIDMaxAlign = 8
const CommitTransactionRefMaxAlign = 8
const CommitTransactionRequestFileID uint32 = 93948
const CommitTransactionRequestMaxAlign = 4
const EndpointFileID uint32 = 10618805
const EndpointMaxAlign = 8
const ErrorFileID uint32 = 14065384
const ErrorMaxAlign = 4
const (
ErrorSlotErrorCode = 0
)
const GetKeyReplyFileID uint32 = 11226513
const GetKeyReplyMaxAlign = 8
const GetKeyRequestFileID uint32 = 10457870
const GetKeyRequestMaxAlign = 8
const GetKeyServerLocationsReplyFileID uint32 = 10636023
const GetKeyServerLocationsReplyMaxAlign = 4
const GetKeyServerLocationsRequestFileID uint32 = 9144680
const GetKeyServerLocationsRequestMaxAlign = 8
const GetKeyValuesReplyFileID uint32 = 1783066
const GetKeyValuesReplyMaxAlign = 8
const GetKeyValuesRequestFileID uint32 = 6795746
const GetKeyValuesRequestMaxAlign = 8
const GetReadVersionReplyFileID uint32 = 15709388
const GetReadVersionReplyMaxAlign = 8
const GetReadVersionRequestFileID uint32 = 838566
const GetReadVersionRequestMaxAlign = 8
const GetValueReplyFileID uint32 = 1378929
const GetValueReplyMaxAlign = 8
const GetValueRequestFileID uint32 = 8454530
const GetValueRequestMaxAlign = 8
const IPAddressMaxAlign = 4
const (
IPAddressSlotAddr = 0
)
const KeyRangeRefMaxAlign = 4
const KeySelectorRefMaxAlign = 4
const KeyValueRefMaxAlign = 4
const LocationPairMaxAlign = 4
const MutationRefMaxAlign = 4
const NetworkAddressFileID uint32 = 14155727
const NetworkAddressListMaxAlign = 4
const NetworkAddressMaxAlign = 4
const OpenDatabaseCoordRequestFileID uint32 = 214728
const OpenDatabaseCoordRequestMaxAlign = 8
const ReadOptionsMaxAlign = 4
const ReplyPromiseFileID uint32 = 18156145
const ReplyPromiseMaxAlign = 8
const (
ReplyPromiseSlotToken = 0
)
const SpanContextMaxAlign = 8
const SplitRangeReplyFileID uint32 = 11813134
const SplitRangeReplyMaxAlign = 4
const (
SplitRangeReplySlotSplitPoints = 0
)
const SplitRangeRequestFileID uint32 = 10725174
const SplitRangeRequestMaxAlign = 8
const StorageMetricsFileID uint32 = 13622226
const StorageMetricsMaxAlign = 8
const TenantInfoMaxAlign = 8
const TenantMapEntryFileID uint32 = 7054389
const TenantMapEntryMaxAlign = 8
const VoidReplyFileID uint32 = 0x021EAD4A
const WaitMetricsRequestFileID uint32 = 1795961
const WaitMetricsRequestMaxAlign = 8
const WatchValueReplyFileID uint32 = 3
const WatchValueReplyMaxAlign = 8
const WatchValueRequestFileID uint32 = 14747733
const WatchValueRequestMaxAlign = 8
Variables ¶
var ClientDBInfoTemplate = wire.NewMessageTemplate( ClientDBInfoFileID, ClientDBInfoVTable, 8, ClientDBInfoVTableClosure, )
var ClientDBInfoVTable = wire.VTable{30, 71, 36, 40, 4, 68, 44, 48, 52, 69, 56, 20, 60, 70, 64}
var ClientDBInfoVTableClosure = []wire.VTable{
{10, 28, 20, 4, 24},
{8, 16, 12, 4},
{8, 24, 20, 4},
{8, 9, 8, 4},
{12, 13, 4, 8, 10, 12},
{12, 14, 12, 4, 13, 8},
{30, 71, 36, 40, 4, 68, 44, 48, 52, 69, 56, 20, 60, 70, 64},
{6, 8, 4},
{10, 13, 12, 4, 8},
{10, 13, 4, 12, 8},
}
var CommitIDTemplate = wire.NewMessageTemplate( CommitIDFileID, CommitIDVTable, 8, CommitIDVTableClosure, )
var CommitIDVTable = wire.VTable{16, 24, 4, 20, 22, 12, 23, 16}
var CommitIDVTableClosure = []wire.VTable{
{6, 8, 4},
{16, 24, 4, 20, 22, 12, 23, 16},
}
var CommitProxyInterfaceVTable = wire.VTable{12, 14, 12, 4, 13, 8}
var CommitTransactionRefVTable = wire.VTable{24, 36, 12, 16, 20, 4, 32, 33, 34, 24, 35, 28}
var CommitTransactionRequestTemplate = wire.NewMessageTemplate( CommitTransactionRequestFileID, CommitTransactionRequestVTable, 4, CommitTransactionRequestVTableClosure, )
var CommitTransactionRequestVTable = wire.VTable{28, 43, 4, 8, 12, 40, 16, 41, 20, 42, 24, 28, 32, 36}
var CommitTransactionRequestVTableClosure = []wire.VTable{
{8, 16, 12, 4},
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{12, 24, 12, 4, 16, 20},
{24, 36, 12, 16, 20, 4, 32, 33, 34, 24, 35, 28},
{8, 12, 4, 8},
{10, 13, 12, 4, 8},
{10, 29, 4, 20, 28},
{28, 43, 4, 8, 12, 40, 16, 41, 20, 42, 24, 28, 32, 36},
}
var EndpointTemplate = wire.NewMessageTemplate( EndpointFileID, EndpointVTable, 8, EndpointVTableClosure, )
var EndpointVTable = wire.VTable{8, 24, 20, 4}
var EndpointVTableClosure = []wire.VTable{
{8, 24, 20, 4},
{8, 9, 8, 4},
{12, 13, 4, 8, 10, 12},
{6, 8, 4},
{10, 13, 4, 12, 8},
}
var ErrorOrErrorTemplate = wire.NewMessageTemplate(
0, errorOrVTable, 4, errorOrErrorVTableClosure,
)
var ErrorTemplate = wire.NewMessageTemplate( ErrorFileID, ErrorVTable, 4, ErrorVTableClosure, )
var ErrorVTable = wire.VTable{6, 6, 4}
var ErrorVTableClosure = []wire.VTable{
{6, 6, 4},
{6, 8, 4},
}
var GetKeyReplyTemplate = wire.NewMessageTemplate( GetKeyReplyFileID, GetKeyReplyVTable, 8, GetKeyReplyVTableClosure, )
var GetKeyReplyVTable = wire.VTable{14, 22, 4, 20, 12, 16, 21}
var GetKeyReplyVTableClosure = []wire.VTable{
{6, 6, 4},
{6, 8, 4},
{10, 13, 4, 12, 8},
{14, 22, 4, 20, 12, 16, 21},
}
var GetKeyRequestTemplate = wire.NewMessageTemplate( GetKeyRequestFileID, GetKeyRequestVTable, 8, GetKeyRequestVTableClosure, )
var GetKeyRequestVTable = wire.VTable{24, 42, 12, 4, 40, 16, 20, 24, 28, 41, 32, 36}
var GetKeyRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{18, 20, 4, 16, 17, 8, 18, 12, 19},
{10, 13, 4, 12, 8},
{10, 29, 4, 20, 28},
{24, 42, 12, 4, 40, 16, 20, 24, 28, 41, 32, 36},
}
var GetKeyServerLocationsReplyTemplate = wire.NewMessageTemplate( GetKeyServerLocationsReplyFileID, GetKeyServerLocationsReplyVTable, 4, GetKeyServerLocationsReplyVTableClosure, )
var GetKeyServerLocationsReplyVTable = wire.VTable{10, 16, 4, 8, 12}
var GetKeyServerLocationsReplyVTableClosure = []wire.VTable{
{8, 24, 4, 20},
{8, 24, 4, 20},
{8, 24, 20, 4},
{8, 9, 8, 4},
{12, 13, 4, 8, 10, 12},
{16, 34, 4, 20, 24, 32, 28, 33},
{6, 8, 4},
{8, 12, 4, 8},
{10, 13, 4, 12, 8},
{10, 16, 4, 8, 12},
}
var GetKeyServerLocationsRequestTemplate = wire.NewMessageTemplate( GetKeyServerLocationsRequestFileID, GetKeyServerLocationsRequestVTable, 8, GetKeyServerLocationsRequestVTableClosure, )
var GetKeyServerLocationsRequestVTable = wire.VTable{22, 38, 12, 36, 16, 20, 37, 24, 28, 32, 4}
var GetKeyServerLocationsRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{10, 29, 4, 20, 28},
{22, 38, 12, 36, 16, 20, 37, 24, 28, 32, 4},
}
var GetKeyValuesReplyTemplate = wire.NewMessageTemplate( GetKeyValuesReplyFileID, GetKeyValuesReplyVTable, 8, GetKeyValuesReplyVTableClosure, )
var GetKeyValuesReplyVTable = wire.VTable{18, 31, 4, 28, 20, 24, 12, 29, 30}
var GetKeyValuesReplyVTableClosure = []wire.VTable{
{6, 6, 4},
{6, 8, 4},
{18, 31, 4, 28, 20, 24, 12, 29, 30},
}
var GetKeyValuesRequestTemplate = wire.NewMessageTemplate( GetKeyValuesRequestFileID, GetKeyValuesRequestVTable, 8, GetKeyValuesRequestVTableClosure, )
var GetKeyValuesRequestVTable = wire.VTable{30, 54, 12, 16, 4, 20, 24, 52, 28, 32, 36, 40, 53, 44, 48}
var GetKeyValuesRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{18, 20, 4, 16, 17, 8, 18, 12, 19},
{10, 13, 4, 12, 8},
{10, 29, 4, 20, 28},
{30, 54, 12, 16, 4, 20, 24, 52, 28, 32, 36, 40, 53, 44, 48},
}
var GetReadVersionReplyTemplate = wire.NewMessageTemplate( GetReadVersionReplyFileID, GetReadVersionReplyVTable, 8, GetReadVersionReplyVTableClosure, )
var GetReadVersionReplyVTable = wire.VTable{28, 64, 44, 20, 60, 61, 48, 52, 28, 62, 63, 56, 4, 36}
var GetReadVersionReplyVTableClosure = []wire.VTable{
{8, 20, 4, 12},
{6, 8, 4},
{8, 12, 4, 8},
{28, 64, 44, 20, 60, 61, 48, 52, 28, 62, 63, 56, 4, 36},
}
var GetReadVersionRequestTemplate = wire.NewMessageTemplate( GetReadVersionRequestFileID, GetReadVersionRequestVTable, 8, GetReadVersionRequestVTableClosure, )
var GetReadVersionRequestVTable = wire.VTable{20, 37, 12, 16, 20, 36, 24, 28, 32, 4}
var GetReadVersionRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{6, 8, 4},
{8, 12, 4, 8},
{10, 29, 4, 20, 28},
{20, 37, 12, 16, 20, 36, 24, 28, 32, 4},
}
var GetValueReplyTemplate = wire.NewMessageTemplate( GetValueReplyFileID, GetValueReplyVTable, 8, GetValueReplyVTableClosure, )
var GetValueReplyVTable = wire.VTable{16, 23, 4, 20, 12, 21, 16, 22}
var GetValueReplyVTableClosure = []wire.VTable{
{6, 6, 4},
{6, 8, 4},
{16, 23, 4, 20, 12, 21, 16, 22},
}
var GetValueRequestTemplate = wire.NewMessageTemplate( GetValueRequestFileID, GetValueRequestVTable, 8, GetValueRequestVTableClosure, )
var GetValueRequestVTable = wire.VTable{24, 42, 12, 4, 40, 16, 20, 24, 28, 41, 32, 36}
var GetValueRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{18, 20, 4, 16, 17, 8, 18, 12, 19},
{10, 29, 4, 20, 28},
{24, 42, 12, 4, 40, 16, 20, 24, 28, 41, 32, 36},
}
var GrvProxyInterfaceVTable = wire.VTable{12, 14, 12, 4, 13, 8}
var IPAddressVTable = wire.VTable{8, 9, 8, 4}
var KeyRangeRefVTable = wire.VTable{8, 12, 4, 8}
var KeySelectorRefVTable = wire.VTable{10, 13, 4, 12, 8}
var KeyValueRefVTable = wire.VTable{8, 12, 4, 8}
var LocationPairVTable = wire.VTable{8, 12, 4, 8}
var MutationRefVTable = wire.VTable{10, 13, 12, 4, 8}
var NetworkAddressListVTable = wire.VTable{10, 13, 4, 12, 8}
var NetworkAddressTemplate = wire.NewMessageTemplate( NetworkAddressFileID, NetworkAddressVTable, 4, NetworkAddressVTableClosure, )
var NetworkAddressVTable = wire.VTable{12, 13, 4, 8, 10, 12}
var NetworkAddressVTableClosure = []wire.VTable{
{8, 9, 8, 4},
{12, 13, 4, 8, 10, 12},
{6, 8, 4},
}
var OpenDatabaseCoordRequestTemplate = wire.NewMessageTemplate( OpenDatabaseCoordRequestFileID, OpenDatabaseCoordRequestVTable, 8, OpenDatabaseCoordRequestVTableClosure, )
var OpenDatabaseCoordRequestVTable = wire.VTable{22, 49, 20, 24, 28, 4, 32, 36, 40, 44, 48}
var OpenDatabaseCoordRequestVTableClosure = []wire.VTable{
{10, 13, 4, 8, 12},
{6, 20, 4},
{8, 9, 8, 4},
{12, 13, 4, 8, 10, 12},
{6, 8, 4},
{22, 49, 20, 24, 28, 4, 32, 36, 40, 44, 48},
{10, 16, 4, 8, 12},
}
var ReadOptionsVTable = wire.VTable{18, 20, 4, 16, 17, 8, 18, 12, 19}
var ReplyPromiseTemplate = wire.NewMessageTemplate( ReplyPromiseFileID, ReplyPromiseVTable, 8, ReplyPromiseVTableClosure, )
var ReplyPromiseVTable = wire.VTable{6, 20, 4}
var ReplyPromiseVTableClosure = []wire.VTable{
{6, 20, 4},
{6, 8, 4},
}
var SpanContextVTable = wire.VTable{10, 29, 4, 20, 28}
var SplitRangeReplyTemplate = wire.NewMessageTemplate( SplitRangeReplyFileID, SplitRangeReplyVTable, 4, SplitRangeReplyVTableClosure, )
var SplitRangeReplyVTable = wire.VTable{6, 8, 4}
var SplitRangeReplyVTableClosure = []wire.VTable{
{6, 8, 4},
}
var SplitRangeRequestTemplate = wire.NewMessageTemplate( SplitRangeRequestFileID, SplitRangeRequestVTable, 8, SplitRangeRequestVTableClosure, )
var SplitRangeRequestVTable = wire.VTable{12, 24, 12, 4, 16, 20}
var SplitRangeRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{12, 24, 12, 4, 16, 20},
{8, 12, 4, 8},
}
var StorageMetricsTemplate = wire.NewMessageTemplate( StorageMetricsFileID, StorageMetricsVTable, 8, StorageMetricsVTableClosure, )
var StorageMetricsVTable = wire.VTable{14, 44, 4, 12, 20, 28, 36}
var StorageMetricsVTableClosure = []wire.VTable{
{6, 8, 4},
{14, 44, 4, 12, 20, 28, 36},
}
var StorageServerInterfaceVTable = wire.VTable{16, 34, 4, 20, 24, 32, 28, 33}
var TenantInfoVTable = wire.VTable{10, 17, 4, 16, 12}
var TenantMapEntryTemplate = wire.NewMessageTemplate( TenantMapEntryFileID, TenantMapEntryVTable, 8, TenantMapEntryVTableClosure, )
var TenantMapEntryVTable = wire.VTable{20, 35, 4, 20, 32, 33, 24, 34, 28, 12}
var TenantMapEntryVTableClosure = []wire.VTable{
{20, 35, 4, 20, 32, 33, 24, 34, 28, 12},
{6, 8, 4},
}
var VoidReplyTemplate = wire.NewMessageTemplate( VoidReplyFileID, errorOrVTable, 4, voidReplyVTableClosure, )
var WaitMetricsRequestTemplate = wire.NewMessageTemplate( WaitMetricsRequestFileID, WaitMetricsRequestVTable, 8, WaitMetricsRequestVTableClosure, )
var WaitMetricsRequestVTable = wire.VTable{16, 32, 12, 16, 20, 24, 28, 4}
var WaitMetricsRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{16, 32, 12, 16, 20, 24, 28, 4},
{14, 44, 4, 12, 20, 28, 36},
{8, 12, 4, 8},
}
var WatchValueReplyTemplate = wire.NewMessageTemplate( WatchValueReplyFileID, WatchValueReplyVTable, 8, WatchValueReplyVTableClosure, )
var WatchValueReplyVTable = wire.VTable{8, 13, 4, 12}
var WatchValueReplyVTableClosure = []wire.VTable{
{6, 8, 4},
{8, 13, 4, 12},
}
var WatchValueRequestTemplate = wire.NewMessageTemplate( WatchValueRequestFileID, WatchValueRequestVTable, 8, WatchValueRequestVTableClosure, )
var WatchValueRequestVTable = wire.VTable{26, 43, 12, 40, 16, 4, 41, 20, 42, 24, 28, 32, 36}
var WatchValueRequestVTableClosure = []wire.VTable{
{6, 20, 4},
{10, 17, 4, 16, 12},
{6, 8, 4},
{10, 29, 4, 20, 28},
{26, 43, 12, 40, 16, 4, 41, 20, 42, 24, 28, 32, 36},
}
Functions ¶
func MarshalErrorOrInlineError ¶
MarshalErrorOrInlineError builds the ErrorOr<GetValueReply>(tag=2) frame that a storage server emits for a read error: a SUCCESSFUL ErrorOr whose nested reply carries ONLY the inline LoadBalancedReply.error (Penalty + HasError + Error{code}) and no value — byte-shape-identical to sendErrorWithPenalty's `Reply r; r.error=err; r.penalty=penalty; promise.send(r)` (storageserver.actor.cpp, 7.3.77). Because the inline-error slots (Penalty@0, HasError@1, Error@2) are IDENTICAL across GetValueReply / GetKeyReply / GetKeyValuesReply (TestLoadBalancedReplyErrorSlots), this single frame is decoded identically by all three read parsers, so one builder covers all of them. The footer carries GetValueReplyFileID for all three (a real server would send the per-RPC fileID), which is fine: ReadErrorOrInto does not validate the fileID, and TestMarshalErrorOrInlineError_RoundTrip pins the decode through every parser.
func MarshalErrorOrValueGetKeyValuesReply ¶
func MarshalErrorOrValueGetKeyValuesReply(reply *GetKeyValuesReply) []byte
MarshalErrorOrValueGetKeyValuesReply wraps a full GetKeyValuesReply in the ErrorOr<...>(tag=2) success envelope a storage server sends. Fault injection uses it to re-emit a reply decoded off the wire with one field mutated (e.g. More flipped to force a getRange continuation) — Data round-trips as an opaque []byte, so the rows are preserved.
Types ¶
type ClientDBInfo ¶
type ClientDBInfo struct {
GrvProxies []byte // slot 0
CommitProxies []byte // slot 1
Id [16]byte // slot 2
HasForward bool // slot 3, optional tag
Forward []byte // slot 4, optional value
History []byte // slot 5
// TenantMode: unregistered nested struct at slot 6
HasEncryptKeyProxy bool // slot 7, optional tag
EncryptKeyProxy []byte // slot 8, optional value
ClusterId [16]byte // slot 9
ClusterType int32 // slot 10
HasMetaclusterName bool // slot 11, optional tag
MetaclusterName []byte // slot 12, optional value
}
func ParseClientDBInfoVectorFromReader ¶
func ParseClientDBInfoVectorFromReader(r *wire.Reader, slot int) []ClientDBInfo
ParseClientDBInfoVectorFromReader reads a FlatBuffers vector of ClientDBInfo.
func (*ClientDBInfo) MarshalFDB ¶
func (m *ClientDBInfo) MarshalFDB() []byte
func (*ClientDBInfo) MarshalFDBPooled ¶
func (m *ClientDBInfo) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*ClientDBInfo) UnmarshalFDB ¶
func (m *ClientDBInfo) UnmarshalFDB(data []byte) error
func (*ClientDBInfo) UnmarshalFromReader ¶
func (m *ClientDBInfo) UnmarshalFromReader(r *wire.Reader)
type CommitID ¶
type CommitID struct {
Version int64 // slot 0
TxnBatchId uint16 // slot 1
HasMetadataVersion bool // slot 2, optional tag
MetadataVersion []byte // slot 3, optional value
HasConflictingKRIndices bool // slot 4, optional tag
ConflictingKRIndices []byte // slot 5, optional value
}
func ParseCommitIDVectorFromReader ¶
ParseCommitIDVectorFromReader reads a FlatBuffers vector of CommitID.
func (*CommitID) MarshalFDB ¶
func (*CommitID) MarshalFDBPooled ¶
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*CommitID) UnmarshalFDB ¶
func (*CommitID) UnmarshalFromReader ¶
type CommitProxyInterface ¶
type CommitProxyInterface struct {
HasProcessId bool // slot 0, optional tag
ProcessId []byte // slot 1, optional value
Provisional bool // slot 2
}
func ParseCommitProxyInterfaceVectorFromReader ¶
func ParseCommitProxyInterfaceVectorFromReader(r *wire.Reader, slot int) []CommitProxyInterface
ParseCommitProxyInterfaceVectorFromReader reads a FlatBuffers vector of CommitProxyInterface.
func (*CommitProxyInterface) UnmarshalFDB ¶
func (m *CommitProxyInterface) UnmarshalFDB(data []byte) error
func (*CommitProxyInterface) UnmarshalFromReader ¶
func (m *CommitProxyInterface) UnmarshalFromReader(r *wire.Reader)
type CommitTransactionRef ¶
type CommitTransactionRef struct {
ReadConflictRanges []KeyRangeRef // slot 0, vector of struct
WriteConflictRanges []KeyRangeRef // slot 1, vector of struct
Mutations []MutationRef // slot 2, vector of struct
ReadSnapshot int64 // slot 3
Report_conflicting_keys bool // slot 4
Lock_aware bool // slot 5
HasRead_conflict_ranges_disabled bool // slot 6, optional tag
Read_conflict_ranges_disabled []byte // slot 7, optional value
HasWrite_conflict_ranges_disabled bool // slot 8, optional tag
Write_conflict_ranges_disabled []byte // slot 9, optional value
}
func ParseCommitTransactionRefVectorFromReader ¶
func ParseCommitTransactionRefVectorFromReader(r *wire.Reader, slot int) []CommitTransactionRef
ParseCommitTransactionRefVectorFromReader reads a FlatBuffers vector of CommitTransactionRef.
func (*CommitTransactionRef) UnmarshalFDB ¶
func (m *CommitTransactionRef) UnmarshalFDB(data []byte) error
func (*CommitTransactionRef) UnmarshalFromReader ¶
func (m *CommitTransactionRef) UnmarshalFromReader(r *wire.Reader)
type CommitTransactionRequest ¶
type CommitTransactionRequest struct {
Transaction CommitTransactionRef // slot 0, nested
Reply ReplyPromise // slot 1, nested
Flags uint32 // slot 2
HasDebugID bool // slot 3, optional tag
DebugID [16]byte // slot 4, optional scalar value
HasCommitCostEstimation bool // slot 5, optional tag
CommitCostEstimation []byte // slot 6, optional value
HasTagSet bool // slot 7, optional tag
TagSet []byte // slot 8, optional value
SpanContext SpanContext // slot 9, nested
TenantInfo TenantInfo // slot 10, nested
IdempotencyId []byte // slot 11
Arena []byte // slot 12
}
func ParseCommitTransactionRequestVectorFromReader ¶
func ParseCommitTransactionRequestVectorFromReader(r *wire.Reader, slot int) []CommitTransactionRequest
ParseCommitTransactionRequestVectorFromReader reads a FlatBuffers vector of CommitTransactionRequest.
func (*CommitTransactionRequest) MarshalFDB ¶
func (m *CommitTransactionRequest) MarshalFDB() []byte
func (*CommitTransactionRequest) MarshalFDBPooled ¶
func (m *CommitTransactionRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*CommitTransactionRequest) UnmarshalFDB ¶
func (m *CommitTransactionRequest) UnmarshalFDB(data []byte) error
func (*CommitTransactionRequest) UnmarshalFromReader ¶
func (m *CommitTransactionRequest) UnmarshalFromReader(r *wire.Reader)
type Endpoint ¶
type Endpoint struct {
Addresses NetworkAddressList // slot 0, nested
Token [16]byte // slot 1
}
func ParseEndpointVectorFromReader ¶
ParseEndpointVectorFromReader reads a FlatBuffers vector of Endpoint.
func (*Endpoint) MarshalFDB ¶
func (*Endpoint) MarshalFDBPooled ¶
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*Endpoint) UnmarshalFDB ¶
func (*Endpoint) UnmarshalFromReader ¶
type Error ¶
type Error struct {
ErrorCode uint16 // slot 0
}
func ParseErrorVectorFromReader ¶
ParseErrorVectorFromReader reads a FlatBuffers vector of Error.
func (*Error) MarshalFDB ¶
func (*Error) MarshalFDBPooled ¶
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*Error) UnmarshalFDB ¶
func (*Error) UnmarshalFromReader ¶
type ErrorOrError ¶
type ErrorOrError struct {
ErrorCode uint16
}
func (*ErrorOrError) MarshalFDB ¶
func (m *ErrorOrError) MarshalFDB() []byte
MarshalFDB serializes ErrorOrError using two-pass PrecomputeSize/WriteToBuffer. Union root: footer points directly to ErrorOr object (no FakeRoot).
type GetKeyReply ¶
type GetKeyReply struct {
Penalty float64 // slot 0
HasError bool // slot 1, optional tag
Error Error // slot 2, optional nested value
// Sel: unregistered nested struct at slot 3
Cached bool // slot 4
}
func ParseGetKeyReplyVectorFromReader ¶
func ParseGetKeyReplyVectorFromReader(r *wire.Reader, slot int) []GetKeyReply
ParseGetKeyReplyVectorFromReader reads a FlatBuffers vector of GetKeyReply.
func (*GetKeyReply) MarshalFDB ¶
func (m *GetKeyReply) MarshalFDB() []byte
func (*GetKeyReply) MarshalFDBPooled ¶
func (m *GetKeyReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetKeyReply) UnmarshalFDB ¶
func (m *GetKeyReply) UnmarshalFDB(data []byte) error
func (*GetKeyReply) UnmarshalFromReader ¶
func (m *GetKeyReply) UnmarshalFromReader(r *wire.Reader)
type GetKeyRequest ¶
type GetKeyRequest struct {
Sel KeySelectorRef // slot 0, nested
Version int64 // slot 1
HasTags bool // slot 2, optional tag
Tags []byte // slot 3, optional value
Reply ReplyPromise // slot 4, nested
SpanContext SpanContext // slot 5, nested
TenantInfo TenantInfo // slot 6, nested
HasOptions bool // slot 7, optional tag
Options ReadOptions // slot 8, optional nested value
SsLatestCommitVersions []byte // slot 9
Field_10 []byte // slot 10
}
func ParseGetKeyRequestVectorFromReader ¶
func ParseGetKeyRequestVectorFromReader(r *wire.Reader, slot int) []GetKeyRequest
ParseGetKeyRequestVectorFromReader reads a FlatBuffers vector of GetKeyRequest.
func (*GetKeyRequest) MarshalFDB ¶
func (m *GetKeyRequest) MarshalFDB() []byte
func (*GetKeyRequest) MarshalFDBPooled ¶
func (m *GetKeyRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetKeyRequest) UnmarshalFDB ¶
func (m *GetKeyRequest) UnmarshalFDB(data []byte) error
func (*GetKeyRequest) UnmarshalFromReader ¶
func (m *GetKeyRequest) UnmarshalFromReader(r *wire.Reader)
type GetKeyServerLocationsReply ¶
type GetKeyServerLocationsReply struct {
Results []byte // slot 0
ResultsTssMapping []byte // slot 1
ResultsTagMapping []byte // slot 2
Arena []byte // slot 3
}
func ParseGetKeyServerLocationsReplyVectorFromReader ¶
func ParseGetKeyServerLocationsReplyVectorFromReader(r *wire.Reader, slot int) []GetKeyServerLocationsReply
ParseGetKeyServerLocationsReplyVectorFromReader reads a FlatBuffers vector of GetKeyServerLocationsReply.
func (*GetKeyServerLocationsReply) MarshalFDB ¶
func (m *GetKeyServerLocationsReply) MarshalFDB() []byte
func (*GetKeyServerLocationsReply) MarshalFDBPooled ¶
func (m *GetKeyServerLocationsReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetKeyServerLocationsReply) UnmarshalFDB ¶
func (m *GetKeyServerLocationsReply) UnmarshalFDB(data []byte) error
func (*GetKeyServerLocationsReply) UnmarshalFromReader ¶
func (m *GetKeyServerLocationsReply) UnmarshalFromReader(r *wire.Reader)
type GetKeyServerLocationsRequest ¶
type GetKeyServerLocationsRequest struct {
Begin []byte // slot 0
HasEnd bool // slot 1, optional tag
End []byte // slot 2, optional value
Limit int32 // slot 3
Reverse bool // slot 4
Reply ReplyPromise // slot 5, nested
SpanContext SpanContext // slot 6, nested
Tenant TenantInfo // slot 7, nested
MinTenantVersion int64 // slot 8
Arena []byte // slot 9
}
func ParseGetKeyServerLocationsRequestVectorFromReader ¶
func ParseGetKeyServerLocationsRequestVectorFromReader(r *wire.Reader, slot int) []GetKeyServerLocationsRequest
ParseGetKeyServerLocationsRequestVectorFromReader reads a FlatBuffers vector of GetKeyServerLocationsRequest.
func (*GetKeyServerLocationsRequest) MarshalFDB ¶
func (m *GetKeyServerLocationsRequest) MarshalFDB() []byte
func (*GetKeyServerLocationsRequest) MarshalFDBPooled ¶
func (m *GetKeyServerLocationsRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetKeyServerLocationsRequest) UnmarshalFDB ¶
func (m *GetKeyServerLocationsRequest) UnmarshalFDB(data []byte) error
func (*GetKeyServerLocationsRequest) UnmarshalFromReader ¶
func (m *GetKeyServerLocationsRequest) UnmarshalFromReader(r *wire.Reader)
type GetKeyValuesReply ¶
type GetKeyValuesReply struct {
Penalty float64 // slot 0
HasError bool // slot 1, optional tag
Error Error // slot 2, optional nested value
Data []byte // slot 3
Version int64 // slot 4
More bool // slot 5
Cached bool // slot 6
Arena []byte // slot 7
}
func ParseGetKeyValuesReplyVectorFromReader ¶
func ParseGetKeyValuesReplyVectorFromReader(r *wire.Reader, slot int) []GetKeyValuesReply
ParseGetKeyValuesReplyVectorFromReader reads a FlatBuffers vector of GetKeyValuesReply.
func (*GetKeyValuesReply) MarshalFDB ¶
func (m *GetKeyValuesReply) MarshalFDB() []byte
func (*GetKeyValuesReply) MarshalFDBPooled ¶
func (m *GetKeyValuesReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetKeyValuesReply) UnmarshalFDB ¶
func (m *GetKeyValuesReply) UnmarshalFDB(data []byte) error
func (*GetKeyValuesReply) UnmarshalFromReader ¶
func (m *GetKeyValuesReply) UnmarshalFromReader(r *wire.Reader)
type GetKeyValuesRequest ¶
type GetKeyValuesRequest struct {
Begin KeySelectorRef // slot 0, nested
End KeySelectorRef // slot 1, nested
Version int64 // slot 2
Limit int32 // slot 3
LimitBytes int32 // slot 4
HasTags bool // slot 5, optional tag
Tags []byte // slot 6, optional value
Reply ReplyPromise // slot 7, nested
SpanContext SpanContext // slot 8, nested
TenantInfo TenantInfo // slot 9, nested
HasOptions bool // slot 10, optional tag
Options ReadOptions // slot 11, optional nested value
SsLatestCommitVersions []byte // slot 12
Arena []byte // slot 13
}
func ParseGetKeyValuesRequestVectorFromReader ¶
func ParseGetKeyValuesRequestVectorFromReader(r *wire.Reader, slot int) []GetKeyValuesRequest
ParseGetKeyValuesRequestVectorFromReader reads a FlatBuffers vector of GetKeyValuesRequest.
func (*GetKeyValuesRequest) MarshalFDB ¶
func (m *GetKeyValuesRequest) MarshalFDB() []byte
func (*GetKeyValuesRequest) MarshalFDBPooled ¶
func (m *GetKeyValuesRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetKeyValuesRequest) UnmarshalFDB ¶
func (m *GetKeyValuesRequest) UnmarshalFDB(data []byte) error
func (*GetKeyValuesRequest) UnmarshalFromReader ¶
func (m *GetKeyValuesRequest) UnmarshalFromReader(r *wire.Reader)
type GetReadVersionReply ¶
type GetReadVersionReply struct {
ProcessBusyTime int32 // slot 0
Version int64 // slot 1
Locked bool // slot 2
HasMetadataVersion bool // slot 3, optional tag
MetadataVersion []byte // slot 4, optional value
TagThrottleInfo []byte // slot 5
MidShardSize int64 // slot 6
RkDefaultThrottled bool // slot 7
RkBatchThrottled bool // slot 8
SsVersionVectorDelta []byte // slot 9
ProxyId [16]byte // slot 10
ProxyTagThrottledDuration float64 // slot 11
}
func ParseGetReadVersionReplyVectorFromReader ¶
func ParseGetReadVersionReplyVectorFromReader(r *wire.Reader, slot int) []GetReadVersionReply
ParseGetReadVersionReplyVectorFromReader reads a FlatBuffers vector of GetReadVersionReply.
func (*GetReadVersionReply) MarshalFDB ¶
func (m *GetReadVersionReply) MarshalFDB() []byte
func (*GetReadVersionReply) MarshalFDBPooled ¶
func (m *GetReadVersionReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetReadVersionReply) UnmarshalFDB ¶
func (m *GetReadVersionReply) UnmarshalFDB(data []byte) error
func (*GetReadVersionReply) UnmarshalFromReader ¶
func (m *GetReadVersionReply) UnmarshalFromReader(r *wire.Reader)
type GetReadVersionRequest ¶
type GetReadVersionRequest struct {
TransactionCount uint32 // slot 0
Flags uint32 // slot 1
Tags []byte // slot 2
HasDebugID bool // slot 3, optional tag
DebugID [16]byte // slot 4, optional scalar value
Reply ReplyPromise // slot 5, nested
SpanContext SpanContext // slot 6, nested
MaxVersion int64 // slot 7
}
func ParseGetReadVersionRequestVectorFromReader ¶
func ParseGetReadVersionRequestVectorFromReader(r *wire.Reader, slot int) []GetReadVersionRequest
ParseGetReadVersionRequestVectorFromReader reads a FlatBuffers vector of GetReadVersionRequest.
func (*GetReadVersionRequest) MarshalFDB ¶
func (m *GetReadVersionRequest) MarshalFDB() []byte
func (*GetReadVersionRequest) MarshalFDBPooled ¶
func (m *GetReadVersionRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetReadVersionRequest) UnmarshalFDB ¶
func (m *GetReadVersionRequest) UnmarshalFDB(data []byte) error
func (*GetReadVersionRequest) UnmarshalFromReader ¶
func (m *GetReadVersionRequest) UnmarshalFromReader(r *wire.Reader)
type GetValueReply ¶
type GetValueReply struct {
Penalty float64 // slot 0
HasError bool // slot 1, optional tag
Error Error // slot 2, optional nested value
HasValue bool // slot 3, optional tag
Value []byte // slot 4, optional value
Cached bool // slot 5
}
func ParseGetValueReplyVectorFromReader ¶
func ParseGetValueReplyVectorFromReader(r *wire.Reader, slot int) []GetValueReply
ParseGetValueReplyVectorFromReader reads a FlatBuffers vector of GetValueReply.
func (*GetValueReply) MarshalFDB ¶
func (m *GetValueReply) MarshalFDB() []byte
func (*GetValueReply) MarshalFDBPooled ¶
func (m *GetValueReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetValueReply) UnmarshalFDB ¶
func (m *GetValueReply) UnmarshalFDB(data []byte) error
func (*GetValueReply) UnmarshalFromReader ¶
func (m *GetValueReply) UnmarshalFromReader(r *wire.Reader)
type GetValueRequest ¶
type GetValueRequest struct {
Key []byte // slot 0
Version int64 // slot 1
HasTags bool // slot 2, optional tag
Tags []byte // slot 3, optional value
Reply ReplyPromise // slot 4, nested
SpanContext SpanContext // slot 5, nested
TenantInfo TenantInfo // slot 6, nested
HasOptions bool // slot 7, optional tag
Options ReadOptions // slot 8, optional nested value
SsLatestCommitVersions []byte // slot 9
}
func ParseGetValueRequestVectorFromReader ¶
func ParseGetValueRequestVectorFromReader(r *wire.Reader, slot int) []GetValueRequest
ParseGetValueRequestVectorFromReader reads a FlatBuffers vector of GetValueRequest.
func (*GetValueRequest) MarshalFDB ¶
func (m *GetValueRequest) MarshalFDB() []byte
func (*GetValueRequest) MarshalFDBPooled ¶
func (m *GetValueRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetValueRequest) UnmarshalFDB ¶
func (m *GetValueRequest) UnmarshalFDB(data []byte) error
func (*GetValueRequest) UnmarshalFromReader ¶
func (m *GetValueRequest) UnmarshalFromReader(r *wire.Reader)
type GrvProxyInterface ¶
type GrvProxyInterface struct {
HasProcessId bool // slot 0, optional tag
ProcessId []byte // slot 1, optional value
Provisional bool // slot 2
}
func ParseGrvProxyInterfaceVectorFromReader ¶
func ParseGrvProxyInterfaceVectorFromReader(r *wire.Reader, slot int) []GrvProxyInterface
ParseGrvProxyInterfaceVectorFromReader reads a FlatBuffers vector of GrvProxyInterface.
func (*GrvProxyInterface) UnmarshalFDB ¶
func (m *GrvProxyInterface) UnmarshalFDB(data []byte) error
func (*GrvProxyInterface) UnmarshalFromReader ¶
func (m *GrvProxyInterface) UnmarshalFromReader(r *wire.Reader)
type IPAddress ¶
type IPAddress struct {
AddrTag uint8 // slot 0, variant tag
AddrAlt0 uint32 // tag=1
AddrAlt1 []byte // tag=2
}
func ParseIPAddressVectorFromReader ¶
ParseIPAddressVectorFromReader reads a FlatBuffers vector of IPAddress.
func (*IPAddress) UnmarshalFDB ¶
func (*IPAddress) UnmarshalFromReader ¶
type KeyRangeRef ¶
func ParseKeyRangeRefStringVector ¶
func ParseKeyRangeRefStringVector(data []byte) []KeyRangeRef
ParseKeyRangeRefStringVector decodes a VectorRef<KeyRangeRef, VecSerStrategy::String>. Each element's DynamicSize fields are inline: [len(4)][data] per field.
func ParseKeyRangeRefVectorFromReader ¶
func ParseKeyRangeRefVectorFromReader(r *wire.Reader, slot int) []KeyRangeRef
ParseKeyRangeRefVectorFromReader reads a FlatBuffers vector of KeyRangeRef.
func (*KeyRangeRef) UnmarshalFDB ¶
func (m *KeyRangeRef) UnmarshalFDB(data []byte) error
UnmarshalFDB constructs a Reader and delegates.
func (*KeyRangeRef) UnmarshalFromReader ¶
func (m *KeyRangeRef) UnmarshalFromReader(r *wire.Reader)
UnmarshalFromReader replaces the generated reader to invert the single-key serialize optimization. Slot 1 (End) being empty signals "first slot carries End; reconstruct Begin = End[:-1]".
Matches C++ KeyRangeRef::serialize deserialization branch.
type KeySelectorRef ¶
func ParseKeySelectorRefVectorFromReader ¶
func ParseKeySelectorRefVectorFromReader(r *wire.Reader, slot int) []KeySelectorRef
ParseKeySelectorRefVectorFromReader reads a FlatBuffers vector of KeySelectorRef.
func (*KeySelectorRef) UnmarshalFDB ¶
func (m *KeySelectorRef) UnmarshalFDB(data []byte) error
func (*KeySelectorRef) UnmarshalFromReader ¶
func (m *KeySelectorRef) UnmarshalFromReader(r *wire.Reader)
type KeyValueRef ¶
func ParseKeyValueRefStringVector ¶
func ParseKeyValueRefStringVector(data []byte) []KeyValueRef
ParseKeyValueRefStringVector decodes a VectorRef<KeyValueRef, VecSerStrategy::String>. Each element's DynamicSize fields are inline: [len(4)][data] per field.
func ParseKeyValueRefVectorFromReader ¶
func ParseKeyValueRefVectorFromReader(r *wire.Reader, slot int) []KeyValueRef
ParseKeyValueRefVectorFromReader reads a FlatBuffers vector of KeyValueRef.
func (*KeyValueRef) UnmarshalFDB ¶
func (m *KeyValueRef) UnmarshalFDB(data []byte) error
func (*KeyValueRef) UnmarshalFromReader ¶
func (m *KeyValueRef) UnmarshalFromReader(r *wire.Reader)
type LocationPair ¶
type LocationPair struct {
KeyRange KeyRangeRef // slot 0, nested
Servers []byte // slot 1
}
func ParseLocationPairVectorFromReader ¶
func ParseLocationPairVectorFromReader(r *wire.Reader, slot int) []LocationPair
ParseLocationPairVectorFromReader reads a FlatBuffers vector of LocationPair.
func (*LocationPair) UnmarshalFDB ¶
func (m *LocationPair) UnmarshalFDB(data []byte) error
func (*LocationPair) UnmarshalFromReader ¶
func (m *LocationPair) UnmarshalFromReader(r *wire.Reader)
type MutationRef ¶
func ParseMutationRefVectorFromReader ¶
func ParseMutationRefVectorFromReader(r *wire.Reader, slot int) []MutationRef
ParseMutationRefVectorFromReader reads a FlatBuffers vector of MutationRef.
func (*MutationRef) UnmarshalFDB ¶
func (m *MutationRef) UnmarshalFDB(data []byte) error
func (*MutationRef) UnmarshalFromReader ¶
func (m *MutationRef) UnmarshalFromReader(r *wire.Reader)
type NetworkAddress ¶
type NetworkAddress struct {
Ip IPAddress // slot 0, nested
Port uint16 // slot 1
Flags uint16 // slot 2
FromHostname bool // slot 3
}
func ParseNetworkAddressVectorFromReader ¶
func ParseNetworkAddressVectorFromReader(r *wire.Reader, slot int) []NetworkAddress
ParseNetworkAddressVectorFromReader reads a FlatBuffers vector of NetworkAddress.
func (*NetworkAddress) MarshalFDB ¶
func (m *NetworkAddress) MarshalFDB() []byte
func (*NetworkAddress) MarshalFDBPooled ¶
func (m *NetworkAddress) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*NetworkAddress) UnmarshalFDB ¶
func (m *NetworkAddress) UnmarshalFDB(data []byte) error
func (*NetworkAddress) UnmarshalFromReader ¶
func (m *NetworkAddress) UnmarshalFromReader(r *wire.Reader)
type NetworkAddressList ¶
type NetworkAddressList struct {
Address NetworkAddress // slot 0, nested
HasSecondaryAddress bool // slot 1, optional tag
SecondaryAddress []byte // slot 2, optional value
}
func ParseNetworkAddressListVectorFromReader ¶
func ParseNetworkAddressListVectorFromReader(r *wire.Reader, slot int) []NetworkAddressList
ParseNetworkAddressListVectorFromReader reads a FlatBuffers vector of NetworkAddressList.
func (*NetworkAddressList) UnmarshalFDB ¶
func (m *NetworkAddressList) UnmarshalFDB(data []byte) error
func (*NetworkAddressList) UnmarshalFromReader ¶
func (m *NetworkAddressList) UnmarshalFromReader(r *wire.Reader)
type OpenDatabaseCoordRequest ¶
type OpenDatabaseCoordRequest struct {
Issues []byte // slot 0
SupportedVersions []byte // slot 1
TraceLogGroup []byte // slot 2
KnownClientInfoID [16]byte // slot 3
ClusterKey []byte // slot 4
Coordinators []byte // slot 5
Reply ReplyPromise // slot 6, nested
Hostnames []byte // slot 7
Internal bool // slot 8
}
func ParseOpenDatabaseCoordRequestVectorFromReader ¶
func ParseOpenDatabaseCoordRequestVectorFromReader(r *wire.Reader, slot int) []OpenDatabaseCoordRequest
ParseOpenDatabaseCoordRequestVectorFromReader reads a FlatBuffers vector of OpenDatabaseCoordRequest.
func (*OpenDatabaseCoordRequest) MarshalFDB ¶
func (m *OpenDatabaseCoordRequest) MarshalFDB() []byte
func (*OpenDatabaseCoordRequest) MarshalFDBPooled ¶
func (m *OpenDatabaseCoordRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*OpenDatabaseCoordRequest) UnmarshalFDB ¶
func (m *OpenDatabaseCoordRequest) UnmarshalFDB(data []byte) error
func (*OpenDatabaseCoordRequest) UnmarshalFromReader ¶
func (m *OpenDatabaseCoordRequest) UnmarshalFromReader(r *wire.Reader)
type ReadOptions ¶
type ReadOptions struct {
Type int32 // slot 0
CacheResult bool // slot 1
HasDebugID bool // slot 2, optional tag
DebugID [16]byte // slot 3, optional scalar value
HasConsistencyCheckStartVersion bool // slot 4, optional tag
ConsistencyCheckStartVersion int64 // slot 5, optional scalar value
LockAware bool // slot 6
}
func ParseReadOptionsVectorFromReader ¶
func ParseReadOptionsVectorFromReader(r *wire.Reader, slot int) []ReadOptions
ParseReadOptionsVectorFromReader reads a FlatBuffers vector of ReadOptions.
func (*ReadOptions) UnmarshalFDB ¶
func (m *ReadOptions) UnmarshalFDB(data []byte) error
func (*ReadOptions) UnmarshalFromReader ¶
func (m *ReadOptions) UnmarshalFromReader(r *wire.Reader)
type ReplyPromise ¶
type ReplyPromise struct {
Token [16]byte // slot 0
}
func ParseReplyPromiseVectorFromReader ¶
func ParseReplyPromiseVectorFromReader(r *wire.Reader, slot int) []ReplyPromise
ParseReplyPromiseVectorFromReader reads a FlatBuffers vector of ReplyPromise.
func (*ReplyPromise) MarshalFDB ¶
func (m *ReplyPromise) MarshalFDB() []byte
func (*ReplyPromise) MarshalFDBPooled ¶
func (m *ReplyPromise) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*ReplyPromise) UnmarshalFDB ¶
func (m *ReplyPromise) UnmarshalFDB(data []byte) error
func (*ReplyPromise) UnmarshalFromReader ¶
func (m *ReplyPromise) UnmarshalFromReader(r *wire.Reader)
type SpanContext ¶
type SpanContext struct {
TraceID [16]byte // slot 0
SpanID uint64 // slot 1
Flags uint8 // slot 2
}
func ParseSpanContextVectorFromReader ¶
func ParseSpanContextVectorFromReader(r *wire.Reader, slot int) []SpanContext
ParseSpanContextVectorFromReader reads a FlatBuffers vector of SpanContext.
func (*SpanContext) UnmarshalFDB ¶
func (m *SpanContext) UnmarshalFDB(data []byte) error
func (*SpanContext) UnmarshalFromReader ¶
func (m *SpanContext) UnmarshalFromReader(r *wire.Reader)
type SplitRangeReply ¶
type SplitRangeReply struct {
SplitPoints []byte // slot 0
}
func ParseSplitRangeReplyVectorFromReader ¶
func ParseSplitRangeReplyVectorFromReader(r *wire.Reader, slot int) []SplitRangeReply
ParseSplitRangeReplyVectorFromReader reads a FlatBuffers vector of SplitRangeReply.
func (*SplitRangeReply) MarshalFDB ¶
func (m *SplitRangeReply) MarshalFDB() []byte
func (*SplitRangeReply) MarshalFDBPooled ¶
func (m *SplitRangeReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*SplitRangeReply) UnmarshalFDB ¶
func (m *SplitRangeReply) UnmarshalFDB(data []byte) error
func (*SplitRangeReply) UnmarshalFromReader ¶
func (m *SplitRangeReply) UnmarshalFromReader(r *wire.Reader)
type SplitRangeRequest ¶
type SplitRangeRequest struct {
Keys KeyRangeRef // slot 0, nested
ChunkSize int64 // slot 1
Reply ReplyPromise // slot 2, nested
TenantInfo TenantInfo // slot 3, nested
Field_4 []byte // slot 4
}
func ParseSplitRangeRequestVectorFromReader ¶
func ParseSplitRangeRequestVectorFromReader(r *wire.Reader, slot int) []SplitRangeRequest
ParseSplitRangeRequestVectorFromReader reads a FlatBuffers vector of SplitRangeRequest.
func (*SplitRangeRequest) MarshalFDB ¶
func (m *SplitRangeRequest) MarshalFDB() []byte
func (*SplitRangeRequest) MarshalFDBPooled ¶
func (m *SplitRangeRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*SplitRangeRequest) UnmarshalFDB ¶
func (m *SplitRangeRequest) UnmarshalFDB(data []byte) error
func (*SplitRangeRequest) UnmarshalFromReader ¶
func (m *SplitRangeRequest) UnmarshalFromReader(r *wire.Reader)
type StorageMetrics ¶
type StorageMetrics struct {
Bytes int64 // slot 0
BytesWrittenPerKSecond int64 // slot 1
IosPerKSecond int64 // slot 2
BytesReadPerKSecond int64 // slot 3
OpsReadPerKSecond int64 // slot 4
}
func ParseStorageMetricsVectorFromReader ¶
func ParseStorageMetricsVectorFromReader(r *wire.Reader, slot int) []StorageMetrics
ParseStorageMetricsVectorFromReader reads a FlatBuffers vector of StorageMetrics.
func (*StorageMetrics) MarshalFDB ¶
func (m *StorageMetrics) MarshalFDB() []byte
func (*StorageMetrics) MarshalFDBPooled ¶
func (m *StorageMetrics) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*StorageMetrics) UnmarshalFDB ¶
func (m *StorageMetrics) UnmarshalFDB(data []byte) error
func (*StorageMetrics) UnmarshalFromReader ¶
func (m *StorageMetrics) UnmarshalFromReader(r *wire.Reader)
type StorageServerInterface ¶
type StorageServerInterface struct {
WatchValue [16]byte // slot 0
// Field_1: unregistered nested struct at slot 1
// Field_2: unregistered nested struct at slot 2
HasField_3 bool // slot 3, optional tag
Field_3 [16]byte // slot 4, optional scalar value
Field_5 bool // slot 5
}
func ParseStorageServerInterfaceVectorFromReader ¶
func ParseStorageServerInterfaceVectorFromReader(r *wire.Reader, slot int) []StorageServerInterface
ParseStorageServerInterfaceVectorFromReader reads a FlatBuffers vector of StorageServerInterface.
func (*StorageServerInterface) UnmarshalFDB ¶
func (m *StorageServerInterface) UnmarshalFDB(data []byte) error
func (*StorageServerInterface) UnmarshalFromReader ¶
func (m *StorageServerInterface) UnmarshalFromReader(r *wire.Reader)
type TenantInfo ¶
type TenantInfo struct {
TenantId int64 // slot 0
HasToken bool // slot 1, optional tag
Token []byte // slot 2, optional value
Arena []byte // slot 3
}
func ParseTenantInfoVectorFromReader ¶
func ParseTenantInfoVectorFromReader(r *wire.Reader, slot int) []TenantInfo
ParseTenantInfoVectorFromReader reads a FlatBuffers vector of TenantInfo.
func (*TenantInfo) UnmarshalFDB ¶
func (m *TenantInfo) UnmarshalFDB(data []byte) error
func (*TenantInfo) UnmarshalFromReader ¶
func (m *TenantInfo) UnmarshalFromReader(r *wire.Reader)
type TenantMapEntry ¶
type TenantMapEntry struct {
Id int64 // slot 0
TenantName []byte // slot 1
TenantLockState uint8 // slot 2
HasTenantLockId bool // slot 3, optional tag
TenantLockId [16]byte // slot 4, optional scalar value
HasTenantGroup bool // slot 5, optional tag
TenantGroup []byte // slot 6, optional value
ConfigurationSequenceNum int64 // slot 7
}
func ParseTenantMapEntryVectorFromReader ¶
func ParseTenantMapEntryVectorFromReader(r *wire.Reader, slot int) []TenantMapEntry
ParseTenantMapEntryVectorFromReader reads a FlatBuffers vector of TenantMapEntry.
func (*TenantMapEntry) MarshalFDB ¶
func (m *TenantMapEntry) MarshalFDB() []byte
func (*TenantMapEntry) MarshalFDBPooled ¶
func (m *TenantMapEntry) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*TenantMapEntry) UnmarshalFDB ¶
func (m *TenantMapEntry) UnmarshalFDB(data []byte) error
func (*TenantMapEntry) UnmarshalFromReader ¶
func (m *TenantMapEntry) UnmarshalFromReader(r *wire.Reader)
type VoidReply ¶
type VoidReply struct{}
func (*VoidReply) MarshalFDB ¶
MarshalFDB serializes VoidReply using two-pass PrecomputeSize/WriteToBuffer. Union root: footer points directly to ErrorOr object (no FakeRoot).
type WaitMetricsRequest ¶
type WaitMetricsRequest struct {
Keys KeyRangeRef // slot 0, nested
Min StorageMetrics // slot 1, nested
Max StorageMetrics // slot 2, nested
Reply ReplyPromise // slot 3, nested
TenantInfo TenantInfo // slot 4, nested
MinVersion int64 // slot 5
Field_6 []byte // slot 6
}
func ParseWaitMetricsRequestVectorFromReader ¶
func ParseWaitMetricsRequestVectorFromReader(r *wire.Reader, slot int) []WaitMetricsRequest
ParseWaitMetricsRequestVectorFromReader reads a FlatBuffers vector of WaitMetricsRequest.
func (*WaitMetricsRequest) MarshalFDB ¶
func (m *WaitMetricsRequest) MarshalFDB() []byte
func (*WaitMetricsRequest) MarshalFDBPooled ¶
func (m *WaitMetricsRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*WaitMetricsRequest) UnmarshalFDB ¶
func (m *WaitMetricsRequest) UnmarshalFDB(data []byte) error
func (*WaitMetricsRequest) UnmarshalFromReader ¶
func (m *WaitMetricsRequest) UnmarshalFromReader(r *wire.Reader)
type WatchValueReply ¶
func ParseWatchValueReplyVectorFromReader ¶
func ParseWatchValueReplyVectorFromReader(r *wire.Reader, slot int) []WatchValueReply
ParseWatchValueReplyVectorFromReader reads a FlatBuffers vector of WatchValueReply.
func (*WatchValueReply) MarshalFDB ¶
func (m *WatchValueReply) MarshalFDB() []byte
func (*WatchValueReply) MarshalFDBPooled ¶
func (m *WatchValueReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*WatchValueReply) UnmarshalFDB ¶
func (m *WatchValueReply) UnmarshalFDB(data []byte) error
func (*WatchValueReply) UnmarshalFromReader ¶
func (m *WatchValueReply) UnmarshalFromReader(r *wire.Reader)
type WatchValueRequest ¶
type WatchValueRequest struct {
Key []byte // slot 0
HasValue bool // slot 1, optional tag
Value []byte // slot 2, optional value
Version int64 // slot 3
HasTags bool // slot 4, optional tag
Tags []byte // slot 5, optional value
HasDebugID bool // slot 6, optional tag
DebugID [16]byte // slot 7, optional scalar value
Reply ReplyPromise // slot 8, nested
SpanContext SpanContext // slot 9, nested
TenantInfo TenantInfo // slot 10, nested
}
func ParseWatchValueRequestVectorFromReader ¶
func ParseWatchValueRequestVectorFromReader(r *wire.Reader, slot int) []WatchValueRequest
ParseWatchValueRequestVectorFromReader reads a FlatBuffers vector of WatchValueRequest.
func (*WatchValueRequest) MarshalFDB ¶
func (m *WatchValueRequest) MarshalFDB() []byte
func (*WatchValueRequest) MarshalFDBPooled ¶
func (m *WatchValueRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*WatchValueRequest) UnmarshalFDB ¶
func (m *WatchValueRequest) UnmarshalFDB(data []byte) error
func (*WatchValueRequest) UnmarshalFromReader ¶
func (m *WatchValueRequest) UnmarshalFromReader(r *wire.Reader)
Source Files
¶
- clientdbinfo_generated.go
- commitid_generated.go
- commitproxyinterface_generated.go
- committransactionref_generated.go
- committransactionrequest_generated.go
- doc.go
- endpoint_generated.go
- error_generated.go
- erroror.go
- getkeyreply_generated.go
- getkeyrequest_generated.go
- getkeyserverlocationsreply_generated.go
- getkeyserverlocationsrequest_generated.go
- getkeyvaluesreply_generated.go
- getkeyvaluesrequest_generated.go
- getreadversionreply_generated.go
- getreadversionrequest_generated.go
- getvaluereply_generated.go
- getvaluerequest_generated.go
- grvproxyinterface_generated.go
- ipaddress_generated.go
- keyrangeref_custom.go
- keyrangeref_generated.go
- keyselectorref_generated.go
- keyvalueref_generated.go
- locationpair_generated.go
- mutationref_generated.go
- networkaddress_generated.go
- networkaddresslist_generated.go
- opendatabasecoordrequest_generated.go
- readoptions_generated.go
- replypromise_generated.go
- spancontext_generated.go
- splitrangereply_generated.go
- splitrangerequest_generated.go
- storagemetrics_generated.go
- storageserverinterface_generated.go
- tenantinfo_generated.go
- tenantmapentry_generated.go
- waitmetricsrequest_generated.go
- watchvaluereply_generated.go
- watchvaluerequest_generated.go