Documentation ¶
Index ¶
- func BlobFAddAtime(b *flatbuffers.Builder, n int64)
- func BlobFAddAtimesec(builder *flatbuffers.Builder, atimesec uint32)
- func BlobFAddDeleted(b *flatbuffers.Builder, n int64)
- func BlobFAddDeletedsec(builder *flatbuffers.Builder, deletedsec uint32)
- func BlobFAddExpires(b *flatbuffers.Builder, n int64)
- func BlobFAddExpiressec(builder *flatbuffers.Builder, expiressec uint32)
- func BlobFAddMtime(b *flatbuffers.Builder, n int64)
- func BlobFAddMtimesec(builder *flatbuffers.Builder, mtimesec uint32)
- func BlobFAddPackedMeta(builder *flatbuffers.Builder, packedMeta uint32)
- func BlobFAddTracts(builder *flatbuffers.Builder, tracts flatbuffers.UOffsetT)
- func BlobFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func BlobFStart(builder *flatbuffers.Builder)
- func BlobFStartTractsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func BuildBlob(b *Blob) []byte
- func BuildPartition(p *Partition) []byte
- func BuildRSChunk(c *RSChunk) []byte
- func CloneBuffer(obj flatbuffers.FlatBuffer) []byte
- func CreateRSC_TractF(builder *flatbuffers.Builder, id_b1 uint16, id_b2 uint16, id_b3 uint16, ...) flatbuffers.UOffsetT
- func CreateRSC_TractFWithID(bu *flatbuffers.Builder, t core.TractID, length uint32, offset uint32) flatbuffers.UOffsetT
- func CreateTractIDF(builder *flatbuffers.Builder, b1 uint16, b2 uint16, b3 uint16, b4 uint16, ...) flatbuffers.UOffsetT
- func HostsContains(hl HostsLister, host core.TractserverID) bool
- func HostsList(l HostsLister) []core.TractserverID
- func PackMeta(storage core.StorageClass, hint core.StorageHint, repl int) uint32
- func PartitionFAddNextBlobKey(builder *flatbuffers.Builder, nextBlobKey uint32)
- func PartitionFAddNextRsChunkKey(builder *flatbuffers.Builder, nextRsChunkKey uint64)
- func PartitionFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func PartitionFStart(builder *flatbuffers.Builder)
- func PutRSChunkID(bu *flatbuffers.Builder, c core.RSChunkID) flatbuffers.UOffsetT
- func PutTractID(bu *flatbuffers.Builder, t core.TractID) flatbuffers.UOffsetT
- func RSC_DataFAddTracts(builder *flatbuffers.Builder, tracts flatbuffers.UOffsetT)
- func RSC_DataFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func RSC_DataFStart(builder *flatbuffers.Builder)
- func RSC_DataFStartTractsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func RSChunkFAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
- func RSChunkFAddHosts(builder *flatbuffers.Builder, hosts flatbuffers.UOffsetT)
- func RSChunkFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func RSChunkFStart(builder *flatbuffers.Builder)
- func RSChunkFStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func RSChunkFStartHostsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TractFAddHosts012(builder *flatbuffers.Builder, hosts012 uint64)
- func TractFAddHosts3p(builder *flatbuffers.Builder, hosts3p flatbuffers.UOffsetT)
- func TractFAddRs103Chunk(builder *flatbuffers.Builder, rs103Chunk flatbuffers.UOffsetT)
- func TractFAddRs125Chunk(builder *flatbuffers.Builder, rs125Chunk flatbuffers.UOffsetT)
- func TractFAddRs63Chunk(builder *flatbuffers.Builder, rs63Chunk flatbuffers.UOffsetT)
- func TractFAddRs83Chunk(builder *flatbuffers.Builder, rs83Chunk flatbuffers.UOffsetT)
- func TractFAddVersion(builder *flatbuffers.Builder, version uint32)
- func TractFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TractFSetupHosts(bu *flatbuffers.Builder, hosts []core.TractserverID) (hosts012 uint64, hosts3p flatbuffers.UOffsetT)
- func TractFStart(builder *flatbuffers.Builder)
- func TractFStartHosts3pVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- type Blob
- type BlobF
- func (b *BlobF) Atime() int64
- func (rcv *BlobF) Atimesec() uint32
- func (b *BlobF) Deleted() int64
- func (rcv *BlobF) Deletedsec() uint32
- func (b *BlobF) Expires() int64
- func (rcv *BlobF) Expiressec() uint32
- func (b *BlobF) Hint() core.StorageHint
- func (rcv *BlobF) Init(buf []byte, i flatbuffers.UOffsetT)
- func (b *BlobF) Mtime() int64
- func (rcv *BlobF) Mtimesec() uint32
- func (b *BlobF) MutateAtime(n int64) bool
- func (rcv *BlobF) MutateAtimesec(n uint32) bool
- func (b *BlobF) MutateDeleted(n int64) bool
- func (rcv *BlobF) MutateDeletedsec(n uint32) bool
- func (b *BlobF) MutateExpires(n int64) bool
- func (rcv *BlobF) MutateExpiressec(n uint32) bool
- func (b *BlobF) MutateMtime(n int64) bool
- func (rcv *BlobF) MutateMtimesec(n uint32) bool
- func (rcv *BlobF) MutatePackedMeta(n uint32) bool
- func (rcv *BlobF) PackedMeta() uint32
- func (b *BlobF) Repl() int
- func (b *BlobF) Storage() core.StorageClass
- func (rcv *BlobF) Table() flatbuffers.Table
- func (b *BlobF) ToStruct() (o *Blob)
- func (rcv *BlobF) Tracts(obj *TractF, j int) bool
- func (rcv *BlobF) TractsLength() int
- type HostsLister
- type Partition
- type PartitionF
- func (rcv *PartitionF) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *PartitionF) MutateNextBlobKey(n uint32) bool
- func (rcv *PartitionF) MutateNextRsChunkKey(n uint64) bool
- func (rcv *PartitionF) NextBlobKey() uint32
- func (rcv *PartitionF) NextRsChunkKey() uint64
- func (rcv *PartitionF) Table() flatbuffers.Table
- func (p *PartitionF) ToStruct() (o *Partition)
- type RSC_Data
- type RSC_DataF
- type RSC_Tract
- type RSC_TractF
- func (rcv *RSC_TractF) Id(obj *TractIDF) *TractIDF
- func (rcv *RSC_TractF) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *RSC_TractF) Length() uint32
- func (rcv *RSC_TractF) MutateLength(n uint32) bool
- func (rcv *RSC_TractF) MutateOffset(n uint32) bool
- func (rcv *RSC_TractF) Offset() uint32
- func (rcv *RSC_TractF) Table() flatbuffers.Table
- func (t *RSC_TractF) ToStruct() (o *RSC_Tract)
- func (t *RSC_TractF) TractID() core.TractID
- type RSChunk
- type RSChunkF
- func (rcv *RSChunkF) Data(obj *RSC_DataF, j int) bool
- func (rcv *RSChunkF) DataLength() int
- func (rcv *RSChunkF) Hosts(j int) uint32
- func (rcv *RSChunkF) HostsLength() int
- func (rcv *RSChunkF) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *RSChunkF) MutateHosts(j int, n uint32) bool
- func (rcv *RSChunkF) Table() flatbuffers.Table
- func (r *RSChunkF) ToStruct() (o *RSChunk)
- type Tract
- type TractF
- func (t *TractF) Hosts(j int) uint32
- func (rcv *TractF) Hosts012() uint64
- func (rcv *TractF) Hosts3p(j int) uint32
- func (rcv *TractF) Hosts3pLength() int
- func (t *TractF) HostsLength() (count int)
- func (rcv *TractF) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *TractF) MutateHosts012(n uint64) bool
- func (rcv *TractF) MutateHosts3p(j int, n uint32) bool
- func (t *TractF) MutateHostsFromSlice(hosts []core.TractserverID) (ok bool)
- func (rcv *TractF) MutateVersion(n uint32) bool
- func (rcv *TractF) Rs103Chunk(obj *TractIDF) *TractIDF
- func (rcv *TractF) Rs125Chunk(obj *TractIDF) *TractIDF
- func (rcv *TractF) Rs63Chunk(obj *TractIDF) *TractIDF
- func (rcv *TractF) Rs83Chunk(obj *TractIDF) *TractIDF
- func (rcv *TractF) Table() flatbuffers.Table
- func (t *TractF) ToStruct() (o *Tract)
- func (rcv *TractF) Version() uint32
- type TractIDF
- func (rcv *TractIDF) B1() uint16
- func (rcv *TractIDF) B2() uint16
- func (rcv *TractIDF) B3() uint16
- func (rcv *TractIDF) B4() uint16
- func (rcv *TractIDF) B5() uint16
- func (rcv *TractIDF) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *TractIDF) MutateB1(n uint16) bool
- func (rcv *TractIDF) MutateB2(n uint16) bool
- func (rcv *TractIDF) MutateB3(n uint16) bool
- func (rcv *TractIDF) MutateB4(n uint16) bool
- func (rcv *TractIDF) MutateB5(n uint16) bool
- func (t *TractIDF) RSChunkID() core.RSChunkID
- func (rcv *TractIDF) Table() flatbuffers.Table
- func (t *TractIDF) TractID() core.TractID
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BlobFAddAtime ¶
func BlobFAddAtime(b *flatbuffers.Builder, n int64)
func BlobFAddAtimesec ¶
func BlobFAddAtimesec(builder *flatbuffers.Builder, atimesec uint32)
func BlobFAddDeleted ¶
func BlobFAddDeleted(b *flatbuffers.Builder, n int64)
func BlobFAddDeletedsec ¶
func BlobFAddDeletedsec(builder *flatbuffers.Builder, deletedsec uint32)
func BlobFAddExpires ¶
func BlobFAddExpires(b *flatbuffers.Builder, n int64)
func BlobFAddExpiressec ¶
func BlobFAddExpiressec(builder *flatbuffers.Builder, expiressec uint32)
func BlobFAddMtime ¶
func BlobFAddMtime(b *flatbuffers.Builder, n int64)
func BlobFAddMtimesec ¶
func BlobFAddMtimesec(builder *flatbuffers.Builder, mtimesec uint32)
func BlobFAddPackedMeta ¶
func BlobFAddPackedMeta(builder *flatbuffers.Builder, packedMeta uint32)
func BlobFAddTracts ¶
func BlobFAddTracts(builder *flatbuffers.Builder, tracts flatbuffers.UOffsetT)
func BlobFEnd ¶
func BlobFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func BlobFStart ¶
func BlobFStart(builder *flatbuffers.Builder)
func BlobFStartTractsVector ¶
func BlobFStartTractsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func BuildPartition ¶
BuildPartition encodes a Partition from a struct.
func BuildRSChunk ¶
BuildRSChunk encodes an RSChunk from a struct.
func CloneBuffer ¶
func CloneBuffer(obj flatbuffers.FlatBuffer) []byte
CloneBuffer copies the entire buffer backing the given FlatBuffer and points it to the new buffer. You have to use this before calling any of the Mutate methods if the FlatBuffer points into BoltDB-managed memory. Even though this copies data, it doesn't have to parse it.
func CreateRSC_TractF ¶
func CreateRSC_TractFWithID ¶
func CreateRSC_TractFWithID(bu *flatbuffers.Builder, t core.TractID, length uint32, offset uint32) flatbuffers.UOffsetT
func CreateTractIDF ¶
func CreateTractIDF(builder *flatbuffers.Builder, b1 uint16, b2 uint16, b3 uint16, b4 uint16, b5 uint16) flatbuffers.UOffsetT
func HostsContains ¶
func HostsContains(hl HostsLister, host core.TractserverID) bool
HostsContains returns true if this list contains the given host.
func HostsList ¶
func HostsList(l HostsLister) []core.TractserverID
HostsList returns the list of hosts as a slice.
func PackMeta ¶
func PackMeta(storage core.StorageClass, hint core.StorageHint, repl int) uint32
func PartitionFAddNextBlobKey ¶
func PartitionFAddNextBlobKey(builder *flatbuffers.Builder, nextBlobKey uint32)
func PartitionFAddNextRsChunkKey ¶
func PartitionFAddNextRsChunkKey(builder *flatbuffers.Builder, nextRsChunkKey uint64)
func PartitionFEnd ¶
func PartitionFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func PartitionFStart ¶
func PartitionFStart(builder *flatbuffers.Builder)
func PutRSChunkID ¶
func PutRSChunkID(bu *flatbuffers.Builder, c core.RSChunkID) flatbuffers.UOffsetT
func PutTractID ¶
func PutTractID(bu *flatbuffers.Builder, t core.TractID) flatbuffers.UOffsetT
func RSC_DataFAddTracts ¶
func RSC_DataFAddTracts(builder *flatbuffers.Builder, tracts flatbuffers.UOffsetT)
func RSC_DataFEnd ¶
func RSC_DataFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func RSC_DataFStart ¶
func RSC_DataFStart(builder *flatbuffers.Builder)
func RSC_DataFStartTractsVector ¶
func RSC_DataFStartTractsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func RSChunkFAddData ¶
func RSChunkFAddData(builder *flatbuffers.Builder, data flatbuffers.UOffsetT)
func RSChunkFAddHosts ¶
func RSChunkFAddHosts(builder *flatbuffers.Builder, hosts flatbuffers.UOffsetT)
func RSChunkFEnd ¶
func RSChunkFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func RSChunkFStart ¶
func RSChunkFStart(builder *flatbuffers.Builder)
func RSChunkFStartDataVector ¶
func RSChunkFStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func RSChunkFStartHostsVector ¶
func RSChunkFStartHostsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TractFAddHosts012 ¶
func TractFAddHosts012(builder *flatbuffers.Builder, hosts012 uint64)
func TractFAddHosts3p ¶
func TractFAddHosts3p(builder *flatbuffers.Builder, hosts3p flatbuffers.UOffsetT)
func TractFAddRs103Chunk ¶
func TractFAddRs103Chunk(builder *flatbuffers.Builder, rs103Chunk flatbuffers.UOffsetT)
func TractFAddRs125Chunk ¶
func TractFAddRs125Chunk(builder *flatbuffers.Builder, rs125Chunk flatbuffers.UOffsetT)
func TractFAddRs63Chunk ¶
func TractFAddRs63Chunk(builder *flatbuffers.Builder, rs63Chunk flatbuffers.UOffsetT)
func TractFAddRs83Chunk ¶
func TractFAddRs83Chunk(builder *flatbuffers.Builder, rs83Chunk flatbuffers.UOffsetT)
func TractFAddVersion ¶
func TractFAddVersion(builder *flatbuffers.Builder, version uint32)
func TractFEnd ¶
func TractFEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TractFSetupHosts ¶
func TractFSetupHosts(bu *flatbuffers.Builder, hosts []core.TractserverID) (hosts012 uint64, hosts3p flatbuffers.UOffsetT)
TractFSetupHosts returns values that should be passed to TractFAddHosts012 and TractFAddHosts3p to encode the given host list. Note that zero is an invalid TractserverID and will not be handled correctly.
func TractFStart ¶
func TractFStart(builder *flatbuffers.Builder)
func TractFStartHosts3pVector ¶
func TractFStartHosts3pVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
Types ¶
type Blob ¶
type Blob struct { Storage core.StorageClass // Storage class for this blob (applies to all tracts). Hint core.StorageHint // Client storage hint. Tracts []*Tract Repl int // Replication factor (for REPLICATED). // Times are in unix nanos. Deleted int64 // Time that this blob was deleted, or zero if it is not deleted. Mtime int64 // Time of last open for write. Atime int64 // Time of last open for read. Expires int64 // Time that this blob can be automatically deleted, or zero if it is permanent. }
Blob is the struct version of BlobF.
type BlobF ¶
type BlobF struct {
// contains filtered or unexported fields
}
func GetRootAsBlobF ¶
func GetRootAsBlobF(buf []byte, offset flatbuffers.UOffsetT) *BlobF
func (*BlobF) Deletedsec ¶
func (*BlobF) Expiressec ¶
func (*BlobF) Hint ¶
func (b *BlobF) Hint() core.StorageHint
func (*BlobF) MutateAtime ¶
func (*BlobF) MutateAtimesec ¶
func (*BlobF) MutateDeleted ¶
func (*BlobF) MutateDeletedsec ¶
func (*BlobF) MutateExpires ¶
func (*BlobF) MutateExpiressec ¶
func (*BlobF) MutateMtime ¶
func (*BlobF) MutateMtimesec ¶
func (*BlobF) MutatePackedMeta ¶
func (*BlobF) PackedMeta ¶
func (*BlobF) Storage ¶
func (b *BlobF) Storage() core.StorageClass
func (*BlobF) Table ¶
func (rcv *BlobF) Table() flatbuffers.Table
func (*BlobF) TractsLength ¶
type HostsLister ¶
HostLister is a flatbuffer that contains a list of hosts, currently: TractF and RSChunkF.
type Partition ¶
type Partition struct { NextBlobKey core.BlobKey NextRsChunkKey uint64 // 48 bits of "blob key" and "tract index" in one value }
Partition is the struct version of PartitionF.
type PartitionF ¶
type PartitionF struct {
// contains filtered or unexported fields
}
func GetRootAsPartitionF ¶
func GetRootAsPartitionF(buf []byte, offset flatbuffers.UOffsetT) *PartitionF
func (*PartitionF) Init ¶
func (rcv *PartitionF) Init(buf []byte, i flatbuffers.UOffsetT)
func (*PartitionF) MutateNextBlobKey ¶
func (rcv *PartitionF) MutateNextBlobKey(n uint32) bool
func (*PartitionF) MutateNextRsChunkKey ¶
func (rcv *PartitionF) MutateNextRsChunkKey(n uint64) bool
func (*PartitionF) NextBlobKey ¶
func (rcv *PartitionF) NextBlobKey() uint32
func (*PartitionF) NextRsChunkKey ¶
func (rcv *PartitionF) NextRsChunkKey() uint64
func (*PartitionF) Table ¶
func (rcv *PartitionF) Table() flatbuffers.Table
func (*PartitionF) ToStruct ¶
func (p *PartitionF) ToStruct() (o *Partition)
ToStruct creates a Blob from a BlobF.
type RSC_Data ¶
type RSC_Data struct {
Tracts []*RSC_Tract // any number of values
}
RSC_Data is the struct version of RSC_DataF.
type RSC_DataF ¶
type RSC_DataF struct {
// contains filtered or unexported fields
}
func GetRootAsRSC_DataF ¶
func GetRootAsRSC_DataF(buf []byte, offset flatbuffers.UOffsetT) *RSC_DataF
func (*RSC_DataF) Table ¶
func (rcv *RSC_DataF) Table() flatbuffers.Table
func (*RSC_DataF) TractsLength ¶
type RSC_Tract ¶
type RSC_Tract struct { Id core.TractID // tract id Length uint32 // length of tract data Offset uint32 // offset within this piece }
RSC_Tract is the struct version of RSC_TractF.
type RSC_TractF ¶
type RSC_TractF struct {
// contains filtered or unexported fields
}
func (*RSC_TractF) Id ¶
func (rcv *RSC_TractF) Id(obj *TractIDF) *TractIDF
func (*RSC_TractF) Init ¶
func (rcv *RSC_TractF) Init(buf []byte, i flatbuffers.UOffsetT)
func (*RSC_TractF) Length ¶
func (rcv *RSC_TractF) Length() uint32
func (*RSC_TractF) MutateLength ¶
func (rcv *RSC_TractF) MutateLength(n uint32) bool
func (*RSC_TractF) MutateOffset ¶
func (rcv *RSC_TractF) MutateOffset(n uint32) bool
func (*RSC_TractF) Offset ¶
func (rcv *RSC_TractF) Offset() uint32
func (*RSC_TractF) Table ¶
func (rcv *RSC_TractF) Table() flatbuffers.Table
func (*RSC_TractF) ToStruct ¶
func (t *RSC_TractF) ToStruct() (o *RSC_Tract)
ToStruct creates a RSC_Tract from a RSC_TractF.
func (*RSC_TractF) TractID ¶
func (t *RSC_TractF) TractID() core.TractID
type RSChunk ¶
type RSChunk struct { Data []*RSC_Data // exactly N values Hosts []core.TractserverID // exactly N+M values }
RSChunk is the struct version of RSChunkF.
type RSChunkF ¶
type RSChunkF struct {
// contains filtered or unexported fields
}
func GetRootAsRSChunkF ¶
func GetRootAsRSChunkF(buf []byte, offset flatbuffers.UOffsetT) *RSChunkF
func (*RSChunkF) DataLength ¶
func (*RSChunkF) HostsLength ¶
func (*RSChunkF) Table ¶
func (rcv *RSChunkF) Table() flatbuffers.Table
type Tract ¶
type Tract struct { // Used for REPLICATED class. Hosts []core.TractserverID Version int // Used for RS_X classes. There must be exactly one of these for each RS_n_m // enum value in core.StorageClass. Rs63Chunk *core.TractID Rs83Chunk *core.TractID Rs103Chunk *core.TractID Rs125Chunk *core.TractID }
Tract is the struct version of TractF.
type TractF ¶
type TractF struct {
// contains filtered or unexported fields
}
func GetRootAsTractF ¶
func GetRootAsTractF(buf []byte, offset flatbuffers.UOffsetT) *TractF
func (*TractF) Hosts3pLength ¶
func (*TractF) HostsLength ¶
HostsLength makes Hosts in TractF look like a normal field.
func (*TractF) MutateHosts012 ¶
func (*TractF) MutateHostsFromSlice ¶
func (t *TractF) MutateHostsFromSlice(hosts []core.TractserverID) (ok bool)
MutateHostsFromSlice handles mutation of the hosts values split over two fields. It cannot change the length of hosts.
func (*TractF) MutateVersion ¶
func (*TractF) Rs103Chunk ¶
func (*TractF) Rs125Chunk ¶
func (*TractF) Table ¶
func (rcv *TractF) Table() flatbuffers.Table