orbit

Aug 22, 2019

Changes in this version

+ var ErrClosed = errors.New("closed")

+ var ErrInvalidVersion = errors.New("invalid version")

+ var ErrOpenTimeout = errors.New("open timeout")

+ type AcceptStreamFunc func(net.Conn) error

+ type AuthFunc func(net.Conn) (value interface{}, err error)

+ type Config struct

+ AuthFunc AuthFunc

+ Codec codec.Codec

+ KeepAliveInterval time.Duration

+ Logger *log.Logger

+ type Init struct

+ AcceptStreams InitAcceptStreams

+ Control InitControl

+ Signaler InitSignaler

+ type InitAcceptStreams map[string]AcceptStreamFunc

+ type InitControl struct

+ Config *control.Config

+ Funcs control.Funcs

+ type InitControls map[string]InitControl

+ type InitMany struct

+ AcceptStreams InitAcceptStreams

+ Controls InitControls

+ Signalers InitSignalers

+ type InitSignal struct

+ Filter signaler.FilterFunc

+ ID string

+ type InitSignaler struct

+ Config *control.Config

+ Signals []InitSignal

+ type InitSignalers map[string]InitSignaler

+ type Server struct

+ func NewServer(ln net.Listener, config *ServerConfig) *Server

+ func NewServerWithCloser(ln net.Listener, config *ServerConfig, cl closer.Closer) *Server

+ func (l *Server) Listen() error

+ func (l *Server) NewSessionChan() <-chan *Session

+ func (l *Server) Session(id string) (s *Session)

+ func (l *Server) Sessions() []*Session

+ type ServerConfig struct

+ NewConnChanSize int

+ NewConnNumberWorkers int

+ NewSessionChanSize int

+ type Session struct

+ Value interface{}

+ func ClientSession(conn net.Conn, config *Config) (s *Session, err error)

+ func ClientSessionWithCloser(conn net.Conn, config *Config, cl closer.Closer) (s *Session, err error)

+ func ServerSession(conn net.Conn, config *Config) (s *Session, err error)

+ func ServerSessionWithCloser(conn net.Conn, config *Config, cl closer.Closer) (s *Session, err error)

+ func (s *Session) AcceptStream(channel string, f AcceptStreamFunc)

+ func (s *Session) ID() string

+ func (s *Session) Init(opts *Init) (control *control.Control, signaler *signaler.Signaler, err error)

+ func (s *Session) InitMany(opts *InitMany) (controls map[string]*control.Control, signalers map[string]*signaler.Signaler, ...)

+ func (s *Session) IsClient() bool

+ func (s *Session) IsServer() bool

+ func (s *Session) LocalAddr() net.Addr

+ func (s *Session) OpenStream(channel string) (stream net.Conn, err error)

+ func (s *Session) OpenStreamTimeout(channel string, timeout time.Duration) (stream net.Conn, err error)

+ func (s *Session) RemoteAddr() net.Addr

+ func (s *Session) SetID(id string)