k8s

Documentation

Index

• Constants
• Variables
• func GetAllResources(discoveryClient discovery.ServerResourcesInterface) (map[schema.GroupVersionResource]struct{}, error)
• type ChangeCollector
  • func NewChangeCollector(eventCollectionInterval time.Duration, backupCollectionInterval time.Duration, ...) *ChangeCollector
  • func (c *ChangeCollector) OnAdd(obj interface{})
  • func (c *ChangeCollector) OnDelete(obj interface{})
  • func (c *ChangeCollector) OnUpdate(oldObj, newObj interface{})
  • func (c *ChangeCollector) Start(ctx context.Context) error
• type ControllerFactory
  • func NewControllerFactory(controllerInitFunc ControllerInitFunc) *ControllerFactory
  • func (factory *ControllerFactory) AddControllerForGvk(gvk schema.GroupVersionKind) error
  • func (factory *ControllerFactory) DoesControllerExistForGvk(gvk schema.GroupVersionKind) bool
• type ControllerInitFunc
• type Metrics
  • func NewMetrics() *Metrics
• type TrafficCollector
  • func NewTrafficCollector(informerFactory dynamicinformer.DynamicSharedInformerFactory, ...) *TrafficCollector
  • func (c *TrafficCollector) Start(ctx context.Context) error

Constants

const EventTypeKey = "event_type"

const ObjectKindKey = "object_kind"

Variables

var BackupGVRs = []schema.GroupVersionResource{
	cronjobGVR,
	daemonsetGVR,
	deploymentGVR,
	endpointSliceGVR,
	endpointsGVR,
	jobGVR,
	namespaceGVR,
	nodeGVR,
	podGVR,
	serviceGVR,
	statefulsetGVR,
}

var WatchedGVRs = []schema.GroupVersionResource{
	configMapGVR,
	cronjobGVR,
	daemonsetGVR,
	deploymentGVR,
	endpointSliceGVR,
	endpointsGVR,
	hpaGVR,
	ingressGVR,
	ingressclassGVR,
	jobGVR,
	kedaScaledObjectGVR,
	mutatingWebhookGVR,
	namespaceGVR,
	networkpolicyGVR,
	nodeGVR,
	persistentvolumeGVR,
	persistentvolumeclaimGVR,
	podGVR,
	podtemplateGVR,
	priorityclassGVR,
	replicasetGVR,
	resourcequotaGVR,
	secretGVR,
	serviceGVR,
	serviceaccountGVR,
	statefulsetGVR,
	validatingWebhookGVR,
	vpaGVR,
}

Functions

func GetAllResources

func GetAllResources(discoveryClient discovery.ServerResourcesInterface) (map[schema.GroupVersionResource]struct{}, error)

Types

type ChangeCollector

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

func NewChangeCollector

func NewChangeCollector(
	eventCollectionInterval time.Duration,
	backupCollectionInterval time.Duration,
	informerFactory dynamicinformer.DynamicSharedInformerFactory,
	discoveryClient discovery.ServerResourcesInterface,
	logger zerolog.Logger,
	client api.Client,
) *ChangeCollector

func (*ChangeCollector) OnAdd

func (c *ChangeCollector) OnAdd(obj interface{})

func (*ChangeCollector) OnDelete

func (c *ChangeCollector) OnDelete(obj interface{})

func (*ChangeCollector) OnUpdate

func (c *ChangeCollector) OnUpdate(oldObj, newObj interface{})

func (*ChangeCollector) Start

func (c *ChangeCollector) Start(ctx context.Context) error

type ControllerFactory

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

func NewControllerFactory

func NewControllerFactory(controllerInitFunc ControllerInitFunc) *ControllerFactory

func (*ControllerFactory) AddControllerForGvk

func (factory *ControllerFactory) AddControllerForGvk(gvk schema.GroupVersionKind) error

AddControllerForGvk adds a controller for GVK with factory's ControllerInitFunc it's up to the client to make sure the gvk is registered with workload cluster

func (*ControllerFactory) DoesControllerExistForGvk

func (factory *ControllerFactory) DoesControllerExistForGvk(gvk schema.GroupVersionKind) bool

type ControllerInitFunc

type ControllerInitFunc func(gvk schema.GroupVersionKind) error

type Metrics

type Metrics struct {
	ChangeEventCounter *prometheus.CounterVec
}

func NewMetrics

func NewMetrics() *Metrics

type TrafficCollector

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

func NewTrafficCollector

func NewTrafficCollector(
	informerFactory dynamicinformer.DynamicSharedInformerFactory,
	interval time.Duration,
	podSelector labels.Selector,
	serverPort,
	metricsPort int,
	logger zerolog.Logger,
	client api.Client,
) *TrafficCollector

func (*TrafficCollector) Start

func (c *TrafficCollector) Start(ctx context.Context) error