scheduler

package
v0.0.0-...-267b159 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 17, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartScheduler

func StartScheduler(ctx context.Context) error

StartScheduler creates and starts a new scheduler instance. This is a blocking call and will block the calling go-routine

Types

type ScheduledExecutor

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

ScheduledExecutor used for executing the schedules saved by the native nebula scheduler in the database.

func (*ScheduledExecutor) Run

func (w *ScheduledExecutor) Run(ctx context.Context) error

Directories

Path Synopsis
Package core This is core package for the scheduler which includes
Package core This is core package for the scheduler which includes
Package dbapi This package implements the event scheduler interface which is called whenever a launchplan is enabled or disabled.
Package dbapi This package implements the event scheduler interface which is called whenever a launchplan is enabled or disabled.
Package executor This package provides an interface to talk to admin for scheduled executions.
Package executor This package provides an interface to talk to admin for scheduled executions.
Package identifier This package provides utility functions for creating a unique schedule name and execution name
Package identifier This package provides utility functions for creating a unique schedule name and execution name
Package repositories This package provides the interfaces and implementations to save and retrieve schedules and snapshots from the DB.
Package repositories This package provides the interfaces and implementations to save and retrieve schedules and snapshots from the DB.
Package snapshoter This package provides the ability to snapshot all the schedules in the scheduler job store and persist them in the DB in GOB binary format.
Package snapshoter This package provides the ability to snapshot all the schedules in the scheduler job store and persist them in the DB in GOB binary format.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL