util

package

Go to main page

Versions in this module

v2

v2.2.8

May 3, 2024

Changes in this version

+ func AddSshFlags(flags *pflag.FlagSet, sshConf *SshConfig)

+ func JumpTo(bClient *ssh.Client, to SshConfig) (client *ssh.Client, err error)

+ func NewPrincipal(name types.PrincipalName, realm string) principal

+ type CCache struct

+ Credentials []*Credential

+ DefaultPrincipal principal

+ Header header

+ Path string

+ Version uint8

+ func LoadCCache(cpath string) (*CCache, error)

+ func NewV4CCache() *CCache

+ func (c *CCache) AddCredential(cred *Credential)

+ func (c *CCache) Contains(p types.PrincipalName) bool

+ func (c *CCache) GetClientPrincipalName() types.PrincipalName

+ func (c *CCache) GetClientRealm() string

+ func (c *CCache) GetEntries() []*Credential

+ func (c *CCache) GetEntry(p types.PrincipalName) (*Credential, bool)

+ func (c *CCache) Marshal() ([]byte, error)

+ func (c *CCache) SetDefaultPrincipal(d principal)

+ func (c *CCache) Unmarshal(b []byte) error

+ type Credential struct

+ Addresses []types.HostAddress

+ AuthData []types.AuthorizationDataEntry

+ AuthTime time.Time

+ Client principal

+ EndTime time.Time

+ IsSKey bool

+ Key types.EncryptionKey

+ RenewTill time.Time

+ SecondTicket []byte

+ Server principal

+ StartTime time.Time

+ Ticket []byte

+ TicketFlags asn1.BitString

type SshConfig

+ Jump string

+ func GetBastion(name string, defaultValue SshConfig) SshConfig

+ func (config SshConfig) AliasRecursion() (client *ssh.Client, err error)

+ func (config SshConfig) Dial() (*ssh.Client, error)

+ func (config SshConfig) GetAuth() ([]ssh.AuthMethod, error)

+ func (config SshConfig) JumpRecursion() (client *ssh.Client, err error)

+ func (s SshConfig) Clone() SshConfig

v2.2.7

Apr 27, 2024

Changes in this version

+ func DownloadFile(uri string) (string, error)

+ func DownloadFileStream(uri string) ([]byte, error)

+ func DownloadFileWithName(uri, name string) (string, error)

+ func GetClusterID(ctx context.Context, client v12.ConfigMapInterface) (types.UID, error)

+ func GetClusterIDByCM(cm *v1.ConfigMap) types.UID

v2.2.6

Apr 16, 2024

v2.2.5

Apr 13, 2024

Changes in this version

+ func CheckPodStatus(cCtx context.Context, cFunc context.CancelFunc, podName string, ...)

+ func ConvertK8sApiServerToDomain(kubeConfigPath string) (newPath string, err error)

+ func ConvertToKubeConfigBytes(factory cmdutil.Factory) ([]byte, string, error)

+ func CopyVolumeIntoContainer(ctx context.Context, volume []mount.Mount, cli *client.Client, id string) error

+ func CreateCIDRPod(ctx context.Context, clientset *kubernetes.Clientset, namespace string) (*v12.Pod, error)

+ func CreateFolder(ctx context.Context, cli *client.Client, id string, src string, target string) (string, error)

+ func GetCIDRByDumpClusterInfo(ctx context.Context, clientset *kubernetes.Clientset) ([]*net.IPNet, error)

+ func GetCIDRFromCNI(ctx context.Context, clientset *kubernetes.Clientset, ...) ([]*net.IPNet, error)

+ func GetDNS(ctx context.Context, f util.Factory, ns, pod string) (*dns.ClientConfig, error)

+ func GetKubeConfigPath(f cmdutil.Factory) string

+ func GetKubeconfigCluster(f cmdutil.Factory) string

+ func GetPodCIDRFromCNI(ctx context.Context, clientset *kubernetes.Clientset, ...) ([]*net.IPNet, error)

+ func GetPodCIDRFromPod(ctx context.Context, clientset *kubernetes.Clientset, namespace string, ...) ([]*net.IPNet, error)

+ func GetRunningPodList(ctx context.Context, clientset *kubernetes.Clientset, ns string, ...) ([]corev1.Pod, error)

+ func GetServiceCIDRByCreateService(ctx context.Context, serviceInterface corev1.ServiceInterface) (*net.IPNet, error)

+ func GetVolume(ctx context.Context, f util.Factory, ns, podName string) (map[string][]mount.Mount, error)

+ func InitFactory(kubeconfigBytes string, ns string) cmdutil.Factory

+ func InitFactoryByPath(kubeconfig string, ns string) cmdutil.Factory

+ func ParseCIDRFromString(content string) (result []*net.IPNet)

+ func RemoveDir(volume map[string][]mount.Mount) error

+ func Rollback(f util.Factory, ns, workload string)

+ func UpdateImage(ctx context.Context, factory util.Factory, ns string, deployName string, ...) error

v2.2.4

Apr 2, 2024

v2.2.3

Mar 4, 2024

Changes in this version

+ func ParsePort(str string) v1.ContainerPort

+ func SshJump(ctx context.Context, conf *SshConfig, flags *pflag.FlagSet, print bool) (path string, err error)

+ func SshJumpAndSetEnv(ctx context.Context, conf *SshConfig, flags *pflag.FlagSet, print bool) error

v2.2.2

Feb 15, 2024

Changes in this version

+ func FindContainerByName(pod *corev1.Pod, name string) (*corev1.Container, int)

+ func FindContainerEnv(container *corev1.Container, key string) (value string, found bool)

+ func InitLoggerForServer(debug bool)

+ func PortMap(ctx context.Context, sshClient *ssh.Client, ...) error

+ func PortMapUntil(ctx context.Context, cli *ssh.Client, remote, local netip.AddrPort) error

+ func SCPAndExec(stdout, stderr io.Writer, client *ssh.Client, filename, to string, ...) error

v2.2.1

Jan 17, 2024

Changes in this version

+ func AddAllowFirewallRule()

+ func AllContainerIsRunning(pod *corev1.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 ConvertToKubeconfigBytes(factory cmdutil.Factory) ([]byte, string, error)

+ func ConvertToTempKubeconfigFile(kubeconfigBytes []byte) (string, error)

+ 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 DialSshRemote(conf *SshConfig) (*ssh.Client, error)

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

+ func Download(client *http.Client, url string, filename string, stdout, stderr io.Writer) error

+ func FindAllowFirewallRule() bool

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

+ func GetAvailableTCPPortOrDie() (int, error)

+ func GetAvailableUDPPortOrDie() (int, error)

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

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

+ func GetClient() (*client.Client, *command.DockerCli, error)

+ func GetClusterId(client v12.ConfigMapInterface) (types.UID, error)

+ func GetDNSIPFromDnsPod(clientset *kubernetes.Clientset) (ips []string, err error)

+ func GetDNSServiceIPFromPod(clientset *kubernetes.Clientset, restclient *rest.RESTClient, ...) (*dns.ClientConfig, error)

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

+ func GetIPBaseNic() (*net.IPNet, error)

+ func GetKrb5Path() string

+ func GetKubeconfigPath(f cmdutil.Factory) string

+ func GetLocalTunIP(tunName string) (net.IP, net.IP, error)

+ func GetManifest(httpCli *http.Client, os string, arch string) (version string, commit string, url string, err error)

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

+ func GetTlsDomain(namespace string) string

+ func GetTopOwnerReference(factory util.Factory, namespace, workload string) (*resource.Info, error)

+ func GetTopOwnerReferenceBySelector(factory util.Factory, namespace, selector string) (sets.Set[string], error)

+ func GetTunDevice(ips ...net.IP) (*net.Interface, error)

+ func GetTunDeviceByConn(tun net.Conn) (*net.Interface, error)

+ func GetUnstructuredObject(f util.Factory, namespace string, workloads string) (*resource.Info, error)

+ func GetUnstructuredObjectBySelector(f util.Factory, namespace string, selector string) ([]*resource.Info, error)

+ func GetUnstructuredObjectList(f util.Factory, namespace string, workloads []string) ([]*resource.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 IsSameCluster(client v12.ConfigMapInterface, namespace string, ...) (bool, error)

+ func IsWindows() bool

+ func Kill(cmd *exec.Cmd) error — windows/amd64

+ func Main(pctx context.Context, remoteEndpoint, localEndpoint netip.AddrPort, ...) error

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

+ func MoveToTemp()

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

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

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

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

+ func PrintStatusInline(pod *corev1.Pod) string

+ func PullImage(ctx context.Context, platform *v1.Platform, cli *client.Client, ...) error

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

+ func RolloutStatus(ctx1 context.Context, factory cmdutil.Factory, namespace, workloads string, ...) (err error)

+ func RunCmd(exe string, arg []string) error — windows/amd64

+ func RunCmd(exe string, args []string) error — darwin/amd64, js/wasm, linux/amd64

+ func RunCmdWithElevated(exe string, arg []string) error — windows/amd64

+ func RunCmdWithElevated(exe string, args []string) error — darwin/amd64, js/wasm, linux/amd64

+ func RunWithElevated()

+ func RunWithElevatedInnerExec() error — windows/amd64

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

+ func RunningInContainer() bool

+ func SCP(stdout, stderr io.Writer, conf *SshConfig, filename, to string, ...) error

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

+ func StartupPProf(port int)

+ func TransferImage(ctx context.Context, conf *SshConfig, imageSource, imageTarget string, ...) error

+ func UnzipKubeVPNIntoFile(zipFile, filename string) error

+ func WaitPod(podInterface v12.PodInterface, list v1.ListOptions, ...) error

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

+ func WaitPortToBeFree(ctx context.Context, port int) error

+ type AssetsEntity struct

+ BrowserDownloadUrl string

+ ContentType string

+ CreatedAt string

+ DownloadCount int64

+ Id int64

+ Label string

+ Name string

+ NodeId string

+ Size int64

+ State string

+ UpdatedAt string

+ Uploader UploaderEntity

+ Url string

+ type AuthorEntity struct

+ AvatarUrl string

+ EventsUrl string

+ FollowersUrl string

+ FollowingUrl string

+ GistsUrl string

+ GravatarId string

+ HtmlUrl string

+ Id int64

+ Login string

+ NodeId string

+ OrganizationsUrl string

+ ReceivedEventsUrl string

+ ReposUrl string

+ SiteAdmin bool

+ StarredUrl string

+ SubscriptionsUrl string

+ Type string

+ Url string

+ type Format struct

+ func (*Format) Format(e *log.Entry) ([]byte, error)

+ type ForwardedPort struct

+ Local uint16

+ Remote uint16

+ type Krb5ClientState int

+ const ContextFlagREADY

+ const InitiatorReady

+ const InitiatorRestart

+ const InitiatorStart

+ const InitiatorWaitForMutal

+ type Krb5InitiatorClient struct

+ func NewKrb5InitiatorClientWithCache(krb5Conf, cacheFile string) (kcl Krb5InitiatorClient, err error)

+ func NewKrb5InitiatorClientWithKeytab(username string, krb5Conf, keytabConf string) (kcl Krb5InitiatorClient, err error)

+ func NewKrb5InitiatorClientWithPassword(username, password, krb5Conf string) (kcl Krb5InitiatorClient, err error)

+ func (k *Krb5InitiatorClient) DeleteSecContext() error

+ func (k *Krb5InitiatorClient) GetMIC(micFiled []byte) ([]byte, error)

+ func (k *Krb5InitiatorClient) InitSecContext(target string, token []byte, isGSSDelegCreds bool) ([]byte, bool, error)

+ 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 ReactionsEntity struct

+ Confused int64

+ Eyes int64

+ Heart int64

+ Hooray int64

+ Laugh int64

+ Normal1 int64

+ Normal11 int64

+ Rocket int64

+ TotalCount int64

+ Url string

+ type RootEntity struct

+ Assets []AssetsEntity

+ AssetsUrl string

+ Body string

+ CreatedAt string

+ Draft bool

+ HtmlUrl string

+ Id int64

+ Name string

+ NodeId string

+ Prerelease bool

+ PublishedAt string

+ Reactions ReactionsEntity

+ TagName string

+ TarballUrl string

+ TargetCommitish string

+ UploadUrl string

+ Url string

+ ZipballUrl string

+ type SshConfig struct

+ Addr string

+ ConfigAlias string

+ GSSAPICacheFile string

+ GSSAPIKeytabConf string

+ GSSAPIPassword string

+ Keyfile string

+ Password string

+ RemoteKubeconfig string

+ User string

+ func ParseSshFromRPC(sshJump *rpc.SshJump) *SshConfig

+ func (s *SshConfig) ToRPC() *rpc.SshJump

+ type UploaderEntity struct

+ AvatarUrl string

+ EventsUrl string

+ FollowersUrl string

+ FollowingUrl string

+ GistsUrl string

+ GravatarId string

+ HtmlUrl string

+ Id int64

+ Login string

+ NodeId string

+ OrganizationsUrl string

+ ReceivedEventsUrl string

+ ReposUrl string

+ SiteAdmin bool

+ StarredUrl string

+ SubscriptionsUrl string

+ Type string

+ Url string

Other modules containing this package

github.com/wencaiwulue/kubevpn

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL