task

Documentation

Overview

Package task Date: 2023/7/19 15:30 Author: Amu Description:

Package task Date: 2023/7/19 15:30 Author: Amu Description:

Package task Date: 2023/7/19 15:45 Author: Amu Description:

Package task Date: 2023/4/4 16:51 Author: Amu Description:

Index

• Constants
• func AddMonth(addTime time.Time, duration int) time.Time
• func NewManager(ctx context.Context, m *Manager)
• type AtomicStatus
  • func (a *AtomicStatus) IsRefresh() bool
  • func (a *AtomicStatus) IsRun() bool
  • func (a *AtomicStatus) IsStart() bool
  • func (a *AtomicStatus) IsStop() bool
  • func (a *AtomicStatus) RefreshToRun() bool
  • func (a *AtomicStatus) SetRefreshStatus()
  • func (a *AtomicStatus) SetRunStatus()
  • func (a *AtomicStatus) SetStopStatus()
  • func (a *AtomicStatus) ToClose() bool
  • func (a *AtomicStatus) ToStart() bool
• type HandlerStruct
• type Manager
  • func (m *Manager) Cancel(taskName string)
  • func (m *Manager) IsRun() bool
  • func (m *Manager) Register(task *Task) error
  • func (m *Manager) Run()
  • func (m *Manager) Stop()
• type Plan
  • func NewPlan(duration int64, startTime *time.Time, durationType uint8) *Plan
  • func (p *Plan) GetFirstDuration() time.Duration
• type Task
  • func NewTask(name string, handler HandlerStruct, plan *Plan, handlerCtx context.Context) *Task

Constants

const (
	DurationMS uint8 = iota + 1
	DurationMonth
	DurationYear
)

Functions

func AddMonth

func AddMonth(addTime time.Time, duration int) time.Time

func NewManager

func NewManager(ctx context.Context, m *Manager)

Types

type AtomicStatus

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

AtomicStatus atmoic status struct

func (*AtomicStatus) IsRefresh

func (a *AtomicStatus) IsRefresh() bool

IsRefresh judge if status is refreshStatus

func (*AtomicStatus) IsRun

func (a *AtomicStatus) IsRun() bool

IsRun judge if status is runStatus

func (*AtomicStatus) IsStart

func (a *AtomicStatus) IsStart() bool

func (*AtomicStatus) IsStop

func (a *AtomicStatus) IsStop() bool

func (*AtomicStatus) RefreshToRun

func (a *AtomicStatus) RefreshToRun() bool

RefreshToRun change status to runStatus from refreshStatus

func (*AtomicStatus) SetRefreshStatus

func (a *AtomicStatus) SetRefreshStatus()

SetRefreshStatus set status to refreshStatus

func (*AtomicStatus) SetRunStatus

func (a *AtomicStatus) SetRunStatus()

SetRunStatus set status to runStatus

func (*AtomicStatus) SetStopStatus

func (a *AtomicStatus) SetStopStatus()

SetStopStatus set status to stopStatus

func (*AtomicStatus) ToClose

func (a *AtomicStatus) ToClose() bool

ToClose change status to stopStatus from runStatus

func (*AtomicStatus) ToStart

func (a *AtomicStatus) ToStart() bool

ToStart change status to startStatus

type HandlerStruct

type HandlerStruct func(ctx context.Context)

type Manager

type Manager struct {
	Ctx context.Context
	// contains filtered or unexported fields
}

func (*Manager) Cancel

func (m *Manager) Cancel(taskName string)

func (*Manager) IsRun

func (m *Manager) IsRun() bool

func (*Manager) Register

func (m *Manager) Register(task *Task) error

func (*Manager) Run

func (m *Manager) Run()

func (*Manager) Stop

func (m *Manager) Stop()

type Plan

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

func NewPlan

func NewPlan(duration int64, startTime *time.Time, durationType uint8) *Plan

func (*Plan) GetFirstDuration

func (p *Plan) GetFirstDuration() time.Duration

type Task

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

func NewTask

func NewTask(name string, handler HandlerStruct, plan *Plan, handlerCtx context.Context) *Task