Documentation
¶
Index ¶
- Constants
- Variables
- 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(ctx *options.ControllerContext, h http.Handler, ...) 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
- type APIResourceListProxy
- type MetricsServerProxy
- type RowData
Constants ¶
View Source
const (
RequestVerbList = "list"
RequestVerbGet = "get"
NodeResource = "nodes"
PodResource = "pods"
APIVersion = "v1beta1"
HeaderContentType = "Content-Type"
LabelSelectorQueryParam = "labelSelector"
)
View Source
const (
K3sConnectPath = "/v1-k3s/connect"
)
View Source
const (
KubectlCommandHeader = "Kubectl-Command"
)
Variables ¶
View Source
var ErrNodeNotInVcluster = errors.New("node not present in vcluster")
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(ctx *options.ControllerContext, h http.Handler, cacheHostClient, cachedVirtualClient client.Client, hostConfig *rest.Config) 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
Types ¶
type APIResourceListProxy ¶ added in v0.15.0
type APIResourceListProxy struct {
// contains filtered or unexported fields
}
func (*APIResourceListProxy) HandleRequest ¶ added in v0.15.0
func (p *APIResourceListProxy) HandleRequest()
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.