filters

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
  • func (p *MetricsServerProxy) HandleRequest()
• type RowData

Constants

const (
	RequestVerbList = "list"
	RequestVerbGet  = "get"
	NodeResource    = "nodes"
	PodResource     = "pods"

	LabelSelectorQueryParam = "labelSelector"
)

const (
	K3sConnectPath = "/v1-k3s/connect"
)

const (
	KubectlCommandHeader = "Kubectl-Command"
)

Functions

func IsKubeletMetrics

func IsKubeletMetrics(path string) bool

func IsKubeletStats

func IsKubeletStats(path string) bool

func NewFakeObjectInterfaces

func NewFakeObjectInterfaces(scheme *runtime.Scheme, restMapper meta.RESTMapper) admission.ObjectInterfaces

func NodeNameFrom

func NodeNameFrom(ctx context.Context) (string, bool)

NodeNameFrom returns a node name if there is any

func WithFakeKubelet

func WithFakeKubelet(h http.Handler, localConfig *rest.Config, cachedVirtualClient client.Client) http.Handler

func WithK3sConnect

func WithK3sConnect(h http.Handler) http.Handler

func WithMetricsProxy

func WithMetricsProxy(h http.Handler, localConfig *rest.Config, cachedVirtualClient client.Client) http.Handler

func WithMetricsServerProxy

func WithMetricsServerProxy(
	h http.Handler,
	targetNamespace string,
	cachedHostClient,
	cachedVirtualClient client.Client,
	hostConfig,
	virtualConfig *rest.Config,
	multiNamespaceMode bool,
) http.Handler

func WithNodeChanges

func WithNodeChanges(ctx context.Context, h http.Handler, uncachedLocalClient, uncachedVirtualClient client.Client, virtualConfig *rest.Config) http.Handler

func WithNodeName

func WithNodeName(h http.Handler, currentNamespace string, fakeKubeletIPs bool, virtualClient, physicalClient client.Client) http.Handler

func WithPprof

func WithPprof(h http.Handler) 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

func WriteObjectNegotiated(w http.ResponseWriter, req *http.Request, object runtime.Object, scheme *runtime.Scheme)

func WriteObjectNegotiatedWithGVK

func WriteObjectNegotiatedWithGVK(w http.ResponseWriter, req *http.Request, object runtime.Object, scheme *runtime.Scheme, groupVersion schema.GroupVersion, overrideMediaType string)

func WriteObjectNegotiatedWithMediaType

func WriteObjectNegotiatedWithMediaType(w http.ResponseWriter, req *http.Request, object runtime.Object, scheme *runtime.Scheme, overrideMediaType string)

Types

type MetricsServerProxy

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

func (*MetricsServerProxy) HandleRequest

func (p *MetricsServerProxy) HandleRequest()

type RowData

type RowData struct {
	Index int
	Cells []interface{}
	Pom   metav1.PartialObjectMetadata
}