kubernetes

Documentation

Index

• Constants
• type DeploymentBackup
• type Forwarder
  • func NewForwarder(forwardType, name, context, namespace string, ports []string, ...) (*Forwarder, error)
  • func (f *Forwarder) Forward() error
  • func (f *Forwarder) GetForwardType() string
  • func (f *Forwarder) GetReadyChannel() chan struct{}
  • func (f *Forwarder) GetStopChannel() chan struct{}
  • func (f *Forwarder) Stop() error
• type Logstreamer
  • func NewLogstreamer(podName string) *Logstreamer
  • func (l *Logstreamer) Write(b []byte) (int, error)

Constants

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"
)

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(forwardType, name, context, namespace string, ports []string, labels map[string]string) (*Forwarder, error)

func (*Forwarder) Forward

func (f *Forwarder) Forward() error

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(podName string) *Logstreamer

func (*Logstreamer) Write

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