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
- func MarshalErrorOrValueGetReadVersionReply(reply *GetReadVersionReply) []byte
- type ClientDBInfo
- type ClientTagThrottleLimits
- type ClientVersionRef
- type CommitID
- type CommitProxyInterface
- type CommitTransactionRef
- type CommitTransactionRequest
- type CoordOpenDatabaseRequest
- type Endpoint
- type Error
- type ErrorOrError
- type GetKeyReply
- type GetKeyRequest
- type GetKeyServerLocationsReply
- type GetKeyServerLocationsRequest
- type GetKeyValuesReply
- type GetKeyValuesRequest
- type GetMappedKeyValuesReply
- type GetMappedKeyValuesRequest
- type GetRangeReqAndResult
- type GetReadVersionReply
- type GetReadVersionRequest
- type GetValueReply
- type GetValueReqAndResult
- type GetValueRequest
- type GrvProxyInterface
- type Hostname
- type IPAddress
- type KeyRangeRef
- type KeySelectorRef
- type KeyValueRef
- type LocationPair
- type MappedKeyValueRef
- type MutationRef
- type NetworkAddress
- type NetworkAddressList
- type OpenDatabaseCoordRequest
- type RangeResultRef
- type ReadOptions
- type ReplyPromise
- type SpanContext
- type SplitRangeReply
- type SplitRangeRequest
- type StorageMetrics
- type StorageServerInterface
- type TenantInfo
- type TenantMapEntry
- type TransactionTagCount
- type TransactionTagThrottle
- 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 ( ClientTagThrottleLimitsSlotTpsRate = 0 ClientTagThrottleLimitsSlotDuration = 1 )
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 ( GetMappedKeyValuesReplySlotPenalty = 0 GetMappedKeyValuesReplySlotError = 1 GetMappedKeyValuesReplySlotData = 3 GetMappedKeyValuesReplySlotVersion = 4 GetMappedKeyValuesReplySlotMore = 5 GetMappedKeyValuesReplySlotCached = 6 GetMappedKeyValuesReplySlotArena = 7 )
const ( GetMappedKeyValuesRequestSlotBegin = 0 GetMappedKeyValuesRequestSlotEnd = 1 GetMappedKeyValuesRequestSlotMapper = 2 GetMappedKeyValuesRequestSlotVersion = 3 GetMappedKeyValuesRequestSlotLimit = 4 GetMappedKeyValuesRequestSlotLimitBytes = 5 GetMappedKeyValuesRequestSlotTags = 6 GetMappedKeyValuesRequestSlotReply = 8 GetMappedKeyValuesRequestSlotSpanContext = 9 GetMappedKeyValuesRequestSlotTenantInfo = 10 GetMappedKeyValuesRequestSlotOptions = 11 GetMappedKeyValuesRequestSlotSsLatestCommitVersions = 13 GetMappedKeyValuesRequestSlotArena = 14 )
const ( GetRangeReqAndResultSlotBegin = 0 GetRangeReqAndResultSlotEnd = 1 GetRangeReqAndResultSlotResult = 2 )
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 ( GetValueReqAndResultSlotKey = 0 GetValueReqAndResultSlotResult = 1 )
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 ( MappedKeyValueRefSlotKeyValue = 0 MappedKeyValueRefSlotReqAndResult = 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 ( RangeResultRefSlotData = 0 RangeResultRefSlotMore = 1 RangeResultRefSlotReadThrough = 2 RangeResultRefSlotReadToBegin = 4 RangeResultRefSlotReadThroughEnd = 5 )
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 ( TransactionTagCountSlotTag = 0 TransactionTagCountSlotCount = 1 )
const ( TransactionTagThrottleSlotTag = 0 TransactionTagThrottleSlotLimits = 1 )
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 ClientTagThrottleLimitsMaxAlign = 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 FlagTLS uint16 = 2
FlagTLS is NetworkAddress::FLAG_TLS (flow/network.h).
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 GetMappedKeyValuesReplyFileID uint32 = 1783067
const GetMappedKeyValuesReplyMaxAlign = 8
const GetMappedKeyValuesRequestFileID uint32 = 6795747
const GetMappedKeyValuesRequestMaxAlign = 8
const GetRangeReqAndResultMaxAlign = 4
const GetReadVersionReplyFileID uint32 = 15709388
const GetReadVersionReplyMaxAlign = 8
const GetReadVersionRequestFileID uint32 = 838566
const GetReadVersionRequestMaxAlign = 8
const GetValueReplyFileID uint32 = 1378929
const GetValueReplyMaxAlign = 8
const GetValueReqAndResultMaxAlign = 4
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 MappedKeyValueRefMaxAlign = 4
const MutationRefMaxAlign = 4
const NetworkAddressFileID uint32 = 14155727
const NetworkAddressListMaxAlign = 4
const NetworkAddressMaxAlign = 4
const OpenDatabaseCoordRequestFileID uint32 = 214728
const OpenDatabaseCoordRequestMaxAlign = 8
const RangeResultRefFileID uint32 = 3985192
const RangeResultRefMaxAlign = 4
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 TransactionTagCountMaxAlign = 4
const TransactionTagThrottleMaxAlign = 4
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 ClientTagThrottleLimitsVTable = wire.VTable{8, 20, 4, 12}
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 GetMappedKeyValuesReplyTemplate = wire.NewMessageTemplate( GetMappedKeyValuesReplyFileID, GetMappedKeyValuesReplyVTable, 8, GetMappedKeyValuesReplyVTableClosure, )
var GetMappedKeyValuesReplyVTable = wire.VTable{18, 31, 4, 28, 20, 24, 12, 29, 30}
var GetMappedKeyValuesReplyVTableClosure = []wire.VTable{
{16, 16, 4, 12, 13, 8, 14, 15},
{6, 6, 4},
{6, 8, 4},
{8, 12, 4, 8},
{10, 13, 4, 12, 8},
{10, 16, 4, 8, 12},
{18, 31, 4, 28, 20, 24, 12, 29, 30},
}
var GetMappedKeyValuesRequestTemplate = wire.NewMessageTemplate( GetMappedKeyValuesRequestFileID, GetMappedKeyValuesRequestVTable, 8, GetMappedKeyValuesRequestVTableClosure, )
var GetMappedKeyValuesRequestVTable = wire.VTable{32, 58, 12, 16, 20, 4, 24, 28, 56, 32, 36, 40, 44, 57, 48, 52}
var GetMappedKeyValuesRequestVTableClosure = []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},
{32, 58, 12, 16, 20, 4, 24, 28, 56, 32, 36, 40, 44, 57, 48, 52},
}
var GetRangeReqAndResultVTable = wire.VTable{10, 16, 4, 8, 12}
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 GetValueReqAndResultVTable = wire.VTable{10, 13, 4, 12, 8}
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 MappedKeyValueRefVTable = wire.VTable{10, 13, 4, 12, 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 RangeResultRefTemplate = wire.NewMessageTemplate( RangeResultRefFileID, RangeResultRefVTable, 4, RangeResultRefVTableClosure, )
var RangeResultRefVTable = wire.VTable{16, 16, 4, 12, 13, 8, 14, 15}
var RangeResultRefVTableClosure = []wire.VTable{
{16, 16, 4, 12, 13, 8, 14, 15},
{6, 8, 4},
{8, 12, 4, 8},
}
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 TransactionTagCountVTable = wire.VTable{8, 12, 4, 8}
var TransactionTagThrottleVTable = wire.VTable{8, 12, 4, 8}
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.
func MarshalErrorOrValueGetReadVersionReply ¶
func MarshalErrorOrValueGetReadVersionReply(reply *GetReadVersionReply) []byte
MarshalErrorOrValueGetReadVersionReply wraps a GetReadVersionReply in the ErrorOr<...>(tag=2) success envelope a GRV proxy sends. Fault injection uses it to re-emit a reply decoded off the wire with one field changed (e.g. Locked).
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 table: decoded as presence only, do not set
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, error)
ParseClientDBInfoVectorFromReader reads a FlatBuffers vector of ClientDBInfo under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type ClientTagThrottleLimits ¶
func ParseClientTagThrottleLimitsVectorFromReader ¶
func ParseClientTagThrottleLimitsVectorFromReader(r *wire.Reader, slot int) ([]ClientTagThrottleLimits, error)
ParseClientTagThrottleLimitsVectorFromReader reads a FlatBuffers vector of ClientTagThrottleLimits under one decode budget.
func (*ClientTagThrottleLimits) UnmarshalFDB ¶
func (m *ClientTagThrottleLimits) UnmarshalFDB(data []byte) error
func (*ClientTagThrottleLimits) UnmarshalFromReader ¶
func (m *ClientTagThrottleLimits) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type ClientVersionRef ¶
ClientVersionRef is C++ ClientVersionRef (fdbclient/ClientVersion.h:27-75).
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 []int32 // slot 5, optional vector of int32
}
func ParseCommitIDVectorFromReader ¶
ParseCommitIDVectorFromReader reads a FlatBuffers vector of CommitID under one decode budget.
func (*CommitID) MarshalFDB ¶
func (*CommitID) MarshalFDBPooled ¶
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*CommitID) UnmarshalFDB ¶
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, error)
ParseCommitProxyInterfaceVectorFromReader reads a FlatBuffers vector of CommitProxyInterface under one decode budget.
func (*CommitProxyInterface) UnmarshalFDB ¶
func (m *CommitProxyInterface) UnmarshalFDB(data []byte) error
func (*CommitProxyInterface) UnmarshalFromReader ¶
func (m *CommitProxyInterface) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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 SpanContext // slot 7, optional nested 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, error)
ParseCommitTransactionRefVectorFromReader reads a FlatBuffers vector of CommitTransactionRef under one decode budget.
func (*CommitTransactionRef) UnmarshalFDB ¶
func (m *CommitTransactionRef) UnmarshalFDB(data []byte) error
func (*CommitTransactionRef) UnmarshalFromReader ¶
func (m *CommitTransactionRef) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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 table: decoded as presence only, do not set
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, error)
ParseCommitTransactionRequestVectorFromReader reads a FlatBuffers vector of CommitTransactionRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type CoordOpenDatabaseRequest ¶
type CoordOpenDatabaseRequest struct {
Issues [][]byte
SupportedVersions []ClientVersionRef
TraceLogGroup []byte
KnownClientInfoID [16]byte
ClusterKey []byte
Coordinators []NetworkAddress
Reply ReplyPromise
Hostnames []Hostname
Internal bool
}
CoordOpenDatabaseRequest is OpenDatabaseCoordRequest with typed vectors. Its encoding is byte-identical to libfdb_c 7.3.77 (pinned by a captured request).
func (*CoordOpenDatabaseRequest) MarshalFDB ¶
func (m *CoordOpenDatabaseRequest) MarshalFDB() []byte
MarshalFDB encodes the request as an ObjectWriter message (save_with_vtables, flat_buffers.h:803-822).
type Endpoint ¶
type Endpoint struct {
Addresses NetworkAddressList // slot 0, nested
Token [16]byte // slot 1
}
func ParseEndpointVectorFromReader ¶
ParseEndpointVectorFromReader reads a FlatBuffers vector of Endpoint under one decode budget.
func (*Endpoint) MarshalFDB ¶
func (*Endpoint) MarshalFDBPooled ¶
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*Endpoint) UnmarshalFDB ¶
type Error ¶
type Error struct {
ErrorCode uint16 // slot 0
}
func ParseErrorVectorFromReader ¶
ParseErrorVectorFromReader reads a FlatBuffers vector of Error under one decode budget.
func (*Error) MarshalFDB ¶
func (*Error) MarshalFDBPooled ¶
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*Error) UnmarshalFDB ¶
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, error)
ParseGetKeyReplyVectorFromReader reads a FlatBuffers vector of GetKeyReply under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGetKeyRequestVectorFromReader reads a FlatBuffers vector of GetKeyRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGetKeyServerLocationsReplyVectorFromReader reads a FlatBuffers vector of GetKeyServerLocationsReply under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGetKeyServerLocationsRequestVectorFromReader reads a FlatBuffers vector of GetKeyServerLocationsRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGetKeyValuesReplyVectorFromReader reads a FlatBuffers vector of GetKeyValuesReply under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGetKeyValuesRequestVectorFromReader reads a FlatBuffers vector of GetKeyValuesRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type GetMappedKeyValuesReply ¶
type GetMappedKeyValuesReply struct {
Penalty float64 // slot 0
HasError bool // slot 1, optional tag
Error Error // slot 2, optional nested value
Data []MappedKeyValueRef // slot 3, vector of struct
Version int64 // slot 4
More bool // slot 5
Cached bool // slot 6
Arena []byte // slot 7
}
func ParseGetMappedKeyValuesReplyVectorFromReader ¶
func ParseGetMappedKeyValuesReplyVectorFromReader(r *wire.Reader, slot int) ([]GetMappedKeyValuesReply, error)
ParseGetMappedKeyValuesReplyVectorFromReader reads a FlatBuffers vector of GetMappedKeyValuesReply under one decode budget.
func (*GetMappedKeyValuesReply) MarshalFDB ¶
func (m *GetMappedKeyValuesReply) MarshalFDB() []byte
func (*GetMappedKeyValuesReply) MarshalFDBPooled ¶
func (m *GetMappedKeyValuesReply) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetMappedKeyValuesReply) UnmarshalFDB ¶
func (m *GetMappedKeyValuesReply) UnmarshalFDB(data []byte) error
func (*GetMappedKeyValuesReply) UnmarshalFromReader ¶
func (m *GetMappedKeyValuesReply) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type GetMappedKeyValuesRequest ¶
type GetMappedKeyValuesRequest struct {
Begin KeySelectorRef // slot 0, nested
End KeySelectorRef // slot 1, nested
Mapper []byte // slot 2
Version int64 // slot 3
Limit int32 // slot 4
LimitBytes int32 // slot 5
HasTags bool // slot 6, optional tag
Tags []byte // slot 7, optional value
Reply ReplyPromise // slot 8, nested
SpanContext SpanContext // slot 9, nested
TenantInfo TenantInfo // slot 10, nested
HasOptions bool // slot 11, optional tag
Options ReadOptions // slot 12, optional nested value
SsLatestCommitVersions []byte // slot 13
Arena []byte // slot 14
}
func ParseGetMappedKeyValuesRequestVectorFromReader ¶
func ParseGetMappedKeyValuesRequestVectorFromReader(r *wire.Reader, slot int) ([]GetMappedKeyValuesRequest, error)
ParseGetMappedKeyValuesRequestVectorFromReader reads a FlatBuffers vector of GetMappedKeyValuesRequest under one decode budget.
func (*GetMappedKeyValuesRequest) MarshalFDB ¶
func (m *GetMappedKeyValuesRequest) MarshalFDB() []byte
func (*GetMappedKeyValuesRequest) MarshalFDBPooled ¶
func (m *GetMappedKeyValuesRequest) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*GetMappedKeyValuesRequest) UnmarshalFDB ¶
func (m *GetMappedKeyValuesRequest) UnmarshalFDB(data []byte) error
func (*GetMappedKeyValuesRequest) UnmarshalFromReader ¶
func (m *GetMappedKeyValuesRequest) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type GetRangeReqAndResult ¶
type GetRangeReqAndResult struct {
Begin KeySelectorRef // slot 0, nested
End KeySelectorRef // slot 1, nested
Result RangeResultRef // slot 2, nested
}
func ParseGetRangeReqAndResultVectorFromReader ¶
func ParseGetRangeReqAndResultVectorFromReader(r *wire.Reader, slot int) ([]GetRangeReqAndResult, error)
ParseGetRangeReqAndResultVectorFromReader reads a FlatBuffers vector of GetRangeReqAndResult under one decode budget.
func (*GetRangeReqAndResult) UnmarshalFDB ¶
func (m *GetRangeReqAndResult) UnmarshalFDB(data []byte) error
func (*GetRangeReqAndResult) UnmarshalFromReader ¶
func (m *GetRangeReqAndResult) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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 []TransactionTagThrottle // slot 5, vector of struct
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, error)
ParseGetReadVersionReplyVectorFromReader reads a FlatBuffers vector of GetReadVersionReply under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type GetReadVersionRequest ¶
type GetReadVersionRequest struct {
TransactionCount uint32 // slot 0
Flags uint32 // slot 1
Tags []TransactionTagCount // slot 2, vector of struct
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, error)
ParseGetReadVersionRequestVectorFromReader reads a FlatBuffers vector of GetReadVersionRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGetValueReplyVectorFromReader reads a FlatBuffers vector of GetValueReply under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type GetValueReqAndResult ¶
type GetValueReqAndResult struct {
Key []byte // slot 0
HasResult bool // slot 1, optional tag
Result []byte // slot 2, optional value
}
func ParseGetValueReqAndResultStringVector ¶
func ParseGetValueReqAndResultStringVector(data []byte) ([]GetValueReqAndResult, error)
ParseGetValueReqAndResultStringVector decodes a VectorRef<GetValueReqAndResult, VecSerStrategy::String>. Each element's DynamicSize fields are inline: [len(4)][data] per field, and the elements must fill the blob exactly. An empty blob is an empty vector.
func ParseGetValueReqAndResultVectorFromReader ¶
func ParseGetValueReqAndResultVectorFromReader(r *wire.Reader, slot int) ([]GetValueReqAndResult, error)
ParseGetValueReqAndResultVectorFromReader reads a FlatBuffers vector of GetValueReqAndResult under one decode budget.
func (*GetValueReqAndResult) UnmarshalFDB ¶
func (m *GetValueReqAndResult) UnmarshalFDB(data []byte) error
func (*GetValueReqAndResult) UnmarshalFromReader ¶
func (m *GetValueReqAndResult) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGetValueRequestVectorFromReader reads a FlatBuffers vector of GetValueRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseGrvProxyInterfaceVectorFromReader reads a FlatBuffers vector of GrvProxyInterface under one decode budget.
func (*GrvProxyInterface) UnmarshalFDB ¶
func (m *GrvProxyInterface) UnmarshalFDB(data []byte) error
func (*GrvProxyInterface) UnmarshalFromReader ¶
func (m *GrvProxyInterface) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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 under one decode budget.
func (*IPAddress) UnmarshalFDB ¶
type KeyRangeRef ¶
func ParseKeyRangeRefStringVector ¶
func ParseKeyRangeRefStringVector(data []byte) ([]KeyRangeRef, error)
ParseKeyRangeRefStringVector decodes a VectorRef<KeyRangeRef, VecSerStrategy::String>. Each element's DynamicSize fields are inline: [len(4)][data] per field, and the elements must fill the blob exactly. An empty blob is an empty vector.
func ParseKeyRangeRefVectorFromReader ¶
func ParseKeyRangeRefVectorFromReader(r *wire.Reader, slot int) ([]KeyRangeRef, error)
ParseKeyRangeRefVectorFromReader reads a FlatBuffers vector of KeyRangeRef under one decode budget.
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) error
UnmarshalFromReader inverts the single-key optimization when slot 1 is empty and slot 0 ends in \x00; without the \x00, where C++ asserts, the range stays inverted.
type KeySelectorRef ¶
func ParseKeySelectorRefVectorFromReader ¶
func ParseKeySelectorRefVectorFromReader(r *wire.Reader, slot int) ([]KeySelectorRef, error)
ParseKeySelectorRefVectorFromReader reads a FlatBuffers vector of KeySelectorRef under one decode budget.
func (*KeySelectorRef) UnmarshalFDB ¶
func (m *KeySelectorRef) UnmarshalFDB(data []byte) error
func (*KeySelectorRef) UnmarshalFromReader ¶
func (m *KeySelectorRef) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type KeyValueRef ¶
func ParseKeyValueRefStringVector ¶
func ParseKeyValueRefStringVector(data []byte) ([]KeyValueRef, error)
ParseKeyValueRefStringVector decodes a VectorRef<KeyValueRef, VecSerStrategy::String>. Each element's DynamicSize fields are inline: [len(4)][data] per field, and the elements must fill the blob exactly. An empty blob is an empty vector.
func ParseKeyValueRefVectorFromReader ¶
func ParseKeyValueRefVectorFromReader(r *wire.Reader, slot int) ([]KeyValueRef, error)
ParseKeyValueRefVectorFromReader reads a FlatBuffers vector of KeyValueRef under one decode budget.
func (*KeyValueRef) UnmarshalFDB ¶
func (m *KeyValueRef) UnmarshalFDB(data []byte) error
func (*KeyValueRef) UnmarshalFromReader ¶
func (m *KeyValueRef) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type LocationPair ¶
type LocationPair struct {
KeyRange KeyRangeRef // slot 0, nested
Servers []byte // slot 1
}
func ParseLocationPairVectorFromReader ¶
func ParseLocationPairVectorFromReader(r *wire.Reader, slot int) ([]LocationPair, error)
ParseLocationPairVectorFromReader reads a FlatBuffers vector of LocationPair under one decode budget.
func (*LocationPair) UnmarshalFDB ¶
func (m *LocationPair) UnmarshalFDB(data []byte) error
func (*LocationPair) UnmarshalFromReader ¶
func (m *LocationPair) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type MappedKeyValueRef ¶
type MappedKeyValueRef struct {
KeyValue KeyValueRef // slot 0, nested
ReqAndResultTag uint8 // slot 1, variant tag
ReqAndResultAlt0 GetValueReqAndResult // tag=1
ReqAndResultAlt1 GetRangeReqAndResult // tag=2
}
func ParseMappedKeyValueRefVectorFromReader ¶
func ParseMappedKeyValueRefVectorFromReader(r *wire.Reader, slot int) ([]MappedKeyValueRef, error)
ParseMappedKeyValueRefVectorFromReader reads a FlatBuffers vector of MappedKeyValueRef under one decode budget.
func (*MappedKeyValueRef) UnmarshalFDB ¶
func (m *MappedKeyValueRef) UnmarshalFDB(data []byte) error
func (*MappedKeyValueRef) UnmarshalFromReader ¶
func (m *MappedKeyValueRef) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type MutationRef ¶
func ParseMutationRefVectorFromReader ¶
func ParseMutationRefVectorFromReader(r *wire.Reader, slot int) ([]MutationRef, error)
ParseMutationRefVectorFromReader reads a FlatBuffers vector of MutationRef under one decode budget.
func (*MutationRef) UnmarshalFDB ¶
func (m *MutationRef) UnmarshalFDB(data []byte) error
func (*MutationRef) UnmarshalFromReader ¶
func (m *MutationRef) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseNetworkAddressVectorFromReader reads a FlatBuffers vector of NetworkAddress under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type NetworkAddressList ¶
type NetworkAddressList struct {
Address NetworkAddress // slot 0, nested
HasSecondaryAddress bool // slot 1, optional tag
SecondaryAddress NetworkAddress // slot 2, optional nested value
}
func ParseNetworkAddressListVectorFromReader ¶
func ParseNetworkAddressListVectorFromReader(r *wire.Reader, slot int) ([]NetworkAddressList, error)
ParseNetworkAddressListVectorFromReader reads a FlatBuffers vector of NetworkAddressList under one decode budget.
func (*NetworkAddressList) UnmarshalFDB ¶
func (m *NetworkAddressList) UnmarshalFDB(data []byte) error
func (*NetworkAddressList) UnmarshalFromReader ¶
func (m *NetworkAddressList) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseOpenDatabaseCoordRequestVectorFromReader reads a FlatBuffers vector of OpenDatabaseCoordRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type RangeResultRef ¶
type RangeResultRef struct {
Data []KeyValueRef // slot 0, vector of struct
More bool // slot 1
HasReadThrough bool // slot 2, optional tag
ReadThrough []byte // slot 3, optional value
ReadToBegin bool // slot 4
ReadThroughEnd bool // slot 5
}
func ParseRangeResultRefVectorFromReader ¶
func ParseRangeResultRefVectorFromReader(r *wire.Reader, slot int) ([]RangeResultRef, error)
ParseRangeResultRefVectorFromReader reads a FlatBuffers vector of RangeResultRef under one decode budget.
func (*RangeResultRef) MarshalFDB ¶
func (m *RangeResultRef) MarshalFDB() []byte
func (*RangeResultRef) MarshalFDBPooled ¶
func (m *RangeResultRef) MarshalFDBPooled(dst []byte) []byte
MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.
func (*RangeResultRef) UnmarshalFDB ¶
func (m *RangeResultRef) UnmarshalFDB(data []byte) error
func (*RangeResultRef) UnmarshalFromReader ¶
func (m *RangeResultRef) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseReadOptionsVectorFromReader reads a FlatBuffers vector of ReadOptions under one decode budget.
func (*ReadOptions) UnmarshalFDB ¶
func (m *ReadOptions) UnmarshalFDB(data []byte) error
func (*ReadOptions) UnmarshalFromReader ¶
func (m *ReadOptions) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type ReplyPromise ¶
type ReplyPromise struct {
Token [16]byte // slot 0
}
func ParseReplyPromiseVectorFromReader ¶
func ParseReplyPromiseVectorFromReader(r *wire.Reader, slot int) ([]ReplyPromise, error)
ParseReplyPromiseVectorFromReader reads a FlatBuffers vector of ReplyPromise under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseSpanContextVectorFromReader reads a FlatBuffers vector of SpanContext under one decode budget.
func (*SpanContext) UnmarshalFDB ¶
func (m *SpanContext) UnmarshalFDB(data []byte) error
func (*SpanContext) UnmarshalFromReader ¶
func (m *SpanContext) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type SplitRangeReply ¶
type SplitRangeReply struct {
SplitPoints []byte // slot 0
}
func ParseSplitRangeReplyVectorFromReader ¶
func ParseSplitRangeReplyVectorFromReader(r *wire.Reader, slot int) ([]SplitRangeReply, error)
ParseSplitRangeReplyVectorFromReader reads a FlatBuffers vector of SplitRangeReply under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseSplitRangeRequestVectorFromReader reads a FlatBuffers vector of SplitRangeRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseStorageMetricsVectorFromReader reads a FlatBuffers vector of StorageMetrics under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseStorageServerInterfaceVectorFromReader reads a FlatBuffers vector of StorageServerInterface under one decode budget.
func (*StorageServerInterface) UnmarshalFDB ¶
func (m *StorageServerInterface) UnmarshalFDB(data []byte) error
func (*StorageServerInterface) UnmarshalFromReader ¶
func (m *StorageServerInterface) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type TenantInfo ¶
type TenantInfo struct {
TenantId int64 // slot 0
HasToken bool // slot 1, optional tag
Token []byte // slot 2, optional table: decoded as presence only, do not set
Arena []byte // slot 3
}
func ParseTenantInfoVectorFromReader ¶
func ParseTenantInfoVectorFromReader(r *wire.Reader, slot int) ([]TenantInfo, error)
ParseTenantInfoVectorFromReader reads a FlatBuffers vector of TenantInfo under one decode budget.
func (*TenantInfo) UnmarshalFDB ¶
func (m *TenantInfo) UnmarshalFDB(data []byte) error
func (*TenantInfo) UnmarshalFromReader ¶
func (m *TenantInfo) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseTenantMapEntryVectorFromReader reads a FlatBuffers vector of TenantMapEntry under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type TransactionTagCount ¶
func ParseTransactionTagCountVectorFromReader ¶
func ParseTransactionTagCountVectorFromReader(r *wire.Reader, slot int) ([]TransactionTagCount, error)
ParseTransactionTagCountVectorFromReader reads a FlatBuffers vector of TransactionTagCount under one decode budget.
func (*TransactionTagCount) UnmarshalFDB ¶
func (m *TransactionTagCount) UnmarshalFDB(data []byte) error
func (*TransactionTagCount) UnmarshalFromReader ¶
func (m *TransactionTagCount) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type TransactionTagThrottle ¶
type TransactionTagThrottle struct {
Tag []byte // slot 0
Limits ClientTagThrottleLimits // slot 1, nested
}
func ParseTransactionTagThrottleVectorFromReader ¶
func ParseTransactionTagThrottleVectorFromReader(r *wire.Reader, slot int) ([]TransactionTagThrottle, error)
ParseTransactionTagThrottleVectorFromReader reads a FlatBuffers vector of TransactionTagThrottle under one decode budget.
func (*TransactionTagThrottle) UnmarshalFDB ¶
func (m *TransactionTagThrottle) UnmarshalFDB(data []byte) error
func (*TransactionTagThrottle) UnmarshalFromReader ¶
func (m *TransactionTagThrottle) UnmarshalFromReader(r *wire.Reader) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseWaitMetricsRequestVectorFromReader reads a FlatBuffers vector of WaitMetricsRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
type WatchValueReply ¶
func ParseWatchValueReplyVectorFromReader ¶
func ParseWatchValueReplyVectorFromReader(r *wire.Reader, slot int) ([]WatchValueReply, error)
ParseWatchValueReplyVectorFromReader reads a FlatBuffers vector of WatchValueReply under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
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, error)
ParseWatchValueRequestVectorFromReader reads a FlatBuffers vector of WatchValueRequest under one decode budget.
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) error
UnmarshalFromReader decodes m from r; on error m holds a partial decode.
Source Files
¶
- clientdbinfo_generated.go
- clienttagthrottlelimits_generated.go
- commitid_generated.go
- commitproxyinterface_generated.go
- committransactionref_generated.go
- committransactionrequest_generated.go
- decoders_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
- getmappedkeyvaluesreply_generated.go
- getmappedkeyvaluesrequest_generated.go
- getrangereqandresult_generated.go
- getreadversionreply_generated.go
- getreadversionrequest_generated.go
- getvaluereply_generated.go
- getvaluereqandresult_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
- mappedkeyvalueref_generated.go
- mutationref_generated.go
- networkaddress_generated.go
- networkaddresslist_generated.go
- opendatabasecoordrequest_custom.go
- opendatabasecoordrequest_generated.go
- rangeresultref_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
- transactiontagcount_generated.go
- transactiontagthrottle_generated.go
- waitmetricsrequest_generated.go
- watchvaluereply_generated.go
- watchvaluerequest_generated.go