server

Documentation

Index

• func NewAgent(c agent.Config) agent.Agent
• func NewClientSession(conn net.Conn) agent.Session
• func StartFileServer(c agent.Config) chan net.Conn
• func StartJsonlServer(c agent.Config) chan net.Conn
• func StartPingServer(c agent.Config) chan net.Conn
• func StartTerminalServer(c agent.Config) chan net.Conn
• func StartVersionServer(c agent.Config) chan net.Conn
• func StartWsEcho2Server(c agent.Config) chan net.Conn
• func StartWsEcho3Server(c agent.Config) chan net.Conn
• func StartWsEchoServer(c agent.Config) chan net.Conn
• func StartXpraServer(c agent.Config) chan net.Conn
• type ChannelFn
• type ChannelListener
  • func NewChannelListener() *ChannelListener
  • func (cl *ChannelListener) Accept() (net.Conn, error)
  • func (cl *ChannelListener) Addr() net.Addr
  • func (cl *ChannelListener) Close() error
  • func (cl *ChannelListener) Network() string
  • func (cl *ChannelListener) String() string
• type ClientSession
  • func (cs *ClientSession) Actions() <-chan func(agent.Agent)
  • func (cs *ClientSession) Close()
  • func (cs *ClientSession) Done() <-chan struct{}
• type WSChannelListener
  • func NewWSChannelListener() *WSChannelListener
  • func (wl *WSChannelListener) Accept() (net.Conn, error)

Functions

func NewAgent

func NewAgent(c agent.Config) agent.Agent

func NewClientSession

func NewClientSession(conn net.Conn) agent.Session

func StartFileServer

func StartFileServer(c agent.Config) chan net.Conn

func StartJsonlServer

func StartJsonlServer(c agent.Config) chan net.Conn

func StartPingServer

func StartPingServer(c agent.Config) chan net.Conn

func StartTerminalServer

func StartTerminalServer(c agent.Config) chan net.Conn

func StartVersionServer

func StartVersionServer(c agent.Config) chan net.Conn

func StartWsEcho2Server

func StartWsEcho2Server(c agent.Config) chan net.Conn

func StartWsEcho3Server

func StartWsEcho3Server(c agent.Config) chan net.Conn

func StartWsEchoServer

func StartWsEchoServer(c agent.Config) chan net.Conn

func StartXpraServer

func StartXpraServer(c agent.Config) chan net.Conn

Types

type ChannelFn

type ChannelFn = func(agent.Config) chan net.Conn

type ChannelListener

type ChannelListener struct {
	Conns chan net.Conn
}

ChannelListener implements net.Listener

func NewChannelListener

func NewChannelListener() *ChannelListener

func (*ChannelListener) Accept

func (cl *ChannelListener) Accept() (net.Conn, error)

func (*ChannelListener) Addr

func (cl *ChannelListener) Addr() net.Addr

func (*ChannelListener) Close

func (cl *ChannelListener) Close() error

func (*ChannelListener) Network

func (cl *ChannelListener) Network() string

func (*ChannelListener) String

func (cl *ChannelListener) String() string

type ClientSession

type ClientSession struct {
	net.Conn
	*bufio.Scanner
	// contains filtered or unexported fields
}

func (*ClientSession) Actions

func (cs *ClientSession) Actions() <-chan func(agent.Agent)

func (*ClientSession) Close

func (cs *ClientSession) Close()

func (*ClientSession) Done

func (cs *ClientSession) Done() <-chan struct{}

type WSChannelListener

type WSChannelListener struct {
	*ChannelListener
	Server *http.Server
	Conns  chan net.Conn
}

func NewWSChannelListener

func NewWSChannelListener() *WSChannelListener

func (*WSChannelListener) Accept

func (wl *WSChannelListener) Accept() (net.Conn, error)