server

Documentation

Index

• func NewAgentManager() hub.AgentManager
• func NewHub(c hub.Config) hub.Hub
• func NewServerSession(conn net.Conn) hub.Session
• func SplitPathPrefix(key string) (string, string, error)
• type HTTPChannelListener
  • func NewHTTPChannelListener() *HTTPChannelListener
  • func (l *HTTPChannelListener) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ServerSession
  • func (ss *ServerSession) Actions() <-chan func(hub.Hub)
  • func (ss *ServerSession) Close()
  • func (ss *ServerSession) Done() <-chan struct{}
  • func (ss *ServerSession) ID() string
  • func (ss *ServerSession) Name() string
  • func (ss *ServerSession) OpenChannel(p api.ProtocolID)
  • func (ss *ServerSession) Ping()
  • func (ss *ServerSession) RemoteIP() string
  • func (ss *ServerSession) Time() time.Time

Functions

func NewAgentManager

func NewAgentManager() hub.AgentManager

func NewHub

func NewHub(c hub.Config) hub.Hub

func NewServerSession

func NewServerSession(conn net.Conn) hub.Session

func SplitPathPrefix

func SplitPathPrefix(key string) (string, string, error)

SplitKey takes a key in the form `/$namespace/$path` and splits it into `$namespace` and `$path`.

Types

type HTTPChannelListener

type HTTPChannelListener struct {
	*server.ChannelListener
}

HTTPChannelListener is an http handler to net.Listener converter HTTPChannelListener implements net.Listener/http.Handler

func NewHTTPChannelListener

func NewHTTPChannelListener() *HTTPChannelListener

func (*HTTPChannelListener) ServeHTTP

func (l *HTTPChannelListener) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServerSession

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

func (*ServerSession) Actions

func (ss *ServerSession) Actions() <-chan func(hub.Hub)

func (*ServerSession) Close

func (ss *ServerSession) Close()

func (*ServerSession) Done

func (ss *ServerSession) Done() <-chan struct{}

func (*ServerSession) ID

func (ss *ServerSession) ID() string

func (*ServerSession) Name

func (ss *ServerSession) Name() string

func (*ServerSession) OpenChannel

func (ss *ServerSession) OpenChannel(p api.ProtocolID)

func (*ServerSession) Ping

func (ss *ServerSession) Ping()

func (*ServerSession) RemoteIP

func (ss *ServerSession) RemoteIP() string

func (*ServerSession) Time

func (ss *ServerSession) Time() time.Time