Versions in this module Expand all Collapse all v0 v0.1.0 Nov 28, 2019 Changes in this version + const UniqueResourceNameSeparator + func DaemonsetReportStatusDeserialize(b []byte) (*reporter.DaemonsetResourceStatus, error) + func DeploymentReportStatusDeserialize(b []byte) (*reporter.DeploymentResourceStatus, error) + func EventReportStatusDeserialize(b []byte) (*reporter.EventResourceStatus, error) + func NodeReportStatusDeserialize(b []byte) (*reporter.NodeResourceStatus, error) + func PodReportStatusDeserialize(b []byte) (*reporter.PodResourceStatus, error) + func ReportDeserialize(b []byte) ([]reporter.Report, error) + func ServiceReportStatusDeserialize(b []byte) (*reporter.ServiceResourceStatus, error) + func UniqueResourceName(obj *metav1.ObjectMeta) error + type ControllerContext struct + PublishChan chan clustermessage.ClusterMessage + StopChan <-chan struct{} + type InitFunc func(ctx *ControllerContext) error + type K8sContext struct + InformerFactory informers.SharedInformerFactory + K8sClient kubernetes.Interface + OteClient oteclient.Interface + OteInformerFactory oteinformer.SharedInformerFactory + type UpstreamProcessor struct + func NewUpstreamProcessor(ctx *K8sContext) *UpstreamProcessor + func (u *UpstreamProcessor) CenterCreateEvent(updateMap map[string]*corev1.Event) + func (u *UpstreamProcessor) CenterDeleteEvent(delMap map[string]*corev1.Event) + func (u *UpstreamProcessor) CreateDaemonset(daemonset *appsv1.DaemonSet) error + func (u *UpstreamProcessor) CreateDeployment(deployment *appsv1.Deployment) error + func (u *UpstreamProcessor) CreateEvent(event *corev1.Event) error + func (u *UpstreamProcessor) CreateNode(node *corev1.Node) error + func (u *UpstreamProcessor) CreateOrUpdateDaemonset(daemonset *appsv1.DaemonSet) error + func (u *UpstreamProcessor) CreateOrUpdateDeployment(deployment *appsv1.Deployment) error + func (u *UpstreamProcessor) CreateOrUpdateNode(node *corev1.Node) error + func (u *UpstreamProcessor) CreateOrUpdatePod(pod *corev1.Pod) error + func (u *UpstreamProcessor) CreateOrUpdateService(service *corev1.Service) error + func (u *UpstreamProcessor) CreatePod(pod *corev1.Pod) error + func (u *UpstreamProcessor) CreateService(service *corev1.Service) error + func (u *UpstreamProcessor) DeleteDaemonset(daemonset *appsv1.DaemonSet) error + func (u *UpstreamProcessor) DeleteDeployment(deployment *appsv1.Deployment) error + func (u *UpstreamProcessor) DeleteEvent(event *corev1.Event) error + func (u *UpstreamProcessor) DeleteNode(node *corev1.Node) error + func (u *UpstreamProcessor) DeletePod(pod *corev1.Pod) error + func (u *UpstreamProcessor) DeleteService(service *corev1.Service) error + func (u *UpstreamProcessor) GetDaemonset(daemonset *appsv1.DaemonSet) (*appsv1.DaemonSet, error) + func (u *UpstreamProcessor) GetDeployment(deployment *appsv1.Deployment) (*appsv1.Deployment, error) + func (u *UpstreamProcessor) GetNode(node *corev1.Node) (*corev1.Node, error) + func (u *UpstreamProcessor) GetPod(pod *corev1.Pod) (*corev1.Pod, error) + func (u *UpstreamProcessor) GetService(service *corev1.Service) (*corev1.Service, error) + func (u *UpstreamProcessor) HandleReceivedMessage(client string, data []byte) (ret error) + func (u *UpstreamProcessor) UpdateClusterStatus(clustername string, status *otev1.ClusterStatus) error + func (u *UpstreamProcessor) UpdateDaemonset(daemonset *appsv1.DaemonSet) error + func (u *UpstreamProcessor) UpdateDeployment(deployment *appsv1.Deployment) error + func (u *UpstreamProcessor) UpdateNode(node *corev1.Node) error + func (u *UpstreamProcessor) UpdatePod(pod *corev1.Pod) error + func (u *UpstreamProcessor) UpdateService(service *corev1.Service) error
Go to main page