v1

Documentation

Index

• func RegisterRayClusterGeneratingHandler(ctx context.Context, controller RayClusterController, apply apply.Apply, ...)
• func RegisterRayClusterStatusHandler(ctx context.Context, controller RayClusterController, condition condition.Cond, ...)
• func RegisterRayJobGeneratingHandler(ctx context.Context, controller RayJobController, apply apply.Apply, ...)
• func RegisterRayJobStatusHandler(ctx context.Context, controller RayJobController, condition condition.Cond, ...)
• func RegisterRayServiceGeneratingHandler(ctx context.Context, controller RayServiceController, apply apply.Apply, ...)
• func RegisterRayServiceStatusHandler(ctx context.Context, controller RayServiceController, condition condition.Cond, ...)
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type RayClusterCache
• type RayClusterClient
• type RayClusterController
• type RayClusterGeneratingHandler
• type RayClusterStatusHandler
• type RayJobCache
• type RayJobClient
• type RayJobController
• type RayJobGeneratingHandler
• type RayJobStatusHandler
• type RayServiceCache
• type RayServiceClient
• type RayServiceController
• type RayServiceGeneratingHandler
• type RayServiceStatusHandler

Functions

func RegisterRayClusterGeneratingHandler

func RegisterRayClusterGeneratingHandler(ctx context.Context, controller RayClusterController, apply apply.Apply,
	condition condition.Cond, name string, handler RayClusterGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterRayClusterGeneratingHandler configures a RayClusterController to execute a RayClusterGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterRayClusterStatusHandler

func RegisterRayClusterStatusHandler(ctx context.Context, controller RayClusterController, condition condition.Cond, name string, handler RayClusterStatusHandler)

RegisterRayClusterStatusHandler configures a RayClusterController to execute a RayClusterStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterRayJobGeneratingHandler

func RegisterRayJobGeneratingHandler(ctx context.Context, controller RayJobController, apply apply.Apply,
	condition condition.Cond, name string, handler RayJobGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterRayJobGeneratingHandler configures a RayJobController to execute a RayJobGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterRayJobStatusHandler

func RegisterRayJobStatusHandler(ctx context.Context, controller RayJobController, condition condition.Cond, name string, handler RayJobStatusHandler)

RegisterRayJobStatusHandler configures a RayJobController to execute a RayJobStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterRayServiceGeneratingHandler

func RegisterRayServiceGeneratingHandler(ctx context.Context, controller RayServiceController, apply apply.Apply,
	condition condition.Cond, name string, handler RayServiceGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterRayServiceGeneratingHandler configures a RayServiceController to execute a RayServiceGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterRayServiceStatusHandler

func RegisterRayServiceStatusHandler(ctx context.Context, controller RayServiceController, condition condition.Cond, name string, handler RayServiceStatusHandler)

RegisterRayServiceStatusHandler configures a RayServiceController to execute a RayServiceStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

Types

type Interface

type Interface interface {
	RayCluster() RayClusterController
	RayJob() RayJobController
	RayService() RayServiceController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type RayClusterCache

type RayClusterCache interface {
	generic.CacheInterface[*v1.RayCluster]
}

RayClusterCache interface for retrieving RayCluster resources in memory.

type RayClusterClient

type RayClusterClient interface {
	generic.ClientInterface[*v1.RayCluster, *v1.RayClusterList]
}

RayClusterClient interface for managing RayCluster resources in Kubernetes.

type RayClusterController

type RayClusterController interface {
	generic.ControllerInterface[*v1.RayCluster, *v1.RayClusterList]
}

RayClusterController interface for managing RayCluster resources.

type RayClusterGeneratingHandler

type RayClusterGeneratingHandler func(obj *v1.RayCluster, status v1.RayClusterStatus) ([]runtime.Object, v1.RayClusterStatus, error)

RayClusterGeneratingHandler is the top-level handler that is executed for every RayCluster event. It extends RayClusterStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type RayClusterStatusHandler

type RayClusterStatusHandler func(obj *v1.RayCluster, status v1.RayClusterStatus) (v1.RayClusterStatus, error)

RayClusterStatusHandler is executed for every added or modified RayCluster. Should return the new status to be updated

type RayJobCache

type RayJobCache interface {
	generic.CacheInterface[*v1.RayJob]
}

RayJobCache interface for retrieving RayJob resources in memory.

type RayJobClient

type RayJobClient interface {
	generic.ClientInterface[*v1.RayJob, *v1.RayJobList]
}

RayJobClient interface for managing RayJob resources in Kubernetes.

type RayJobController

type RayJobController interface {
	generic.ControllerInterface[*v1.RayJob, *v1.RayJobList]
}

RayJobController interface for managing RayJob resources.

type RayJobGeneratingHandler

type RayJobGeneratingHandler func(obj *v1.RayJob, status v1.RayJobStatus) ([]runtime.Object, v1.RayJobStatus, error)

RayJobGeneratingHandler is the top-level handler that is executed for every RayJob event. It extends RayJobStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type RayJobStatusHandler

type RayJobStatusHandler func(obj *v1.RayJob, status v1.RayJobStatus) (v1.RayJobStatus, error)

RayJobStatusHandler is executed for every added or modified RayJob. Should return the new status to be updated

type RayServiceCache

type RayServiceCache interface {
	generic.CacheInterface[*v1.RayService]
}

RayServiceCache interface for retrieving RayService resources in memory.

type RayServiceClient

type RayServiceClient interface {
	generic.ClientInterface[*v1.RayService, *v1.RayServiceList]
}

RayServiceClient interface for managing RayService resources in Kubernetes.

type RayServiceController

type RayServiceController interface {
	generic.ControllerInterface[*v1.RayService, *v1.RayServiceList]
}

RayServiceController interface for managing RayService resources.

type RayServiceGeneratingHandler

type RayServiceGeneratingHandler func(obj *v1.RayService, status v1.RayServiceStatuses) ([]runtime.Object, v1.RayServiceStatuses, error)

RayServiceGeneratingHandler is the top-level handler that is executed for every RayService event. It extends RayServiceStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type RayServiceStatusHandler

type RayServiceStatusHandler func(obj *v1.RayService, status v1.RayServiceStatuses) (v1.RayServiceStatuses, error)

RayServiceStatusHandler is executed for every added or modified RayService. Should return the new status to be updated