Versions in this module Expand all Collapse all v0 v0.7.2 Jan 15, 2024 Changes in this version + const KindAnnotation + const KindLabel + func IsObject(obj KubernetesResource) bool + func SetID(obj *KubernetesResource) + type ExecObject struct + Data string + ID string + type ExecRequest struct + Container string + ID string + Name string + Namespace string + Stop bool + type ExecRequests map[string]ExecRequest + type K8SService struct + func (s *K8SService) Process(data []byte, k8sresource *KubernetesResource, evtype broker.EventType) error + type KubernetesKeyValue struct + ID string + Key string + Kind string + UniqueID string + Value string + type KubernetesResource struct + APIVersion string + BinaryData string + ClusterID string + ComponentMetadata map[string]interface{} + Data string + ID string + Immutable string + Kind string + KubernetesResourceMeta *KubernetesResourceObjectMeta + PatternResource *uuid.UUID + Spec *KubernetesResourceSpec + Status *KubernetesResourceStatus + StringData string + Type string + func ParseList(object unstructured.Unstructured, eventType broker.EventType) KubernetesResource + func (obj *KubernetesResource) BeforeCreate(tx *gorm.DB) (err error) + func (obj *KubernetesResource) BeforeDelete(tx *gorm.DB) (err error) + func (obj *KubernetesResource) BeforeSave(tx *gorm.DB) (err error) + type KubernetesResourceObjectMeta struct + Annotations []*KubernetesKeyValue + ClusterID string + ClusterName string + CreationTimestamp string + DeletionGracePeriodSeconds *int64 + DeletionTimestamp string + Finalizers string + GenerateName string + Generation int64 + ID string + Labels []*KubernetesKeyValue + ManagedFields string + Name string + Namespace string + OwnerReferences string + ResourceVersion string + SelfLink string + UID string + type KubernetesResourceSpec struct + Attribute string + ID string + type KubernetesResourceStatus struct + Attribute string + ID string + type LogObject struct + Data string + ID string + Primary string + Secondary string + type LogRequest struct + Container string + Follow bool + ID string + Name string + Namespace string + Previous bool + Stop bool + TailLines int64 + type LogRequests map[string]LogRequest + type ProcessFunc interface + Process func(obj []byte, k8sresource *KubernetesResource, evtype broker.EventType) error + func GetProcessorInstance(kind string) ProcessFunc