types

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Nov 4, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

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

View Source
const (
	ClientDBInfoSlotGrvProxies      = 0
	ClientDBInfoSlotCommitProxies   = 1
	ClientDBInfoSlotId              = 2
	ClientDBInfoSlotForward         = 3
	ClientDBInfoSlotHistory         = 5
	ClientDBInfoSlotTenantMode      = 6
	ClientDBInfoSlotEncryptKeyProxy = 7
	ClientDBInfoSlotClusterId       = 9
	ClientDBInfoSlotClusterType     = 10
	ClientDBInfoSlotMetaclusterName = 11
)
View Source
const (
	ClientTagThrottleLimitsSlotTpsRate  = 0
	ClientTagThrottleLimitsSlotDuration = 1
)
View Source
const (
	CommitIDSlotVersion              = 0
	CommitIDSlotTxnBatchId           = 1
	CommitIDSlotMetadataVersion      = 2
	CommitIDSlotConflictingKRIndices = 4
)
View Source
const (
	CommitProxyInterfaceSlotProcessId   = 0
	CommitProxyInterfaceSlotProvisional = 2
	CommitProxyInterfaceSlotCommit      = 3
)
View Source
const (
	CommitProxyInterfaceFileID   uint32 = 8954922
	CommitProxyInterfaceMaxAlign        = 4
)
View Source
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
)
View Source
const (
	CommitTransactionRequestSlotTransaction          = 0
	CommitTransactionRequestSlotReply                = 1
	CommitTransactionRequestSlotFlags                = 2
	CommitTransactionRequestSlotDebugID              = 3
	CommitTransactionRequestSlotCommitCostEstimation = 5
	CommitTransactionRequestSlotTagSet               = 7
	CommitTransactionRequestSlotSpanContext          = 9
	CommitTransactionRequestSlotTenantInfo           = 10
	CommitTransactionRequestSlotIdempotencyId        = 11
	CommitTransactionRequestSlotArena                = 12
)
View Source
const (
	EndpointSlotAddresses = 0
	EndpointSlotToken     = 1
)
View Source
const (
	GetKeyReplySlotPenalty = 0
	GetKeyReplySlotError   = 1
	GetKeyReplySlotSel     = 3
	GetKeyReplySlotCached  = 4
)
View Source
const (
	GetKeyRequestSlotSel                    = 0
	GetKeyRequestSlotVersion                = 1
	GetKeyRequestSlotTags                   = 2
	GetKeyRequestSlotReply                  = 4
	GetKeyRequestSlotSpanContext            = 5
	GetKeyRequestSlotTenantInfo             = 6
	GetKeyRequestSlotOptions                = 7
	GetKeyRequestSlotSsLatestCommitVersions = 9
	GetKeyRequestSlotField_10               = 10
)
View Source
const (
	GetKeyServerLocationsReplySlotResults           = 0
	GetKeyServerLocationsReplySlotResultsTssMapping = 1
	GetKeyServerLocationsReplySlotResultsTagMapping = 2
	GetKeyServerLocationsReplySlotArena             = 3
)
View Source
const (
	GetKeyServerLocationsRequestSlotBegin            = 0
	GetKeyServerLocationsRequestSlotEnd              = 1
	GetKeyServerLocationsRequestSlotLimit            = 3
	GetKeyServerLocationsRequestSlotReverse          = 4
	GetKeyServerLocationsRequestSlotReply            = 5
	GetKeyServerLocationsRequestSlotSpanContext      = 6
	GetKeyServerLocationsRequestSlotTenant           = 7
	GetKeyServerLocationsRequestSlotMinTenantVersion = 8
	GetKeyServerLocationsRequestSlotArena            = 9
)
View Source
const (
	GetKeyValuesReplySlotPenalty = 0
	GetKeyValuesReplySlotError   = 1
	GetKeyValuesReplySlotData    = 3
	GetKeyValuesReplySlotVersion = 4
	GetKeyValuesReplySlotMore    = 5
	GetKeyValuesReplySlotCached  = 6
	GetKeyValuesReplySlotArena   = 7
)
View Source
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
)
View Source
const (
	GetMappedKeyValuesReplySlotPenalty = 0
	GetMappedKeyValuesReplySlotError   = 1
	GetMappedKeyValuesReplySlotData    = 3
	GetMappedKeyValuesReplySlotVersion = 4
	GetMappedKeyValuesReplySlotMore    = 5
	GetMappedKeyValuesReplySlotCached  = 6
	GetMappedKeyValuesReplySlotArena   = 7
)
View Source
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
)
View Source
const (
	GetRangeReqAndResultSlotBegin  = 0
	GetRangeReqAndResultSlotEnd    = 1
	GetRangeReqAndResultSlotResult = 2
)
View Source
const (
	GetReadVersionReplySlotProcessBusyTime           = 0
	GetReadVersionReplySlotVersion                   = 1
	GetReadVersionReplySlotLocked                    = 2
	GetReadVersionReplySlotMetadataVersion           = 3
	GetReadVersionReplySlotTagThrottleInfo           = 5
	GetReadVersionReplySlotMidShardSize              = 6
	GetReadVersionReplySlotRkDefaultThrottled        = 7
	GetReadVersionReplySlotRkBatchThrottled          = 8
	GetReadVersionReplySlotSsVersionVectorDelta      = 9
	GetReadVersionReplySlotProxyId                   = 10
	GetReadVersionReplySlotProxyTagThrottledDuration = 11
)
View Source
const (
	GetReadVersionRequestSlotTransactionCount = 0
	GetReadVersionRequestSlotFlags            = 1
	GetReadVersionRequestSlotTags             = 2
	GetReadVersionRequestSlotDebugID          = 3
	GetReadVersionRequestSlotReply            = 5
	GetReadVersionRequestSlotSpanContext      = 6
	GetReadVersionRequestSlotMaxVersion       = 7
)
View Source
const (
	GetValueReplySlotPenalty = 0
	GetValueReplySlotError   = 1
	GetValueReplySlotValue   = 3
	GetValueReplySlotCached  = 5
)
View Source
const (
	GetValueReqAndResultSlotKey    = 0
	GetValueReqAndResultSlotResult = 1
)
View Source
const (
	GetValueRequestSlotKey                    = 0
	GetValueRequestSlotVersion                = 1
	GetValueRequestSlotTags                   = 2
	GetValueRequestSlotReply                  = 4
	GetValueRequestSlotSpanContext            = 5
	GetValueRequestSlotTenantInfo             = 6
	GetValueRequestSlotOptions                = 7
	GetValueRequestSlotSsLatestCommitVersions = 9
)
View Source
const (
	GrvProxyInterfaceSlotProcessId                = 0
	GrvProxyInterfaceSlotProvisional              = 2
	GrvProxyInterfaceSlotGetConsistentReadVersion = 3
)
View Source
const (
	GrvProxyInterfaceFileID   uint32 = 8743216
	GrvProxyInterfaceMaxAlign        = 4
)
View Source
const (
	KeyRangeRefSlotBegin = 0
	KeyRangeRefSlotEnd   = 1
)
View Source
const (
	KeySelectorRefSlotKey     = 0
	KeySelectorRefSlotOrEqual = 1
	KeySelectorRefSlotOffset  = 2
)
View Source
const (
	KeyValueRefSlotKey   = 0
	KeyValueRefSlotValue = 1
)
View Source
const (
	LocationPairSlotKeyRange = 0
	LocationPairSlotServers  = 1
)
View Source
const (
	MappedKeyValueRefSlotKeyValue     = 0
	MappedKeyValueRefSlotReqAndResult = 1
)
View Source
const (
	MutationRefSlotMutType = 0
	MutationRefSlotParam1  = 1
	MutationRefSlotParam2  = 2
)
View Source
const (
	NetworkAddressSlotIp           = 0
	NetworkAddressSlotPort         = 1
	NetworkAddressSlotFlags        = 2
	NetworkAddressSlotFromHostname = 3
)
View Source
const (
	NetworkAddressListSlotAddress          = 0
	NetworkAddressListSlotSecondaryAddress = 1
)
View Source
const (
	OpenDatabaseCoordRequestSlotIssues            = 0
	OpenDatabaseCoordRequestSlotSupportedVersions = 1
	OpenDatabaseCoordRequestSlotTraceLogGroup     = 2
	OpenDatabaseCoordRequestSlotKnownClientInfoID = 3
	OpenDatabaseCoordRequestSlotClusterKey        = 4
	OpenDatabaseCoordRequestSlotCoordinators      = 5
	OpenDatabaseCoordRequestSlotReply             = 6
	OpenDatabaseCoordRequestSlotHostnames         = 7
	OpenDatabaseCoordRequestSlotInternal          = 8
)
View Source
const (
	RangeResultRefSlotData           = 0
	RangeResultRefSlotMore           = 1
	RangeResultRefSlotReadThrough    = 2
	RangeResultRefSlotReadToBegin    = 4
	RangeResultRefSlotReadThroughEnd = 5
)
View Source
const (
	ReadOptionsSlotType                         = 0
	ReadOptionsSlotCacheResult                  = 1
	ReadOptionsSlotDebugID                      = 2
	ReadOptionsSlotConsistencyCheckStartVersion = 4
	ReadOptionsSlotLockAware                    = 6
)
View Source
const (
	SpanContextSlotTraceID = 0
	SpanContextSlotSpanID  = 1
	SpanContextSlotFlags   = 2
)
View Source
const (
	SplitRangeRequestSlotKeys       = 0
	SplitRangeRequestSlotChunkSize  = 1
	SplitRangeRequestSlotReply      = 2
	SplitRangeRequestSlotTenantInfo = 3
	SplitRangeRequestSlotField_4    = 4
)
View Source
const (
	StorageMetricsSlotBytes                  = 0
	StorageMetricsSlotBytesWrittenPerKSecond = 1
	StorageMetricsSlotIosPerKSecond          = 2
	StorageMetricsSlotBytesReadPerKSecond    = 3
	StorageMetricsSlotOpsReadPerKSecond      = 4
)
View Source
const (
	StorageServerInterfaceSlotWatchValue = 0
	StorageServerInterfaceSlotField_1    = 1
	StorageServerInterfaceSlotField_2    = 2
	StorageServerInterfaceSlotField_3    = 3
	StorageServerInterfaceSlotField_5    = 5
)
View Source
const (
	StorageServerInterfaceFileID   uint32 = 15302073
	StorageServerInterfaceMaxAlign        = 8
)
View Source
const (
	TenantInfoSlotTenantId = 0
	TenantInfoSlotToken    = 1
	TenantInfoSlotArena    = 3
)
View Source
const (
	TenantMapEntrySlotId                       = 0
	TenantMapEntrySlotTenantName               = 1
	TenantMapEntrySlotTenantLockState          = 2
	TenantMapEntrySlotTenantLockId             = 3
	TenantMapEntrySlotTenantGroup              = 5
	TenantMapEntrySlotConfigurationSequenceNum = 7
)
View Source
const (
	TransactionTagCountSlotTag   = 0
	TransactionTagCountSlotCount = 1
)
View Source
const (
	TransactionTagThrottleSlotTag    = 0
	TransactionTagThrottleSlotLimits = 1
)
View Source
const (
	WaitMetricsRequestSlotKeys       = 0
	WaitMetricsRequestSlotMin        = 1
	WaitMetricsRequestSlotMax        = 2
	WaitMetricsRequestSlotReply      = 3
	WaitMetricsRequestSlotTenantInfo = 4
	WaitMetricsRequestSlotMinVersion = 5
	WaitMetricsRequestSlotField_6    = 6
)
View Source
const (
	WatchValueReplySlotVersion = 0
	WatchValueReplySlotCached  = 1
)
View Source
const (
	WatchValueRequestSlotKey         = 0
	WatchValueRequestSlotValue       = 1
	WatchValueRequestSlotVersion     = 3
	WatchValueRequestSlotTags        = 4
	WatchValueRequestSlotDebugID     = 6
	WatchValueRequestSlotReply       = 8
	WatchValueRequestSlotSpanContext = 9
	WatchValueRequestSlotTenantInfo  = 10
)
View Source
const ClientDBInfoFileID uint32 = 5355080
View Source
const ClientDBInfoMaxAlign = 8
View Source
const ClientTagThrottleLimitsMaxAlign = 8
View Source
const CommitIDFileID uint32 = 14254927
View Source
const CommitIDMaxAlign = 8
View Source
const CommitTransactionRefMaxAlign = 8
View Source
const CommitTransactionRequestFileID uint32 = 93948
View Source
const CommitTransactionRequestMaxAlign = 4
View Source
const EndpointFileID uint32 = 10618805
View Source
const EndpointMaxAlign = 8
View Source
const ErrorFileID uint32 = 14065384
View Source
const ErrorMaxAlign = 4
View Source
const (
	ErrorSlotErrorCode = 0
)
View Source
const FlagTLS uint16 = 2

FlagTLS is NetworkAddress::FLAG_TLS (flow/network.h).

View Source
const GetKeyReplyFileID uint32 = 11226513
View Source
const GetKeyReplyMaxAlign = 8
View Source
const GetKeyRequestFileID uint32 = 10457870
View Source
const GetKeyRequestMaxAlign = 8
View Source
const GetKeyServerLocationsReplyFileID uint32 = 10636023
View Source
const GetKeyServerLocationsReplyMaxAlign = 4
View Source
const GetKeyServerLocationsRequestFileID uint32 = 9144680
View Source
const GetKeyServerLocationsRequestMaxAlign = 8
View Source
const GetKeyValuesReplyFileID uint32 = 1783066
View Source
const GetKeyValuesReplyMaxAlign = 8
View Source
const GetKeyValuesRequestFileID uint32 = 6795746
View Source
const GetKeyValuesRequestMaxAlign = 8
View Source
const GetMappedKeyValuesReplyFileID uint32 = 1783067
View Source
const GetMappedKeyValuesReplyMaxAlign = 8
View Source
const GetMappedKeyValuesRequestFileID uint32 = 6795747
View Source
const GetMappedKeyValuesRequestMaxAlign = 8
View Source
const GetRangeReqAndResultMaxAlign = 4
View Source
const GetReadVersionReplyFileID uint32 = 15709388
View Source
const GetReadVersionReplyMaxAlign = 8
View Source
const GetReadVersionRequestFileID uint32 = 838566
View Source
const GetReadVersionRequestMaxAlign = 8
View Source
const GetValueReplyFileID uint32 = 1378929
View Source
const GetValueReplyMaxAlign = 8
View Source
const GetValueReqAndResultMaxAlign = 4
View Source
const GetValueRequestFileID uint32 = 8454530
View Source
const GetValueRequestMaxAlign = 8
View Source
const IPAddressMaxAlign = 4
View Source
const (
	IPAddressSlotAddr = 0
)
View Source
const KeyRangeRefMaxAlign = 4
View Source
const KeySelectorRefMaxAlign = 4
View Source
const KeyValueRefMaxAlign = 4
View Source
const LocationPairMaxAlign = 4
View Source
const MappedKeyValueRefMaxAlign = 4
View Source
const MutationRefMaxAlign = 4
View Source
const NetworkAddressFileID uint32 = 14155727
View Source
const NetworkAddressListMaxAlign = 4
View Source
const NetworkAddressMaxAlign = 4
View Source
const OpenDatabaseCoordRequestFileID uint32 = 214728
View Source
const OpenDatabaseCoordRequestMaxAlign = 8
View Source
const RangeResultRefFileID uint32 = 3985192
View Source
const RangeResultRefMaxAlign = 4
View Source
const ReadOptionsMaxAlign = 4
View Source
const ReplyPromiseFileID uint32 = 18156145
View Source
const ReplyPromiseMaxAlign = 8
View Source
const (
	ReplyPromiseSlotToken = 0
)
View Source
const SpanContextMaxAlign = 8
View Source
const SplitRangeReplyFileID uint32 = 11813134
View Source
const SplitRangeReplyMaxAlign = 4
View Source
const (
	SplitRangeReplySlotSplitPoints = 0
)
View Source
const SplitRangeRequestFileID uint32 = 10725174
View Source
const SplitRangeRequestMaxAlign = 8
View Source
const StorageMetricsFileID uint32 = 13622226
View Source
const StorageMetricsMaxAlign = 8
View Source
const TenantInfoMaxAlign = 8
View Source
const TenantMapEntryFileID uint32 = 7054389
View Source
const TenantMapEntryMaxAlign = 8
View Source
const TransactionTagCountMaxAlign = 4
View Source
const TransactionTagThrottleMaxAlign = 4
View Source
const VoidReplyFileID uint32 = 0x021EAD4A
View Source
const WaitMetricsRequestFileID uint32 = 1795961
View Source
const WaitMetricsRequestMaxAlign = 8
View Source
const WatchValueReplyFileID uint32 = 3
View Source
const WatchValueReplyMaxAlign = 8
View Source
const WatchValueRequestFileID uint32 = 14747733
View Source
const WatchValueRequestMaxAlign = 8

Variables

View Source
var ClientDBInfoVTable = wire.VTable{30, 71, 36, 40, 4, 68, 44, 48, 52, 69, 56, 20, 60, 70, 64}
View Source
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},
}
View Source
var ClientTagThrottleLimitsVTable = wire.VTable{8, 20, 4, 12}
View Source
var CommitIDVTable = wire.VTable{16, 24, 4, 20, 22, 12, 23, 16}
View Source
var CommitIDVTableClosure = []wire.VTable{
	{6, 8, 4},
	{16, 24, 4, 20, 22, 12, 23, 16},
}
View Source
var CommitProxyInterfaceVTable = wire.VTable{12, 14, 12, 4, 13, 8}
View Source
var CommitTransactionRefVTable = wire.VTable{24, 36, 12, 16, 20, 4, 32, 33, 34, 24, 35, 28}
View Source
var CommitTransactionRequestVTable = wire.VTable{28, 43, 4, 8, 12, 40, 16, 41, 20, 42, 24, 28, 32, 36}
View Source
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},
}
View Source
var EndpointVTable = wire.VTable{8, 24, 20, 4}
View Source
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},
}
View Source
var ErrorOrErrorTemplate = wire.NewMessageTemplate(
	0, errorOrVTable, 4, errorOrErrorVTableClosure,
)
View Source
var ErrorVTable = wire.VTable{6, 6, 4}
View Source
var ErrorVTableClosure = []wire.VTable{
	{6, 6, 4},
	{6, 8, 4},
}
View Source
var GetKeyReplyVTable = wire.VTable{14, 22, 4, 20, 12, 16, 21}
View Source
var GetKeyReplyVTableClosure = []wire.VTable{
	{6, 6, 4},
	{6, 8, 4},
	{10, 13, 4, 12, 8},
	{14, 22, 4, 20, 12, 16, 21},
}
View Source
var GetKeyRequestVTable = wire.VTable{24, 42, 12, 4, 40, 16, 20, 24, 28, 41, 32, 36}
View Source
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},
}
View Source
var GetKeyServerLocationsReplyVTable = wire.VTable{10, 16, 4, 8, 12}
View Source
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},
}
View Source
var GetKeyServerLocationsRequestVTable = wire.VTable{22, 38, 12, 36, 16, 20, 37, 24, 28, 32, 4}
View Source
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},
}
View Source
var GetKeyValuesReplyVTable = wire.VTable{18, 31, 4, 28, 20, 24, 12, 29, 30}
View Source
var GetKeyValuesReplyVTableClosure = []wire.VTable{
	{6, 6, 4},
	{6, 8, 4},
	{18, 31, 4, 28, 20, 24, 12, 29, 30},
}
View Source
var GetKeyValuesRequestVTable = wire.VTable{30, 54, 12, 16, 4, 20, 24, 52, 28, 32, 36, 40, 53, 44, 48}
View Source
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},
}
View Source
var GetMappedKeyValuesReplyVTable = wire.VTable{18, 31, 4, 28, 20, 24, 12, 29, 30}
View Source
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},
}
View Source
var GetMappedKeyValuesRequestVTable = wire.VTable{32, 58, 12, 16, 20, 4, 24, 28, 56, 32, 36, 40, 44, 57, 48, 52}
View Source
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},
}
View Source
var GetRangeReqAndResultVTable = wire.VTable{10, 16, 4, 8, 12}
View Source
var GetReadVersionReplyVTable = wire.VTable{28, 64, 44, 20, 60, 61, 48, 52, 28, 62, 63, 56, 4, 36}
View Source
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},
}
View Source
var GetReadVersionRequestVTable = wire.VTable{20, 37, 12, 16, 20, 36, 24, 28, 32, 4}
View Source
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},
}
View Source
var GetValueReplyVTable = wire.VTable{16, 23, 4, 20, 12, 21, 16, 22}
View Source
var GetValueReplyVTableClosure = []wire.VTable{
	{6, 6, 4},
	{6, 8, 4},
	{16, 23, 4, 20, 12, 21, 16, 22},
}
View Source
var GetValueReqAndResultVTable = wire.VTable{10, 13, 4, 12, 8}
View Source
var GetValueRequestVTable = wire.VTable{24, 42, 12, 4, 40, 16, 20, 24, 28, 41, 32, 36}
View Source
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},
}
View Source
var GrvProxyInterfaceVTable = wire.VTable{12, 14, 12, 4, 13, 8}
View Source
var IPAddressVTable = wire.VTable{8, 9, 8, 4}
View Source
var KeyRangeRefVTable = wire.VTable{8, 12, 4, 8}
View Source
var KeySelectorRefVTable = wire.VTable{10, 13, 4, 12, 8}
View Source
var KeyValueRefVTable = wire.VTable{8, 12, 4, 8}
View Source
var LocationPairVTable = wire.VTable{8, 12, 4, 8}
View Source
var MappedKeyValueRefVTable = wire.VTable{10, 13, 4, 12, 8}
View Source
var MutationRefVTable = wire.VTable{10, 13, 12, 4, 8}
View Source
var NetworkAddressListVTable = wire.VTable{10, 13, 4, 12, 8}
View Source
var NetworkAddressVTable = wire.VTable{12, 13, 4, 8, 10, 12}
View Source
var NetworkAddressVTableClosure = []wire.VTable{
	{8, 9, 8, 4},
	{12, 13, 4, 8, 10, 12},
	{6, 8, 4},
}
View Source
var OpenDatabaseCoordRequestVTable = wire.VTable{22, 49, 20, 24, 28, 4, 32, 36, 40, 44, 48}
View Source
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},
}
View Source
var RangeResultRefVTable = wire.VTable{16, 16, 4, 12, 13, 8, 14, 15}
View Source
var RangeResultRefVTableClosure = []wire.VTable{
	{16, 16, 4, 12, 13, 8, 14, 15},
	{6, 8, 4},
	{8, 12, 4, 8},
}
View Source
var ReadOptionsVTable = wire.VTable{18, 20, 4, 16, 17, 8, 18, 12, 19}
View Source
var ReplyPromiseVTable = wire.VTable{6, 20, 4}
View Source
var ReplyPromiseVTableClosure = []wire.VTable{
	{6, 20, 4},
	{6, 8, 4},
}
View Source
var SpanContextVTable = wire.VTable{10, 29, 4, 20, 28}
View Source
var SplitRangeReplyVTable = wire.VTable{6, 8, 4}
View Source
var SplitRangeReplyVTableClosure = []wire.VTable{
	{6, 8, 4},
}
View Source
var SplitRangeRequestVTable = wire.VTable{12, 24, 12, 4, 16, 20}
View Source
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},
}
View Source
var StorageMetricsVTable = wire.VTable{14, 44, 4, 12, 20, 28, 36}
View Source
var StorageMetricsVTableClosure = []wire.VTable{
	{6, 8, 4},
	{14, 44, 4, 12, 20, 28, 36},
}
View Source
var StorageServerInterfaceVTable = wire.VTable{16, 34, 4, 20, 24, 32, 28, 33}
View Source
var TenantInfoVTable = wire.VTable{10, 17, 4, 16, 12}
View Source
var TenantMapEntryVTable = wire.VTable{20, 35, 4, 20, 32, 33, 24, 34, 28, 12}
View Source
var TenantMapEntryVTableClosure = []wire.VTable{
	{20, 35, 4, 20, 32, 33, 24, 34, 28, 12},
	{6, 8, 4},
}
View Source
var TransactionTagCountVTable = wire.VTable{8, 12, 4, 8}
View Source
var TransactionTagThrottleVTable = wire.VTable{8, 12, 4, 8}
View Source
var VoidReplyTemplate = wire.NewMessageTemplate(
	VoidReplyFileID, errorOrVTable, 4, voidReplyVTableClosure,
)
View Source
var WaitMetricsRequestVTable = wire.VTable{16, 32, 12, 16, 20, 24, 28, 4}
View Source
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},
}
View Source
var WatchValueReplyVTable = wire.VTable{8, 13, 4, 12}
View Source
var WatchValueReplyVTableClosure = []wire.VTable{
	{6, 8, 4},
	{8, 13, 4, 12},
}
View Source
var WatchValueRequestVTable = wire.VTable{26, 43, 12, 40, 16, 4, 41, 20, 42, 24, 28, 32, 36}
View Source
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

func MarshalErrorOrInlineError(code uint16, penalty float64) []byte

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

type ClientTagThrottleLimits struct {
	TpsRate  float64 // slot 0
	Duration float64 // slot 1
}

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

type ClientVersionRef struct {
	ClientVersion   []byte
	SourceVersion   []byte
	ProtocolVersion []byte
}

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

func ParseCommitIDVectorFromReader(r *wire.Reader, slot int) ([]CommitID, error)

ParseCommitIDVectorFromReader reads a FlatBuffers vector of CommitID under one decode budget.

func (*CommitID) MarshalFDB

func (m *CommitID) MarshalFDB() []byte

func (*CommitID) MarshalFDBPooled

func (m *CommitID) MarshalFDBPooled(dst []byte) []byte

MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.

func (*CommitID) UnmarshalFDB

func (m *CommitID) UnmarshalFDB(data []byte) error

func (*CommitID) UnmarshalFromReader

func (m *CommitID) UnmarshalFromReader(r *wire.Reader) error

UnmarshalFromReader decodes m from r; on error m holds a partial decode.

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

func ParseEndpointVectorFromReader(r *wire.Reader, slot int) ([]Endpoint, error)

ParseEndpointVectorFromReader reads a FlatBuffers vector of Endpoint under one decode budget.

func (*Endpoint) MarshalFDB

func (m *Endpoint) MarshalFDB() []byte

func (*Endpoint) MarshalFDBPooled

func (m *Endpoint) MarshalFDBPooled(dst []byte) []byte

MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.

func (*Endpoint) UnmarshalFDB

func (m *Endpoint) UnmarshalFDB(data []byte) error

func (*Endpoint) UnmarshalFromReader

func (m *Endpoint) UnmarshalFromReader(r *wire.Reader) error

UnmarshalFromReader decodes m from r; on error m holds a partial decode.

type Error

type Error struct {
	ErrorCode uint16 // slot 0
}

func ParseErrorVectorFromReader

func ParseErrorVectorFromReader(r *wire.Reader, slot int) ([]Error, error)

ParseErrorVectorFromReader reads a FlatBuffers vector of Error under one decode budget.

func (*Error) MarshalFDB

func (m *Error) MarshalFDB() []byte

func (*Error) MarshalFDBPooled

func (m *Error) MarshalFDBPooled(dst []byte) []byte

MarshalFDBPooled is like MarshalFDB but reuses dst if capacity is sufficient.

func (*Error) UnmarshalFDB

func (m *Error) UnmarshalFDB(data []byte) error

func (*Error) UnmarshalFromReader

func (m *Error) UnmarshalFromReader(r *wire.Reader) error

UnmarshalFromReader decodes m from r; on error m holds a partial decode.

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 Hostname

type Hostname struct {
	Host    []byte
	Service []byte // decimal port
	IsTLS   bool
}

Hostname is C++ Hostname (flow/Hostname.h:29-70).

type IPAddress

type IPAddress struct {
	AddrTag  uint8  // slot 0, variant tag
	AddrAlt0 uint32 // tag=1
	AddrAlt1 []byte // tag=2
}

func ParseIPAddressVectorFromReader

func ParseIPAddressVectorFromReader(r *wire.Reader, slot int) ([]IPAddress, error)

ParseIPAddressVectorFromReader reads a FlatBuffers vector of IPAddress under one decode budget.

func (*IPAddress) UnmarshalFDB

func (m *IPAddress) UnmarshalFDB(data []byte) error

func (*IPAddress) UnmarshalFromReader

func (m *IPAddress) UnmarshalFromReader(r *wire.Reader) error

UnmarshalFromReader decodes m from r; on error m holds a partial decode.

type KeyRangeRef

type KeyRangeRef struct {
	Begin []byte // slot 0
	End   []byte // slot 1
}

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

type KeySelectorRef struct {
	Key     []byte // slot 0
	OrEqual bool   // slot 1
	Offset  int32  // slot 2
}

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

type KeyValueRef struct {
	Key   []byte // slot 0
	Value []byte // slot 1
}

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

type MutationRef struct {
	MutType uint8  // slot 0
	Param1  []byte // slot 1
	Param2  []byte // slot 2
}

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

type TransactionTagCount struct {
	Tag   []byte // slot 0
	Count uint32 // slot 1
}

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

func (m *VoidReply) MarshalFDB() []byte

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

type WatchValueReply struct {
	Version int64 // slot 0
	Cached  bool  // slot 1
}

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

Jump to

Keyboard shortcuts

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