hub

package
v0.6.2 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2021 License: Apache-2.0 Imports: 24 Imported by: 16

Documentation

Index

Constants

View Source 
const KnownUID = "__known__"
View Source 
const PoolSize = 1024 // This number should match the max number of concurrent clusters handled

Variables

View Source 
var (
	KnownResources KV = &KVMap{
		cache: make(map[string]*v1alpha1.ResourceDescriptor),
	}
	KnownClasses = make(map[string]*v1alpha1.ResourceClass)
	LatestGVRs   = make(map[schema.GroupResource]schema.GroupVersionResource)
)

Functions

This section is empty.

Types

type HelmVersion added in v0.3.9 

type HelmVersion string
const (
	HelmUnused HelmVersion = ""
	Helm2      HelmVersion = "Helm 2"
	Helm3      HelmVersion = "Helm 3"
)

func DiscoverHelm added in v0.3.9 

func DiscoverHelm(cfg *rest.Config) (HelmVersion, string, error)

type KV 

type KV interface {
	Set(key string, val *v1alpha1.ResourceDescriptor)
	Get(key string) (*v1alpha1.ResourceDescriptor, bool)
	Visit(func(key string, val *v1alpha1.ResourceDescriptor))
}

func NewKVLocal 

func NewKVLocal() KV

type KVLocal 

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

KVLocal is not concurrent safe.

func (*KVLocal) Get 

func (s *KVLocal) Get(key string) (*v1alpha1.ResourceDescriptor, bool)

func (*KVLocal) Set 

func (s *KVLocal) Set(key string, val *v1alpha1.ResourceDescriptor)

func (*KVLocal) Visit 

func (s *KVLocal) Visit(f func(key string, val *v1alpha1.ResourceDescriptor))

type KVMap 

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

KVMap is concurrent safe.

func (*KVMap) Get 

func (s *KVMap) Get(key string) (*v1alpha1.ResourceDescriptor, bool)

func (*KVMap) Set 

func (s *KVMap) Set(key string, val *v1alpha1.ResourceDescriptor)

func (*KVMap) Visit 

func (s *KVMap) Visit(f func(key string, val *v1alpha1.ResourceDescriptor))

type Pool 

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

func MustPool 

func MustPool(kvFactory func() KV) *Pool

func NewPool 

func NewPool(kvFactory func() KV) (*Pool, error)

func (*Pool) GetRegistry 

func (p *Pool) GetRegistry(uid string, helm HelmVersion) *Registry

type Registry 

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

func NewRegistry 

func NewRegistry(uid string, helm HelmVersion, cache KV) *Registry

func NewRegistryOfKnownResources 

func NewRegistryOfKnownResources() *Registry

func (*Registry) CompleteResourcePanel added in v0.3.8 

func (r *Registry) CompleteResourcePanel() (*v1alpha1.ResourcePanel, error)

func (*Registry) DefaultResourcePanel 

func (r *Registry) DefaultResourcePanel() (*v1alpha1.ResourcePanel, error)

func (*Registry) DiscoverResources added in v0.3.3 

func (r *Registry) DiscoverResources(cfg *rest.Config) error

func (*Registry) ExistsGVK added in v0.5.5 

func (r *Registry) ExistsGVK(gvk schema.GroupVersionKind) (bool, error)

func (*Registry) ExistsGVR added in v0.5.5 

func (r *Registry) ExistsGVR(gvr schema.GroupVersionResource) (bool, error)

func (*Registry) GVK 

func (r *Registry) GVK(gvr schema.GroupVersionResource) (schema.GroupVersionKind, error)

func (*Registry) GVR 

func (r *Registry) GVR(gvk schema.GroupVersionKind) (schema.GroupVersionResource, error)

func (*Registry) IsNamespaced 

func (r *Registry) IsNamespaced(gvr schema.GroupVersionResource) (bool, error)

func (*Registry) IsPreferred added in v0.5.3 

func (r *Registry) IsPreferred(gvr schema.GroupVersionResource) (bool, error)

func (*Registry) LoadByFile 

func (r *Registry) LoadByFile(filename string) (*v1alpha1.ResourceDescriptor, error)

func (*Registry) LoadByGVR 

func (r *Registry) LoadByGVR(gvr schema.GroupVersionResource) (*v1alpha1.ResourceDescriptor, error)

func (*Registry) LoadByName 

func (r *Registry) LoadByName(name string) (*v1alpha1.ResourceDescriptor, error)

func (*Registry) Missing added in v0.3.11 

func (r *Registry) Missing(in schema.GroupVersionResource) bool

func (*Registry) Preferred added in v0.5.3 

func (r *Registry) Preferred(gvr schema.GroupVersionResource) (schema.GroupVersionResource, error)

func (*Registry) Refresh added in v0.3.11 

func (r *Registry) Refresh(cfg *rest.Config) error

func (*Registry) Register 

func (r *Registry) Register(gvr schema.GroupVersionResource, cfg *rest.Config) error

func (*Registry) Reset added in v0.5.6 

func (r *Registry) Reset()

func (*Registry) ResourceIDForGVK added in v0.5.6 

func (r *Registry) ResourceIDForGVK(gvk schema.GroupVersionKind) (*kmapi.ResourceID, error)

func (*Registry) ResourceIDForGVR added in v0.5.6 

func (r *Registry) ResourceIDForGVR(gvr schema.GroupVersionResource) (*kmapi.ResourceID, error)

func (*Registry) Resources 

func (r *Registry) Resources() []schema.GroupVersionResource

func (*Registry) SetHelmVersion added in v0.3.9 

func (r *Registry) SetHelmVersion(helm HelmVersion)

func (*Registry) TypeMeta 

func (r *Registry) TypeMeta(gvr schema.GroupVersionResource) (metav1.TypeMeta, error)

func (*Registry) Visit 

func (r *Registry) Visit(f func(key string, val *v1alpha1.ResourceDescriptor))

type UnregisteredErr 

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

func (UnregisteredErr) Error 

func (e UnregisteredErr) Error() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.