resouce_cache

Documentation

Index

• Variables
• func AddSearcherByKubeconfig(kubeconfigBytes []byte, namespace string) error
• func ConvertGvkToApiResource(gvk *schema.GroupVersionKind, grs []*restmapper.APIGroupResources) (*metav1.APIResource, error)
• func ConvertRuntimeObjectToCRD(obj runtime.Object) (*apiextensions.CustomResourceDefinition, error)
• func GetAllAppNameByNamespace(kubeconfigBytes []byte, ns string) sets.String
• func GetApiGroupResources(kubeBytes []byte, ns string) ([]*restmapper.APIGroupResources, error)
• func RemoveSearcherByKubeconfig(kubeconfigBytes []byte, namespace string) error
• type GvkGvrWithAlias
  • func ConvertCRDToGgwa(crdObj *apiextensions.CustomResourceDefinition, ...) []GvkGvrWithAlias
  • func (g *GvkGvrWithAlias) GetFullName() string
• type ResourceEventHandlerFuncs
  • func NewResourceEventHandlerFuncs(resource informers.GenericInformer, kubeconfigBytes []byte, ...) *ResourceEventHandlerFuncs
  • func (r *ResourceEventHandlerFuncs) OnAdd(interface{})
  • func (r *ResourceEventHandlerFuncs) OnDelete(obj interface{})
  • func (r *ResourceEventHandlerFuncs) OnUpdate(_, _ interface{})
• type Searcher
  • func GetSearcherWithLRU(kubeconfigBytes []byte, namespace string) (search *Searcher, err error)
  • func (s *Searcher) Criteria() *criteria
  • func (s *Searcher) GetKubeconfigBytes() []byte
  • func (s *Searcher) GetResourceInfo(resourceType string) (GvkGvrWithAlias, error)
  • func (s *Searcher) GetSupportSchema() *sync.Map
  • func (s *Searcher) Start()
  • func (s *Searcher) Stop()

Variables

var GroupToTypeMap = []struct {
	K string
	V []string
}{
	{
		K: "Workloads",
		V: []string{
			"Deployment.v1.apps",
			"StatefulSet.v1.apps",
			"DaemonSet.v1.apps",
			"Job.v1.batch",
			"CronJob.v1beta1.batch",
			"CronJob.v1.batch",
			"Pod.v1.",
		},
	},
	{
		K: "Networks",
		V: []string{
			"Service.v1.",
			"Endpoints.v1.",
			"Ingress.v1.networking.k8s.io",
			"NetworkPolicy.v1.networking.k8s.io",
		},
	},
	{
		K: "Configurations",
		V: []string{
			"ConfigMap.v1.",
			"Secret.v1.",
			"HorizontalPodAutoscaler.v1.autoscaling",
			"ResourceQuota.v1.",
			"PodDisruptionBudget.v1.policy",
		},
	},
	{
		K: "Storages",
		V: []string{
			"PersistentVolume.v1.",
			"PersistentVolumeClaim.v1.",
			"StorageClass.v1.storage.k8s.io",
		},
	},
}

GroupToTypeMap K: Workloads/Networks/Configurations V: deployments/statefulset

Functions

func AddSearcherByKubeconfig

func AddSearcherByKubeconfig(kubeconfigBytes []byte, namespace string) error

AddSearcherByKubeconfig init informer in advance

func ConvertGvkToApiResource

func ConvertGvkToApiResource(gvk *schema.GroupVersionKind, grs []*restmapper.APIGroupResources) (*metav1.APIResource, error)

func ConvertRuntimeObjectToCRD

func ConvertRuntimeObjectToCRD(obj runtime.Object) (*apiextensions.CustomResourceDefinition, error)

func GetAllAppNameByNamespace

func GetAllAppNameByNamespace(kubeconfigBytes []byte, ns string) sets.String

func GetApiGroupResources

func GetApiGroupResources(kubeBytes []byte, ns string) ([]*restmapper.APIGroupResources, error)

func RemoveSearcherByKubeconfig

func RemoveSearcherByKubeconfig(kubeconfigBytes []byte, namespace string) error

RemoveSearcherByKubeconfig remove informer from cache

Types

type GvkGvrWithAlias

type GvkGvrWithAlias struct {
	Gvr schema.GroupVersionResource
	Gvk schema.GroupVersionKind

	// namespaced indicates if a resource is namespaced or not.
	Namespaced bool
	// contains filtered or unexported fields
}

func ConvertCRDToGgwa

func ConvertCRDToGgwa(crdObj *apiextensions.CustomResourceDefinition, agrs []*restmapper.APIGroupResources) []GvkGvrWithAlias

func (*GvkGvrWithAlias) GetFullName

func (g *GvkGvrWithAlias) GetFullName() string

type ResourceEventHandlerFuncs

type ResourceEventHandlerFuncs struct {
	cache.ResourceEventHandler

	Gvr schema.GroupVersionResource
	// contains filtered or unexported fields
}

func NewResourceEventHandlerFuncs

func NewResourceEventHandlerFuncs(resource informers.GenericInformer, kubeconfigBytes []byte, gvr schema.GroupVersionResource) *ResourceEventHandlerFuncs

func (*ResourceEventHandlerFuncs) OnAdd

func (r *ResourceEventHandlerFuncs) OnAdd(interface{})

func (*ResourceEventHandlerFuncs) OnDelete

func (r *ResourceEventHandlerFuncs) OnDelete(obj interface{})

func (*ResourceEventHandlerFuncs) OnUpdate

func (r *ResourceEventHandlerFuncs) OnUpdate(_, _ interface{})

type Searcher

type Searcher struct {
	SupportSchemaList []GvkGvrWithAlias
	// contains filtered or unexported fields
}

func GetSearcherWithLRU

func GetSearcherWithLRU(kubeconfigBytes []byte, namespace string) (search *Searcher, err error)

GetSearcherWithLRU GetSearchWithLRU will cache kubeconfig with LRU

func (*Searcher) Criteria

func (s *Searcher) Criteria() *criteria

func (*Searcher) GetKubeconfigBytes

func (s *Searcher) GetKubeconfigBytes() []byte

func (*Searcher) GetResourceInfo

func (s *Searcher) GetResourceInfo(resourceType string) (GvkGvrWithAlias, error)

func (*Searcher) GetSupportSchema

func (s *Searcher) GetSupportSchema() *sync.Map

func (*Searcher) Start

func (s *Searcher) Start()

Start wait searcher to close

func (*Searcher) Stop

func (s *Searcher) Stop()

Stop to stop the searcher