Versions in this module Expand all Collapse all v1 v1.1.30 Apr 17, 2023 Changes in this version + func AddAllowFirewallRule() + func AllContainerIsRunning(pod *v1.Pod) bool + func BytesToInt(b []byte) uint32 + func CanI(clientset *kubernetes.Clientset, sa, ns string, resource *rbacv1.PolicyRule) (allowed bool, err error) + func CleanExtensionLib() + func Deduplicate(cidr []*net.IPNet) (result []*net.IPNet) + func DeleteAllowFirewallRule() + func DeleteBlockFirewallRule(_ context.Context) — darwin/amd64, js/wasm, linux/amd64 + func DeleteBlockFirewallRule(ctx context.Context) — windows/amd64 + func DoReq(request *http.Request) (body []byte, err error) + func FindAllowFirewallRule() bool + func GetAnnotation(f util.Factory, ns string, resources string) (map[string]string, error) + func GetAvailableTCPPortOrDie() int + func GetAvailableUDPPortOrDie() int + func GetCIDRElegant(clientset *kubernetes.Clientset, restclient *rest.RESTClient, ...) (result []*net.IPNet, err1 error) + func GetCIDRFromResourceUgly(clientset *kubernetes.Clientset, namespace string) ([]*net.IPNet, error) + func GetEnv(ctx context.Context, f util.Factory, ns, pod string) (map[string][]string, error) + func GetPodTemplateSpecPath(u *unstructured.Unstructured) (*v1.PodTemplateSpec, []string, error) + func GetTlsDomain(namespace string) string + func GetTopOwnerReference(factory cmdutil.Factory, namespace, workload string) (*runtimeresource.Info, error) + func GetTopOwnerReferenceBySelector(factory cmdutil.Factory, namespace, selector string) (sets.Set[string], error) + func GetUnstructuredObject(f cmdutil.Factory, namespace string, workloads string) (*runtimeresource.Info, error) + func GetUnstructuredObjectBySelector(f cmdutil.Factory, namespace string, selector string) ([]*runtimeresource.Info, error) + func GetUnstructuredObjectList(f cmdutil.Factory, namespace string, workloads []string) ([]*runtimeresource.Info, error) + func Heartbeats() + func InitLogger(debug bool) + func IsAdmin() bool + func IsIPv4(packet []byte) bool + func IsIPv6(packet []byte) bool + func IsPortListening(port int) bool + func IsWindows() bool + func Main(remoteEndpoint, localEndpoint *netip.AddrPort, conf *SshConfig, ...) error + func MoveToTemp() + func Ping(targetIP string) (bool, error) + func PortForwardPod(config *rest.Config, clientset *rest.RESTClient, ...) error + func Print(writer io.Writer, slogan string) + func PrintStatus(pod *corev1.Pod, writer io.Writer) + func PrintStatusInline(pod *corev1.Pod) string + func RolloutStatus(ctx1 context.Context, factory cmdutil.Factory, namespace, workloads string, ...) error + func RunWithElevated() + func RunWithElevatedInnerExec() error — windows/amd64 + func RunWithRollingOutWithChecker(cmd *osexec.Cmd, checker func(log string)) (string, string, error) + func SCP(conf *SshConfig, filename string, commands ...string) error + func Shell(clientset *kubernetes.Clientset, restclient *rest.RESTClient, ...) (string, error) + func StartupPProf(port int) + func WaitPod(podInterface v12.PodInterface, list metav1.ListOptions, ...) error + func WaitPodToBeReady(ctx context.Context, podInterface v12.PodInterface, ...) error + func WaitPortToBeFree(ctx context.Context, port int) error + type Format struct + func (*Format) Format(e *log.Entry) ([]byte, error) + type ForwardedPort struct + Local uint16 + Remote uint16 + type PodRouteConfig struct + LocalTunIPv4 string + LocalTunIPv6 string + type PortForwarder struct + Ready chan struct{} + func NewOnAddresses(dialer httpstream.Dialer, addresses []string, ports []string, ...) (*PortForwarder, error) + func (pf *PortForwarder) Close() + func (pf *PortForwarder) ForwardPorts() error + func (pf *PortForwarder) GetPorts() ([]ForwardedPort, error) + type SshConfig struct + Addr string + ConfigAlias string + Keyfile string + Password string + User string
Go to main page