dynamicmapper

Documentation

Index

• type FakeDiscovery
  • func (c *FakeDiscovery) OpenAPISchema() (*openapi_v2.Document, error)
  • func (c *FakeDiscovery) RESTClient() restclient.Interface
  • func (c *FakeDiscovery) ServerGroups() (*metav1.APIGroupList, error)
  • func (c *FakeDiscovery) ServerGroupsAndResources() ([]*metav1.APIGroup, []*metav1.APIResourceList, error)
  • func (c *FakeDiscovery) ServerPreferredNamespacedResources() ([]*metav1.APIResourceList, error)
  • func (c *FakeDiscovery) ServerPreferredResources() ([]*metav1.APIResourceList, error)
  • func (c *FakeDiscovery) ServerResources() ([]*metav1.APIResourceList, error)
  • func (c *FakeDiscovery) ServerResourcesForGroupVersion(groupVersion string) (*metav1.APIResourceList, error)
  • func (c *FakeDiscovery) ServerVersion() (*version.Info, error)
  • func (c *FakeDiscovery) SwaggerSchema(version schema.GroupVersion) (*swagger.ApiDeclaration, error)
• type RegeneratingDiscoveryRESTMapper
  • func NewRESTMapper(discoveryClient discovery.DiscoveryInterface, refreshInterval time.Duration) (*RegeneratingDiscoveryRESTMapper, error)
  • func (m *RegeneratingDiscoveryRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error)
  • func (m *RegeneratingDiscoveryRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error)
  • func (m *RegeneratingDiscoveryRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)
  • func (m *RegeneratingDiscoveryRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error)
  • func (m *RegeneratingDiscoveryRESTMapper) RegenerateMappings() error
  • func (m *RegeneratingDiscoveryRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)
  • func (m *RegeneratingDiscoveryRESTMapper) ResourceSingularizer(resource string) (singular string, err error)
  • func (m *RegeneratingDiscoveryRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)
  • func (m *RegeneratingDiscoveryRESTMapper) RunUntil(stop <-chan struct{})

Types

type FakeDiscovery

type FakeDiscovery struct {
	*testing.Fake
}

func (*FakeDiscovery) OpenAPISchema

func (c *FakeDiscovery) OpenAPISchema() (*openapi_v2.Document, error)

func (*FakeDiscovery) RESTClient

func (c *FakeDiscovery) RESTClient() restclient.Interface

func (*FakeDiscovery) ServerGroups

func (c *FakeDiscovery) ServerGroups() (*metav1.APIGroupList, error)

func (*FakeDiscovery) ServerGroupsAndResources

func (c *FakeDiscovery) ServerGroupsAndResources() ([]*metav1.APIGroup, []*metav1.APIResourceList, error)

func (*FakeDiscovery) ServerPreferredNamespacedResources

func (c *FakeDiscovery) ServerPreferredNamespacedResources() ([]*metav1.APIResourceList, error)

func (*FakeDiscovery) ServerPreferredResources

func (c *FakeDiscovery) ServerPreferredResources() ([]*metav1.APIResourceList, error)

func (*FakeDiscovery) ServerResources

func (c *FakeDiscovery) ServerResources() ([]*metav1.APIResourceList, error)

func (*FakeDiscovery) ServerResourcesForGroupVersion

func (c *FakeDiscovery) ServerResourcesForGroupVersion(groupVersion string) (*metav1.APIResourceList, error)

func (*FakeDiscovery) ServerVersion

func (c *FakeDiscovery) ServerVersion() (*version.Info, error)

func (*FakeDiscovery) SwaggerSchema

func (c *FakeDiscovery) SwaggerSchema(version schema.GroupVersion) (*swagger.ApiDeclaration, error)

type RegeneratingDiscoveryRESTMapper

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

RengeneratingDiscoveryRESTMapper is a RESTMapper which Regenerates its cache of mappings periodically. It functions by recreating a normal discovery RESTMapper at the specified interval. We don't refresh automatically on cache misses, since we get called on every label, plenty of which will be unrelated to Kubernetes resources.

func NewRESTMapper

func NewRESTMapper(discoveryClient discovery.DiscoveryInterface, refreshInterval time.Duration) (*RegeneratingDiscoveryRESTMapper, error)

func (*RegeneratingDiscoveryRESTMapper) KindFor

func (m *RegeneratingDiscoveryRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error)

func (*RegeneratingDiscoveryRESTMapper) KindsFor

func (m *RegeneratingDiscoveryRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error)

func (*RegeneratingDiscoveryRESTMapper) RESTMapping

func (m *RegeneratingDiscoveryRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)

func (*RegeneratingDiscoveryRESTMapper) RESTMappings

func (m *RegeneratingDiscoveryRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error)

func (*RegeneratingDiscoveryRESTMapper) RegenerateMappings

func (m *RegeneratingDiscoveryRESTMapper) RegenerateMappings() error

func (*RegeneratingDiscoveryRESTMapper) ResourceFor

func (m *RegeneratingDiscoveryRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)

func (*RegeneratingDiscoveryRESTMapper) ResourceSingularizer

func (m *RegeneratingDiscoveryRESTMapper) ResourceSingularizer(resource string) (singular string, err error)

func (*RegeneratingDiscoveryRESTMapper) ResourcesFor

func (m *RegeneratingDiscoveryRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)

func (*RegeneratingDiscoveryRESTMapper) RunUntil

func (m *RegeneratingDiscoveryRESTMapper) RunUntil(stop <-chan struct{})

RunUtil runs the mapping refresher until the given stop channel is closed.