const minPacketLength … const channelMaxPacket … const channelWindowSize … type NewChannel … type Channel … type Request … // Reply sends a response to a request. It must be called for all requests // where WantReply is true and is a no-op otherwise. The payload argument is // ignored for replies to channel-specific requests. func (r *Request) Reply(ok bool, payload []byte) error { … } type RejectionReason … const Prohibited … const ConnectionFailed … const UnknownChannelType … const ResourceShortage … // String converts the rejection reason to human readable form. func (r RejectionReason) String() string { … } func min(a uint32, b int) uint32 { … } type channelDirection … const channelInbound … const channelOutbound … type channel … // writePacket sends a packet. If the packet is a channel close, it updates // sentClose. This method takes the lock c.writeMu. func (ch *channel) writePacket(packet []byte) error { … } func (ch *channel) sendMessage(msg interface{ … } // WriteExtended writes data to a specific extended stream. These streams are // used, for example, for stderr. func (ch *channel) WriteExtended(data []byte, extendedCode uint32) (n int, err error) { … } func (ch *channel) handleData(packet []byte) error { … } func (c *channel) adjustWindow(adj uint32) error { … } func (c *channel) ReadExtended(data []byte, extended uint32) (n int, err error) { … } func (c *channel) close() { … } // responseMessageReceived is called when a success or failure message is // received on a channel to check that such a message is reasonable for the // given channel. func (ch *channel) responseMessageReceived() error { … } func (ch *channel) handlePacket(packet []byte) error { … } func (m *mux) newChannel(chanType string, direction channelDirection, extraData []byte) *channel { … } var errUndecided … var errDecidedAlready … type extChannel … func (e *extChannel) Write(data []byte) (n int, err error) { … } func (e *extChannel) Read(data []byte) (n int, err error) { … } func (ch *channel) Accept() (Channel, <-chan *Request, error) { … } func (ch *channel) Reject(reason RejectionReason, message string) error { … } func (ch *channel) Read(data []byte) (int, error) { … } func (ch *channel) Write(data []byte) (int, error) { … } func (ch *channel) CloseWrite() error { … } func (ch *channel) Close() error { … } // Extended returns an io.ReadWriter that sends and receives data on the given, // SSH extended stream. Such streams are used, for example, for stderr. func (ch *channel) Extended(code uint32) io.ReadWriter { … } func (ch *channel) Stderr() io.ReadWriter { … } func (ch *channel) SendRequest(name string, wantReply bool, payload []byte) (bool, error) { … } // ackRequest either sends an ack or nack to the channel request. func (ch *channel) ackRequest(ok bool) error { … } func (ch *channel) ChannelType() string { … } func (ch *channel) ExtraData() []byte { … }
Codebase Browser
kubernetes