kubernetes

package
v1.0.14 Latest Latest
Warning

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

Go to latest
Published: Oct 27, 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

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.View, 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

func (f *Forwarder) GetForwardType() string

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

func (*Forwarder) GetReadyChannel

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

GetReadyChannel returns the Kubernetes go client channel for ready event

func (*Forwarder) GetStopChannel

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

GetStopChannel returns the Kubernetes go client channel for stop event

func (*Forwarder) Stop

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.View, 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