shell_operator

Documentation

Index

• Variables
• func CreateOnStartupTasks()
• func Init() (err error)
• func InitHttpServer(listenAddr *net.TCPAddr)
• func ManagersEventsHandler()
• func Run()
• func RunMetrics()
• func TasksRunner()
• func UpdateScheduledHooks(storage schedule_hook.ScheduledHooksStorage) schedule_hook.ScheduledHooksStorage

Variables

var (
	WorkingDir string
	TempDir    string

	// The hostname is the same as the pod name. Can be used for API requests.
	Hostname string

	TasksQueue *task.TasksQueue

	HookManager hook.HookManager

	ScheduleManager schedule_manager.ScheduleManager
	ScheduledHooks  schedule_hook.ScheduledHooksStorage

	KubeEventsManager kube_events_manager.KubeEventsManager
	KubeEventsHooks   kube_event_hook.KubeEventsHooksController

	MetricsStorage *metrics_storage.MetricStorage

	// ManagersEventsHandlerStopCh is the channel object for stopping infinite loop of the ManagersEventsHandler.
	ManagersEventsHandlerStopCh chan struct{}
)

var (
	QueueIsEmptyDelay = 3 * time.Second
	FailedHookDelay   = 5 * time.Second
)

Functions

func CreateOnStartupTasks

func CreateOnStartupTasks()

func Init

func Init() (err error)

Start is an implementation of a start command

func InitHttpServer

func InitHttpServer(listenAddr *net.TCPAddr)

func ManagersEventsHandler

func ManagersEventsHandler()

func Run

func Run()

func RunMetrics

func RunMetrics()

func TasksRunner

func TasksRunner()

func UpdateScheduledHooks

func UpdateScheduledHooks(storage schedule_hook.ScheduledHooksStorage) schedule_hook.ScheduledHooksStorage