Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WatchNodes ¶
func WatchNodes(ctx context.Context, nodes scheduler.SchedulerServiceServer)
WatchNodes updates the node state and resource counters every 5 seconds. This blocks until the context is canceled.
func WatchTaskStates ¶
func WatchTaskStates(ctx context.Context, counter TaskStateCounter)
WatchTaskStates updates the task state counter every 5 seconds. This blocks until the context is canceled.
Types ¶
Click to show internal directories.
Click to hide internal directories.