94 lines
2.7 KiB
Go
94 lines
2.7 KiB
Go
package cli
|
|
|
|
import (
|
|
"context"
|
|
|
|
models "github.com/portainer/portainer/api/http/models/kubernetes"
|
|
corev1 "k8s.io/api/core/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
)
|
|
|
|
// GetEvents gets all the Events for a given namespace and resource
|
|
// If the user is a kube admin, it returns all events in the namespace
|
|
// Otherwise, it returns only the events in the non-admin namespaces
|
|
func (kcl *KubeClient) GetEvents(namespace string, resourceId string) ([]models.K8sEvent, error) {
|
|
if kcl.IsKubeAdmin {
|
|
return kcl.fetchAllEvents(namespace, resourceId)
|
|
}
|
|
|
|
return kcl.fetchEventsForNonAdmin(namespace, resourceId)
|
|
}
|
|
|
|
// fetchEventsForNonAdmin returns all events in the given namespace and resource
|
|
// It returns only the events in the non-admin namespaces
|
|
func (kcl *KubeClient) fetchEventsForNonAdmin(namespace string, resourceId string) ([]models.K8sEvent, error) {
|
|
if len(kcl.NonAdminNamespaces) == 0 {
|
|
return nil, nil
|
|
}
|
|
|
|
events, err := kcl.fetchAllEvents(namespace, resourceId)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
nonAdminNamespaceSet := kcl.buildNonAdminNamespacesMap()
|
|
results := make([]models.K8sEvent, 0)
|
|
for _, event := range events {
|
|
if _, ok := nonAdminNamespaceSet[event.Namespace]; ok {
|
|
results = append(results, event)
|
|
}
|
|
}
|
|
|
|
return results, nil
|
|
}
|
|
|
|
// fetchEventsForNonAdmin returns all events in the given namespace and resource
|
|
// It returns all events in the namespace and resource
|
|
func (kcl *KubeClient) fetchAllEvents(namespace string, resourceId string) ([]models.K8sEvent, error) {
|
|
options := metav1.ListOptions{}
|
|
if resourceId != "" {
|
|
options.FieldSelector = "involvedObject.uid=" + resourceId
|
|
}
|
|
|
|
list, err := kcl.cli.CoreV1().Events(namespace).List(context.TODO(), options)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
results := make([]models.K8sEvent, 0)
|
|
for _, event := range list.Items {
|
|
results = append(results, parseEvent(&event))
|
|
}
|
|
|
|
return results, nil
|
|
}
|
|
|
|
func parseEvent(event *corev1.Event) models.K8sEvent {
|
|
result := models.K8sEvent{
|
|
Type: event.Type,
|
|
Name: event.Name,
|
|
Message: event.Message,
|
|
Reason: event.Reason,
|
|
Namespace: event.Namespace,
|
|
EventTime: event.EventTime.UTC(),
|
|
Kind: event.Kind,
|
|
Count: event.Count,
|
|
UID: string(event.ObjectMeta.GetUID()),
|
|
InvolvedObjectKind: models.K8sEventInvolvedObject{
|
|
Kind: event.InvolvedObject.Kind,
|
|
UID: string(event.InvolvedObject.UID),
|
|
Name: event.InvolvedObject.Name,
|
|
Namespace: event.InvolvedObject.Namespace,
|
|
},
|
|
}
|
|
|
|
if !event.LastTimestamp.Time.IsZero() {
|
|
result.LastTimestamp = &event.LastTimestamp.Time
|
|
}
|
|
if !event.FirstTimestamp.Time.IsZero() {
|
|
result.FirstTimestamp = &event.FirstTimestamp.Time
|
|
}
|
|
|
|
return result
|
|
}
|