Versions in this module Expand all Collapse all v0 v0.3.7 Jan 23, 2026 Changes in this version + const AlternativeDnsPort + const ComponentConnect + const ComponentExchange + const ComponentForward + const ComponentMesh + const ComponentPreview + const ConnectModeShuttle + const ConnectModeTun2Socks + const ControlBy + const DefaultContainer + const DefaultNamespace + const DnsModeHosts + const DnsModeLocalDns + const DnsModePodDns + const DnsOrderCluster + const DnsOrderUpstream + const EnvKubeConfig + const Eol + const ExchangeModeScale + const ExchangeModeSelector + const ExchangePodInfix + 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 ImageKtRouter + const ImageKtShadow + const IpAddrPattern + 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 PortForwardHeartBeatIntervalSec + const PostfixRsaKey + const RectifierPodPrefix + const ResolvConf — darwin/amd64, js/wasm, linux/amd64 + const ResourceHeartBeatIntervalMinus + const RoleConnectShadow + const RoleExchangeShadow + const RoleMeshShadow + const RolePreviewShadow + const RoleRouter + const RouterBin + const RouterPodSuffix + const SortByName + const SortByStatus + const SshAuthKey + const SshAuthPrivateKey + const SshBitSize + const StuntmanServiceSuffix + const TunNameLinux + const TunNameMac + const TunNameWin + var BackgroundLogger = io.Discard + var KtConfigFile = fmt.Sprintf("%s/config", KtHome) + var KtHome = fmt.Sprintf("%s/.kt", UserHome) + 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) + var TimeDifference int64 = 0 + var UserHome = os.Getenv("HOME") — darwin/amd64, js/wasm, linux/amd64 + var UserHome = os.Getenv("USERPROFILE") — windows/amd64 + func Append(base string, inc string) string + func ArrayDelete(arr []string, item string) []string + func ArrayEquals(src, target []string) bool + func BackgroundRun(cmd *exec.Cmd, name string, res chan error) error + func CanRun(cmd *exec.Cmd) bool + func Capitalize(word string) string + func CleanBackgroundLogs() + func CleanRsaKeys() + func Contains(container any, target any) bool + func CreateDirIfNotExist(dir string) error + func DashSeparated(word string) string + func ExtractErrorMessage(msg string) string + func ExtractHostIp(url string) string + func FindBrokenLocalPort(exposePorts string) string + func FindInvalidRemotePort(exposePorts string, svcPorts map[int]string) string + func FixFileOwner(path string) (err error) + func FormattedTime() string + func GetAdminUserName() string + func GetDaemonRunning(componentName string) int + func GetLocalUserName() string + func GetRandomTcpPort() int + func GetTime() int64 + func GetTimestamp() string + func IsCmd() bool + func IsLinux() bool + func IsMacos() bool + func IsProcessExist(pid int) bool + func IsRunAsAdmin() bool + func IsValidIp(ip string) bool + func IsWindows() bool + func MapContains(subset, fullset map[string]string) bool + func MapEquals(src, target map[string]string) bool + func MapPut(m map[string]string, k, v string) map[string]string + func MergeMap(m1, m2 map[string]string) map[string]string + func ParsePortMapping(exposePort string) (int, int, error) + func ParseTimestamp(timestamp string) int64 + func PrepareLogger(enable bool) + func PrivateKeyPath(name string) string + func RandomPort() int + func RandomSeconds(min, max int) time.Duration + func RandomString(n int) string + func RemoveColor(msg string) string + func RunAndWait(cmd *exec.Cmd) (string, string, error) + func String2Map(str string) map[string]string + func UnCapitalize(word string) string + func WritePidFile(componentName string, ch chan os.Signal) error + func WritePrivateKey(privateKeyPath string, data []byte) error + type FileWriter struct + func (f FileWriter) Write(p []byte) (n int, err error) + type InterpretableReader struct + func NewInterpretableReader(r io.Reader) InterpretableReader + func (r InterpretableReader) Cancel() + func (r InterpretableReader) Read(p []byte) (n int, err error) + type SSHGenerator struct + PrivateKey []byte + PrivateKeyPath string + PublicKey []byte + func Generate(privateKeyPath string) (*SSHGenerator, error) + func NewSSHGenerator(privateKey string, publicKey string, privateKeyPath string) *SSHGenerator