reporter

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

type DaemonsetReporter struct {
	SyncChan chan clustermessage.ClusterMessage
	// contains filtered or unexported fields
}

type DaemonsetResourceStatus struct {
	// UpdateMap stores created/updated resource obj.
	UpdateMap map[string]*appsv1.DaemonSet `json:"updateMap"`
	// DelMap stores deleted resource obj.
	DelMap map[string]*appsv1.DaemonSet `json:"delMap"`
	// FullList stores full resource obj.
	FullList []*appsv1.DaemonSet `json:"fullList"`
}

type DeploymentReporter struct {
	SyncChan chan clustermessage.ClusterMessage
	// contains filtered or unexported fields
}

type DeploymentResourceStatus struct {
	// UpdateMap stores created/updated resource obj.
	UpdateMap map[string]*appsv1.Deployment `json:"updateMap"`
	// DelMap stores deleted resource obj.
	DelMap map[string]*appsv1.Deployment `json:"delMap"`
	// FullList stores full resource obj.
	FullList []*appsv1.Deployment `json:"fullList"`
}

type EventReporter struct {
	SyncChan chan clustermessage.ClusterMessage
	// contains filtered or unexported fields
}

type EventResourceStatus struct {
	// UpdateMap stores created/updated resource obj.
	UpdateMap map[string]*corev1.Event `json:"updateMap"`
	// DelMap stores deleted resource obj.
	DelMap map[string]*corev1.Event `json:"delMap"`
	// FullList stores full resource obj.
	FullList []*corev1.Event `json:"fullList"`
}

type InitFunc func(ctx *ReporterContext) error

type NodeReporter struct {
	SyncChan chan clustermessage.ClusterMessage
	// contains filtered or unexported fields
}

type NodeResourceStatus struct {
	// UpdateMap stores created/updated resource obj.
	UpdateMap map[string]*corev1.Node `json:"updateMap"`
	// DelMap stores deleted resource obj.
	DelMap map[string]*corev1.Node `json:"delMap"`
	// FullList stores full resource obj.
	FullList []*corev1.Node `json:"fullList"`
}

type PodReporter struct {
	SyncChan chan clustermessage.ClusterMessage
	// contains filtered or unexported fields
}

type PodResourceStatus struct {
	// UpdateMap stores created/updated resource obj.
	UpdateMap map[string]*corev1.Pod `json:"updateMap"`
	// DelMap stores deleted resource obj.
	DelMap map[string]*corev1.Pod `json:"delMap"`
	// FullList stores full resource obj.
	FullList []*corev1.Pod `json:"fullList"`
}

type Report struct {
	ResourceType int `json:"resourceType"`
	// Body defines different resource status.
	Body []byte `json:"body"`
}

type ReporterContext struct {
	// InformerFactory gives access to informers for the reporter.
	InformerFactory informers.SharedInformerFactory
	// ClusterName gets the cluster name.
	ClusterName func() string
	// SyncChan is used for synchronizing status of the edge cluster.
	SyncChan chan clustermessage.ClusterMessage
	// StopChan is the stop channel.
	StopChan <-chan struct{}
	// KubeClient is the kubernetes client interface for the reporter to use.
	KubeClient kubernetes.Interface
}

type Reports []Report

type ServiceReporter struct {
	SyncChan chan clustermessage.ClusterMessage
	// contains filtered or unexported fields
}

type ServiceResourceStatus struct {
	// UpdateMap stores created/updated resource obj.
	UpdateMap map[string]*corev1.Service `json:"updateMap"`
	// DelMap stores deleted resource obj.
	DelMap map[string]*corev1.Service `json:"delMap"`
	// FullList stores full resource obj.
	FullList []*corev1.Service `json:"fullList"`
}