v1

Documentation

Index

• func RegisterNamespaceGeneratingHandler(ctx context.Context, controller NamespaceController, apply apply.Apply, ...)
• func RegisterNamespaceStatusHandler(ctx context.Context, controller NamespaceController, condition condition.Cond, ...)
• func RegisterPodGeneratingHandler(ctx context.Context, controller PodController, apply apply.Apply, ...)
• func RegisterPodStatusHandler(ctx context.Context, controller PodController, condition condition.Cond, ...)
• func RegisterServiceGeneratingHandler(ctx context.Context, controller ServiceController, apply apply.Apply, ...)
• func RegisterServiceStatusHandler(ctx context.Context, controller ServiceController, condition condition.Cond, ...)
• type EndpointsCache
• type EndpointsClient
• type EndpointsController
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type NamespaceCache
• type NamespaceClient
• type NamespaceController
• type NamespaceGeneratingHandler
• type NamespaceStatusHandler
• type PodCache
• type PodClient
• type PodController
• type PodGeneratingHandler
• type PodStatusHandler
• type ServiceCache
• type ServiceClient
• type ServiceController
• type ServiceGeneratingHandler
• type ServiceStatusHandler

Functions

func RegisterNamespaceGeneratingHandler

func RegisterNamespaceGeneratingHandler(ctx context.Context, controller NamespaceController, apply apply.Apply,
	condition condition.Cond, name string, handler NamespaceGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterNamespaceGeneratingHandler configures a NamespaceController to execute a NamespaceGeneratingHandler 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 RegisterNamespaceStatusHandler

func RegisterNamespaceStatusHandler(ctx context.Context, controller NamespaceController, condition condition.Cond, name string, handler NamespaceStatusHandler)

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

func RegisterPodGeneratingHandler

func RegisterPodGeneratingHandler(ctx context.Context, controller PodController, apply apply.Apply,
	condition condition.Cond, name string, handler PodGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterPodGeneratingHandler configures a PodController to execute a PodGeneratingHandler 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 RegisterPodStatusHandler

func RegisterPodStatusHandler(ctx context.Context, controller PodController, condition condition.Cond, name string, handler PodStatusHandler)

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

func RegisterServiceGeneratingHandler

func RegisterServiceGeneratingHandler(ctx context.Context, controller ServiceController, apply apply.Apply,
	condition condition.Cond, name string, handler ServiceGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterServiceGeneratingHandler configures a ServiceController to execute a ServiceGeneratingHandler 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 RegisterServiceStatusHandler

func RegisterServiceStatusHandler(ctx context.Context, controller ServiceController, condition condition.Cond, name string, handler ServiceStatusHandler)

RegisterServiceStatusHandler configures a ServiceController to execute a ServiceStatusHandler 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 EndpointsCache

type EndpointsCache interface {
	generic.CacheInterface[*v1.Endpoints]
}

EndpointsCache interface for retrieving Endpoints resources in memory.

type EndpointsClient

type EndpointsClient interface {
	generic.ClientInterface[*v1.Endpoints, *v1.EndpointsList]
}

EndpointsClient interface for managing Endpoints resources in Kubernetes.

type EndpointsController

type EndpointsController interface {
	generic.ControllerInterface[*v1.Endpoints, *v1.EndpointsList]
}

EndpointsController interface for managing Endpoints resources.

type Interface

type Interface interface {
	Endpoints() EndpointsController
	Namespace() NamespaceController
	Pod() PodController
	Service() ServiceController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type NamespaceCache

type NamespaceCache interface {
	generic.NonNamespacedCacheInterface[*v1.Namespace]
}

NamespaceCache interface for retrieving Namespace resources in memory.

type NamespaceClient

type NamespaceClient interface {
	generic.NonNamespacedClientInterface[*v1.Namespace, *v1.NamespaceList]
}

NamespaceClient interface for managing Namespace resources in Kubernetes.

type NamespaceController

type NamespaceController interface {
	generic.NonNamespacedControllerInterface[*v1.Namespace, *v1.NamespaceList]
}

NamespaceController interface for managing Namespace resources.

type NamespaceGeneratingHandler

type NamespaceGeneratingHandler func(obj *v1.Namespace, status v1.NamespaceStatus) ([]runtime.Object, v1.NamespaceStatus, error)

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

type NamespaceStatusHandler

type NamespaceStatusHandler func(obj *v1.Namespace, status v1.NamespaceStatus) (v1.NamespaceStatus, error)

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

type PodCache

type PodCache interface {
	generic.CacheInterface[*v1.Pod]
}

PodCache interface for retrieving Pod resources in memory.

type PodClient

type PodClient interface {
	generic.ClientInterface[*v1.Pod, *v1.PodList]
}

PodClient interface for managing Pod resources in Kubernetes.

type PodController

type PodController interface {
	generic.ControllerInterface[*v1.Pod, *v1.PodList]
}

PodController interface for managing Pod resources.

type PodGeneratingHandler

type PodGeneratingHandler func(obj *v1.Pod, status v1.PodStatus) ([]runtime.Object, v1.PodStatus, error)

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

type PodStatusHandler

type PodStatusHandler func(obj *v1.Pod, status v1.PodStatus) (v1.PodStatus, error)

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

type ServiceCache

type ServiceCache interface {
	generic.CacheInterface[*v1.Service]
}

ServiceCache interface for retrieving Service resources in memory.

type ServiceClient

type ServiceClient interface {
	generic.ClientInterface[*v1.Service, *v1.ServiceList]
}

ServiceClient interface for managing Service resources in Kubernetes.

type ServiceController

type ServiceController interface {
	generic.ControllerInterface[*v1.Service, *v1.ServiceList]
}

ServiceController interface for managing Service resources.

type ServiceGeneratingHandler

type ServiceGeneratingHandler func(obj *v1.Service, status v1.ServiceStatus) ([]runtime.Object, v1.ServiceStatus, error)

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

type ServiceStatusHandler

type ServiceStatusHandler func(obj *v1.Service, status v1.ServiceStatus) (v1.ServiceStatus, error)

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