Versions in this module Expand all Collapse all v0 v0.1.0 Jun 1, 2016 Changes in this version type Distributor + func (d *Distributor) WriteBuf(ctx context.Context, i torus.BlockRef) ([]byte, error) v0.0.1 Apr 27, 2016 Changes in this version + var ErrNoPeersBlock = errors.New("distributor: no peers available for a block") + func ListenReplication(s *agro.Server, addr string) error + func OpenReplication(s *agro.Server) error + type Distributor struct + func (d *Distributor) Block(ctx context.Context, req *models.BlockRequest) (*models.BlockResponse, error) + func (d *Distributor) BlockIterator() agro.BlockIterator + func (d *Distributor) BlockSize() uint64 + func (d *Distributor) Close() error + func (d *Distributor) DeleteBlock(ctx context.Context, i agro.BlockRef) error + func (d *Distributor) Flush() error + func (d *Distributor) GetBlock(ctx context.Context, i agro.BlockRef) ([]byte, error) + func (d *Distributor) HasBlock(ctx context.Context, i agro.BlockRef) (bool, error) + func (d *Distributor) Kind() string + func (d *Distributor) NumBlocks() uint64 + func (d *Distributor) PutBlock(ctx context.Context, req *models.PutBlockRequest) (*models.PutResponse, error) + func (d *Distributor) RebalanceCheck(ctx context.Context, req *models.RebalanceCheckRequest) (*models.RebalanceCheckResponse, error) + func (d *Distributor) Ring() agro.Ring + func (d *Distributor) UUID() string + func (d *Distributor) UsedBlocks() uint64 + func (d *Distributor) WriteBlock(ctx context.Context, i agro.BlockRef, data []byte) error