dynamicmapper

Documentation

Index

• 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 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.