Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LoadKubeClient ¶
func LoadKubeClient(p string)
Types ¶
type Executable ¶
type Executable struct {
// contains filtered or unexported fields
}
func (*Executable) ID ¶
func (e *Executable) ID() string
func (*Executable) MonitorMemory ¶
func (e *Executable) MonitorMemory(pid int, rec chan output.Message)
type PortForwardAPodRequest ¶
type PortForwardAPodRequest struct {
// Pod is the selected pod for this port forwarding
Pod v1.Pod
// LocalPort is the local port that will be selected to expose the PodPort
LocalPort int
// PodPort is the target port for the pod
PodPort int
// Steams configures where to write or read input from
Streams genericclioptions.IOStreams
// Stop is the channel used to manage the port forward lifecycle
Stop <-chan struct{}
// Ready communicates when the tunnel is ready to receive traffic
Ready chan struct{}
}
type Runnable ¶
type Runnable interface {
ID() string
Start(ctx context.Context, rec chan output.Message) error
Stop(ctx context.Context, rec chan output.Message) error
}
func NewExecutable ¶
func NewExecutable(logger *output.Logger, c *configuration.Executable) Runnable
type Runner ¶
type Runner struct {
Receiver chan output.Message
Configuration *configuration.Configuration
Logger *output.Logger
// contains filtered or unexported fields
}
func New ¶
func New(log *output.Logger, c *configuration.Configuration) *Runner
Click to show internal directories.
Click to hide internal directories.