Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Start ¶
func Start(ctx context.Context, config Config, eventSource *schemaeventsource.EventSource, client routing.CallClient, timelineClient *timelineclient.Client) error
Start the cron service. Blocks until the context is cancelled.
Types ¶
type Config ¶
type Config struct {
Bind *url.URL `help:"Address to bind to." env:"FTL_BIND" default:"http://127.0.0.1:8990"`
SchemaServiceEndpoint *url.URL `name:"ftl-endpoint" help:"Schema Service endpoint." env:"FTL_SCHEMA_ENDPOINT" default:"http://127.0.0.1:8892"`
TimelineEndpoint *url.URL `help:"Timeline endpoint." env:"FTL_TIMELINE_ENDPOINT" default:"http://127.0.0.1:8892"`
Raft raft.RaftConfig `embed:"" prefix:"raft-"`
}
type CronEvent ¶ added in v0.445.0
type CronEvent struct {
// Job that was executed
JobKey string
// When the job was executed
ExecutedAt time.Time
// Next scheduled execution
NextExecution time.Time
}
CronEvent represents changes to the cron state
func (CronEvent) MarshalBinary ¶ added in v0.445.0
func (*CronEvent) UnmarshalBinary ¶ added in v0.445.0
type CronState ¶ added in v0.445.0
type CronState struct {
// Map of job key to last execution time
LastExecutions map[string]time.Time `protobuf:"1"`
// Map of job key to next scheduled time
NextExecutions map[string]time.Time `protobuf:"2"`
}
CronState is the state of scheduled cron jobs
func CronStateFromProto ¶ added in v0.445.0
Click to show internal directories.
Click to hide internal directories.