model

Documentation

Index

• Constants
• func IsObject(obj KubernetesResource) bool
• func SetID(obj *KubernetesResource)
• type ExecObject
• type ExecRequest
• type ExecRequests
• type K8SService
  • func (s *K8SService) Process(data []byte, k8sresource *KubernetesResource, evtype broker.EventType) error
• type KubernetesKeyValue
• type KubernetesResource
  • 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
• type KubernetesResourceSpec
• type KubernetesResourceStatus
• type LogObject
• type LogRequest
• type LogRequests
• type ProcessFunc
  • func GetProcessorInstance(kind string) ProcessFunc

Constants

const (
	KindLabel      string = "label"
	KindAnnotation string = "annotation"
)

Functions

func IsObject

func IsObject(obj KubernetesResource) bool

func SetID

func SetID(obj *KubernetesResource)

Types

type ExecObject

type ExecObject struct {
	ID   string `json:"id,omitempty"`
	Data string `json:"data,omitempty"`
}

type ExecRequest

type ExecRequest struct {
	ID        string `json:"id,omitempty"`
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
	Container string `json:"container,omitempty"`
	Stop      bool   `json:"stop,omitempty"`
}

type ExecRequests

type ExecRequests map[string]ExecRequest

type K8SService

type K8SService struct{}

func (*K8SService) Process

func (s *K8SService) Process(data []byte, k8sresource *KubernetesResource, evtype broker.EventType) error

type KubernetesKeyValue

type KubernetesKeyValue struct {
	ID       string `json:"id" gorm:"primarykey"`
	UniqueID string `json:"unique_id" gorm:"index"`
	Kind     string `json:"kind" gorm:"primarykey"`
	Key      string `json:"key,omitempty" gorm:"primarykey"`
	Value    string `json:"value,omitempty" gorm:"primarykey"`
}

type KubernetesResource

type KubernetesResource struct {
	ID                     string                        `json:"id" gorm:"primarykey"`
	APIVersion             string                        `json:"apiVersion" gorm:"index"`
	Kind                   string                        `json:"kind" gorm:"index"`
	KubernetesResourceMeta *KubernetesResourceObjectMeta `json:"metadata" gorm:"foreignkey:ID;references:id;constraint:OnUpdate:CASCADE,OnDelete:SET NULL;"`
	Spec                   *KubernetesResourceSpec       `json:"spec,omitempty" gorm:"foreignkey:ID;references:id;constraint:OnUpdate:CASCADE,OnDelete:SET NULL;"`
	Status                 *KubernetesResourceStatus     `json:"status,omitempty" gorm:"foreignkey:ID;references:id;constraint:OnUpdate:CASCADE,OnDelete:SET NULL;"`
	ClusterID              string                        `json:"cluster_id"`
	PatternResource        *uuid.UUID                    `json:"pattern_resource"`
	ComponentMetadata      map[string]interface{}        `json:"component_metadata" gorm:"type:bytes;serializer:json"`
	// Secondary fields for configsmaps and secrets
	Immutable  string `json:"immutable,omitempty"`
	Data       string `json:"data,omitempty"`
	BinaryData string `json:"binaryData,omitempty"`
	StringData string `json:"stringData,omitempty"`
	Type       string `json:"type,omitempty"`
}

func ParseList

func ParseList(object unstructured.Unstructured, eventType broker.EventType) KubernetesResource

func (*KubernetesResource) BeforeCreate

func (obj *KubernetesResource) BeforeCreate(tx *gorm.DB) (err error)

func (*KubernetesResource) BeforeDelete

func (obj *KubernetesResource) BeforeDelete(tx *gorm.DB) (err error)

func (*KubernetesResource) BeforeSave

func (obj *KubernetesResource) BeforeSave(tx *gorm.DB) (err error)

type KubernetesResourceObjectMeta

type KubernetesResourceObjectMeta struct {
	ID                         string                `json:"id" gorm:"primarykey"`
	Name                       string                `json:"name,omitempty" gorm:"index"`
	GenerateName               string                `json:"generateName,omitempty"`
	Namespace                  string                `json:"namespace,omitempty"`
	SelfLink                   string                `json:"selfLink,omitempty"`
	UID                        string                `json:"uid"`
	ResourceVersion            string                `json:"resourceVersion,omitempty"`
	Generation                 int64                 `json:"generation,omitempty"`
	CreationTimestamp          string                `json:"creationTimestamp,omitempty"`
	DeletionTimestamp          string                `json:"deletionTimestamp,omitempty"`
	DeletionGracePeriodSeconds *int64                `json:"deletionGracePeriodSeconds,omitempty"`
	Labels                     []*KubernetesKeyValue `json:"labels,omitempty" gorm:"foreignkey:ID;references:id;constraint:OnUpdate:CASCADE,OnDelete:SET NULL;"`
	Annotations                []*KubernetesKeyValue `json:"annotations,omitempty" gorm:"foreignkey:ID;references:id;constraint:OnUpdate:CASCADE,OnDelete:SET NULL;"`
	OwnerReferences            string                `json:"ownerReferences,omitempty" gorm:"-"`
	Finalizers                 string                `json:"finalizers,omitempty" gorm:"-"`
	ClusterName                string                `json:"clusterName,omitempty"`
	ManagedFields              string                `json:"managedFields,omitempty" gorm:"-"`
	ClusterID                  string                `json:"cluster_id"`
}

type KubernetesResourceSpec

type KubernetesResourceSpec struct {
	ID        string `json:"id" gorm:"primarykey"`
	Attribute string `json:"attribute,omitempty"`
}

type KubernetesResourceStatus

type KubernetesResourceStatus struct {
	ID        string `json:"id" gorm:"primarykey"`
	Attribute string `json:"attribute,omitempty"`
}

type LogObject

type LogObject struct {
	ID   string `json:"id,omitempty"`
	Data string `json:"data,omitempty"`
	// Name of Pod, Svc, Deply getting logs for
	Primary string `json:"primary,omitempty"`
	// Specific detail about the log like Container or Pod Name
	Secondary string `json:"secondary,omitempty"`
}

type LogRequest

type LogRequest struct {
	ID        string `json:"id,omitempty"`
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
	Container string `json:"container,omitempty"`
	Follow    bool   `json:"follow,omitempty"`
	Previous  bool   `json:"previous,omitempty"`
	TailLines int64  `json:"taillines,omitempty"`
	Stop      bool   `json:"stop,omitempty"`
}

type LogRequests

type LogRequests map[string]LogRequest

type ProcessFunc

type ProcessFunc interface {
	Process(obj []byte, k8sresource *KubernetesResource, evtype broker.EventType) error
}

func GetProcessorInstance

func GetProcessorInstance(kind string) ProcessFunc