kubernetes

Aug 19, 2021

Changes in this version

+ func NamespacedNameFrom(name string) (types.NamespacedName, error)

Jul 2, 2021

Changes in this version

type Client

+ func (c Client) IsMetricsEnabled(pod *corev1.Pod) bool

type Controller

+ IsMetricsEnabled func(*corev1.Pod) bool

type MockController

+ func (m *MockController) IsMetricsEnabled(arg0 *v1.Pod) bool

type MockControllerMockRecorder

+ func (mr *MockControllerMockRecorder) IsMetricsEnabled(arg0 interface{}) *gomock.Call

Jun 14, 2021

Changes in this version

+ func GetKubernetesServerVersionNumber(kubeClient kubernetes.Interface) ([]int, error)

+ func PatchSecretHandler(kubeClient kubernetes.Interface) chan struct

type Client

+ func (c Client) ListServiceIdentitiesForService(svc service.MeshService) ([]identity.K8sServiceAccount, error)

type Controller

+ ListServiceIdentitiesForService func(svc service.MeshService) ([]identity.K8sServiceAccount, error)

type MockController

+ func (m *MockController) ListServiceIdentitiesForService(arg0 service.MeshService) ([]identity.K8sServiceAccount, error)

type MockControllerMockRecorder

+ func (mr *MockControllerMockRecorder) ListServiceIdentitiesForService(arg0 interface{}) *gomock.Call

Mar 17, 2021

Changes in this version

+ func DialerToPod(conf *rest.Config, clientSet kubernetes.Interface, podName string, ...) (httpstream.Dialer, error)

type Client

+ func (c Client) ListServiceAccounts() []*corev1.ServiceAccount

type Controller

+ ListServiceAccounts func() []*corev1.ServiceAccount

type InformerKey

+ const ServiceAccounts

type MockController

+ func (m *MockController) ListServiceAccounts() []*v1.ServiceAccount

type MockControllerMockRecorder

+ func (mr *MockControllerMockRecorder) ListServiceAccounts() *gomock.Call

type PortForwarder

+ func (pf *PortForwarder) Done() <-chan struct{}

Feb 4, 2021

Changes in this version

+ func GetAppProtocolFromPortName(portName string) string

type Client

+ func (c Client) GetEndpoints(svc service.MeshService) (*corev1.Endpoints, error)

type Controller

+ GetEndpoints func(svc service.MeshService) (*corev1.Endpoints, error)

type InformerKey

+ const Endpoints

type MockController

+ func (m *MockController) GetEndpoints(arg0 service.MeshService) (*v1.Endpoints, error)

type MockControllerMockRecorder

+ func (mr *MockControllerMockRecorder) GetEndpoints(arg0 interface{}) *gomock.Call

Dec 15, 2020

Changes in this version

type Client

+ func (c Client) ListServiceAccountsForService(svc service.MeshService) ([]service.K8sServiceAccount, error)

type Controller

+ ListServiceAccountsForService func(svc service.MeshService) ([]service.K8sServiceAccount, error)

type EventType

+ const AddEvent

+ func (et EventType) String() string

+ type EventTypes struct

+ Add a.AnnouncementType

+ Delete a.AnnouncementType

+ Update a.AnnouncementType

type MockController

+ func (m *MockController) ListServiceAccountsForService(svc service.MeshService) ([]service.K8sServiceAccount, error)

type MockControllerMockRecorder

+ func (mr *MockControllerMockRecorder) ListServiceAccountsForService(svc interface{}) *gomock.Call

+ type PortForwarder struct

+ func NewPortForwarder(conf *rest.Config, clientSet kubernetes.Interface, podName string, ...) (*PortForwarder, error)

+ func (pf *PortForwarder) Start(readyFunc func(pf *PortForwarder) error) error

+ func (pf *PortForwarder) Stop()

Oct 5, 2020

Changes in this version

type Client

+ func (c Client) GetNamespace(ns string) *corev1.Namespace

+ func (c Client) ListPods() []*corev1.Pod

type Controller

+ GetNamespace func(ns string) *corev1.Namespace

+ ListPods func() []*corev1.Pod

type InformerKey

+ const Pods

type MockController

+ func (m *MockController) GetNamespace(arg0 string) *v1.Namespace

+ func (m *MockController) ListPods() []*v1.Pod

type MockControllerMockRecorder

+ func (mr *MockControllerMockRecorder) GetNamespace(arg0 interface{}) *gomock.Call

+ func (mr *MockControllerMockRecorder) ListPods() *gomock.Call

Sep 24, 2020

Changes in this version

+ const ProviderName

+ type Client struct

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

+ func (c Client) GetService(svc service.MeshService) *corev1.Service

+ func (c Client) IsMonitoredNamespace(namespace string) bool

+ func (c Client) ListMonitoredNamespaces() ([]string, error)

+ func (c Client) ListServices() []*corev1.Service

+ type Controller interface

+ GetAnnouncementsChannel func(informerID InformerKey) <-chan interface{}

+ GetService func(svc service.MeshService) *corev1.Service

+ IsMonitoredNamespace func(string) bool

+ ListMonitoredNamespaces func() ([]string, error)

+ ListServices func() []*corev1.Service

+ func NewKubernetesController(kubeClient kubernetes.Interface, meshName string, stop chan struct{}) (Controller, error)

+ type InformerCollection map[InformerKey]cache.SharedIndexInformer

+ type InformerKey string

+ const Namespaces

+ const Services

+ type MockController struct

+ func NewMockController(ctrl *gomock.Controller) *MockController

+ func (m *MockController) EXPECT() *MockControllerMockRecorder

+ func (m *MockController) GetAnnouncementsChannel(arg0 InformerKey) <-chan interface{}

+ func (m *MockController) GetService(arg0 service.MeshService) *v1.Service

+ func (m *MockController) IsMonitoredNamespace(arg0 string) bool

+ func (m *MockController) ListMonitoredNamespaces() ([]string, error)

+ func (m *MockController) ListServices() []*v1.Service

+ type MockControllerMockRecorder struct

+ func (mr *MockControllerMockRecorder) GetAnnouncementsChannel(arg0 interface{}) *gomock.Call

+ func (mr *MockControllerMockRecorder) GetService(arg0 interface{}) *gomock.Call

+ func (mr *MockControllerMockRecorder) IsMonitoredNamespace(arg0 interface{}) *gomock.Call

+ func (mr *MockControllerMockRecorder) ListMonitoredNamespaces() *gomock.Call

+ func (mr *MockControllerMockRecorder) ListServices() *gomock.Call

Aug 12, 2020

Changes in this version

+ func GetHostnamesForService(service *corev1.Service) []string

+ func GetServiceFromHostname(host string) string

Jul 31, 2020

Changes in this version

+ const DefaultKubeEventResyncInterval

+ func GetDomainsForService(service *corev1.Service) []string

+ func GetKubernetesEventHandlers(informerName string, providerName string, announcements chan interface{}, ...) cache.ResourceEventHandlerFuncs

+ type Event struct

+ Type EventType

+ Value interface{}

+ type EventType int

+ const CreateEvent

+ const DeleteEvent

+ const UpdateEvent