db

Mar 5, 2024

Changes in this version

type DB

+ func (db *DB) Dump(gvr types.GVR)

Feb 17, 2024

Changes in this version

+ func Cast[T any](o runtime.Object) (T, error)

+ func LoadResource[T metav1.ObjectMetaAccessor](ctx context.Context, l *Loader, gvr types.GVR) error

+ func MatchLabels(labels, sel map[string]string) bool

+ func MatchSelector(labels map[string]string, sel *metav1.LabelSelector) bool

+ func Save[T metav1.ObjectMetaAccessor](ctx context.Context, dba *DB, gvr types.GVR, oo []runtime.Object) error

+ type CastFn func(o runtime.Object) (*T, error)

+ type ConvertFn func(o runtime.Object) (any, error)

+ type DB struct

+ func NewDB(db *memdb.MemDB) *DB

+ func (db *DB) DumpNS() error

+ func (db *DB) Exists(kind types.GVR, fqn string) bool

+ func (db *DB) Find(kind types.GVR, fqn string) (any, error)

+ func (db *DB) FindJobs(fqn string) ([]*batchv1.Job, error)

+ func (db *DB) FindNMX(fqn string) (*mv1beta1.NodeMetrics, error)

+ func (db *DB) FindNS(ns string) (*v1.Namespace, error)

+ func (db *DB) FindNSBySel(sel *metav1.LabelSelector) ([]*v1.Namespace, error)

+ func (db *DB) FindNSNameBySel(sel *metav1.LabelSelector) ([]string, error)

+ func (db *DB) FindPMX(fqn string) (*mv1beta1.PodMetrics, error)

+ func (db *DB) FindPod(ns string, sel map[string]string) (*v1.Pod, error)

+ func (db *DB) FindPods(ns string, sel map[string]string) ([]*v1.Pod, error)

+ func (db *DB) FindPodsBySel(ns string, sel *metav1.LabelSelector) ([]*v1.Pod, error)

+ func (db *DB) ITFor(gvr types.GVR) (*memdb.Txn, memdb.ResultIterator, error)

+ func (db *DB) ListNMX() ([]*mv1beta1.NodeMetrics, error)

+ func (db *DB) ListNodes() (map[string]*v1.Node, error)

+ func (db *DB) MustITFor(gvr types.GVR) (*memdb.Txn, memdb.ResultIterator)

+ func (db *DB) MustITForNS(gvr types.GVR, ns string) (*memdb.Txn, memdb.ResultIterator)

+ type Loader struct

+ DB *DB

+ func NewLoader(db *DB) *Loader

+ func (l *Loader) LoadGeneric(ctx context.Context, gvr types.GVR) error

+ func (l *Loader) LoadNodeMX(ctx context.Context) error

+ func (l *Loader) LoadPodMX(ctx context.Context) error