Versions in this module Expand all Collapse all v0 v0.1.0 Nov 28, 2019 Changes in this version + const ClusterLabel + const EdgeNodeName + const EdgeVersionLabel + const ResourceTypeClusterStatus + const ResourceTypeDaemonset + const ResourceTypeDeployment + const ResourceTypeEvent + const ResourceTypeNode + const ResourceTypePod + const ResourceTypeService + const ResourceTypeStatefulset + func NewReporterInitializers() map[string]InitFunc + type ClusterStatusReporter struct + func (c *ClusterStatusReporter) Run(stopCh <-chan struct{}) + type DaemonsetReporter struct + SyncChan chan clustermessage.ClusterMessage + type DaemonsetResourceStatus struct + DelMap map[string]*appsv1.DaemonSet + FullList []*appsv1.DaemonSet + UpdateMap map[string]*appsv1.DaemonSet + type DeploymentReporter struct + SyncChan chan clustermessage.ClusterMessage + type DeploymentResourceStatus struct + DelMap map[string]*appsv1.Deployment + FullList []*appsv1.Deployment + UpdateMap map[string]*appsv1.Deployment + type EventReporter struct + SyncChan chan clustermessage.ClusterMessage + type EventResourceStatus struct + DelMap map[string]*corev1.Event + FullList []*corev1.Event + UpdateMap map[string]*corev1.Event + type InitFunc func(ctx *ReporterContext) error + type NodeReporter struct + SyncChan chan clustermessage.ClusterMessage + type NodeResourceStatus struct + DelMap map[string]*corev1.Node + FullList []*corev1.Node + UpdateMap map[string]*corev1.Node + type PodReporter struct + SyncChan chan clustermessage.ClusterMessage + func (pr *PodReporter) Run(stopCh <-chan struct{}) error + func (pr *PodReporter) SetDelMap(name string, pod *corev1.Pod) + func (pr *PodReporter) SetUpdateMap(name string, pod *corev1.Pod) + type PodResourceStatus struct + DelMap map[string]*corev1.Pod + FullList []*corev1.Pod + UpdateMap map[string]*corev1.Pod + type Report struct + Body []byte + ResourceType int + type ReporterContext struct + ClusterName func() string + InformerFactory informers.SharedInformerFactory + KubeClient kubernetes.Interface + StopChan <-chan struct{} + SyncChan chan clustermessage.ClusterMessage + func (ctx *ReporterContext) IsValid() bool + type Reports []Report + func (r Reports) ToClusterMessage(clusterName string) (*clustermessage.ClusterMessage, error) + type ServiceReporter struct + SyncChan chan clustermessage.ClusterMessage + type ServiceResourceStatus struct + DelMap map[string]*corev1.Service + FullList []*corev1.Service + UpdateMap map[string]*corev1.Service
Go to main page