task

package module

v0.0.0-...-32eaf10 Latest Latest Go to latest Published: May 10, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/amuluze/amutool

Links

Open Source Insights

Documentation ¶

Overview ¶

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
type HandlerStruct
type Manager
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 ¶

View Source

const (
	DurationMS uint8 = iota + 1
	DurationMonth
	DurationYear
)

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

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