fb

package
v0.0.0-...-fd5963e Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2019 License: MIT Imports: 2 Imported by: 0

Documentation

Index

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 BuildBlob 

func BuildBlob(b *Blob) []byte

BuildBlob encodes a Blob from a struct.

func BuildPartition 

func BuildPartition(p *Partition) []byte

BuildPartition encodes a Partition from a struct.

func BuildRSChunk 

func BuildRSChunk(c *RSChunk) []byte

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_TractF(builder *flatbuffers.Builder, id_b1 uint16, id_b2 uint16, id_b3 uint16, id_b4 uint16, id_b5 uint16, length uint32, offset uint32) flatbuffers.UOffsetT

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) Atime 

func (b *BlobF) Atime() int64

func (*BlobF) Atimesec 

func (rcv *BlobF) Atimesec() uint32

func (*BlobF) Deleted 

func (b *BlobF) Deleted() int64

func (*BlobF) Deletedsec 

func (rcv *BlobF) Deletedsec() uint32

func (*BlobF) Expires 

func (b *BlobF) Expires() int64

func (*BlobF) Expiressec 

func (rcv *BlobF) Expiressec() uint32

func (*BlobF) Hint 

func (b *BlobF) Hint() core.StorageHint

func (*BlobF) Init 

func (rcv *BlobF) Init(buf []byte, i flatbuffers.UOffsetT)

func (*BlobF) Mtime 

func (b *BlobF) Mtime() int64

func (*BlobF) Mtimesec 

func (rcv *BlobF) Mtimesec() uint32

func (*BlobF) MutateAtime 

func (b *BlobF) MutateAtime(n int64) bool

func (*BlobF) MutateAtimesec 

func (rcv *BlobF) MutateAtimesec(n uint32) bool

func (*BlobF) MutateDeleted 

func (b *BlobF) MutateDeleted(n int64) bool

func (*BlobF) MutateDeletedsec 

func (rcv *BlobF) MutateDeletedsec(n uint32) bool

func (*BlobF) MutateExpires 

func (b *BlobF) MutateExpires(n int64) bool

func (*BlobF) MutateExpiressec 

func (rcv *BlobF) MutateExpiressec(n uint32) bool

func (*BlobF) MutateMtime 

func (b *BlobF) MutateMtime(n int64) bool

func (*BlobF) MutateMtimesec 

func (rcv *BlobF) MutateMtimesec(n uint32) bool

func (*BlobF) MutatePackedMeta 

func (rcv *BlobF) MutatePackedMeta(n uint32) bool

func (*BlobF) PackedMeta 

func (rcv *BlobF) PackedMeta() uint32

func (*BlobF) Repl 

func (b *BlobF) Repl() int

func (*BlobF) Storage 

func (b *BlobF) Storage() core.StorageClass

func (*BlobF) Table 

func (rcv *BlobF) Table() flatbuffers.Table

func (*BlobF) ToStruct 

func (b *BlobF) ToStruct() (o *Blob)

ToStruct creates a Blob from a BlobF.

func (*BlobF) Tracts 

func (rcv *BlobF) Tracts(obj *TractF, j int) bool

func (*BlobF) TractsLength 

func (rcv *BlobF) TractsLength() int

type HostsLister 

type HostsLister interface {
	HostsLength() int
	Hosts(j int) uint32
}

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) Init 

func (rcv *RSC_DataF) Init(buf []byte, i flatbuffers.UOffsetT)

func (*RSC_DataF) Table 

func (rcv *RSC_DataF) Table() flatbuffers.Table

func (*RSC_DataF) ToStruct 

func (d *RSC_DataF) ToStruct() (o *RSC_Data)

ToStruct creates a RSC_Data from a RSC_DataF.

func (*RSC_DataF) Tracts 

func (rcv *RSC_DataF) Tracts(obj *RSC_TractF, j int) bool

func (*RSC_DataF) TractsLength 

func (rcv *RSC_DataF) TractsLength() int

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) Data 

func (rcv *RSChunkF) Data(obj *RSC_DataF, j int) bool

func (*RSChunkF) DataLength 

func (rcv *RSChunkF) DataLength() int

func (*RSChunkF) Hosts 

func (rcv *RSChunkF) Hosts(j int) uint32

func (*RSChunkF) HostsLength 

func (rcv *RSChunkF) HostsLength() int

func (*RSChunkF) Init 

func (rcv *RSChunkF) Init(buf []byte, i flatbuffers.UOffsetT)

func (*RSChunkF) MutateHosts 

func (rcv *RSChunkF) MutateHosts(j int, n uint32) bool

func (*RSChunkF) Table 

func (rcv *RSChunkF) Table() flatbuffers.Table

func (*RSChunkF) ToStruct 

func (r *RSChunkF) ToStruct() (o *RSChunk)

ToStruct creates a RSChunk from a RSChunkF.

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) Hosts 

func (t *TractF) Hosts(j int) uint32

Hosts makes Hosts in TractF look like a normal field.

func (*TractF) Hosts012 

func (rcv *TractF) Hosts012() uint64

func (*TractF) Hosts3p 

func (rcv *TractF) Hosts3p(j int) uint32

func (*TractF) Hosts3pLength 

func (rcv *TractF) Hosts3pLength() int

func (*TractF) HostsLength 

func (t *TractF) HostsLength() (count int)

HostsLength makes Hosts in TractF look like a normal field.

func (*TractF) Init 

func (rcv *TractF) Init(buf []byte, i flatbuffers.UOffsetT)

func (*TractF) MutateHosts012 

func (rcv *TractF) MutateHosts012(n uint64) bool

func (*TractF) MutateHosts3p 

func (rcv *TractF) MutateHosts3p(j int, n uint32) bool

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 (rcv *TractF) MutateVersion(n uint32) bool

func (*TractF) Rs103Chunk 

func (rcv *TractF) Rs103Chunk(obj *TractIDF) *TractIDF

func (*TractF) Rs125Chunk 

func (rcv *TractF) Rs125Chunk(obj *TractIDF) *TractIDF

func (*TractF) Rs63Chunk 

func (rcv *TractF) Rs63Chunk(obj *TractIDF) *TractIDF

func (*TractF) Rs83Chunk 

func (rcv *TractF) Rs83Chunk(obj *TractIDF) *TractIDF

func (*TractF) Table 

func (rcv *TractF) Table() flatbuffers.Table

func (*TractF) ToStruct 

func (t *TractF) ToStruct() (o *Tract)

ToStruct creates a Tract from a TractF.

func (*TractF) Version 

func (rcv *TractF) Version() uint32

type TractIDF 

type TractIDF struct {
	// contains filtered or unexported fields
}

func (*TractIDF) B1 

func (rcv *TractIDF) B1() uint16

func (*TractIDF) B2 

func (rcv *TractIDF) B2() uint16

func (*TractIDF) B3 

func (rcv *TractIDF) B3() uint16

func (*TractIDF) B4 

func (rcv *TractIDF) B4() uint16

func (*TractIDF) B5 

func (rcv *TractIDF) B5() uint16

func (*TractIDF) Init 

func (rcv *TractIDF) Init(buf []byte, i flatbuffers.UOffsetT)

func (*TractIDF) MutateB1 

func (rcv *TractIDF) MutateB1(n uint16) bool

func (*TractIDF) MutateB2 

func (rcv *TractIDF) MutateB2(n uint16) bool

func (*TractIDF) MutateB3 

func (rcv *TractIDF) MutateB3(n uint16) bool

func (*TractIDF) MutateB4 

func (rcv *TractIDF) MutateB4(n uint16) bool

func (*TractIDF) MutateB5 

func (rcv *TractIDF) MutateB5(n uint16) bool

func (*TractIDF) RSChunkID 

func (t *TractIDF) RSChunkID() core.RSChunkID

func (*TractIDF) Table 

func (rcv *TractIDF) Table() flatbuffers.Table

func (*TractIDF) TractID 

func (t *TractIDF) TractID() core.TractID

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.