server

Documentation

Index

• type Listener
  • func NewListener() (Listener, error)
• type PortInformation
• type PortManager
  • func NewPortManager(cb func(*PortInformation)) *PortManager
  • func (pm *PortManager) AddTarget(name string, namespace string, port int) (*PortInformation, error)
  • func (pm *PortManager) RemoveTarget(name string, namespace string, port int) *PortInformation
  • func (pm *PortManager) RemoveTargetForAllPorts(name string, namespace string) []*PortInformation
• type Server
  • func NewServer(ip string, clientset kubernetes.Interface) *Server
  • func (s *Server) Run(ctx context.Context) error
• type Target

Types

type Listener

type Listener interface {
	net.Listener
	Port() int
}

func NewListener

func NewListener() (Listener, error)

type PortInformation

type PortInformation struct {
	Target      Target
	Listener    Listener
	Connections []net.Conn
}

type PortManager

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

func NewPortManager

func NewPortManager(cb func(*PortInformation)) *PortManager

func (*PortManager) AddTarget

func (pm *PortManager) AddTarget(name string, namespace string, port int) (*PortInformation, error)

func (*PortManager) RemoveTarget

func (pm *PortManager) RemoveTarget(name string, namespace string, port int) *PortInformation

func (*PortManager) RemoveTargetForAllPorts

func (pm *PortManager) RemoveTargetForAllPorts(name string, namespace string) []*PortInformation

type Server

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

func NewServer

func NewServer(ip string, clientset kubernetes.Interface) *Server

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

type Target

type Target struct {
	Name      string
	Namespace string
	Port      int
}