ingress

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2020 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Package ingress is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

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

Client is a struct for all components necessary to connect to and maintain state of a Kubernetes cluster.

func (Client) GetAnnouncementsChannel

func (c Client) GetAnnouncementsChannel() <-chan interface{}

GetAnnouncementsChannel returns the announcement channel for the Ingress client

func (Client) GetIngressResources

func (c Client) GetIngressResources(meshService service.MeshService) ([]*extensionsV1beta.Ingress, error)

GetIngressResources returns the ingress resources whose backends correspond to the service

type MockMonitor added in v0.4.0

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

MockMonitor is a mock of Monitor interface

func NewMockMonitor added in v0.4.0

func NewMockMonitor(ctrl *gomock.Controller) *MockMonitor

NewMockMonitor creates a new mock instance

func (*MockMonitor) EXPECT added in v0.4.0

func (m *MockMonitor) EXPECT() *MockMonitorMockRecorder

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

func (*MockMonitor) GetAnnouncementsChannel added in v0.4.0

func (m *MockMonitor) GetAnnouncementsChannel() <-chan interface{}

GetAnnouncementsChannel mocks base method

func (*MockMonitor) GetIngressResources added in v0.4.0

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

GetIngressResources mocks base method

type MockMonitorMockRecorder added in v0.4.0

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

MockMonitorMockRecorder is the mock recorder for MockMonitor

func (*MockMonitorMockRecorder) GetAnnouncementsChannel added in v0.4.0

func (mr *MockMonitorMockRecorder) GetAnnouncementsChannel() *gomock.Call

GetAnnouncementsChannel indicates an expected call of GetAnnouncementsChannel

func (*MockMonitorMockRecorder) GetIngressResources added in v0.4.0

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

GetIngressResources indicates an expected call of GetIngressResources

type Monitor

type Monitor interface {
	// GetIngressResources returns the ingress resources whose backends correspond to the service
	GetIngressResources(service.MeshService) ([]*extensionsV1beta.Ingress, error)

	// GetAnnouncementsChannel returns the channel on which Ingress Monitor makes annoucements
	GetAnnouncementsChannel() <-chan interface{}
}

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) (Monitor, error)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL