types

package
v0.0.0-...-29d77a8 Latest Latest
Warning

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

Go to latest
Published: Jul 6, 2026 License: Apache-2.0 Imports: 3 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 (
	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 (
	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 (
	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 (
	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 (
	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 (
	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 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 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 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 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 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 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 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 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 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 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 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 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 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.

Types

type ClientDBInfo

type ClientDBInfo struct {
	GrvProxies    []byte   // slot 0
	CommitProxies []byte   // slot 1
	Id            [16]byte // slot 2
	HasForward    bool     // slot 3, optional tag
	Forward       []byte   // slot 4, optional value
	History       []byte   // slot 5
	// TenantMode: unregistered nested struct at slot 6
	HasEncryptKeyProxy bool     // slot 7, optional tag
	EncryptKeyProxy    []byte   // slot 8, optional value
	ClusterId          [16]byte // slot 9
	ClusterType        int32    // slot 10
	HasMetaclusterName bool     // slot 11, optional tag
	MetaclusterName    []byte   // slot 12, optional value
}

func ParseClientDBInfoVectorFromReader

func ParseClientDBInfoVectorFromReader(r *wire.Reader, slot int) []ClientDBInfo

ParseClientDBInfoVectorFromReader reads a FlatBuffers vector of ClientDBInfo.

func (*ClientDBInfo) MarshalFDB

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

func (*ClientDBInfo) MarshalFDBPooled

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

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

func (*ClientDBInfo) UnmarshalFDB

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

func (*ClientDBInfo) UnmarshalFromReader

func (m *ClientDBInfo) UnmarshalFromReader(r *wire.Reader)

type CommitID

type CommitID struct {
	Version                 int64  // slot 0
	TxnBatchId              uint16 // slot 1
	HasMetadataVersion      bool   // slot 2, optional tag
	MetadataVersion         []byte // slot 3, optional value
	HasConflictingKRIndices bool   // slot 4, optional tag
	ConflictingKRIndices    []byte // slot 5, optional value
}

func ParseCommitIDVectorFromReader

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

ParseCommitIDVectorFromReader reads a FlatBuffers vector of CommitID.

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)

type CommitProxyInterface

type CommitProxyInterface struct {
	HasProcessId bool   // slot 0, optional tag
	ProcessId    []byte // slot 1, optional value
	Provisional  bool   // slot 2

}

func ParseCommitProxyInterfaceVectorFromReader

func ParseCommitProxyInterfaceVectorFromReader(r *wire.Reader, slot int) []CommitProxyInterface

ParseCommitProxyInterfaceVectorFromReader reads a FlatBuffers vector of CommitProxyInterface.

func (*CommitProxyInterface) UnmarshalFDB

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

func (*CommitProxyInterface) UnmarshalFromReader

func (m *CommitProxyInterface) UnmarshalFromReader(r *wire.Reader)

type CommitTransactionRef

type CommitTransactionRef struct {
	ReadConflictRanges                []KeyRangeRef // slot 0, vector of struct
	WriteConflictRanges               []KeyRangeRef // slot 1, vector of struct
	Mutations                         []MutationRef // slot 2, vector of struct
	ReadSnapshot                      int64         // slot 3
	Report_conflicting_keys           bool          // slot 4
	Lock_aware                        bool          // slot 5
	HasRead_conflict_ranges_disabled  bool          // slot 6, optional tag
	Read_conflict_ranges_disabled     []byte        // slot 7, optional value
	HasWrite_conflict_ranges_disabled bool          // slot 8, optional tag
	Write_conflict_ranges_disabled    []byte        // slot 9, optional value
}

func ParseCommitTransactionRefVectorFromReader

func ParseCommitTransactionRefVectorFromReader(r *wire.Reader, slot int) []CommitTransactionRef

ParseCommitTransactionRefVectorFromReader reads a FlatBuffers vector of CommitTransactionRef.

func (*CommitTransactionRef) UnmarshalFDB

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

func (*CommitTransactionRef) UnmarshalFromReader

func (m *CommitTransactionRef) UnmarshalFromReader(r *wire.Reader)

type CommitTransactionRequest

type CommitTransactionRequest struct {
	Transaction             CommitTransactionRef // slot 0, nested
	Reply                   ReplyPromise         // slot 1, nested
	Flags                   uint32               // slot 2
	HasDebugID              bool                 // slot 3, optional tag
	DebugID                 [16]byte             // slot 4, optional scalar value
	HasCommitCostEstimation bool                 // slot 5, optional tag
	CommitCostEstimation    []byte               // slot 6, optional value
	HasTagSet               bool                 // slot 7, optional tag
	TagSet                  []byte               // slot 8, optional value
	SpanContext             SpanContext          // slot 9, nested
	TenantInfo              TenantInfo           // slot 10, nested
	IdempotencyId           []byte               // slot 11
	Arena                   []byte               // slot 12
}

func ParseCommitTransactionRequestVectorFromReader

func ParseCommitTransactionRequestVectorFromReader(r *wire.Reader, slot int) []CommitTransactionRequest

ParseCommitTransactionRequestVectorFromReader reads a FlatBuffers vector of CommitTransactionRequest.

func (*CommitTransactionRequest) MarshalFDB

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

func (*CommitTransactionRequest) MarshalFDBPooled

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

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

func (*CommitTransactionRequest) UnmarshalFDB

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

func (*CommitTransactionRequest) UnmarshalFromReader

func (m *CommitTransactionRequest) UnmarshalFromReader(r *wire.Reader)

type Endpoint

type Endpoint struct {
	Addresses NetworkAddressList // slot 0, nested
	Token     [16]byte           // slot 1
}

func ParseEndpointVectorFromReader

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

ParseEndpointVectorFromReader reads a FlatBuffers vector of Endpoint.

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)

type Error

type Error struct {
	ErrorCode uint16 // slot 0
}

func ParseErrorVectorFromReader

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

ParseErrorVectorFromReader reads a FlatBuffers vector of Error.

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)

type ErrorOrError

type ErrorOrError struct {
	ErrorCode uint16
}

func (*ErrorOrError) MarshalFDB

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

MarshalFDB serializes ErrorOrError using two-pass PrecomputeSize/WriteToBuffer. Union root: footer points directly to ErrorOr object (no FakeRoot).

type GetKeyReply

type GetKeyReply struct {
	Penalty  float64 // slot 0
	HasError bool    // slot 1, optional tag
	Error    Error   // slot 2, optional nested value
	// Sel: unregistered nested struct at slot 3
	Cached bool // slot 4
}

func ParseGetKeyReplyVectorFromReader

func ParseGetKeyReplyVectorFromReader(r *wire.Reader, slot int) []GetKeyReply

ParseGetKeyReplyVectorFromReader reads a FlatBuffers vector of GetKeyReply.

func (*GetKeyReply) MarshalFDB

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

func (*GetKeyReply) MarshalFDBPooled

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

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

func (*GetKeyReply) UnmarshalFDB

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

func (*GetKeyReply) UnmarshalFromReader

func (m *GetKeyReply) UnmarshalFromReader(r *wire.Reader)

type GetKeyRequest

type GetKeyRequest struct {
	Sel                    KeySelectorRef // slot 0, nested
	Version                int64          // slot 1
	HasTags                bool           // slot 2, optional tag
	Tags                   []byte         // slot 3, optional value
	Reply                  ReplyPromise   // slot 4, nested
	SpanContext            SpanContext    // slot 5, nested
	TenantInfo             TenantInfo     // slot 6, nested
	HasOptions             bool           // slot 7, optional tag
	Options                ReadOptions    // slot 8, optional nested value
	SsLatestCommitVersions []byte         // slot 9
	Field_10               []byte         // slot 10
}

func ParseGetKeyRequestVectorFromReader

func ParseGetKeyRequestVectorFromReader(r *wire.Reader, slot int) []GetKeyRequest

ParseGetKeyRequestVectorFromReader reads a FlatBuffers vector of GetKeyRequest.

func (*GetKeyRequest) MarshalFDB

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

func (*GetKeyRequest) MarshalFDBPooled

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

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

func (*GetKeyRequest) UnmarshalFDB

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

func (*GetKeyRequest) UnmarshalFromReader

func (m *GetKeyRequest) UnmarshalFromReader(r *wire.Reader)

type GetKeyServerLocationsReply

type GetKeyServerLocationsReply struct {
	Results           []byte // slot 0
	ResultsTssMapping []byte // slot 1
	ResultsTagMapping []byte // slot 2
	Arena             []byte // slot 3
}

func ParseGetKeyServerLocationsReplyVectorFromReader

func ParseGetKeyServerLocationsReplyVectorFromReader(r *wire.Reader, slot int) []GetKeyServerLocationsReply

ParseGetKeyServerLocationsReplyVectorFromReader reads a FlatBuffers vector of GetKeyServerLocationsReply.

func (*GetKeyServerLocationsReply) MarshalFDB

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

func (*GetKeyServerLocationsReply) MarshalFDBPooled

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

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

func (*GetKeyServerLocationsReply) UnmarshalFDB

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

func (*GetKeyServerLocationsReply) UnmarshalFromReader

func (m *GetKeyServerLocationsReply) UnmarshalFromReader(r *wire.Reader)

type GetKeyServerLocationsRequest

type GetKeyServerLocationsRequest struct {
	Begin            []byte       // slot 0
	HasEnd           bool         // slot 1, optional tag
	End              []byte       // slot 2, optional value
	Limit            int32        // slot 3
	Reverse          bool         // slot 4
	Reply            ReplyPromise // slot 5, nested
	SpanContext      SpanContext  // slot 6, nested
	Tenant           TenantInfo   // slot 7, nested
	MinTenantVersion int64        // slot 8
	Arena            []byte       // slot 9
}

func ParseGetKeyServerLocationsRequestVectorFromReader

func ParseGetKeyServerLocationsRequestVectorFromReader(r *wire.Reader, slot int) []GetKeyServerLocationsRequest

ParseGetKeyServerLocationsRequestVectorFromReader reads a FlatBuffers vector of GetKeyServerLocationsRequest.

func (*GetKeyServerLocationsRequest) MarshalFDB

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

func (*GetKeyServerLocationsRequest) MarshalFDBPooled

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

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

func (*GetKeyServerLocationsRequest) UnmarshalFDB

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

func (*GetKeyServerLocationsRequest) UnmarshalFromReader

func (m *GetKeyServerLocationsRequest) UnmarshalFromReader(r *wire.Reader)

type GetKeyValuesReply

type GetKeyValuesReply struct {
	Penalty  float64 // slot 0
	HasError bool    // slot 1, optional tag
	Error    Error   // slot 2, optional nested value
	Data     []byte  // slot 3
	Version  int64   // slot 4
	More     bool    // slot 5
	Cached   bool    // slot 6
	Arena    []byte  // slot 7
}

func ParseGetKeyValuesReplyVectorFromReader

func ParseGetKeyValuesReplyVectorFromReader(r *wire.Reader, slot int) []GetKeyValuesReply

ParseGetKeyValuesReplyVectorFromReader reads a FlatBuffers vector of GetKeyValuesReply.

func (*GetKeyValuesReply) MarshalFDB

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

func (*GetKeyValuesReply) MarshalFDBPooled

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

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

func (*GetKeyValuesReply) UnmarshalFDB

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

func (*GetKeyValuesReply) UnmarshalFromReader

func (m *GetKeyValuesReply) UnmarshalFromReader(r *wire.Reader)

type GetKeyValuesRequest

type GetKeyValuesRequest struct {
	Begin                  KeySelectorRef // slot 0, nested
	End                    KeySelectorRef // slot 1, nested
	Version                int64          // slot 2
	Limit                  int32          // slot 3
	LimitBytes             int32          // slot 4
	HasTags                bool           // slot 5, optional tag
	Tags                   []byte         // slot 6, optional value
	Reply                  ReplyPromise   // slot 7, nested
	SpanContext            SpanContext    // slot 8, nested
	TenantInfo             TenantInfo     // slot 9, nested
	HasOptions             bool           // slot 10, optional tag
	Options                ReadOptions    // slot 11, optional nested value
	SsLatestCommitVersions []byte         // slot 12
	Arena                  []byte         // slot 13
}

func ParseGetKeyValuesRequestVectorFromReader

func ParseGetKeyValuesRequestVectorFromReader(r *wire.Reader, slot int) []GetKeyValuesRequest

ParseGetKeyValuesRequestVectorFromReader reads a FlatBuffers vector of GetKeyValuesRequest.

func (*GetKeyValuesRequest) MarshalFDB

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

func (*GetKeyValuesRequest) MarshalFDBPooled

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

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

func (*GetKeyValuesRequest) UnmarshalFDB

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

func (*GetKeyValuesRequest) UnmarshalFromReader

func (m *GetKeyValuesRequest) UnmarshalFromReader(r *wire.Reader)

type GetReadVersionReply

type GetReadVersionReply struct {
	ProcessBusyTime           int32    // slot 0
	Version                   int64    // slot 1
	Locked                    bool     // slot 2
	HasMetadataVersion        bool     // slot 3, optional tag
	MetadataVersion           []byte   // slot 4, optional value
	TagThrottleInfo           []byte   // slot 5
	MidShardSize              int64    // slot 6
	RkDefaultThrottled        bool     // slot 7
	RkBatchThrottled          bool     // slot 8
	SsVersionVectorDelta      []byte   // slot 9
	ProxyId                   [16]byte // slot 10
	ProxyTagThrottledDuration float64  // slot 11
}

func ParseGetReadVersionReplyVectorFromReader

func ParseGetReadVersionReplyVectorFromReader(r *wire.Reader, slot int) []GetReadVersionReply

ParseGetReadVersionReplyVectorFromReader reads a FlatBuffers vector of GetReadVersionReply.

func (*GetReadVersionReply) MarshalFDB

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

func (*GetReadVersionReply) MarshalFDBPooled

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

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

func (*GetReadVersionReply) UnmarshalFDB

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

func (*GetReadVersionReply) UnmarshalFromReader

func (m *GetReadVersionReply) UnmarshalFromReader(r *wire.Reader)

type GetReadVersionRequest

type GetReadVersionRequest struct {
	TransactionCount uint32       // slot 0
	Flags            uint32       // slot 1
	Tags             []byte       // slot 2
	HasDebugID       bool         // slot 3, optional tag
	DebugID          [16]byte     // slot 4, optional scalar value
	Reply            ReplyPromise // slot 5, nested
	SpanContext      SpanContext  // slot 6, nested
	MaxVersion       int64        // slot 7
}

func ParseGetReadVersionRequestVectorFromReader

func ParseGetReadVersionRequestVectorFromReader(r *wire.Reader, slot int) []GetReadVersionRequest

ParseGetReadVersionRequestVectorFromReader reads a FlatBuffers vector of GetReadVersionRequest.

func (*GetReadVersionRequest) MarshalFDB

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

func (*GetReadVersionRequest) MarshalFDBPooled

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

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

func (*GetReadVersionRequest) UnmarshalFDB

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

func (*GetReadVersionRequest) UnmarshalFromReader

func (m *GetReadVersionRequest) UnmarshalFromReader(r *wire.Reader)

type GetValueReply

type GetValueReply struct {
	Penalty  float64 // slot 0
	HasError bool    // slot 1, optional tag
	Error    Error   // slot 2, optional nested value
	HasValue bool    // slot 3, optional tag
	Value    []byte  // slot 4, optional value
	Cached   bool    // slot 5
}

func ParseGetValueReplyVectorFromReader

func ParseGetValueReplyVectorFromReader(r *wire.Reader, slot int) []GetValueReply

ParseGetValueReplyVectorFromReader reads a FlatBuffers vector of GetValueReply.

func (*GetValueReply) MarshalFDB

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

func (*GetValueReply) MarshalFDBPooled

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

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

func (*GetValueReply) UnmarshalFDB

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

func (*GetValueReply) UnmarshalFromReader

func (m *GetValueReply) UnmarshalFromReader(r *wire.Reader)

type GetValueRequest

type GetValueRequest struct {
	Key                    []byte       // slot 0
	Version                int64        // slot 1
	HasTags                bool         // slot 2, optional tag
	Tags                   []byte       // slot 3, optional value
	Reply                  ReplyPromise // slot 4, nested
	SpanContext            SpanContext  // slot 5, nested
	TenantInfo             TenantInfo   // slot 6, nested
	HasOptions             bool         // slot 7, optional tag
	Options                ReadOptions  // slot 8, optional nested value
	SsLatestCommitVersions []byte       // slot 9
}

func ParseGetValueRequestVectorFromReader

func ParseGetValueRequestVectorFromReader(r *wire.Reader, slot int) []GetValueRequest

ParseGetValueRequestVectorFromReader reads a FlatBuffers vector of GetValueRequest.

func (*GetValueRequest) MarshalFDB

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

func (*GetValueRequest) MarshalFDBPooled

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

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

func (*GetValueRequest) UnmarshalFDB

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

func (*GetValueRequest) UnmarshalFromReader

func (m *GetValueRequest) UnmarshalFromReader(r *wire.Reader)

type GrvProxyInterface

type GrvProxyInterface struct {
	HasProcessId bool   // slot 0, optional tag
	ProcessId    []byte // slot 1, optional value
	Provisional  bool   // slot 2

}

func ParseGrvProxyInterfaceVectorFromReader

func ParseGrvProxyInterfaceVectorFromReader(r *wire.Reader, slot int) []GrvProxyInterface

ParseGrvProxyInterfaceVectorFromReader reads a FlatBuffers vector of GrvProxyInterface.

func (*GrvProxyInterface) UnmarshalFDB

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

func (*GrvProxyInterface) UnmarshalFromReader

func (m *GrvProxyInterface) UnmarshalFromReader(r *wire.Reader)

type IPAddress

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

func ParseIPAddressVectorFromReader

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

ParseIPAddressVectorFromReader reads a FlatBuffers vector of IPAddress.

func (*IPAddress) UnmarshalFDB

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

func (*IPAddress) UnmarshalFromReader

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

type KeyRangeRef

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

func ParseKeyRangeRefStringVector

func ParseKeyRangeRefStringVector(data []byte) []KeyRangeRef

ParseKeyRangeRefStringVector decodes a VectorRef<KeyRangeRef, VecSerStrategy::String>. Each element's DynamicSize fields are inline: [len(4)][data] per field.

func ParseKeyRangeRefVectorFromReader

func ParseKeyRangeRefVectorFromReader(r *wire.Reader, slot int) []KeyRangeRef

ParseKeyRangeRefVectorFromReader reads a FlatBuffers vector of KeyRangeRef.

func (*KeyRangeRef) UnmarshalFDB

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

UnmarshalFDB constructs a Reader and delegates.

func (*KeyRangeRef) UnmarshalFromReader

func (m *KeyRangeRef) UnmarshalFromReader(r *wire.Reader)

UnmarshalFromReader replaces the generated reader to invert the single-key serialize optimization. Slot 1 (End) being empty signals "first slot carries End; reconstruct Begin = End[:-1]".

Matches C++ KeyRangeRef::serialize deserialization branch.

type KeySelectorRef

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

ParseKeySelectorRefVectorFromReader reads a FlatBuffers vector of KeySelectorRef.

func (*KeySelectorRef) UnmarshalFDB

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

func (*KeySelectorRef) UnmarshalFromReader

func (m *KeySelectorRef) UnmarshalFromReader(r *wire.Reader)

type KeyValueRef

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

func ParseKeyValueRefStringVector

func ParseKeyValueRefStringVector(data []byte) []KeyValueRef

ParseKeyValueRefStringVector decodes a VectorRef<KeyValueRef, VecSerStrategy::String>. Each element's DynamicSize fields are inline: [len(4)][data] per field.

func ParseKeyValueRefVectorFromReader

func ParseKeyValueRefVectorFromReader(r *wire.Reader, slot int) []KeyValueRef

ParseKeyValueRefVectorFromReader reads a FlatBuffers vector of KeyValueRef.

func (*KeyValueRef) UnmarshalFDB

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

func (*KeyValueRef) UnmarshalFromReader

func (m *KeyValueRef) UnmarshalFromReader(r *wire.Reader)

type LocationPair

type LocationPair struct {
	KeyRange KeyRangeRef // slot 0, nested
	Servers  []byte      // slot 1
}

func ParseLocationPairVectorFromReader

func ParseLocationPairVectorFromReader(r *wire.Reader, slot int) []LocationPair

ParseLocationPairVectorFromReader reads a FlatBuffers vector of LocationPair.

func (*LocationPair) UnmarshalFDB

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

func (*LocationPair) UnmarshalFromReader

func (m *LocationPair) UnmarshalFromReader(r *wire.Reader)

type MutationRef

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

ParseMutationRefVectorFromReader reads a FlatBuffers vector of MutationRef.

func (*MutationRef) UnmarshalFDB

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

func (*MutationRef) UnmarshalFromReader

func (m *MutationRef) UnmarshalFromReader(r *wire.Reader)

type NetworkAddress

type NetworkAddress struct {
	Ip           IPAddress // slot 0, nested
	Port         uint16    // slot 1
	Flags        uint16    // slot 2
	FromHostname bool      // slot 3
}

func ParseNetworkAddressVectorFromReader

func ParseNetworkAddressVectorFromReader(r *wire.Reader, slot int) []NetworkAddress

ParseNetworkAddressVectorFromReader reads a FlatBuffers vector of NetworkAddress.

func (*NetworkAddress) MarshalFDB

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

func (*NetworkAddress) MarshalFDBPooled

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

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

func (*NetworkAddress) UnmarshalFDB

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

func (*NetworkAddress) UnmarshalFromReader

func (m *NetworkAddress) UnmarshalFromReader(r *wire.Reader)

type NetworkAddressList

type NetworkAddressList struct {
	Address             NetworkAddress // slot 0, nested
	HasSecondaryAddress bool           // slot 1, optional tag
	SecondaryAddress    []byte         // slot 2, optional value
}

func ParseNetworkAddressListVectorFromReader

func ParseNetworkAddressListVectorFromReader(r *wire.Reader, slot int) []NetworkAddressList

ParseNetworkAddressListVectorFromReader reads a FlatBuffers vector of NetworkAddressList.

func (*NetworkAddressList) UnmarshalFDB

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

func (*NetworkAddressList) UnmarshalFromReader

func (m *NetworkAddressList) UnmarshalFromReader(r *wire.Reader)

type OpenDatabaseCoordRequest

type OpenDatabaseCoordRequest struct {
	Issues            []byte       // slot 0
	SupportedVersions []byte       // slot 1
	TraceLogGroup     []byte       // slot 2
	KnownClientInfoID [16]byte     // slot 3
	ClusterKey        []byte       // slot 4
	Coordinators      []byte       // slot 5
	Reply             ReplyPromise // slot 6, nested
	Hostnames         []byte       // slot 7
	Internal          bool         // slot 8
}

func ParseOpenDatabaseCoordRequestVectorFromReader

func ParseOpenDatabaseCoordRequestVectorFromReader(r *wire.Reader, slot int) []OpenDatabaseCoordRequest

ParseOpenDatabaseCoordRequestVectorFromReader reads a FlatBuffers vector of OpenDatabaseCoordRequest.

func (*OpenDatabaseCoordRequest) MarshalFDB

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

func (*OpenDatabaseCoordRequest) MarshalFDBPooled

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

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

func (*OpenDatabaseCoordRequest) UnmarshalFDB

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

func (*OpenDatabaseCoordRequest) UnmarshalFromReader

func (m *OpenDatabaseCoordRequest) UnmarshalFromReader(r *wire.Reader)

type ReadOptions

type ReadOptions struct {
	Type                            int32    // slot 0
	CacheResult                     bool     // slot 1
	HasDebugID                      bool     // slot 2, optional tag
	DebugID                         [16]byte // slot 3, optional scalar value
	HasConsistencyCheckStartVersion bool     // slot 4, optional tag
	ConsistencyCheckStartVersion    int64    // slot 5, optional scalar value
	LockAware                       bool     // slot 6
}

func ParseReadOptionsVectorFromReader

func ParseReadOptionsVectorFromReader(r *wire.Reader, slot int) []ReadOptions

ParseReadOptionsVectorFromReader reads a FlatBuffers vector of ReadOptions.

func (*ReadOptions) UnmarshalFDB

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

func (*ReadOptions) UnmarshalFromReader

func (m *ReadOptions) UnmarshalFromReader(r *wire.Reader)

type ReplyPromise

type ReplyPromise struct {
	Token [16]byte // slot 0
}

func ParseReplyPromiseVectorFromReader

func ParseReplyPromiseVectorFromReader(r *wire.Reader, slot int) []ReplyPromise

ParseReplyPromiseVectorFromReader reads a FlatBuffers vector of ReplyPromise.

func (*ReplyPromise) MarshalFDB

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

func (*ReplyPromise) MarshalFDBPooled

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

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

func (*ReplyPromise) UnmarshalFDB

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

func (*ReplyPromise) UnmarshalFromReader

func (m *ReplyPromise) UnmarshalFromReader(r *wire.Reader)

type SpanContext

type SpanContext struct {
	TraceID [16]byte // slot 0
	SpanID  uint64   // slot 1
	Flags   uint8    // slot 2
}

func ParseSpanContextVectorFromReader

func ParseSpanContextVectorFromReader(r *wire.Reader, slot int) []SpanContext

ParseSpanContextVectorFromReader reads a FlatBuffers vector of SpanContext.

func (*SpanContext) UnmarshalFDB

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

func (*SpanContext) UnmarshalFromReader

func (m *SpanContext) UnmarshalFromReader(r *wire.Reader)

type SplitRangeReply

type SplitRangeReply struct {
	SplitPoints []byte // slot 0
}

func ParseSplitRangeReplyVectorFromReader

func ParseSplitRangeReplyVectorFromReader(r *wire.Reader, slot int) []SplitRangeReply

ParseSplitRangeReplyVectorFromReader reads a FlatBuffers vector of SplitRangeReply.

func (*SplitRangeReply) MarshalFDB

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

func (*SplitRangeReply) MarshalFDBPooled

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

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

func (*SplitRangeReply) UnmarshalFDB

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

func (*SplitRangeReply) UnmarshalFromReader

func (m *SplitRangeReply) UnmarshalFromReader(r *wire.Reader)

type SplitRangeRequest

type SplitRangeRequest struct {
	Keys       KeyRangeRef  // slot 0, nested
	ChunkSize  int64        // slot 1
	Reply      ReplyPromise // slot 2, nested
	TenantInfo TenantInfo   // slot 3, nested
	Field_4    []byte       // slot 4
}

func ParseSplitRangeRequestVectorFromReader

func ParseSplitRangeRequestVectorFromReader(r *wire.Reader, slot int) []SplitRangeRequest

ParseSplitRangeRequestVectorFromReader reads a FlatBuffers vector of SplitRangeRequest.

func (*SplitRangeRequest) MarshalFDB

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

func (*SplitRangeRequest) MarshalFDBPooled

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

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

func (*SplitRangeRequest) UnmarshalFDB

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

func (*SplitRangeRequest) UnmarshalFromReader

func (m *SplitRangeRequest) UnmarshalFromReader(r *wire.Reader)

type StorageMetrics

type StorageMetrics struct {
	Bytes                  int64 // slot 0
	BytesWrittenPerKSecond int64 // slot 1
	IosPerKSecond          int64 // slot 2
	BytesReadPerKSecond    int64 // slot 3
	OpsReadPerKSecond      int64 // slot 4
}

func ParseStorageMetricsVectorFromReader

func ParseStorageMetricsVectorFromReader(r *wire.Reader, slot int) []StorageMetrics

ParseStorageMetricsVectorFromReader reads a FlatBuffers vector of StorageMetrics.

func (*StorageMetrics) MarshalFDB

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

func (*StorageMetrics) MarshalFDBPooled

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

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

func (*StorageMetrics) UnmarshalFDB

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

func (*StorageMetrics) UnmarshalFromReader

func (m *StorageMetrics) UnmarshalFromReader(r *wire.Reader)

type StorageServerInterface

type StorageServerInterface struct {
	WatchValue [16]byte // slot 0
	// Field_1: unregistered nested struct at slot 1
	// Field_2: unregistered nested struct at slot 2
	HasField_3 bool     // slot 3, optional tag
	Field_3    [16]byte // slot 4, optional scalar value
	Field_5    bool     // slot 5
}

func ParseStorageServerInterfaceVectorFromReader

func ParseStorageServerInterfaceVectorFromReader(r *wire.Reader, slot int) []StorageServerInterface

ParseStorageServerInterfaceVectorFromReader reads a FlatBuffers vector of StorageServerInterface.

func (*StorageServerInterface) UnmarshalFDB

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

func (*StorageServerInterface) UnmarshalFromReader

func (m *StorageServerInterface) UnmarshalFromReader(r *wire.Reader)

type TenantInfo

type TenantInfo struct {
	TenantId int64  // slot 0
	HasToken bool   // slot 1, optional tag
	Token    []byte // slot 2, optional value
	Arena    []byte // slot 3
}

func ParseTenantInfoVectorFromReader

func ParseTenantInfoVectorFromReader(r *wire.Reader, slot int) []TenantInfo

ParseTenantInfoVectorFromReader reads a FlatBuffers vector of TenantInfo.

func (*TenantInfo) UnmarshalFDB

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

func (*TenantInfo) UnmarshalFromReader

func (m *TenantInfo) UnmarshalFromReader(r *wire.Reader)

type TenantMapEntry

type TenantMapEntry struct {
	Id                       int64    // slot 0
	TenantName               []byte   // slot 1
	TenantLockState          uint8    // slot 2
	HasTenantLockId          bool     // slot 3, optional tag
	TenantLockId             [16]byte // slot 4, optional scalar value
	HasTenantGroup           bool     // slot 5, optional tag
	TenantGroup              []byte   // slot 6, optional value
	ConfigurationSequenceNum int64    // slot 7
}

func ParseTenantMapEntryVectorFromReader

func ParseTenantMapEntryVectorFromReader(r *wire.Reader, slot int) []TenantMapEntry

ParseTenantMapEntryVectorFromReader reads a FlatBuffers vector of TenantMapEntry.

func (*TenantMapEntry) MarshalFDB

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

func (*TenantMapEntry) MarshalFDBPooled

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

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

func (*TenantMapEntry) UnmarshalFDB

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

func (*TenantMapEntry) UnmarshalFromReader

func (m *TenantMapEntry) UnmarshalFromReader(r *wire.Reader)

type VoidReply

type VoidReply struct{}

func (*VoidReply) MarshalFDB

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

ParseWaitMetricsRequestVectorFromReader reads a FlatBuffers vector of WaitMetricsRequest.

func (*WaitMetricsRequest) MarshalFDB

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

func (*WaitMetricsRequest) MarshalFDBPooled

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

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

func (*WaitMetricsRequest) UnmarshalFDB

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

func (*WaitMetricsRequest) UnmarshalFromReader

func (m *WaitMetricsRequest) UnmarshalFromReader(r *wire.Reader)

type WatchValueReply

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

func ParseWatchValueReplyVectorFromReader

func ParseWatchValueReplyVectorFromReader(r *wire.Reader, slot int) []WatchValueReply

ParseWatchValueReplyVectorFromReader reads a FlatBuffers vector of WatchValueReply.

func (*WatchValueReply) MarshalFDB

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

func (*WatchValueReply) MarshalFDBPooled

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

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

func (*WatchValueReply) UnmarshalFDB

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

func (*WatchValueReply) UnmarshalFromReader

func (m *WatchValueReply) UnmarshalFromReader(r *wire.Reader)

type WatchValueRequest

type WatchValueRequest struct {
	Key         []byte       // slot 0
	HasValue    bool         // slot 1, optional tag
	Value       []byte       // slot 2, optional value
	Version     int64        // slot 3
	HasTags     bool         // slot 4, optional tag
	Tags        []byte       // slot 5, optional value
	HasDebugID  bool         // slot 6, optional tag
	DebugID     [16]byte     // slot 7, optional scalar value
	Reply       ReplyPromise // slot 8, nested
	SpanContext SpanContext  // slot 9, nested
	TenantInfo  TenantInfo   // slot 10, nested
}

func ParseWatchValueRequestVectorFromReader

func ParseWatchValueRequestVectorFromReader(r *wire.Reader, slot int) []WatchValueRequest

ParseWatchValueRequestVectorFromReader reads a FlatBuffers vector of WatchValueRequest.

func (*WatchValueRequest) MarshalFDB

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

func (*WatchValueRequest) MarshalFDBPooled

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

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

func (*WatchValueRequest) UnmarshalFDB

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

func (*WatchValueRequest) UnmarshalFromReader

func (m *WatchValueRequest) UnmarshalFromReader(r *wire.Reader)

Jump to

Keyboard shortcuts

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