jobCounter

Documentation

Index

• type Counter
  • func AllCounter() []*Counter
  • func New(name string) *Counter
  • func (this *Counter) Add(jobId string, state ...string)
  • func (this *Counter) ClientId() string
  • func (this *Counter) Done(jobId string)
  • func (this *Counter) Name() string
  • func (this *Counter) RunningJobs() (jobs []*Job)
  • func (this *Counter) SetState(jobId, state string)
  • func (this *Counter) Size() int
• type Job

Types

type Counter

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

func AllCounter

func AllCounter() []*Counter

func New

func New(name string) *Counter

func (*Counter) Add

func (this *Counter) Add(jobId string, state ...string)

func (*Counter) ClientId

func (this *Counter) ClientId() string

func (*Counter) Done

func (this *Counter) Done(jobId string)

func (*Counter) Name

func (this *Counter) Name() string

func (*Counter) RunningJobs

func (this *Counter) RunningJobs() (jobs []*Job)

func (*Counter) SetState

func (this *Counter) SetState(jobId, state string)

func (*Counter) Size

func (this *Counter) Size() int

type Job

type Job struct {
	JobId string    `json:"job_id,omitempty"`
	Time  time.Time `json:"time,omitempty"`
	State string    `json:"state,omitempty"`
}