plotter

Documentation

Index

• type Agent
• type CpuAgent
  • func NewCpuAgent() *CpuAgent
  • func (self *CpuAgent) Cancel()
  • func (self *CpuAgent) SetReturnCh(ch chan<- *Result)
  • func (self *CpuAgent) Start()
  • func (self *CpuAgent) Stop()
  • func (self *CpuAgent) Work() chan<- *Work
• type Plotter
  • func New(addr common.Address, dir string) *Plotter
  • func (self *Plotter) ClearPlotData() error
  • func (self *Plotter) CommitWork(start uint64, quantity uint64) (tid string, err error)
  • func (self *Plotter) GetPlotDatalist() (list []string, err error)
  • func (self *Plotter) GetPlotdataDir() string
  • func (self *Plotter) GetSeed() common.Address
  • func (self *Plotter) GetTaskIds() []string
  • func (self *Plotter) GetTaskProgress(tid string) (rate int64, err error)
  • func (self *Plotter) HavePlotData(addr common.Address) error
  • func (self *Plotter) Ploting() bool
  • func (self *Plotter) Register(agent Agent)
  • func (self *Plotter) RemovePlotDataById(id string) (err error)
  • func (self *Plotter) SetPlotdataDir(dir string)
  • func (self *Plotter) SetSeed(addr common.Address)
  • func (self *Plotter) Start()
  • func (self *Plotter) Stop()
  • func (self *Plotter) Unregister(agent Agent)
• type ProgressResult
• type Result
• type Work

Types

type Agent

type Agent interface {
	Work() chan<- *Work
	SetReturnCh(chan<- *Result)
	Start()
	Stop()
}

type CpuAgent

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

func NewCpuAgent

func NewCpuAgent() *CpuAgent

func (*CpuAgent) Cancel

func (self *CpuAgent) Cancel()

Cancel the current task

func (*CpuAgent) SetReturnCh

func (self *CpuAgent) SetReturnCh(ch chan<- *Result)

func (*CpuAgent) Start

func (self *CpuAgent) Start()

func (*CpuAgent) Stop

func (self *CpuAgent) Stop()

func (*CpuAgent) Work

func (self *CpuAgent) Work() chan<- *Work

type Plotter

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

func New

func New(addr common.Address, dir string) *Plotter

func (*Plotter) ClearPlotData

func (self *Plotter) ClearPlotData() error

func (*Plotter) CommitWork

func (self *Plotter) CommitWork(start uint64, quantity uint64) (tid string, err error)

func (*Plotter) GetPlotDatalist

func (self *Plotter) GetPlotDatalist() (list []string, err error)

func (*Plotter) GetPlotdataDir

func (self *Plotter) GetPlotdataDir() string

func (*Plotter) GetSeed

func (self *Plotter) GetSeed() common.Address

func (*Plotter) GetTaskIds

func (self *Plotter) GetTaskIds() []string

func (*Plotter) GetTaskProgress

func (self *Plotter) GetTaskProgress(tid string) (rate int64, err error)

func (*Plotter) HavePlotData

func (self *Plotter) HavePlotData(addr common.Address) error

func (*Plotter) Ploting

func (self *Plotter) Ploting() bool

func (*Plotter) Register

func (self *Plotter) Register(agent Agent)

func (*Plotter) RemovePlotDataById

func (self *Plotter) RemovePlotDataById(id string) (err error)

func (*Plotter) SetPlotdataDir

func (self *Plotter) SetPlotdataDir(dir string)

func (*Plotter) SetSeed

func (self *Plotter) SetSeed(addr common.Address)

func (*Plotter) Start

func (self *Plotter) Start()

func (*Plotter) Stop

func (self *Plotter) Stop()

func (*Plotter) Unregister

func (self *Plotter) Unregister(agent Agent)

type ProgressResult

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

type Result

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

type Work

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