task

Documentation

Index

• type ByLastActivity
  • func (n ByLastActivity) Len() int
  • func (n ByLastActivity) Less(i, j int) bool
  • func (n ByLastActivity) Swap(i, j int)
• type ByName
  • func (n ByName) Len() int
  • func (n ByName) Less(i, j int) bool
  • func (n ByName) Swap(i, j int)
• type Config
• type Info
• type State
  • func GetState(state string) State
  • func (s State) MarshalJSON() ([]byte, error)
  • func (s State) String() string
  • func (s *State) UnmarshalJSON(b []byte) error
• type Task
  • func (t *Task) Config() any
  • func (t *Task) Context() context.Context
  • func (t *Task) FS() *fs.FileSystem
  • func (t *Task) Feed() feed.Feed
  • func (t *Task) ID() uuid.UUID
  • func (t *Task) L(ctx context.Context) *zap.Logger
  • func (t *Task) Name() string
  • func (t *Task) Queue() *queue.Queue
  • func (t *Task) Svcs() lifecycle.ServiceLifecycle
  • func (t *Task) Tracer() trace.Tracer
• type TaskFactory
  • func NewFactory(svcs lifecycle.ServiceLifecycle, queue *queue.Queue, fs *fs.FileSystem, ...) TaskFactory
• type Tasker

Types

type ByLastActivity

type ByLastActivity []Info

func (ByLastActivity) Len

func (n ByLastActivity) Len() int

func (ByLastActivity) Less

func (n ByLastActivity) Less(i, j int) bool

func (ByLastActivity) Swap

func (n ByLastActivity) Swap(i, j int)

type ByName

type ByName []Info

func (ByName) Len

func (n ByName) Len() int

func (ByName) Less

func (n ByName) Less(i, j int) bool

func (ByName) Swap

func (n ByName) Swap(i, j int)

type Config

type Config struct {
	Period time.Duration
	Other  any
}

type Info

type Info struct {
	ID           uuid.UUID     `json:"id"`
	Name         string        `json:"name"`
	State        State         `json:"state"`
	LastActivity time.Time     `json:"lastActivity,omitempty"`
	StartedAt    *time.Time    `json:"startedAt,omitempty"`
	EndedAt      *time.Time    `json:"endedAt,omitempty"`
	NextActivity *time.Time    `json:"nextActivity,omitempty"`
	Period       time.Duration `json:"period"`
}

type State

type State int

const (
	State_Undefined State = 1 << iota
	State_Enable
	State_Disable
	State_Passive
	State_Active
)

func GetState

func GetState(state string) State

func (State) MarshalJSON

func (s State) MarshalJSON() ([]byte, error)

func (State) String

func (s State) String() string

func (*State) UnmarshalJSON

func (s *State) UnmarshalJSON(b []byte) error

type Task

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

func (*Task) Config

func (t *Task) Config() any

func (*Task) Context

func (t *Task) Context() context.Context

func (*Task) FS

func (t *Task) FS() *fs.FileSystem

func (*Task) Feed

func (t *Task) Feed() feed.Feed

func (*Task) ID

func (t *Task) ID() uuid.UUID

func (*Task) L

func (t *Task) L(ctx context.Context) *zap.Logger

func (*Task) Name

func (t *Task) Name() string

func (*Task) Queue

func (t *Task) Queue() *queue.Queue

func (*Task) Svcs

func (t *Task) Svcs() lifecycle.ServiceLifecycle

func (*Task) Tracer

func (t *Task) Tracer() trace.Tracer

type TaskFactory

type TaskFactory interface {
	Create(name string, config any) *Task
}

func NewFactory

func NewFactory(
	svcs lifecycle.ServiceLifecycle,
	queue *queue.Queue,
	fs *fs.FileSystem,
	feed feed.Feed,
) TaskFactory

type Tasker

type Tasker interface {
	Config() any
	Svcs() lifecycle.ServiceLifecycle
	Queue() *queue.Queue
	FS() *fs.FileSystem
	Feed() feed.Feed
	ID() uuid.UUID
	Name() string
	Run(ctx context.Context) error
	L(ctx context.Context) *zap.Logger
}