Documentation
¶
Index ¶
- Constants
- func IsKubeletMetrics(path string) bool
- func IsKubeletStats(path string) bool
- func NewFakeObjectInterfaces(scheme *runtime.Scheme, restMapper meta.RESTMapper) admission.ObjectInterfaces
- func NodeNameFrom(ctx context.Context) (string, bool)
- func WithFakeKubelet(h http.Handler, localConfig *rest.Config, cachedVirtualClient client.Client) http.Handler
- func WithK3sConnect(h http.Handler) http.Handler
- func WithMetricsProxy(h http.Handler, localConfig *rest.Config, cachedVirtualClient client.Client) http.Handler
- func WithMetricsServerProxy(h http.Handler, targetNamespace string, ...) http.Handler
- func WithNodeChanges(ctx context.Context, h http.Handler, ...) http.Handler
- func WithNodeName(h http.Handler, currentNamespace string, fakeKubeletIPs bool, ...) http.Handler
- func WithPprof(h http.Handler) http.Handler
- func WithRedirect(h http.Handler, localConfig *rest.Config, localScheme *runtime.Scheme, ...) http.Handler
- func WithServiceCreateRedirect(handler http.Handler, uncachedLocalClient, uncachedVirtualClient client.Client, ...) http.Handler
- func WriteObjectNegotiated(w http.ResponseWriter, req *http.Request, object runtime.Object, ...)
- func WriteObjectNegotiatedWithGVK(w http.ResponseWriter, req *http.Request, object runtime.Object, ...)
- func WriteObjectNegotiatedWithMediaType(w http.ResponseWriter, req *http.Request, object runtime.Object, ...)
- type MetricsServerProxy
- type RowData
Constants ¶
View Source
const (
RequestVerbList = "list"
RequestVerbGet = "get"
NodeResource = "nodes"
PodResource = "pods"
LabelSelectorQueryParam = "labelSelector"
)
View Source
const (
K3sConnectPath = "/v1-k3s/connect"
)
View Source
const (
KubectlCommandHeader = "Kubectl-Command"
)
Variables ¶
This section is empty.
Functions ¶
func IsKubeletMetrics ¶ added in v0.3.0
func IsKubeletMetrics(path string) bool
func IsKubeletStats ¶ added in v0.3.0
func IsKubeletStats(path string) bool
func NewFakeObjectInterfaces ¶ added in v0.3.0
func NewFakeObjectInterfaces(scheme *runtime.Scheme, restMapper meta.RESTMapper) admission.ObjectInterfaces
func NodeNameFrom ¶ added in v0.3.0
func NodeNameFrom(ctx context.Context) (string, bool)
NodeNameFrom returns a node name if there is any
func WithFakeKubelet ¶ added in v0.3.0
func WithFakeKubelet(h http.Handler, localConfig *rest.Config, cachedVirtualClient client.Client) http.Handler
func WithK3sConnect ¶ added in v0.10.2
func WithK3sConnect(h http.Handler) http.Handler
func WithMetricsProxy ¶ added in v0.3.0
func WithMetricsProxy(h http.Handler, localConfig *rest.Config, cachedVirtualClient client.Client) http.Handler
func WithMetricsServerProxy ¶ added in v0.15.0
func WithMetricsServerProxy(
h http.Handler,
targetNamespace string,
cachedHostClient,
cachedVirtualClient client.Client,
hostConfig,
virtualConfig *rest.Config,
multiNamespaceMode bool,
) http.Handler
func WithNodeChanges ¶ added in v0.3.0
func WithNodeChanges(ctx context.Context, h http.Handler, uncachedLocalClient, uncachedVirtualClient client.Client, virtualConfig *rest.Config) http.Handler
func WithNodeName ¶ added in v0.3.0
func WithNodeName(h http.Handler, currentNamespace string, fakeKubeletIPs bool, virtualClient, physicalClient client.Client) http.Handler
func WithRedirect ¶
func WithRedirect(h http.Handler, localConfig *rest.Config, localScheme *runtime.Scheme, uncachedVirtualClient client.Client, admit admission.Interface, resources []delegatingauthorizer.GroupVersionResourceVerb) http.Handler
func WithServiceCreateRedirect ¶
func WithServiceCreateRedirect(handler http.Handler, uncachedLocalClient, uncachedVirtualClient client.Client, virtualConfig *rest.Config, syncedLabels []string) http.Handler
func WriteObjectNegotiated ¶ added in v0.19.0
func WriteObjectNegotiated(w http.ResponseWriter, req *http.Request, object runtime.Object, scheme *runtime.Scheme)
func WriteObjectNegotiatedWithGVK ¶ added in v0.19.0
func WriteObjectNegotiatedWithGVK(w http.ResponseWriter, req *http.Request, object runtime.Object, scheme *runtime.Scheme, groupVersion schema.GroupVersion, overrideMediaType string)
func WriteObjectNegotiatedWithMediaType ¶ added in v0.19.0
func WriteObjectNegotiatedWithMediaType(w http.ResponseWriter, req *http.Request, object runtime.Object, scheme *runtime.Scheme, overrideMediaType string)
Types ¶
type MetricsServerProxy ¶ added in v0.15.0
type MetricsServerProxy struct {
// contains filtered or unexported fields
}
func (*MetricsServerProxy) HandleRequest ¶ added in v0.15.0
func (p *MetricsServerProxy) HandleRequest()
Source Files
Click to show internal directories.
Click to hide internal directories.