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 ¶
View Source
const (
K3sConnectPath = "/v1-k3s/connect"
)
Variables ¶
This section is empty.
Functions ¶
func ExecuteRequest ¶ added in v0.20.0
func ExecuteRequest(req *http.Request, h http.Handler) (int, http.Header, []byte, error)
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 MetricsDecode ¶ added in v0.20.0
func MetricsDecode(data []byte) ([]*dto.MetricFamily, error)
func MetricsEncode ¶ added in v0.20.0
func MetricsEncode(metricsFamilies []*dto.MetricFamily, format expfmt.Format) ([]byte, error)
func MetricsRewrite ¶ added in v0.20.0
func MetricsRewrite(ctx *synccontext.SyncContext, metricsFamilies []*dto.MetricFamily) ([]*dto.MetricFamily, error)
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, registerCtx *synccontext.RegisterContext) 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, registerCtx *synccontext.RegisterContext) 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, 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 ¶ 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)
func WriteWithHeader ¶ added in v0.20.0
func WriteWithHeader(w http.ResponseWriter, code int, header http.Header, body []byte)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.