fwdport

package
v1.20.0 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2021 License: Apache-2.0 Imports: 22 Imported by: 6

Documentation

Overview

Package fwdport is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PortForward 

func PortForward(pfo *PortForwardOpts) error

PortForward does the port-forward for a single pod. It is a blocking call and will return when an error occurred or after a cancellation signal has been received.

Types

type HostFileWithLock added in v1.13.1 

type HostFileWithLock struct {
	Hosts *txeh.Hosts
	sync.Mutex
}

HostFileWithLock

type HostsOperator added in v1.20.0 

type HostsOperator interface {
	AddHosts()
	RemoveHosts()
	RemoveInterfaceAlias()
}

type HostsParams added in v1.13.1 

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

HostsParams

type MockHostsOperator added in v1.20.0 

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

MockHostsOperator is a mock of HostsOperator interface

func NewMockHostsOperator added in v1.20.0 

func NewMockHostsOperator(ctrl *gomock.Controller) *MockHostsOperator

NewMockHostsOperator creates a new mock instance

func (*MockHostsOperator) AddHosts added in v1.20.0 

func (m *MockHostsOperator) AddHosts()

AddHosts mocks base method

func (*MockHostsOperator) EXPECT added in v1.20.0 

func (m *MockHostsOperator) EXPECT() *MockHostsOperatorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockHostsOperator) RemoveHosts added in v1.20.0 

func (m *MockHostsOperator) RemoveHosts()

RemoveHosts mocks base method

func (*MockHostsOperator) RemoveInterfaceAlias added in v1.20.0 

func (m *MockHostsOperator) RemoveInterfaceAlias()

RemoveInterfaceAlias mocks base method

type MockHostsOperatorMockRecorder added in v1.20.0 

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

MockHostsOperatorMockRecorder is the mock recorder for MockHostsOperator

func (*MockHostsOperatorMockRecorder) AddHosts added in v1.20.0 

func (mr *MockHostsOperatorMockRecorder) AddHosts() *gomock.Call

AddHosts indicates an expected call of AddHosts

func (*MockHostsOperatorMockRecorder) RemoveHosts added in v1.20.0 

func (mr *MockHostsOperatorMockRecorder) RemoveHosts() *gomock.Call

RemoveHosts indicates an expected call of RemoveHosts

func (*MockHostsOperatorMockRecorder) RemoveInterfaceAlias added in v1.20.0 

func (mr *MockHostsOperatorMockRecorder) RemoveInterfaceAlias() *gomock.Call

RemoveInterfaceAlias indicates an expected call of RemoveInterfaceAlias

type MockPodStateWaiter added in v1.20.0 

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

MockPodStateWaiter is a mock of PodStateWaiter interface

func NewMockPodStateWaiter added in v1.20.0 

func NewMockPodStateWaiter(ctrl *gomock.Controller) *MockPodStateWaiter

NewMockPodStateWaiter creates a new mock instance

func (*MockPodStateWaiter) EXPECT added in v1.20.0 

func (m *MockPodStateWaiter) EXPECT() *MockPodStateWaiterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockPodStateWaiter) WaitUntilPodRunning added in v1.20.0 

func (m *MockPodStateWaiter) WaitUntilPodRunning(stopChannel <-chan struct{}) (*v1.Pod, error)

WaitUntilPodRunning mocks base method

type MockPodStateWaiterMockRecorder added in v1.20.0 

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

MockPodStateWaiterMockRecorder is the mock recorder for MockPodStateWaiter

func (*MockPodStateWaiterMockRecorder) WaitUntilPodRunning added in v1.20.0 

func (mr *MockPodStateWaiterMockRecorder) WaitUntilPodRunning(stopChannel interface{}) *gomock.Call

WaitUntilPodRunning indicates an expected call of WaitUntilPodRunning

type MockPortForwardHelper added in v1.20.0 

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

MockPortForwardHelper is a mock of PortForwardHelper interface

func NewMockPortForwardHelper added in v1.20.0 

func NewMockPortForwardHelper(ctrl *gomock.Controller) *MockPortForwardHelper

NewMockPortForwardHelper creates a new mock instance

func (*MockPortForwardHelper) EXPECT added in v1.20.0 

func (m *MockPortForwardHelper) EXPECT() *MockPortForwardHelperMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockPortForwardHelper) ForwardPorts added in v1.20.0 

func (m *MockPortForwardHelper) ForwardPorts(forwarder *portforward.PortForwarder) error

ForwardPorts mocks base method

func (*MockPortForwardHelper) GetPortForwardRequest added in v1.20.0 

func (m *MockPortForwardHelper) GetPortForwardRequest(pfo *PortForwardOpts) *rest.Request

GetPortForwardRequest mocks base method

func (*MockPortForwardHelper) NewDialer added in v1.20.0 

func (m *MockPortForwardHelper) NewDialer(upgrader spdy.Upgrader, client *http.Client, method string, pfRequest *rest.Request) httpstream.Dialer

NewDialer mocks base method

func (*MockPortForwardHelper) NewOnAddresses added in v1.20.0 

func (m *MockPortForwardHelper) NewOnAddresses(dialer httpstream.Dialer, addresses, ports []string, stopChan <-chan struct{}, readyChan chan struct{}, out, errOut io.Writer) (*portforward.PortForwarder, error)

NewOnAddresses mocks base method

func (*MockPortForwardHelper) RoundTripperFor added in v1.20.0 

func (m *MockPortForwardHelper) RoundTripperFor(config *rest.Config) (http.RoundTripper, spdy.Upgrader, error)

RoundTripperFor mocks base method

type MockPortForwardHelperMockRecorder added in v1.20.0 

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

MockPortForwardHelperMockRecorder is the mock recorder for MockPortForwardHelper

func (*MockPortForwardHelperMockRecorder) ForwardPorts added in v1.20.0 

func (mr *MockPortForwardHelperMockRecorder) ForwardPorts(forwarder interface{}) *gomock.Call

ForwardPorts indicates an expected call of ForwardPorts

func (*MockPortForwardHelperMockRecorder) GetPortForwardRequest added in v1.20.0 

func (mr *MockPortForwardHelperMockRecorder) GetPortForwardRequest(pfo interface{}) *gomock.Call

GetPortForwardRequest indicates an expected call of GetPortForwardRequest

func (*MockPortForwardHelperMockRecorder) NewDialer added in v1.20.0 

func (mr *MockPortForwardHelperMockRecorder) NewDialer(upgrader, client, method, pfRequest interface{}) *gomock.Call

NewDialer indicates an expected call of NewDialer

func (*MockPortForwardHelperMockRecorder) NewOnAddresses added in v1.20.0 

func (mr *MockPortForwardHelperMockRecorder) NewOnAddresses(dialer, addresses, ports, stopChan, readyChan, out, errOut interface{}) *gomock.Call

NewOnAddresses indicates an expected call of NewOnAddresses

func (*MockPortForwardHelperMockRecorder) RoundTripperFor added in v1.20.0 

func (mr *MockPortForwardHelperMockRecorder) RoundTripperFor(config interface{}) *gomock.Call

RoundTripperFor indicates an expected call of RoundTripperFor

type MockServiceFWD added in v1.20.0 

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

MockServiceFWD is a mock of ServiceFWD interface

func NewMockServiceFWD added in v1.20.0 

func NewMockServiceFWD(ctrl *gomock.Controller) *MockServiceFWD

NewMockServiceFWD creates a new mock instance

func (*MockServiceFWD) AddServicePod added in v1.20.0 

func (m *MockServiceFWD) AddServicePod(pfo *PortForwardOpts)

AddServicePod mocks base method

func (*MockServiceFWD) EXPECT added in v1.20.0 

func (m *MockServiceFWD) EXPECT() *MockServiceFWDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockServiceFWD) GetServicePodPortForwards added in v1.20.0 

func (m *MockServiceFWD) GetServicePodPortForwards(servicePodName string) []*PortForwardOpts

GetServicePodPortForwards mocks base method

func (*MockServiceFWD) ListServicePodNames added in v1.20.0 

func (m *MockServiceFWD) ListServicePodNames() []string

ListServicePodNames mocks base method

func (*MockServiceFWD) RemoveServicePod added in v1.20.0 

func (m *MockServiceFWD) RemoveServicePod(servicePodName string, stop bool)

RemoveServicePod mocks base method

func (*MockServiceFWD) RemoveServicePodByPort added in v1.20.0 

func (m *MockServiceFWD) RemoveServicePodByPort(servicePodName, podPort string, stop bool)

RemoveServicePodByPort mocks base method

func (*MockServiceFWD) String added in v1.20.0 

func (m *MockServiceFWD) String() string

String mocks base method

func (*MockServiceFWD) SyncPodForwards added in v1.20.0 

func (m *MockServiceFWD) SyncPodForwards(arg0 bool)

SyncPodForwards mocks base method

type MockServiceFWDMockRecorder added in v1.20.0 

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

MockServiceFWDMockRecorder is the mock recorder for MockServiceFWD

func (*MockServiceFWDMockRecorder) AddServicePod added in v1.20.0 

func (mr *MockServiceFWDMockRecorder) AddServicePod(pfo interface{}) *gomock.Call

AddServicePod indicates an expected call of AddServicePod

func (*MockServiceFWDMockRecorder) GetServicePodPortForwards added in v1.20.0 

func (mr *MockServiceFWDMockRecorder) GetServicePodPortForwards(servicePodName interface{}) *gomock.Call

GetServicePodPortForwards indicates an expected call of GetServicePodPortForwards

func (*MockServiceFWDMockRecorder) ListServicePodNames added in v1.20.0 

func (mr *MockServiceFWDMockRecorder) ListServicePodNames() *gomock.Call

ListServicePodNames indicates an expected call of ListServicePodNames

func (*MockServiceFWDMockRecorder) RemoveServicePod added in v1.20.0 

func (mr *MockServiceFWDMockRecorder) RemoveServicePod(servicePodName, stop interface{}) *gomock.Call

RemoveServicePod indicates an expected call of RemoveServicePod

func (*MockServiceFWDMockRecorder) RemoveServicePodByPort added in v1.20.0 

func (mr *MockServiceFWDMockRecorder) RemoveServicePodByPort(servicePodName, podPort, stop interface{}) *gomock.Call

RemoveServicePodByPort indicates an expected call of RemoveServicePodByPort

func (*MockServiceFWDMockRecorder) String added in v1.20.0 

func (mr *MockServiceFWDMockRecorder) String() *gomock.Call

String indicates an expected call of String

func (*MockServiceFWDMockRecorder) SyncPodForwards added in v1.20.0 

func (mr *MockServiceFWDMockRecorder) SyncPodForwards(arg0 interface{}) *gomock.Call

SyncPodForwards indicates an expected call of SyncPodForwards

type PodStateWaiter added in v1.20.0 

type PodStateWaiter interface {
	WaitUntilPodRunning(stopChannel <-chan struct{}) (*v1.Pod, error)
}

type PodStateWaiterImpl added in v1.20.0 

type PodStateWaiterImpl struct {
	Namespace  string
	PodName    string
	ClientSet  kubernetes.Clientset
	ServiceFwd ServiceFWD
}

func (*PodStateWaiterImpl) ListenUntilPodDeleted added in v1.20.0 

func (waiter *PodStateWaiterImpl) ListenUntilPodDeleted(stopChannel <-chan struct{}, pod *v1.Pod)

ListenUntilPodDeleted listen for pod is deleted

func (*PodStateWaiterImpl) WaitUntilPodRunning added in v1.20.0 

func (waiter *PodStateWaiterImpl) WaitUntilPodRunning(stopChannel <-chan struct{}) (*v1.Pod, error)

WaitUntilPodRunning Waiting for the pod running

type PortForwardHelper added in v1.20.0 

type PortForwardHelper interface {
	GetPortForwardRequest(pfo *PortForwardOpts) *restclient.Request
	NewOnAddresses(dialer httpstream.Dialer, addresses []string, ports []string, stopChan <-chan struct{}, readyChan chan struct{}, out, errOut io.Writer) (*portforward.PortForwarder, error)
	ForwardPorts(forwarder *portforward.PortForwarder) error

	RoundTripperFor(config *restclient.Config) (http.RoundTripper, spdy.Upgrader, error)
	NewDialer(upgrader spdy.Upgrader, client *http.Client, method string, pfRequest *restclient.Request) httpstream.Dialer
}

type PortForwardHelperImpl added in v1.20.0 

type PortForwardHelperImpl struct{}

func (PortForwardHelperImpl) ForwardPorts added in v1.20.0 

func (p PortForwardHelperImpl) ForwardPorts(forwarder *portforward.PortForwarder) error

func (PortForwardHelperImpl) GetPortForwardRequest added in v1.20.0 

func (p PortForwardHelperImpl) GetPortForwardRequest(pfo *PortForwardOpts) *restclient.Request

func (PortForwardHelperImpl) NewDialer added in v1.20.0 

func (p PortForwardHelperImpl) NewDialer(upgrader spdy.Upgrader, client *http.Client, method string, pfRequest *restclient.Request) httpstream.Dialer

func (PortForwardHelperImpl) NewOnAddresses added in v1.20.0 

func (p PortForwardHelperImpl) NewOnAddresses(dialer httpstream.Dialer, addresses []string, ports []string, stopChan <-chan struct{}, readyChan chan struct{}, out, errOut io.Writer) (*portforward.PortForwarder, error)

func (PortForwardHelperImpl) RoundTripperFor added in v1.20.0 

func (p PortForwardHelperImpl) RoundTripperFor(config *restclient.Config) (http.RoundTripper, spdy.Upgrader, error)

type PortForwardOpts 

type PortForwardOpts struct {
	Out        *fwdpub.Publisher
	Config     restclient.Config
	ClientSet  kubernetes.Clientset
	RESTClient restclient.Interface

	Service    string
	ServiceFwd ServiceFWD
	PodName    string
	PodPort    string
	LocalIp    net.IP
	LocalPort  string
	HostFile   *HostFileWithLock

	// Context is a unique key (string) in kubectl config representing
	// a user/cluster combination. Kubefwd uses context as the
	// cluster name when forwarding to more than one cluster.
	Context string

	// Namespace is the current Kubernetes Namespace to locate services
	// and the pods that back them for port-forwarding
	Namespace string

	// ClusterN is the ordinal index of the cluster (from configuration)
	// cluster 0 is considered local while > 0 is remote
	ClusterN int

	// NamespaceN is the ordinal index of the namespace from the
	// perspective of the user. Namespace 0 is considered local
	// while > 0 is an external namespace
	NamespaceN int

	Domain         string
	HostsParams    *HostsParams
	Hosts          []string
	ManualStopChan chan struct{} // Send a signal on this to stop the portforwarding
	DoneChan       chan struct{} // Listen on this channel for when the shutdown is completed.

	StateWaiter       PodStateWaiter
	PortForwardHelper PortForwardHelper
	HostsOperator     HostsOperator
}

PortForwardOpts

func (*PortForwardOpts) Stop added in v1.13.1 

func (pfo *PortForwardOpts) Stop()

Stop sends the shutdown signal to the port-forwarding process. In case the shutdown signal was already given before, this is a no-op.

func (*PortForwardOpts) String added in v1.20.0 

func (pfo *PortForwardOpts) String() string

type PortForwardOptsHostsOperator added in v1.20.0 

type PortForwardOptsHostsOperator struct {
	Pfo *PortForwardOpts
}

func (PortForwardOptsHostsOperator) AddHosts added in v1.20.0 

func (operator PortForwardOptsHostsOperator) AddHosts()

AddHosts adds hostname entries to /etc/hosts

func (PortForwardOptsHostsOperator) RemoveHosts added in v1.20.0 

func (operator PortForwardOptsHostsOperator) RemoveHosts()

RemoveHosts removes hosts /etc/hosts associated with a forwarded pod

func (PortForwardOptsHostsOperator) RemoveInterfaceAlias added in v1.20.0 

func (operator PortForwardOptsHostsOperator) RemoveInterfaceAlias()

type ServiceFWD added in v1.17.3 

type ServiceFWD interface {
	String() string
	SyncPodForwards(bool)
	ListServicePodNames() []string
	AddServicePod(pfo *PortForwardOpts)
	GetServicePodPortForwards(servicePodName string) []*PortForwardOpts
	RemoveServicePod(servicePodName string, stop bool)
	RemoveServicePodByPort(servicePodName string, podPort string, stop bool)
}

ServiceFWD PodSyncer interface is used to represent a fwdservice.ServiceFWD reference, which cannot be used directly due to circular imports. It's a reference from a pod to it's parent service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳