schedule

type Config struct {
	Action             string `json:"action"`
	Schedule           string `json:"schedule"`
	Key                string `json:"key"`
	MaxParallel        int    `json:"max_parallel"`
	Require            string `json:"require,omitempty"`
	RequireCollector   bool   `json:"require_collector"`
	RequireProvisioned bool   `json:"require_provisioned"`
	RunDir             string `json:"-"`

	// RequireReplicationSource schedules the action on the node the
	// data is replicated from only.
	RequireReplicationSource bool `json:"require_replication_source,omitempty"`

	// StatefileKey is used in the last run filename and last run success formatters.
	// Defaults to Action if empty.
	StatefileKey string `json:"-"`

	// On are the events running the action, each one an event kind
	// and the values of the fields of the event it requires:
	// "NetworkPeersUpdated,name=backend1".
	On []string `json:"on,omitempty"`

	// Pace paces the runs the events ask for: "@30s" runs at
	// most once each 30s, "@30s backoff @1m" stretches the interval
	// up to 1m while the events keep coming.
	Pace string `json:"pace,omitempty"`
}

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

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

type Dataer interface {
	Table
}

type Entry struct {
	Config
	LastRunAt time.Time   `json:"last_run_at"`
	NextRunAt time.Time   `json:"next_run_at"`
	Node      string      `json:"node"`
	Path      naming.Path `json:"path"`
}

type OnFilter struct {
	Kind   string
	Fields map[string]string
}

type OnPace struct {
	Interval time.Duration
	Max      time.Duration
}

type Table []Entry