watch_endpointslice

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 29, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewWatchEndpointSlice

func NewWatchEndpointSlice(ioStreams genericclioptions.IOStreams) *cobra.Command

Types

type EndpointSliceController

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

func NewEndpointWatcher

func NewEndpointWatcher(
	backendPrefix string,
	namespaceName string,
	serviceName string,
	stopConfigMapName string,
	myNodeName string,
	scheme string,
	path string,
	expectedStatusCode int,
	recorder monitorapi.RecorderWriter,
	outFile io.Writer,

	endpointSliceInformer discoveryinformers.EndpointSliceInformer,
	configmapInformer coreinformers.ConfigMapInformer,
) *EndpointSliceController

func (*EndpointSliceController) Run

func (c *EndpointSliceController) Run(ctx context.Context, finishedCleanup chan struct{})

Run starts the controller and blocks until stopCh is closed.

type WatchEndpointSliceFlags

type WatchEndpointSliceFlags struct {
	ConfigFlags        *genericclioptions.ConfigFlags
	OutputFlags        *iooptions.OutputFlags
	ServiceName        string
	BackendPrefix      string
	Scheme             string
	Path               string
	ExpectedStatusCode int
	MyNodeName         string
	StopConfigMapName  string

	genericclioptions.IOStreams
}

WatchEndpointSliceFlags is used to run a monitoring process against the provided server as a command line interaction.

func NewWatchEndpointSliceFlags

func NewWatchEndpointSliceFlags(streams genericclioptions.IOStreams) *WatchEndpointSliceFlags

func (*WatchEndpointSliceFlags) BindOptions

func (f *WatchEndpointSliceFlags) BindOptions(flags *pflag.FlagSet)

func (*WatchEndpointSliceFlags) SetIOStreams

func (f *WatchEndpointSliceFlags) SetIOStreams(streams genericclioptions.IOStreams)

func (*WatchEndpointSliceFlags) ToOptions

func (*WatchEndpointSliceFlags) Validate

func (f *WatchEndpointSliceFlags) Validate() error

type WatchEndpointSliceOptions

type WatchEndpointSliceOptions struct {
	KubeClient kubernetes.Interface
	Namespace  string

	OutputFile         string
	BackendPrefix      string
	ServiceName        string
	MyNodeName         string
	Scheme             string
	Path               string
	ExpectedStatusCode int
	StopConfigMapName  string

	OriginalOutFile io.Writer
	CloseFn         iooptions.CloseFunc
	genericclioptions.IOStreams
}

func (*WatchEndpointSliceOptions) Run

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL