Versions in this module Expand all Collapse all v0 v0.4.0 May 5, 2022 Changes in this version + const QUEUE_SIZE + func NewHeartBeater(interval time.Duration, handle base.IHBHandle) base.IHeartbeater + type Cmd = uint8 + const QUIT + type OpExecFunc func(op iops.IOp) + type OpWorker struct + ClosedCh chan struct{} + CmdC chan Cmd + ExecFunc OpExecFunc + Name string + OpC chan iops.IOp + Pending int64 + State State + Stats Stats + func NewOpWorker(name string, args ...int) *OpWorker + func (w *OpWorker) SendOp(op iops.IOp) bool + func (w *OpWorker) Start() + func (w *OpWorker) StatsString() string + func (w *OpWorker) Stop() + func (w *OpWorker) StopReceiver() + func (w *OpWorker) WaitStop() + type State = int32 + const CREATED + const RUNNING + const STOPPED + const STOPPING_CMD + const STOPPING_RECEIVER + type Stats struct + AvgTime int64 + Failed uint64 + Processed uint64 + Successed uint64 + func (s *Stats) AddFailed() + func (s *Stats) AddProcessed() + func (s *Stats) AddSuccessed() + func (s *Stats) RecordTime(t int64) + func (s *Stats) String() string
Go to main page