poll_service

package

v1.6.0 Latest Latest Go to latest Published: Jul 29, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/openshift/origin

Links

Documentation ¶

Index ¶

func NewPollService(ioStreams genericclioptions.IOStreams) *cobra.Command
type PollServiceController
- func NewPollServiceWatcher(backendPrefix string, nodeName string, namespaceName string, clusterIP string, ...) *PollServiceController
- func (c *PollServiceController) Run(ctx context.Context, finishedCleanup chan struct{})
type PollServiceFlags
- func NewPollServiceFlags(streams genericclioptions.IOStreams) *PollServiceFlags
type PollServiceOptions
- func (o *PollServiceOptions) Run(ctx context.Context) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewPollService ¶

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

Types ¶

type PollServiceController ¶

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

func NewPollServiceWatcher ¶

func NewPollServiceWatcher(
	backendPrefix string,
	nodeName string,
	namespaceName string,
	clusterIP string,
	port uint16,
	recorder monitorapi.RecorderWriter,
	outFile io.Writer,
	stopConfigMapName string,
	configmapInformer coreinformers.ConfigMapInformer,
) *PollServiceController

func (*PollServiceController) Run ¶

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

type PollServiceFlags ¶

type PollServiceFlags struct {
	ConfigFlags       *genericclioptions.ConfigFlags
	OutputFlags       *iooptions.OutputFlags
	BackendPrefix     string
	MyNodeName        string
	StopConfigMapName string
	ServiceClusterIP  string
	ServicePort       uint16

	genericclioptions.IOStreams
}

func NewPollServiceFlags ¶

func NewPollServiceFlags(streams genericclioptions.IOStreams) *PollServiceFlags

func (*PollServiceFlags) BindOptions ¶

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

func (*PollServiceFlags) SetIOStreams ¶

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

func (*PollServiceFlags) ToOptions ¶

func (f *PollServiceFlags) ToOptions() (*PollServiceOptions, error)

func (*PollServiceFlags) Validate ¶

func (f *PollServiceFlags) Validate() error

type PollServiceOptions ¶

type PollServiceOptions struct {
	KubeClient kubernetes.Interface
	Namespace  string
	ClusterIP  string
	Port       uint16

	BackendPrefix     string
	OutputFile        string
	MyNodeName        string
	StopConfigMapName string

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

func (*PollServiceOptions) Run ¶

func (o *PollServiceOptions) Run(ctx context.Context) error

Source Files ¶

View all Source files

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