kubernetes/vendor/golang.org/x/crypto/ssh/transport.go

const debugTransport …

const gcm128CipherID …

const gcm256CipherID …

const aes128cbcID …

const tripledescbcID …

type packetConn …

type transport …

type packetCipher …

type connectionState …

func (t *transport) setStrictMode() error { … }

func (t *transport) setInitialKEXDone() { … }

// prepareKeyChange sets up key material for a keychange. The key changes in
// both directions are triggered by reading and writing a msgNewKey packet
// respectively.
func (t *transport) prepareKeyChange(algs *algorithms, kexResult *kexResult) error { … }

func (t *transport) printPacket(p []byte, write bool) { … }

// Read and decrypt next packet.
func (t *transport) readPacket() (p []byte, err error) { … }

func (s *connectionState) readPacket(r *bufio.Reader, strictMode bool) ([]byte, error) { … }

func (t *transport) writePacket(packet []byte) error { … }

func (s *connectionState) writePacket(w *bufio.Writer, rand io.Reader, packet []byte, strictMode bool) error { … }

func newTransport(rwc io.ReadWriteCloser, rand io.Reader, isClient bool) *transport { … }

type direction …

var serverKeys …

var clientKeys …

// setupKeys sets the cipher and MAC keys from kex.K, kex.H and sessionId, as
// described in RFC 4253, section 6.4. direction should either be serverKeys
// (to setup server->client keys) or clientKeys (for client->server keys).
func newPacketCipher(d direction, algs directionAlgorithms, kex *kexResult) (packetCipher, error) { … }

// generateKeyMaterial fills out with key material generated from tag, K, H
// and sessionId, as specified in RFC 4253, section 7.2.
func generateKeyMaterial(out, tag []byte, r *kexResult) { … }

const packageVersion …

// Sends and receives a version line.  The versionLine string should
// be US ASCII, start with "SSH-2.0-", and should not include a
// newline. exchangeVersions returns the other side's version line.
func exchangeVersions(rw io.ReadWriter, versionLine []byte) (them []byte, err error) { … }

const maxVersionStringBytes …

// Read version string as specified by RFC 4253, section 4.2.
func readVersion(r io.Reader) ([]byte, error) { … }