Documentation
¶
Index ¶
Constants ¶
View Source
const (
QUEUE_SIZE = 10000
)
Variables ¶
View Source
var ErrOpCancelled = errors.New("Op cancelled")
Functions ¶
func NewHeartBeater ¶
Types ¶
type OpExecFunc ¶
type OpWorker ¶
type OpWorker struct {
Name string
OpC chan iops.IOp
CmdC chan Cmd
State State
Pending int64
ClosedCh chan struct{}
Stats Stats
ExecFunc OpExecFunc
CancelFunc OpExecFunc
}
func NewOpWorker ¶
func (*OpWorker) StatsString ¶
func (*OpWorker) StopReceiver ¶
func (w *OpWorker) StopReceiver()
type Stats ¶
func (*Stats) AddProcessed ¶
func (s *Stats) AddProcessed()
func (*Stats) AddSuccessed ¶
func (s *Stats) AddSuccessed()
func (*Stats) RecordTime ¶
Click to show internal directories.
Click to hide internal directories.