Versions in this module Expand all Collapse all v0 v0.1.0 Feb 25, 2023 Changes in this version + var ErrEndOfStream = message.ErrEndOfStream + func Run(s *Session, h Handler) + type Capabilities []string + func (c Capabilities) Has(uri string) bool + type Config struct + Capabilities Capabilities + ID uint32 + type Handler interface + OnClose func(*Session) + OnError func(*Session) + OnEstablish func(*Session) + OnMessage func(*Session) + type HandlerFunc func(*Session) + type Session struct + Config Config + Message *message.Splitter + State *State + func New(src io.Reader, dst io.WriteCloser, config Config) *Session + func (s *Session) AddError(errs ...error) (added int) + func (s *Session) Close() error + func (s *Session) Errors() []error + func (s *Session) Incoming() *message.Decoder + func (s *Session) InitialHandshake() (ok bool) + func (s *Session) Outgoing() *message.Encoder + func (s *Session) Run(handler Handler) + type State struct + Capabilities Capabilities + Counters struct{ ... } + ID uint32 + Opaque interface{} + Status Status + type Status int + const StatusCapabilitiesExchange + const StatusClosed + const StatusError + const StatusEstablished + const StatusInactive
Go to main page