type PFClient struct {
// contains filtered or unexported fields
}
func NewPFClient(kubernetesClient kclient.ClientInterface, stateClient state.Client) *PFClient
func (o *PFClient) GetForwardedPorts() map[string][]v1alpha2.Endpoint
func (o *PFClient) StartPortForwarding(ctx context.Context, devFileObj parser.DevfileObj, componentName string, debug bool, randomPorts bool, out io.Writer, errOut io.Writer, definedPorts []api.ForwardedPort, customAddress string) error
func (o *PFClient) StopPortForwarding(ctx context.Context, componentName string)
type PortWriter struct {
// contains filtered or unexported fields
}
func NewPortWriter(buffer io.Writer, len int, mapping map[string][]v1alpha2.Endpoint, customAddress string) *PortWriter
NewPortWriter creates a writer that will write the content in buffer, and Wait will return after strings "Forwarding from 127.0.0.1:" has been written "len" times
func (o *PortWriter) GetForwardedPorts() []api.ForwardedPort
func (o *PortWriter) Wait()
func (o *PortWriter) Write(buf []byte) (n int, err error)