Versions in this module Expand all Collapse all v1 v1.9.2 Apr 2, 2023 Changes in this version + func ClientsetFromEnv(kubeConfigPath string) (*kubernetes.Clientset, error) + func DefaultServerCiphers() []uint16 + func FilterPodsForNodeName(name string) node.PodEventFilterFunc + func NodeLeaseV1Client(client kubernetes.Interface) coordclientset.LeaseInterface + func PodFilters(filters ...node.PodEventFilterFunc) node.PodEventFilterFunc + func PodInformerFilter(node string) kubeinformers.SharedInformerOption + func WithAuth(auth Auth, h http.Handler) http.Handler + func WithCACert(pem []byte) func(*tls.Config) error + func WithCAFromPath(p string) func(*tls.Config) error + func WithKeyPairFromPath(cert, key string) func(*tls.Config) error + type Auth interface + func InstrumentAuth(auth Auth) Auth + func NoAuth() Auth + func WebhookAuth(client kubernetes.Interface, nodeName string, opts ...WebhookAuthOption) (Auth, error) + type NewProviderFunc func(ProviderConfig) (Provider, node.NodeProvider, error) + type Node struct + func NewNode(name string, newProvider NewProviderFunc, opts ...NodeOpt) (*Node, error) + func (n *Node) Done() <-chan struct{} + func (n *Node) Err() error + func (n *Node) NodeController() *node.NodeController + func (n *Node) PodController() *node.PodController + func (n *Node) Ready() <-chan struct{} + func (n *Node) Run(ctx context.Context) (retErr error) + func (n *Node) WaitReady(ctx context.Context, timeout time.Duration) error + type NodeConfig struct + Client kubernetes.Interface + DebugHTTP bool + EventRecorder record.EventRecorder + HTTPListenAddr string + Handler http.Handler + InformerResyncPeriod time.Duration + KubeconfigPath string + NodeSpec v1.Node + NumWorkers int + StreamCreationTimeout time.Duration + StreamIdleTimeout time.Duration + TLSConfig *tls.Config + type NodeOpt func(c *NodeConfig) error + func AttachProviderRoutes(mux api.ServeMux) NodeOpt + func WithClient(c kubernetes.Interface) NodeOpt + func WithNodeConfig(c NodeConfig) NodeOpt + func WithTLSConfig(opts ...func(*tls.Config) error) NodeOpt + type NodeRequestAttr struct + NodeName string + func (a NodeRequestAttr) GetRequestAttributes(u user.Info, r *http.Request) authorizer.Attributes + type Provider interface + AttachToContainer func(ctx context.Context, namespace, podName, containerName string, ...) error + GetContainerLogs func(ctx context.Context, namespace, podName, containerName string, ...) (io.ReadCloser, error) + GetMetricsResource func(context.Context) ([]*dto.MetricFamily, error) + GetStatsSummary func(context.Context) (*statsv1alpha1.Summary, error) + RunInContainer func(ctx context.Context, namespace, podName, containerName string, cmd []string, ...) error + type ProviderConfig struct + ConfigMaps corev1listers.ConfigMapLister + Node *v1.Node + Pods corev1listers.PodLister + Secrets corev1listers.SecretLister + Services corev1listers.ServiceLister + type WebhookAuthConfig struct + AuthnConfig authenticatorfactory.DelegatingAuthenticatorConfig + AuthzConfig authorizerfactory.DelegatingAuthorizerConfig + type WebhookAuthOption func(*WebhookAuthConfig) error