watch

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 17, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlameStatistics

type BlameStatistics struct {
	Managers     map[string]*ManagerStatistics `json:"managers"`
	LatestUpdate time.Time                     `json:"lastUpdate"`
}

func (*BlameStatistics) DeepCopy

func (in *BlameStatistics) DeepCopy() *BlameStatistics

func (*BlameStatistics) DeepCopyInto

func (in *BlameStatistics) DeepCopyInto(out *BlameStatistics)

type BlameWatcher

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

func NewBlameWatcher

func NewBlameWatcher(logger logr.Logger, kube *client.KubeClient, gvk schema.GroupVersionKind, resource string) *BlameWatcher

func (*BlameWatcher) Start

func (w *BlameWatcher) Start(ctx context.Context) error

func (*BlameWatcher) Statistics

func (w *BlameWatcher) Statistics() *BlameStatistics

type ManagerStatistics

type ManagerStatistics struct {
	UpdateCount int `json:"update"`
}

type NamespaceStatistics

type NamespaceStatistics struct {
	Resources map[string]*ResourceStatistics `json:"resources"`
}

func (*NamespaceStatistics) DeepCopy

func (in *NamespaceStatistics) DeepCopy() *NamespaceStatistics

func (*NamespaceStatistics) DeepCopyInto

func (in *NamespaceStatistics) DeepCopyInto(out *NamespaceStatistics)

type ResourceStatistics

type ResourceStatistics struct {
	AddCount    int `json:"add"`
	DeleteCount int `json:"delete"`
	UpdateCount int `json:"update"`
}

type Statistics

type Statistics struct {
	GroupVersionKind metav1.GroupVersionKind         `json:"gvk"`
	Namespaces       map[string]*NamespaceStatistics `json:"namespaces"`
}

func (*Statistics) DeepCopy

func (in *Statistics) DeepCopy() *Statistics

func (*Statistics) DeepCopyInto

func (in *Statistics) DeepCopyInto(out *Statistics)

type Watcher

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

func NewWatcher

func NewWatcher(logger logr.Logger, kube *client.KubeClient, gvk schema.GroupVersionKind, nsSelector labels.Selector, resSelector labels.Selector) *Watcher

func (*Watcher) Start

func (w *Watcher) Start(ctx context.Context) error

func (*Watcher) Statistics

func (w *Watcher) Statistics() *Statistics

func (*Watcher) Stop

func (w *Watcher) Stop() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL