mux

Documentation

Index

• func NewInboundMuxConnSession(conn io.ReadWriteCloser, passwordHash string) (protocol.ConnSession, error)
• func NewOutboundMuxConnSession(conn io.ReadWriteCloser, req *protocol.Request) (protocol.ConnSession, error)
• type MuxConnSession
  • func (m *MuxConnSession) Close() error
  • func (m *MuxConnSession) GetRequest() *protocol.Request
  • func (m *MuxConnSession) Read(p []byte) (int, error)
  • func (m *MuxConnSession) SetMeter(meter stat.TrafficMeter)
  • func (m *MuxConnSession) Write(p []byte) (int, error)

Functions

func NewInboundMuxConnSession

func NewInboundMuxConnSession(conn io.ReadWriteCloser, passwordHash string) (protocol.ConnSession, error)

func NewOutboundMuxConnSession

func NewOutboundMuxConnSession(conn io.ReadWriteCloser, req *protocol.Request) (protocol.ConnSession, error)

Types

type MuxConnSession

type MuxConnSession struct {
	protocol.ConnSession
	protocol.NeedMeter
	protocol.HasRequest
	// contains filtered or unexported fields
}

func (*MuxConnSession) Close

func (m *MuxConnSession) Close() error

func (*MuxConnSession) GetRequest

func (m *MuxConnSession) GetRequest() *protocol.Request

func (*MuxConnSession) Read

func (m *MuxConnSession) Read(p []byte) (int, error)

func (*MuxConnSession) SetMeter

func (m *MuxConnSession) SetMeter(meter stat.TrafficMeter)

func (*MuxConnSession) Write

func (m *MuxConnSession) Write(p []byte) (int, error)