culler

Documentation

Index

• Constants
• func GetRequeueTime() time.Duration
• func NotebookNeedsCulling(meta metav1.ObjectMeta) bool
• func SetStopAnnotation(meta *metav1.ObjectMeta, m *metrics.Metrics)
• func StopAnnotationIsSet(meta metav1.ObjectMeta) bool
• func UpdateNotebookLastActivityAnnotation(meta *metav1.ObjectMeta) bool
• type KernelStatus

Constants

const (
	KERNEL_EXECUTION_STATE_IDLE     = "idle"
	KERNEL_EXECUTION_STATE_BUSY     = "busy"
	KERNEL_EXECUTION_STATE_STARTING = "starting"
)

const DEFAULT_CLUSTER_DOMAIN = "cluster.local"

const DEFAULT_CULL_IDLE_TIME = "1440" // One day

const DEFAULT_DEV = "false"

const DEFAULT_ENABLE_CULLING = "false"

const DEFAULT_IDLENESS_CHECK_PERIOD = "1"

const LAST_ACTIVITY_ANNOTATION = "notebooks.kubeflow.org/last-activity"

const STOP_ANNOTATION = "kubeflow-resource-stopped"

Functions

func GetRequeueTime

func GetRequeueTime() time.Duration

func NotebookNeedsCulling

func NotebookNeedsCulling(meta metav1.ObjectMeta) bool

func SetStopAnnotation

func SetStopAnnotation(meta *metav1.ObjectMeta, m *metrics.Metrics)

func StopAnnotationIsSet

func StopAnnotationIsSet(meta metav1.ObjectMeta) bool

func UpdateNotebookLastActivityAnnotation

func UpdateNotebookLastActivityAnnotation(meta *metav1.ObjectMeta) bool

Types

type KernelStatus

type KernelStatus struct {
	ID             string `json:"id"`
	Name           string `json:"name"`
	LastActivity   string `json:"last_activity"`
	ExecutionState string `json:"execution_state"`
	Connections    int    `json:"connections"`
}