kubernetes

package
v1.0.13 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2020 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// RemoteSSHProxyPort is the SSH proxy port used by the 'ekofr/monday-proxy' docker image
	// to make a remote-forward on the Kubernetes pod to be able to next forward trafic locally
	RemoteSSHProxyPort = 5022

	// ProxyDockerImage is the path to the public Docker image acting as a proxy in the
	// Kubernetes cluster
	ProxyDockerImage = "ekofr/monday-proxy"

	// ProxyPortName is the name given to the SSH port used when deploying the proxy image into the
	// cluster
	ProxyPortName = "ssh-proxy"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DeploymentBackup added in v0.0.5

type DeploymentBackup struct {
	OldImage   string
	OldPorts   []apiv1.ContainerPort
	Deployment *appsv1.Deployment
}

type Forwarder

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

func NewForwarder

func NewForwarder(view ui.ViewInterface, forwardType, name, context, namespace string, ports []string, labels map[string]string) (*Forwarder, error)

func (*Forwarder) Forward

func (f *Forwarder) Forward() error

Forward method executes the local or remote port-forward depending on the given type

func (*Forwarder) GetForwardType added in v0.0.5

func (f *Forwarder) GetForwardType() string

GetForwardType returns the type of the forward specified in the configuration (ssh, ssh-remote, kubernetes, ...)

func (*Forwarder) GetReadyChannel added in v0.0.6

func (f *Forwarder) GetReadyChannel() chan struct{}

GetReadyChannel returns the Kubernetes go client channel for ready event

func (*Forwarder) GetStopChannel added in v0.0.6

func (f *Forwarder) GetStopChannel() chan struct{}

GetStopChannel returns the Kubernetes go client channel for stop event

func (*Forwarder) Stop added in v0.0.5

func (f *Forwarder) Stop() error

Stop stops the current forwarder

type Logstreamer

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

func NewLogstreamer

func NewLogstreamer(view ui.ViewInterface, podName string) *Logstreamer

func (*Logstreamer) Write

func (l *Logstreamer) Write(b []byte) (int, error)

Jump to

Keyboard shortcuts

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