filters

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

Constants

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

	HeaderContentType = "Content-Type"

	LabelSelectorQueryParam = "labelSelector"
)

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

const (
	KubectlCommandHeader = "Kubectl-Command"
)

Variables

var ErrNodeNotInVcluster = errors.New("node not present in vcluster")

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(ctx *vclustercontext.ControllerContext, h http.Handler, cacheHostClient, cachedVirtualClient client.Client, hostConfig *rest.Config) 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

Types

type APIResourceListProxy

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

func (*APIResourceListProxy) HandleRequest

func (p *APIResourceListProxy) HandleRequest()

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
}