util

Jul 7, 2022

Changes in this version

+ const ComponentForward

+ const SortByName

+ const SortByStatus

+ func IsValidIp(ip string) bool

May 29, 2022

Changes in this version

+ const DnsOrderCluster

+ const DnsOrderUpstream

+ const PortForwardHeartBeatIntervalSec

+ var KtConfigFile = fmt.Sprintf("%s/config", KtHome)

+ var KtKeyDir = fmt.Sprintf("%s/key", KtHome)

+ var KtLockDir = fmt.Sprintf("%s/lock", KtHome)

+ var KtPidDir = fmt.Sprintf("%s/pid", KtHome)

+ var KtProfileDir = fmt.Sprintf("%s/profile", KtHome)

+ func Capitalize(word string) string

+ func CleanBackgroundLogs()

+ func DashSeparated(word string) string

+ func IsMacos() bool

+ func UnCapitalize(word string) string

May 4, 2022

Changes in this version

+ const ImageKtNavigator

+ const ImageKtRouter

+ const ImageKtShadow

+ var BackgroundLogger = io.Discard

+ func FormattedTime() string

+ func PrepareLogger(enable bool)

+ type FileWriter struct

+ func (f FileWriter) Write(p []byte) (n int, err error)

Apr 27, 2022

Changes in this version

+ const IpAddrPattern

+ const RectifierPodPrefix

+ var TimeDifference int64 = 0

+ func ExtractHostIp(url string) string

+ func GetTime() int64

Mar 28, 2022

Changes in this version

+ func ArrayDelete(arr []string, item string) []string

+ func ArrayEquals(src, target []string) bool

Feb 20, 2022

Changes in this version

+ const EnvKubeConfig

+ const Eol

+ const FieldDomain — darwin/amd64, js/wasm, linux/amd64

+ const FieldNameserver — darwin/amd64, js/wasm, linux/amd64

+ const FieldSearch — darwin/amd64, js/wasm, linux/amd64

+ const HostsFilePath

+ const ResolvConf — darwin/amd64, js/wasm, linux/amd64

+ func GetRandomTcpPort() (int, error)

+ type InterpretableReader struct

+ func NewInterpretableReader(r io.Reader) InterpretableReader

+ func (r InterpretableReader) Cancel()

+ func (r InterpretableReader) Read(p []byte) (n int, err error)

Feb 13, 2022

Changes in this version

+ const AlternativeDnsPort

+ const ComponentConnect

+ const ComponentExchange

+ const ComponentMesh

+ const ComponentPreview

+ const ConnectModeShuttle

+ const ConnectModeTun2Socks

+ const ControlBy

+ const DefaultContainer

+ const DefaultNamespace

+ const DnsModeHosts

+ const DnsModeLocalDns

+ const DnsModePodDns

+ const DumpHostsLock

+ const ExchangeModeEphemeral

+ const ExchangeModeScale

+ const ExchangeModeSelector

+ const ExchangePodInfix

+ const KtConfig

+ const KtExchangeContainer

+ const KtLastHeartBeat

+ const KtLock

+ const KtRefCount

+ const KtRole

+ const KtSelector

+ const KtTarget

+ const KtUser

+ const KubernetesToolkit

+ const MeshModeAuto

+ const MeshModeManual

+ const MeshPodInfix

+ const PostfixRsaKey

+ const RoleConnectShadow

+ const RoleExchangeShadow

+ const RoleMeshShadow

+ const RolePreviewShadow

+ const RoleRouter

+ const RouterBin

+ const RouterPodSuffix

+ const SshAuthKey

+ const SshAuthPrivateKey

+ const SshBitSize

+ const StuntmanServiceSuffix

+ const TunNameLinux

+ const TunNameMac

+ const TunNameWin

+ func FindBrokenLocalPort(exposePorts string) string

+ func FindInvalidRemotePort(exposePorts string, svcPorts []coreV1.ServicePort) string

+ func GetAdminUserName() string

+ func IsRunAsAdmin() bool

+ func ParseTimestamp(timestamp string) int64

Dec 29, 2021

Changes in this version

+ func MapEquals(src, target map[string]string) bool

+ func RandomSeconds(min, max int) time.Duration

Dec 23, 2021

Changes in this version

+ func BackgroundRunWithCtx(cmdCtx *CMDContext) (err error)

+ func CanRun(cmd *exec.Cmd) bool

+ func MergeMap(m1 map[string]string, m2 map[string]string) map[string]string

+ func RunAndWait(cmd *exec.Cmd, name string) (err error)

+ type CMDContext struct

+ Cmd *exec.Cmd

+ Ctx context.Context

+ Name string

+ Stop chan struct{}

Dec 10, 2021

Changes in this version

+ func CopyMap(m map[string]string) map[string]string

+ func ExtractErrorMessage(msg string) string

+ func MapContains(subset, fullset map[string]string) bool

+ func MapPut(m map[string]string, k, v string)

+ func ParsePortMapping(exposePort string) (string, string)

+ func RandomDuration(n int) time.Duration

+ func RandomPort() int

+ func RemoveColor(msg string) string

Nov 11, 2021

Changes in this version

+ func FindBrokenPort(exposePorts string) string

Oct 17, 2021

Changes in this version

+ func Append(base string, inc string) string

+ func GetLocalIps() (ips []string)

+ func GetLocalUserName() string

+ func SetupPodHeartBeat(ctx context.Context, client coreV1.PodInterface, name string)

Aug 28, 2021

Changes in this version

+ const ResourceHeartBeatIntervalMinus

+ func AddNameserver(nameserver string) error

+ func GetLocalDomains() string

+ func RestoreConfig() error

+ func SetupConfigMapHeartBeat(client v1.ConfigMapInterface, name string)

+ func SetupDeploymentHeartBeat(client appV1.DeploymentInterface, name string)

+ func SetupPortForwardHeartBeat(port int)

+ func SetupServiceHeartBeat(client v1.ServiceInterface, name string)

Aug 19, 2021

Changes in this version

+ func FixFileOwner(path string)

+ func GetTimestamp() string

+ func IsCmd() bool

+ func WaitPortBeReady(waitTime, port int) bool

Aug 8, 2021

Changes in this version

+ var KtHome = fmt.Sprintf("%s/.ktctl", UserHome)

+ var UserHome = os.Getenv("HOME") — darwin/amd64, js/wasm, linux/amd64

+ var UserHome = os.Getenv("USERPROFILE") — windows/amd64

+ func CleanRsaKeys()

+ func Contains(obj interface{}, target interface{}) bool

+ func ExtractNetMaskFromCidr(cidr string) string

+ func GetDaemonRunning(componentName string) string

+ func GetJvmrcFilePath(jvmrcDir string) string

+ func IsLinux() bool

+ func IsPidFileExist() bool

+ func IsProcessExist(pid int) bool

+ func KubeConfig() string

+ func WritePrivateKey(privateKeyPath string, data []byte) error

+ type SSHCredential struct

+ Port string

+ PrivateKeyPath string

+ RemoteHost string

+ func NewDefaultSSHCredential() *SSHCredential

+ type SSHGenerator struct

+ PrivateKey []byte

+ PrivateKeyPath string

+ PublicKey []byte

+ func Generate(privateKeyPath string) (*SSHGenerator, error)

+ func NewSSHGenerator(privateKey string, publicKey string, privateKeyPath string) *SSHGenerator

Apr 13, 2020

Changes in this version

+ func DropHosts(hostsMap map[string]string)

+ func DumpHosts(hostsMap map[string]string)

+ func IsWindows() bool

+ func PrepareSSHPrivateKey() (err error)

+ func PrivateKeyPath() string

+ func String2Map(str string) map[string]string

+ func WritePidFile(pidFile string) (pid int, err error)

Jul 29, 2019

Changes in this version

+ func BackgroundRun(cmd *exec.Cmd, name string, debug bool) (err error)

+ func CreateDirIfNotExist(dir string)

+ func GetCirds(clientset *kubernetes.Clientset, podCIDR string) (cidrs []string, err error)

+ func GetOutboundIP() (address string)

+ func GetRandomSSHPort(podIP string) string

+ func HomeDir() string

+ func IsDaemonRunning(pidFile string) bool

+ func PortForward(kubeConifg string, namespace string, resource string, remotePort int) *exec.Cmd

+ func RandomString(n int) string

+ func SSHRemotePortForward(localPort string, remoteHost string, remotePort string, remoteSSHPort int) *exec.Cmd

+ func SSHUttle(remoteHost string, remotePort int, DNSServer string, disableDNS bool, ...) *exec.Cmd