ops

Documentation

Index

• Constants
• func NewHeartBeater(interval time.Duration, handle base.IHBHandle) *heartbeater
• func NewHeartBeaterWithFunc(interval time.Duration, onExec, onStop func()) *heartbeater
• type Cmd
• type OpExecFunc
• type OpWorker
  • func NewOpWorker(ctx context.Context, 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 Stats
  • func (s *Stats) AddFailed()
  • func (s *Stats) AddProcessed()
  • func (s *Stats) AddSuccessed()
  • func (s *Stats) RecordTime(t int64)
  • func (s *Stats) String() string

Constants

const (
	CREATED int32 = iota
	RUNNING
	StoppingReceiver
	StoppingCMD
	STOPPED
)

const (
	QueueSize = 10000
)

Functions

func NewHeartBeater

func NewHeartBeater(interval time.Duration, handle base.IHBHandle) *heartbeater

func NewHeartBeaterWithFunc

func NewHeartBeaterWithFunc(interval time.Duration, onExec, onStop func()) *heartbeater

Types

type Cmd

type Cmd = uint8

const (
	QUIT Cmd = iota
)

type OpExecFunc

type OpExecFunc func(op iops.IOp)

type OpWorker

type OpWorker struct {
	Ctx        context.Context
	Name       string
	OpC        chan iops.IOp
	CmdC       chan Cmd
	State      atomic.Int32
	Pending    atomic.Int64
	ClosedCh   chan struct{}
	Stats      Stats
	ExecFunc   OpExecFunc
	CancelFunc OpExecFunc
}

func NewOpWorker

func NewOpWorker(ctx context.Context, name string, args ...int) *OpWorker

func (*OpWorker) SendOp

func (w *OpWorker) SendOp(op iops.IOp) bool

func (*OpWorker) Start

func (w *OpWorker) Start()

func (*OpWorker) StatsString

func (w *OpWorker) StatsString() string

func (*OpWorker) Stop

func (w *OpWorker) Stop()

func (*OpWorker) StopReceiver

func (w *OpWorker) StopReceiver()

func (*OpWorker) WaitStop

func (w *OpWorker) WaitStop()

type Stats

type Stats struct {
	Processed atomic.Uint64
	Successed atomic.Uint64
	Failed    atomic.Uint64
	AvgTime   atomic.Int64
}

func (*Stats) AddFailed

func (s *Stats) AddFailed()

func (*Stats) AddProcessed

func (s *Stats) AddProcessed()

func (*Stats) AddSuccessed

func (s *Stats) AddSuccessed()

func (*Stats) RecordTime

func (s *Stats) RecordTime(t int64)

func (*Stats) String

func (s *Stats) String() string