nodeutil

Jan 19, 2024

Changes in this version

type NodeConfig

+ NodeStatusUpdateErrorHandler node.ErrorHandler

Jun 16, 2023

Changes in this version

type Provider

+ PortForward func(ctx context.Context, namespace, pod string, port int32, ...) error

Apr 15, 2023

Changes in this version

type Provider

+ AttachToContainer func(ctx context.Context, namespace, podName, containerName string, ...) error

+ GetMetricsResource func(context.Context) ([]*dto.MetricFamily, error)

Sep 14, 2021

Changes in this version

+ func DefaultServerCiphers() []uint16

+ 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

+ GetContainerLogs func(ctx context.Context, namespace, podName, containerName string, ...) (io.ReadCloser, 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

Jan 20, 2021

Changes in this version

+ func ClientsetFromEnv(kubeConfigPath string) (*kubernetes.Clientset, error)

+ 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