discovery

Documentation

Index

• func HasListAndWatchVerbs(apiResource metav1.APIResource) bool
• type CustomResourceCache
• type DynamicDiscoveryManager
  • func NewDynamicDiscoveryManager(name string, discovery discovery.DiscoveryInterface) (*DynamicDiscoveryManager, error)
  • func (c *DynamicDiscoveryManager) AttachAllCustomResourcesToSyncResources(resources []clusterv1alpha2.ClusterGroupResources) []clusterv1alpha2.ClusterGroupResources
  • func (c *DynamicDiscoveryManager) GetAPIResourceAndVersions(resource schema.GroupResource) (*metav1.APIResource, []string)
  • func (c *DynamicDiscoveryManager) GetAllResourcesAsSyncResources() []clusterv1alpha2.ClusterGroupResources
  • func (c *DynamicDiscoveryManager) GetAndFetchServerVersion() (version.Info, error)
  • func (c *DynamicDiscoveryManager) GetResourcesAsSyncResourcesByGroup(group string) *clusterv1alpha2.ClusterGroupResources
  • func (c *DynamicDiscoveryManager) RemoveCustomResource(resource schema.GroupResource)
  • func (c *DynamicDiscoveryManager) ResolveGroupType(group string) GroupType
  • func (c *DynamicDiscoveryManager) Run(stopCh <-chan struct{})
  • func (c *DynamicDiscoveryManager) SetGroupVersions(groupVersions map[string][]string, aggregatorGroups sets.String)
  • func (c *DynamicDiscoveryManager) SetResourceMutationHandler(handler func())
  • func (c *DynamicDiscoveryManager) SetWatchAggregatorResourceTypes(watch bool)
  • func (c *DynamicDiscoveryManager) SetWatchServerVersion(watch bool)
  • func (c *DynamicDiscoveryManager) StorageVersion() version.Info
  • func (c *DynamicDiscoveryManager) UpdateCustomResource(resource schema.GroupResource, apiResource metav1.APIResource, ...)
• type GroupType
• type GroupVersionCache

Functions

func HasListAndWatchVerbs

func HasListAndWatchVerbs(apiResource metav1.APIResource) bool

Types

type CustomResourceCache

type CustomResourceCache interface {
	UpdateCustomResource(resource schema.GroupResource, apiResource metav1.APIResource, versions []string)
	RemoveCustomResource(resource schema.GroupResource)
}

type DynamicDiscoveryManager

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

func NewDynamicDiscoveryManager

func NewDynamicDiscoveryManager(name string, discovery discovery.DiscoveryInterface) (*DynamicDiscoveryManager, error)

func (*DynamicDiscoveryManager) AttachAllCustomResourcesToSyncResources

func (c *DynamicDiscoveryManager) AttachAllCustomResourcesToSyncResources(resources []clusterv1alpha2.ClusterGroupResources) []clusterv1alpha2.ClusterGroupResources

func (*DynamicDiscoveryManager) GetAPIResourceAndVersions

func (c *DynamicDiscoveryManager) GetAPIResourceAndVersions(resource schema.GroupResource) (*metav1.APIResource, []string)

func (*DynamicDiscoveryManager) GetAllResourcesAsSyncResources

func (c *DynamicDiscoveryManager) GetAllResourcesAsSyncResources() []clusterv1alpha2.ClusterGroupResources

func (*DynamicDiscoveryManager) GetAndFetchServerVersion

func (c *DynamicDiscoveryManager) GetAndFetchServerVersion() (version.Info, error)

func (*DynamicDiscoveryManager) GetResourcesAsSyncResourcesByGroup

func (c *DynamicDiscoveryManager) GetResourcesAsSyncResourcesByGroup(group string) *clusterv1alpha2.ClusterGroupResources

func (*DynamicDiscoveryManager) RemoveCustomResource

func (c *DynamicDiscoveryManager) RemoveCustomResource(resource schema.GroupResource)

func (*DynamicDiscoveryManager) ResolveGroupType

func (c *DynamicDiscoveryManager) ResolveGroupType(group string) GroupType

func (*DynamicDiscoveryManager) Run

func (c *DynamicDiscoveryManager) Run(stopCh <-chan struct{})

func (*DynamicDiscoveryManager) SetGroupVersions

func (c *DynamicDiscoveryManager) SetGroupVersions(groupVersions map[string][]string, aggregatorGroups sets.String)

func (*DynamicDiscoveryManager) SetResourceMutationHandler

func (c *DynamicDiscoveryManager) SetResourceMutationHandler(handler func())

func (*DynamicDiscoveryManager) SetWatchAggregatorResourceTypes

func (c *DynamicDiscoveryManager) SetWatchAggregatorResourceTypes(watch bool)

func (*DynamicDiscoveryManager) SetWatchServerVersion

func (c *DynamicDiscoveryManager) SetWatchServerVersion(watch bool)

func (*DynamicDiscoveryManager) StorageVersion

func (c *DynamicDiscoveryManager) StorageVersion() version.Info

func (*DynamicDiscoveryManager) UpdateCustomResource

func (c *DynamicDiscoveryManager) UpdateCustomResource(resource schema.GroupResource, apiResource metav1.APIResource, versions []string)

type GroupType

type GroupType int

const (
	KubeResource GroupType = iota
	CustomResource
	AggregatorResource
	UnknownResource
)

type GroupVersionCache

type GroupVersionCache interface {
	SetGroupVersions(groupVersions map[string][]string, aggregatorGroups sets.String)
}