workerstatus

Documentation

Index

• type WorkerStatus
  • func NewWorkerStatus(initial WorkerStatusValue) *WorkerStatus
  • func (self *WorkerStatus) Reset()
  • func (self *WorkerStatus) Set(value WorkerStatusValue)
  • func (self *WorkerStatus) Sum(in []*WorkerStatusRO)
  • func (self *WorkerStatus) UpdateSelf(other *WorkerStatusRO)
• type WorkerStatusRO
  • func (self *WorkerStatusRO) Get() WorkerStatusValue
  • func (self *WorkerStatusRO) IsStopped() bool
  • func (self *WorkerStatusRO) Stopped() bool
  • func (self *WorkerStatusRO) StringT() string
  • func (self *WorkerStatusRO) StringTitle() string
  • func (self *WorkerStatusRO) UpdateOther(other *WorkerStatus)
• type WorkerStatusValue
  • func (self WorkerStatusValue) String() string

Types

type WorkerStatus

type WorkerStatus struct {
	WorkerStatusRO
}

func NewWorkerStatus

func NewWorkerStatus(initial WorkerStatusValue) *WorkerStatus

func (*WorkerStatus) Reset

func (self *WorkerStatus) Reset()

func (*WorkerStatus) Set

func (self *WorkerStatus) Set(value WorkerStatusValue)

func (*WorkerStatus) Sum

func (self *WorkerStatus) Sum(in []*WorkerStatusRO)

func (*WorkerStatus) UpdateSelf

func (self *WorkerStatus) UpdateSelf(other *WorkerStatusRO)

type WorkerStatusRO

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

func (*WorkerStatusRO) Get

func (self *WorkerStatusRO) Get() WorkerStatusValue

func (*WorkerStatusRO) IsStopped

func (self *WorkerStatusRO) IsStopped() bool

func (*WorkerStatusRO) Stopped

func (self *WorkerStatusRO) Stopped() bool

func (*WorkerStatusRO) StringT

func (self *WorkerStatusRO) StringT() string

func (*WorkerStatusRO) StringTitle

func (self *WorkerStatusRO) StringTitle() string

func (*WorkerStatusRO) UpdateOther

func (self *WorkerStatusRO) UpdateOther(other *WorkerStatus)

type WorkerStatusValue

type WorkerStatusValue uint

const (
	Stopped WorkerStatusValue = iota
	Starting
	Working
	Stopping
)

func (WorkerStatusValue) String

func (self WorkerStatusValue) String() string