cache

Documentation

Index

• Constants
• func FQN(ns, n string) string
• func ListAvailableMetrics(db *db.DB) (v1.ResourceList, error)
• func MatchLabels(labels, sel map[string]string) bool
• func MetaFQN(m metav1.ObjectMeta) string
• func ResFqn(k, s string) string
• type Cluster
  • func NewCluster(v *semver.Version) *Cluster
  • func (c *Cluster) ListVersion() (*semver.Version, error)
• type ClusterRole
  • func NewClusterRole(db *db.DB) *ClusterRole
  • func (r *ClusterRole) AggregationMatchers(refs *sync.Map)
• type ClusterRoleBinding
  • func NewClusterRoleBinding(db *db.DB) *ClusterRoleBinding
  • func (c *ClusterRoleBinding) ClusterRoleRefs(refs *sync.Map)
• type Ingress
  • func NewIngress(db *db.DB) *Ingress
  • func (d *Ingress) IngressRefs(refs *sync.Map) error
• type Pod
  • func NewPod(dba *db.DB) *Pod
  • func (p *Pod) PodRefs(refs *sync.Map) error
• type RoleBinding
  • func NewRoleBinding(db *db.DB) *RoleBinding
  • func (r *RoleBinding) RoleRefs(refs *sync.Map)
• type ServiceAccount
  • func NewServiceAccount(db *db.DB) *ServiceAccount
  • func (s *ServiceAccount) ServiceAccountRefs(refs *sync.Map) error

Constants

const (
	// SecretKey tracks Secret resource references
	SecretKey = "sec"

	// ClusterRoleKey tracks ClusterRole resource references
	ClusterRoleKey = "clusterrole"

	// ConfigMapKey tracks ConfigMap resource references
	ConfigMapKey = "cm"
)

const ClusterKey = "cl"

ClusterKey tracks Cluster resource references

const IngressKey = "ing"

IngressKey tracks Ingress resource references

const RoleKey = "role"

RoleKey represents a role identifier.

Functions

func FQN

func FQN(ns, n string) string

FQN returns a fully qualified resource identifier.

func ListAvailableMetrics

func ListAvailableMetrics(db *db.DB) (v1.ResourceList, error)

ListAvailableMetrics return the total cluster available cpu/mem.

func MatchLabels

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

MatchLabels check if pod labels match a selector.

func MetaFQN

func MetaFQN(m metav1.ObjectMeta) string

MetaFQN returns a fully qualified resource identifier based on object meta.

func ResFqn

func ResFqn(k, s string) string

ResFqn returns a resource specific fqn.

Types

type Cluster

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

Cluster represents Cluster cache.

func NewCluster

func NewCluster(v *semver.Version) *Cluster

NewCluster returns a new Cluster cache.

func (*Cluster) ListVersion

func (c *Cluster) ListVersion() (*semver.Version, error)

ListVersion returns cluster server version.

type ClusterRole

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

ClusterRole represents ClusterRole cache.

func NewClusterRole

func NewClusterRole(db *db.DB) *ClusterRole

NewClusterRole returns a new ClusterRole cache.

func (*ClusterRole) AggregationMatchers

func (r *ClusterRole) AggregationMatchers(refs *sync.Map)

RoleRefs computes all role external references.

type ClusterRoleBinding

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

ClusterRoleBinding represents ClusterRoleBinding cache.

func NewClusterRoleBinding

func NewClusterRoleBinding(db *db.DB) *ClusterRoleBinding

NewClusterRoleBinding returns a new ClusterRoleBinding cache.

func (*ClusterRoleBinding) ClusterRoleRefs

func (c *ClusterRoleBinding) ClusterRoleRefs(refs *sync.Map)

ClusterRoleRefs computes all clusterrole external references.

type Ingress

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

Ingress represents Ingress cache.

func NewIngress

func NewIngress(db *db.DB) *Ingress

NewIngress returns a new Ingress cache.

func (*Ingress) IngressRefs

func (d *Ingress) IngressRefs(refs *sync.Map) error

IngressRefs computes all ingress external references.

type Pod

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

Pod represents a Pod cache.

func NewPod

func NewPod(dba *db.DB) *Pod

NewPod returns a Pod cache.

func (*Pod) PodRefs

func (p *Pod) PodRefs(refs *sync.Map) error

PodRefs computes all pods external references.

type RoleBinding

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

RoleBinding represents RoleBinding cache.

func NewRoleBinding

func NewRoleBinding(db *db.DB) *RoleBinding

NewRoleBinding returns a new RoleBinding cache.

func (*RoleBinding) RoleRefs

func (r *RoleBinding) RoleRefs(refs *sync.Map)

RoleRefs computes all role external references.

type ServiceAccount

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

ServiceAccount tracks serviceaccounts.

func NewServiceAccount

func NewServiceAccount(db *db.DB) *ServiceAccount

NewServiceAccount returns a new serviceaccount loader.

func (*ServiceAccount) ServiceAccountRefs

func (s *ServiceAccount) ServiceAccountRefs(refs *sync.Map) error

ServiceAccountRefs computes all serviceaccount external references.