humantimetaskqueue2

package
v0.0.0-...-2ababa6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2019 License: Apache-2.0, Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

humantimetask를 관리 실행해주는 관리자.

humantimetask를 관리 실행해주는 관리자.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func TrueString

func TrueString(b bool, truestr, falsestr string) string

Types

type TaskQueue

type TaskQueue struct {
	Name string
	// contains filtered or unexported fields
}

func New

func New(name string, popDelay time.Duration, logger loggeri.LoggerI) *TaskQueue

func (*TaskQueue) FlushTaskTill

func (tq *TaskQueue) FlushTaskTill(till time.Time)

func (*TaskQueue) GetActStat

func (tq *TaskQueue) GetActStat() *actpersec.ActPerSec

func (TaskQueue) GetTaskStat

func (tq TaskQueue) GetTaskStat() *taskstat.TaskStat

func (TaskQueue) IsPaused

func (tq TaskQueue) IsPaused() bool

func (*TaskQueue) Len

func (tq *TaskQueue) Len() int

func (*TaskQueue) Pause

func (tq *TaskQueue) Pause()

func (*TaskQueue) Peek

func (tq *TaskQueue) Peek() *humantimetask.Task

func (*TaskQueue) Pop

func (tq *TaskQueue) Pop() *humantimetask.Task

func (*TaskQueue) Push

func (tq *TaskQueue) Push(t *humantimetask.Task)

func (*TaskQueue) Remove

func (tq *TaskQueue) Remove(t *humantimetask.Task) error

func (*TaskQueue) Resume

func (tq *TaskQueue) Resume()

func (*TaskQueue) Run

func (tq *TaskQueue) Run(ctx context.Context)

func (TaskQueue) String

func (tq TaskQueue) String() string

func (*TaskQueue) UpdateTaskArgAndTime

func (tq *TaskQueue) UpdateTaskArgAndTime(t *humantimetask.Task, uparg interface{}, uptime time.Time) error

func (*TaskQueue) UpdateTaskTime

func (tq *TaskQueue) UpdateTaskTime(t *humantimetask.Task, uptime time.Time) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL