filters

Documentation

Index

• Constants
• func ExecuteRequest(req *http.Request, h http.Handler) (int, http.Header, []byte, error)
• func IsKubeletMetrics(path string) bool
• func IsKubeletStats(path string) bool
• func MetricsDecode(data []byte) ([]*dto.MetricFamily, error)
• func MetricsEncode(metricsFamilies []*dto.MetricFamily, format expfmt.Format) ([]byte, error)
• func MetricsRewrite(ctx *synccontext.SyncContext, metricsFamilies []*dto.MetricFamily) ([]*dto.MetricFamily, error)
• func NewFakeObjectInterfaces(scheme *runtime.Scheme, restMapper meta.RESTMapper) admission.ObjectInterfaces
• func NodeNameFrom(ctx context.Context) (string, bool)
• func WithFakeKubelet(h http.Handler, registerCtx *synccontext.RegisterContext) http.Handler
• func WithK3sConnect(h http.Handler) http.Handler
• func WithMetricsProxy(h http.Handler, registerCtx *synccontext.RegisterContext) 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, registerCtx *synccontext.RegisterContext, ...) http.Handler
• func WithServiceCreateRedirect(handler http.Handler, registerCtx *synccontext.RegisterContext, ...) 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, ...)
• func WriteWithHeader(w http.ResponseWriter, code int, header http.Header, body []byte)

Constants

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

Functions

func ExecuteRequest

func ExecuteRequest(req *http.Request, h http.Handler) (int, http.Header, []byte, error)

func IsKubeletMetrics

func IsKubeletMetrics(path string) bool

func IsKubeletStats

func IsKubeletStats(path string) bool

func MetricsDecode

func MetricsDecode(data []byte) ([]*dto.MetricFamily, error)

func MetricsEncode

func MetricsEncode(metricsFamilies []*dto.MetricFamily, format expfmt.Format) ([]byte, error)

func MetricsRewrite

func MetricsRewrite(ctx *synccontext.SyncContext, metricsFamilies []*dto.MetricFamily) ([]*dto.MetricFamily, error)

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, registerCtx *synccontext.RegisterContext) http.Handler

func WithK3sConnect

func WithK3sConnect(h http.Handler) http.Handler

func WithMetricsProxy

func WithMetricsProxy(h http.Handler, registerCtx *synccontext.RegisterContext) 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, registerCtx *synccontext.RegisterContext, uncachedVirtualClient client.Client, admit admission.Interface, resources []delegatingauthorizer.GroupVersionResourceVerb) http.Handler

func WithServiceCreateRedirect

func WithServiceCreateRedirect(handler http.Handler, registerCtx *synccontext.RegisterContext, uncachedLocalClient, uncachedVirtualClient client.Client) 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)

func WriteWithHeader

func WriteWithHeader(w http.ResponseWriter, code int, header http.Header, body []byte)