k8s

Documentation

Index

• Constants
• type Container
• type K8SResourceType
• type K8sCollector
  • func NewK8sCollector(parentCtx context.Context) (*K8sCollector, error)
  • func (k *K8sCollector) Done() <-chan struct{}
  • func (k *K8sCollector) GetK8sVersion() string
  • func (k *K8sCollector) Init(events chan interface{}) error
• type K8sNamespaceResources
• type K8sResourceMessage

Constants

const (
	SERVICE     = "Service"
	POD         = "Pod"
	REPLICASET  = "ReplicaSet"
	DEPLOYMENT  = "Deployment"
	ENDPOINTS   = "Endpoints"
	CONTAINER   = "Container"
	DAEMONSET   = "DaemonSet"
	STATEFULSET = "StatefulSet"
)

const (
	ADD    = "Add"
	UPDATE = "Update"
	DELETE = "Delete"
)

Types

type Container

type Container struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	PodUID    string `json:"pod"` // Pod UID
	Image     string `json:"image"`
	Ports     []struct {
		Port     int32  `json:"port"`
		Protocol string `json:"protocol"`
	} `json:"ports"`
}

type K8SResourceType

type K8SResourceType string

type K8sCollector

type K8sCollector struct {
	Events chan interface{}
	// contains filtered or unexported fields
}

func NewK8sCollector

func NewK8sCollector(parentCtx context.Context) (*K8sCollector, error)

func (*K8sCollector) Done

func (k *K8sCollector) Done() <-chan struct{}

func (*K8sCollector) GetK8sVersion

func (k *K8sCollector) GetK8sVersion() string

func (*K8sCollector) Init

func (k *K8sCollector) Init(events chan interface{}) error

type K8sNamespaceResources

type K8sNamespaceResources struct {
	Pods     map[string]corev1.Pod     `json:"pods"`     // map[podName]Pod
	Services map[string]corev1.Service `json:"services"` // map[serviceName]Service
}

type K8sResourceMessage

type K8sResourceMessage struct {
	ResourceType string      `json:"type"`
	EventType    string      `json:"eventType"`
	Object       interface{} `json:"object"`
}