task

package

v0.0.1 Latest Latest Go to latest Published: Aug 28, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrTaskAlreadyExists = errors.New("task already exists")
	ErrTaskNotFound      = errors.New("task not found")
)

This section is empty.

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

func NewGroup(tasks ...Task) *Group

func (g *Group) Identifier() string

func (g *Group) IsStarted() bool

func (g *Group) IsStopped() bool

func (g *Group) Start(ctx context.Context) error

func (g *Group) Stop(ctx context.Context) error

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

func NewManager() *Manager

func (m *Manager) GetRunningTasks() []string

func (m *Manager) GetTaskCount() int

func (m *Manager) IsRunning(name string) bool

func (m *Manager) StartTask(ctx context.Context, name string, task Task) error

func (m *Manager) StopAll(ctx context.Context) error

func (m *Manager) StopTask(ctx context.Context, name string) error

func (m *Manager) Wait() error

type Task interface {
	Identifier() string
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
}

Path	Synopsis
testtask