dh

Documentation

Index

• func NewReplicationEncoder([]cluster.Slave)
• type DataHandler
• type EcEncoder
  • func NewEcEncoder(dataNum int, parityNum int) (EcEncoder, error)
  • func (ec *EcEncoder) AssignData(data []byte, slaveAddrList []cluster.Slave) (map[string][]byte, error)
• type ReplicationEncoder
  • func (r *ReplicationEncoder) AssignData(data []byte, slaveAddrList []string) (map[string][]byte, error)

Functions

func NewReplicationEncoder

func NewReplicationEncoder([]cluster.Slave)

Types

type DataHandler

type DataHandler interface {
	//AssignData assign data to slave list, return a map with single slave address as key and data as value
	AssignData(data []byte, slaveAddrList []string) (map[string][]byte, error)
}

type EcEncoder

type EcEncoder struct {
	reedsolomon.Encoder
}

func NewEcEncoder

func NewEcEncoder(dataNum int, parityNum int) (EcEncoder, error)

func (*EcEncoder) AssignData

func (ec *EcEncoder) AssignData(data []byte, slaveAddrList []cluster.Slave) (map[string][]byte, error)

type ReplicationEncoder

type ReplicationEncoder struct {
}

func (*ReplicationEncoder) AssignData

func (r *ReplicationEncoder) AssignData(data []byte, slaveAddrList []string) (map[string][]byte, error)