distributor

package

v0.0.1 Latest Latest Go to latest Published: Apr 27, 2016 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrNoPeersBlock = errors.New("distributor: no peers available for a block")
)

func ListenReplication(s *agro.Server, addr string) error

ListenReplication opens the internal networking port and connects to the cluster

func OpenReplication(s *agro.Server) error

OpenReplication connects to the cluster without opening the internal networking.

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

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

Path	Synopsis
rebalance