ingress

Documentation

Overview

Package ingress is a generated GoMock package.

Package ingress implements functionality to monitor and retrieve Kubernetes Ingress resources.

Index

• Variables
• type MockMonitor
  • func NewMockMonitor(ctrl *gomock.Controller) *MockMonitor
  • func (m *MockMonitor) EXPECT() *MockMonitorMockRecorder
  • func (m *MockMonitor) GetIngressNetworkingV1(arg0 service.MeshService) ([]*v1.Ingress, error)
  • func (m *MockMonitor) GetIngressNetworkingV1beta1(arg0 service.MeshService) ([]*v1beta1.Ingress, error)
• type MockMonitorMockRecorder
  • func (mr *MockMonitorMockRecorder) GetIngressNetworkingV1(arg0 interface{}) *gomock.Call
  • func (mr *MockMonitorMockRecorder) GetIngressNetworkingV1beta1(arg0 interface{}) *gomock.Call
• type Monitor
  • func NewIngressClient(kubeClient kubernetes.Interface, kubeController k8s.Controller, ...) (Monitor, error)

Variables

var (

	// ErrUnsupportedAPIVersion indicates the requested version of ingress is unsupported
	ErrUnsupportedAPIVersion = errors.New("Unsupported ingress API version")
)

Types

type MockMonitor

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

MockMonitor is a mock of Monitor interface.

func NewMockMonitor

func NewMockMonitor(ctrl *gomock.Controller) *MockMonitor

NewMockMonitor creates a new mock instance.

func (*MockMonitor) EXPECT

func (m *MockMonitor) EXPECT() *MockMonitorMockRecorder

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

func (*MockMonitor) GetIngressNetworkingV1

func (m *MockMonitor) GetIngressNetworkingV1(arg0 service.MeshService) ([]*v1.Ingress, error)

GetIngressNetworkingV1 mocks base method.

func (*MockMonitor) GetIngressNetworkingV1beta1

func (m *MockMonitor) GetIngressNetworkingV1beta1(arg0 service.MeshService) ([]*v1beta1.Ingress, error)

GetIngressNetworkingV1beta1 mocks base method.

type MockMonitorMockRecorder

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

MockMonitorMockRecorder is the mock recorder for MockMonitor.

func (*MockMonitorMockRecorder) GetIngressNetworkingV1

func (mr *MockMonitorMockRecorder) GetIngressNetworkingV1(arg0 interface{}) *gomock.Call

GetIngressNetworkingV1 indicates an expected call of GetIngressNetworkingV1.

func (*MockMonitorMockRecorder) GetIngressNetworkingV1beta1

func (mr *MockMonitorMockRecorder) GetIngressNetworkingV1beta1(arg0 interface{}) *gomock.Call

GetIngressNetworkingV1beta1 indicates an expected call of GetIngressNetworkingV1beta1.

type Monitor

type Monitor interface {
	// GetIngressNetworkingV1beta1 returns the networking.k8s.io/v1beta1 ingress resources whose backends correspond to the service
	GetIngressNetworkingV1beta1(service.MeshService) ([]*networkingV1beta1.Ingress, error)

	// GetIngressNetworkingV1 returns the networking.k8s.io/v1 ingress resources whose backends correspond to the service
	GetIngressNetworkingV1(service.MeshService) ([]*networkingV1.Ingress, error)
}

Monitor is the client interface for K8s Ingress resource

func NewIngressClient

func NewIngressClient(kubeClient kubernetes.Interface, kubeController k8s.Controller, stop chan struct{},
	cfg configurator.Configurator, certProvider certificate.Manager, msgBroker *messaging.Broker) (Monitor, error)

NewIngressClient implements ingress.Monitor and creates the Kubernetes client to monitor Ingress resources.