schedule

Documentation

Index

• func InitData()
• type Data
  • func NewData[T Dataer]() *Data[T]
  • func (c *Data[T]) Get(p naming.Path) *T
  • func (c *Data[T]) GetAll() []DataElement[T]
  • func (c *Data[T]) GetPaths() naming.Paths
  • func (c *Data[T]) Set(p naming.Path, v *T)
  • func (c *Data[T]) Unset(p naming.Path)
• type DataElement
• type Dataer
• type Entry
  • func (t Entry) GetNext() (time.Time, time.Duration, error)
  • func (t Entry) RID() string
  • func (t Entry) SetLastRun(tm time.Time) error
  • func (t Entry) SetLastSuccess(tm time.Time) error
• type Table
  • func NewTable(entries ...Entry) Table
  • func (t Table) Add(i interface{}) Table
  • func (t Table) AddEntries(l ...Entry) Table
  • func (t Table) AddTable(l Table) Table
  • func (t Table) DelEntry(e Entry) Table
  • func (t Table) Merge(i interface{}) Table
  • func (t Table) MergeEntries(l ...Entry) Table
  • func (t Table) MergeEntry(e Entry) Table

Functions

func InitData

func InitData()

InitData reset package objects data, it can be used for tests.

Types

type Data

type Data[T Dataer] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Data defines a shared holder for all objects Dataer

var (
	// TableData is the package data holder for all objects schedule
	TableData *Data[Table]
)

func NewData

func NewData[T Dataer]() *Data[T]

func (*Data[T]) Get

func (c *Data[T]) Get(p naming.Path) *T

func (*Data[T]) GetAll

func (c *Data[T]) GetAll() []DataElement[T]

func (*Data[T]) GetPaths

func (c *Data[T]) GetPaths() naming.Paths

func (*Data[T]) Set

func (c *Data[T]) Set(p naming.Path, v *T)

func (*Data[T]) Unset

func (c *Data[T]) Unset(p naming.Path)

type DataElement

type DataElement[T Dataer] struct {
	Path  naming.Path
	Value *T
}

type Dataer

type Dataer interface {
	Table
}

type Entry

type Entry struct {
	Action             string      `json:"action"`
	Schedule           string      `json:"schedule"`
	Key                string      `json:"key"`
	LastRunAt          time.Time   `json:"last_run_at"`
	LastRunFile        string      `json:"last_run_file"`
	LastSuccessFile    string      `json:"last_success_file"`
	NextRunAt          time.Time   `json:"next_run_at"`
	Node               string      `json:"node"`
	Path               naming.Path `json:"path"`
	RequireCollector   bool        `json:"require_collector"`
	RequireProvisioned bool        `json:"require_provisioned"`
}

func (Entry) GetNext

func (t Entry) GetNext() (time.Time, time.Duration, error)

func (Entry) RID

func (t Entry) RID() string

func (Entry) SetLastRun

func (t Entry) SetLastRun(tm time.Time) error

func (Entry) SetLastSuccess

func (t Entry) SetLastSuccess(tm time.Time) error

type Table

type Table []Entry

func NewTable

func NewTable(entries ...Entry) Table

func (Table) Add

func (t Table) Add(i interface{}) Table

func (Table) AddEntries

func (t Table) AddEntries(l ...Entry) Table

func (Table) AddTable

func (t Table) AddTable(l Table) Table

func (Table) DelEntry

func (t Table) DelEntry(e Entry) Table

func (Table) Merge

func (t Table) Merge(i interface{}) Table

func (Table) MergeEntries

func (t Table) MergeEntries(l ...Entry) Table

func (Table) MergeEntry

func (t Table) MergeEntry(e Entry) Table