Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetEventHandlerFuncs ¶
func GetEventHandlerFuncs(shouldObserve observeFilter, eventTypes EventTypes, msgBroker *messaging.Broker) cache.ResourceEventHandlerFuncs
GetEventHandlerFuncs returns the ResourceEventHandlerFuncs object used to receive events when a k8s object is added/updated/deleted.
Types ¶
type Controller ¶
type Controller interface {
// IsMonitoredNamespace returns whether a namespace with the given name is being monitored
// by the mesh
IsMonitoredNamespace(namespace string) bool
// ListMonitoredNamespaces returns the namespaces monitored by the mesh
ListMonitoredNamespaces() ([]string, error)
// GetNamespace returns k8s namespace present in cache
GetNamespace(namespace string) *corev1.Namespace
IsMonitoredPod(pod string, namespace string) bool
// ListAllPods returns all pods
ListAllPods() []*corev1.Pod
// ListMonitoredPods returns the pods monitored by the mesh
ListMonitoredPods() []*corev1.Pod
// ListSidecarPods returns the gateway pods as sidecar.
ListSidecarPods() []*corev1.Pod
}
Controller is the controller interface for K8s services
func NewKubernetesController ¶
func NewKubernetesController(informerCollection *informers.InformerCollection, msgBroker *messaging.Broker, meshExcludeNamespaces []string) Controller
NewKubernetesController returns a new kubernetes.Controller which means to provide access to locally-cached k8s resources
Click to show internal directories.
Click to hide internal directories.