sharding

Documentation

Index

• Variables
• func ReadTransact(shardingKey []byte, tx func(tr fdb.ReadTransaction) (interface{}, error)) (interface{}, error)
• func Transact(shardingKey []byte, tx func(tr fdb.Transaction) (interface{}, error)) (interface{}, error)
• type FDBWorker
  • func NewFDBWorker(clusterFileIndex uint64, concurrencyLimit int) *FDBWorker
  • func (w *FDBWorker) ShardReadTransact(tx func(tr fdb.ReadTransaction) (interface{}, error)) (interface{}, error)
  • func (w *FDBWorker) ShardTransact(tx func(tr fdb.Transaction) (interface{}, error)) (interface{}, error)

Variables

var FDBPartitionsPool []*FDBWorker = make([]*FDBWorker, 256)

Functions

func ReadTransact

func ReadTransact(shardingKey []byte, tx func(tr fdb.ReadTransaction) (interface{}, error)) (interface{}, error)

func Transact

func Transact(shardingKey []byte, tx func(tr fdb.Transaction) (interface{}, error)) (interface{}, error)

Types

type FDBWorker

type FDBWorker struct {
	Concurrency int
	// contains filtered or unexported fields
}

func NewFDBWorker

func NewFDBWorker(clusterFileIndex uint64, concurrencyLimit int) *FDBWorker

func (*FDBWorker) ShardReadTransact

func (w *FDBWorker) ShardReadTransact(tx func(tr fdb.ReadTransaction) (interface{}, error)) (interface{}, error)

func (*FDBWorker) ShardTransact

func (w *FDBWorker) ShardTransact(tx func(tr fdb.Transaction) (interface{}, error)) (interface{}, error)