util

Sep 2, 2023

Changes in this version

+ func RunningInContainer() bool

Jun 1, 2023

Changes in this version

+ func Run(conf *SshConfig, cmd string, env []string) (output []byte, errOut []byte, err error)

type SshConfig

+ RemoteKubeconfig string

May 17, 2023

Changes in this version

+ func Merge(fromMap, ToMap map[K]V) map[K]V

Apr 12, 2023

Changes in this version

+ func SCP(conf *SshConfig, filename string, commands ...string) error

type PodRouteConfig

+ LocalTunIPv4 string

+ LocalTunIPv6 string

Mar 17, 2023

Changes in this version

+ func GetEnv(ctx context.Context, f util.Factory, ns, pod string) (map[string][]string, error)

+ func MoveToTemp()

+ func Print(writer io.Writer, slogan string)

+ func StartupPProf(port int)

+ func WaitPodToBeReady(ctx context.Context, podInterface v12.PodInterface, ...) error

Mar 10, 2023

Changes in this version

+ func AddAllowFirewallRule()

+ func DeleteAllowFirewallRule()

+ func DeleteBlockFirewallRule(_ context.Context) — darwin/amd64, js/wasm, linux/amd64

+ func DeleteBlockFirewallRule(ctx context.Context) — windows/amd64

+ func FindAllowFirewallRule() bool

+ func GetUnstructuredObjectList(f cmdutil.Factory, namespace string, workloads []string) ([]*runtimeresource.Info, error)

Mar 9, 2023

Changes in this version

+ func AllContainerIsRunning(pod *v1.Pod) bool

+ func CleanExtensionLib()

+ func Deduplicate(cidr []*net.IPNet) (result []*net.IPNet)

+ func PrintStatusInline(pod *corev1.Pod) string

Mar 4, 2023

Changes in this version

+ func Main(remoteEndpoint, localEndpoint *netip.AddrPort, conf SshConfig, ...) error

+ type SshConfig struct

+ Addr string

+ ConfigAlias string

+ Keyfile string

+ Password string

+ User string

Feb 23, 2023

Changes in this version

+ func DoReq(request *http.Request) (body []byte, err error)

+ func GetTlsDomain(namespace string) string

Feb 21, 2023

Changes in this version

+ func CanI(clientset *kubernetes.Clientset, sa, ns string, resource *rbacv1.PolicyRule) (allowed bool, err error)

Feb 20, 2023

Changes in this version

+ func IsIPv4(packet []byte) bool

+ func IsIPv6(packet []byte) bool

Feb 18, 2023

Changes in this version

+ func GetAnnotation(f util.Factory, ns string, resources string) (map[string]string, error)

Jan 29, 2023

Changes in this version

+ func DeleteFirewallRule()

+ func RunWithElevatedInnerExec() error — windows/amd64

Jan 14, 2023

Changes in this version

+ func PrintStatus(pod *corev1.Pod, writer io.Writer)

Nov 23, 2022

Changes in this version

+ func GetCIDRElegant(clientset *kubernetes.Clientset, restclient *rest.RESTClient, ...) ([]*net.IPNet, error)

+ func GetCIDRFromResourceUgly(clientset *kubernetes.Clientset, namespace string) ([]*net.IPNet, error)

Nov 6, 2022

Changes in this version

+ func AddFirewallRule()

+ func BytesToInt(b []byte) uint32

+ func DeleteWindowsFirewallRule(ctx context.Context)

+ func FindRule() bool

+ func GetAvailableTCPPortOrDie() int

+ func GetAvailableUDPPortOrDie() int

+ func GetCIDRFromResource(clientset *kubernetes.Clientset, namespace string) ([]*net.IPNet, error)

+ func GetCidrFromCNI(clientset *kubernetes.Clientset, restclient *rest.RESTClient, ...) ([]*net.IPNet, error)

+ func GetPodTemplateSpecPath(u *unstructured.Unstructured) (*v1.PodTemplateSpec, []string, error)

+ func GetTopOwnerReference(factory cmdutil.Factory, namespace, workload string) (*runtimeresource.Info, error)

+ func GetTopOwnerReferenceBySelector(factory cmdutil.Factory, namespace, selector string) (sets.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 Heartbeats(ctx context.Context)

+ func InitLogger(debug bool)

+ func IsAdmin() bool

+ func IsPortListening(port int) bool

+ func IsWindows() bool

+ func Ping(targetIP string) (bool, error)

+ func PortForwardPod(config *rest.Config, clientset *rest.RESTClient, ...) error

+ func RolloutStatus(factory cmdutil.Factory, namespace, workloads string, timeout time.Duration) error

+ func RunWithElevated()

+ func RunWithRollingOutWithChecker(cmd *osexec.Cmd, checker func(log string)) (string, string, error)

+ func Shell(clientset *kubernetes.Clientset, restclient *rest.RESTClient, ...) (string, error)

+ func WaitPod(podInterface v12.PodInterface, list metav1.ListOptions, ...) 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

+ InboundPodTunIP string

+ LocalTunIP string

+ Route string

+ TrafficManagerRealIP 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)