ssh

Jan 24, 2025

Changes in this version

+ func ExposeLocalPortToRemote(ctx context.Context, remoteSSHServer, remotePort, localPort netip.AddrPort) error

Oct 25, 2024

Changes in this version

type SshConfig

+ func (config *SshConfig) IsEmpty() bool

Aug 3, 2024

Changes in this version

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

+ func DialSshRemote(ctx context.Context, conf *SshConfig) (remote *ssh.Client, err error)

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

+ func GetKrb5Path() string

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

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

+ func PortMapUntil(ctx context.Context, conf *SshConfig, remote, local netip.AddrPort) error

+ func PrintLine(f func(...any), msg ...string)

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

+ func RemoteRun(client *ssh.Client, cmd string, env map[string]string) (output []byte, errOut []byte, err error)

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

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

+ 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

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

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

+ Addr string

+ ConfigAlias string

+ GSSAPICacheFile string

+ GSSAPIKeytabConf string

+ GSSAPIPassword string

+ Jump string

+ Keyfile string

+ Password string

+ RemoteKubeconfig string

+ User string

+ func GetBastion(name string, defaultValue SshConfig) SshConfig

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

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

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

+ func (config SshConfig) Dial(ctx context.Context) (client *ssh.Client, err error)

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

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

+ func (s SshConfig) Clone() SshConfig