kubelet

Documentation

Index

• type Controller
  • func New(logger *slog.Logger, kclient kubernetes.Interface, r prometheus.Registerer, ...) (*Controller, error)
  • func (c *Controller) Run(ctx context.Context) error
• type ControllerOption
  • func WithEndpointSlice() ControllerOption
  • func WithEndpoints() ControllerOption
  • func WithMaxEndpointsPerSlice(v int) ControllerOption
  • func WithNodeAddressPriority(s string) ControllerOption

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

func New

func New(
	logger *slog.Logger,
	kclient kubernetes.Interface,
	r prometheus.Registerer,
	kubeletServiceName string,
	kubeletServiceNamespace string,
	kubeletSelector operator.LabelSelector,
	commonAnnotations operator.Map,
	commonLabels operator.Map,
	opts ...ControllerOption,
) (*Controller, error)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context) error

type ControllerOption

type ControllerOption func(*Controller)

func WithEndpointSlice

func WithEndpointSlice() ControllerOption

func WithEndpoints

func WithEndpoints() ControllerOption

func WithMaxEndpointsPerSlice

func WithMaxEndpointsPerSlice(v int) ControllerOption

func WithNodeAddressPriority

func WithNodeAddressPriority(s string) ControllerOption