operator

package
v2.11.0 Latest Latest
Warning

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

Go to latest
Published: Sep 24, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultDelveListenPort = ":2345"
)

Variables

This section is empty.

Functions

func AllNamespacesOperatorEnv

func AllNamespacesOperatorEnv(operatorNamespace string) []string

func DefaultOperatorEnv

func DefaultOperatorEnv(namespace string) []string

func NoGoRunEnvSet

func NoGoRunEnvSet() bool

func RunDelveEnvSet

func RunDelveEnvSet() bool

func RunEmbeddedSet

func RunEmbeddedSet() bool

Types

type EmbeddedOperator

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

func NewEmbeddedOperator

func NewEmbeddedOperator(runnerFunc RunnerFunc, args []string) *EmbeddedOperator

func (*EmbeddedOperator) Running

func (e *EmbeddedOperator) Running() bool

func (*EmbeddedOperator) Start

func (e *EmbeddedOperator) Start(t testingT)

func (*EmbeddedOperator) Stop

func (e *EmbeddedOperator) Stop(t testingT)

func (*EmbeddedOperator) Wait

func (e *EmbeddedOperator) Wait(t testingT)

type Operator

type Operator interface {
	Start(t testingT)
	Running() bool
	Wait(t testingT)
	Stop(t testingT)
}

func NewOperator

func NewOperator(env []string, stdout, stderr io.Writer, cmdArgs ...string) Operator

type OperatorProcess

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

func (*OperatorProcess) Running

func (o *OperatorProcess) Running() bool

func (*OperatorProcess) Start

func (o *OperatorProcess) Start(t testingT)

func (*OperatorProcess) Stop

func (o *OperatorProcess) Stop(t testingT)

func (*OperatorProcess) Wait

func (o *OperatorProcess) Wait(t testingT)

type RunnerFunc

type RunnerFunc func(context.Context, *flag.FlagSet, []string) error

Jump to

Keyboard shortcuts

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