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

const debugMux …

type chanList …

// Assigns a channel ID to the given channel.
func (c *chanList) add(ch *channel) uint32 { … }

// getChan returns the channel for the given ID.
func (c *chanList) getChan(id uint32) *channel { … }

func (c *chanList) remove(id uint32) { … }

// dropAll forgets all channels it knows, returning them in a slice.
func (c *chanList) dropAll() []*channel { … }

type mux …

var globalOff …

func (m *mux) Wait() error { … }

// newMux returns a mux that runs over the given connection.
func newMux(p packetConn) *mux { … }

func (m *mux) sendMessage(msg interface{ … }

func (m *mux) SendRequest(name string, wantReply bool, payload []byte) (bool, []byte, error) { … }

// ackRequest must be called after processing a global request that
// has WantReply set.
func (m *mux) ackRequest(ok bool, data []byte) error { … }

func (m *mux) Close() error { … }

// loop runs the connection machine. It will process packets until an
// error is encountered. To synchronize on loop exit, use mux.Wait.
func (m *mux) loop() { … }

// onePacket reads and processes one packet.
func (m *mux) onePacket() error { … }

func (m *mux) handleGlobalPacket(packet []byte) error { … }

// handleChannelOpen schedules a channel to be Accept()ed.
func (m *mux) handleChannelOpen(packet []byte) error { … }

func (m *mux) OpenChannel(chanType string, extra []byte) (Channel, <-chan *Request, error) { … }

func (m *mux) openChannel(chanType string, extra []byte) (*channel, error) { … }

func (m *mux) handleUnknownChannelPacket(id uint32, packet []byte) error { … }