Documentation ¶
Overview ¶
Index ¶
- func AddEntry(name, iface string, port int) error
- func Copy(local io.Reader, remote io.WriteCloser)
- func Exec(ctx context.Context, iface string, remotePort int, tty bool, inR io.Reader, ...) error
- func GenerateKeys() error
- func GetPort(name string) (int, error)
- func GetPublicKey() string
- func KeyExists() bool
- func RemoveEntry(name string) error
- type Copier
- type ForwardManager
- func (fm *ForwardManager) Add(f forwardModel.Forward) error
- func (fm *ForwardManager) AddReverse(f model.Reverse) error
- func (fm *ForwardManager) Start(devPod, namespace string) error
- func (fm *ForwardManager) StartGlobalForwarding() error
- func (fm *ForwardManager) Stop()
- func (fm *ForwardManager) TransformLabelsToServiceName(f forwardModel.Forward) (forwardModel.Forward, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Exec ¶
func Exec(ctx context.Context, iface string, remotePort int, tty bool, inR io.Reader, outW, errW io.Writer, command []string) error
Exec executes the command over SSH
func RemoveEntry ¶
RemoveEntry removes the entry to the user's sshconfig if found
Types ¶
type Copier ¶
type Copier struct { Local io.Reader Remote io.WriteCloser }
Copier copies from local to remote terminalhandles the lifecycle of all the forwards
type ForwardManager ¶
type ForwardManager struct {
// contains filtered or unexported fields
}
ForwardManager handles the lifecycle of all the forwards
func NewForwardManager ¶
func NewForwardManager(ctx context.Context, sshAddr, localInterface, remoteInterface string, pf *k8sForward.PortForwardManager, namespace string) *ForwardManager
NewForwardManager returns a newly initialized instance of ForwardManager
func (*ForwardManager) Add ¶
func (fm *ForwardManager) Add(f forwardModel.Forward) error
Add initializes a remote forward
func (*ForwardManager) AddReverse ¶
func (fm *ForwardManager) AddReverse(f model.Reverse) error
AddReverse adds a reverse forward
func (*ForwardManager) Start ¶
func (fm *ForwardManager) Start(devPod, namespace string) error
Start starts a port-forward to the remote port and then starts forwards and reverse forwards as goroutines
func (*ForwardManager) StartGlobalForwarding ¶
func (fm *ForwardManager) StartGlobalForwarding() error
StartGlobalForwarding implements from the interface types.forwarder nolint:unparam
func (*ForwardManager) Stop ¶
func (fm *ForwardManager) Stop()
Stop sends a stop signal to all the connections
func (*ForwardManager) TransformLabelsToServiceName ¶
func (fm *ForwardManager) TransformLabelsToServiceName(f forwardModel.Forward) (forwardModel.Forward, error)
Click to show internal directories.
Click to hide internal directories.