lba

Documentation

Index

• Constants
• type LBA
  • func NewLBA(vdiskID string, blockCount, cacheLimitInBytes int64, ...) (lba *LBA, err error)
  • func (lba *LBA) Delete(blockIndex int64) (err error)
  • func (lba *LBA) Flush() (err error)
  • func (lba *LBA) Get(blockIndex int64) (h zerodisk.Hash, err error)
  • func (lba *LBA) Set(blockIndex int64, h zerodisk.Hash) (err error)
• type MetaRedisProvider

Constants

const (
	//NumberOfRecordsPerLBAShard is the fixed length of the LBAShards
	NumberOfRecordsPerLBAShard = 128
	// BytesPerShard defines how many bytes each shards requires
	BytesPerShard = NumberOfRecordsPerLBAShard * zerodisk.HashSize
)

Types

type LBA

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

LBA implements the functionality to lookup block keys through the logical block index. The data is persisted to an external metadataserver in shards of n keys, where n = NumberOfRecordsPerLBAShard.

func NewLBA

func NewLBA(vdiskID string, blockCount, cacheLimitInBytes int64, provider MetaRedisProvider) (lba *LBA, err error)

NewLBA creates a new LBA

func (*LBA) Delete

func (lba *LBA) Delete(blockIndex int64) (err error)

Delete the content hash for a specific block. When a key is updated, the shard containing this blockindex is marked as dirty and will be stored in the external metadaserver when Flush is called Deleting means actually that the nilhash will be set for this blockindex.

func (*LBA) Flush

func (lba *LBA) Flush() (err error)

Flush stores all dirty shards to the external metadaserver

func (*LBA) Get

func (lba *LBA) Get(blockIndex int64) (h zerodisk.Hash, err error)

Get returns the hash for a block, nil if no hash registered If the shard containing this blockindex is not present, it is fetched from the external metadaserver

func (*LBA) Set

func (lba *LBA) Set(blockIndex int64, h zerodisk.Hash) (err error)

Set the content hash for a specific block. When a key is updated, the shard containing this blockindex is marked as dirty and will be stored in the external metadataserver when Flush is called.

type MetaRedisProvider

type MetaRedisProvider interface {
	MetaRedisConnection() (redis.Conn, error)
}

MetaRedisProvider is used by the LBA, to retreive a Redis Meta Connection