hub

package
v0.10.9 Latest Latest
Warning

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

Go to latest
Published: Mar 23, 2022 License: Apache-2.0 Imports: 21 Imported by: 16

README

How to update Hub files in kube-ui-server

export UI_SERVER_NAMESPACE=kubeops
export UI_SERVER_POD=$(kubectl get pods -n $UI_SERVER_NAMESPACE -l app.kubernetes.io/instance=kube-ui-server -o jsonpath={.items[0].metadata.name})

kubectl cp hub $UI_SERVER_POD:/tmp -n $UI_SERVER_NAMESPACE
# verify
kubectl exec -it $UI_SERVER_POD -n $UI_SERVER_NAMESPACE -- ls -l /tmp/hub

LOCATION=hub/resourceeditors/kubedb.com/v1alpha2/elasticsearches.yaml
kubectl cp $LOCATION $UI_SERVER_POD:/tmp/$LOCATION -n $UI_SERVER_NAMESPACE
# verify
kubectl exec -it $UI_SERVER_POD -n $UI_SERVER_NAMESPACE -- cat /tmp/$LOCATION

# trigger reload
kubectl exec -it $UI_SERVER_POD -n $UI_SERVER_NAMESPACE -- sh -c "date > /tmp/hub/resourceeditors/trigger"
# verify
kubectl exec -it $UI_SERVER_POD -n $UI_SERVER_NAMESPACE -- cat /tmp/hub/resourceeditors/trigger

How to modify GET & LIST proxy calls

$ cd ~/go/src/kmodules.xyz/resource-metadata
$ ln -s $(pwd)/hub /tmp/hub

# Now modify the trigger file and refresh ui

Documentation

Index

Constants

View Source
const (
	CRDIconSVG = "https://cdn.appscode.com/k8s/icons/apiextensions.k8s.io/customresourcedefinitions.svg"
)
View Source
const KnownUID = "__known__"
View Source
const PoolSize = 1024 // This number should match the max number of concurrent clusters handled

Variables

This section is empty.

Functions

func IsUnregisteredErr added in v0.9.0

func IsUnregisteredErr(err error) bool

func ListEdgeLabels added in v0.8.0

func ListEdgeLabels(skipLabels ...kmapi.EdgeLabel) []kmapi.EdgeLabel

Types

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) *Registry

type Registry

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

func NewRegistry

func NewRegistry(uid string, cache KV) *Registry

func NewRegistryOfKnownResources

func NewRegistryOfKnownResources() *Registry

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) FindGVR added in v0.9.0

func (r *Registry) FindGVR(in *metav1.GroupKind, keepOfficialTypes bool) (schema.GroupVersionResource, bool)

func (*Registry) GVK

func (*Registry) GVR

func (*Registry) IsGVKNamespaced added in v0.8.0

func (r *Registry) IsGVKNamespaced(gvr schema.GroupVersionKind) (bool, error)

func (*Registry) IsGVRNamespaced added in v0.8.0

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

func (*Registry) IsPreferred added in v0.5.3

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

func (*Registry) Kinds added in v0.8.0

func (r *Registry) Kinds() []schema.GroupVersionKind

func (*Registry) LoadByFile

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

func (*Registry) LoadByGVK added in v0.8.0

func (*Registry) LoadByGVR

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 (*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(in schema.GroupVersionKind) (*kmapi.ResourceID, error)

func (*Registry) ResourceIDForGVR added in v0.5.6

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

func (*Registry) Resources

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

func (*Registry) TypeMeta

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

Jump to

Keyboard shortcuts

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