Versions in this module Expand all Collapse all v0 v0.1.1 Jan 25, 2019 Changes in this version + type Server struct + Addr string + Received <-chan frame.Frame + func NewServer(ctx context.Context) (*Server, error) + func (m *Server) AssertReceived(ctx context.Context, frameTypes ...api.BaseCommand_Type) error + func (m *Server) Broadcast(f frame.Frame) error + func (m *Server) CloseAll() error + func (m *Server) SetIgnoreConnects(ignore bool) + func (m *Server) SetIgnorePings(ignore bool) + func (m *Server) SetTopicLookupResp(topic, serviceURL string, respType api.CommandLookupTopicResponse_LookupType, ...) + func (m *Server) TotalNumConns() int
Go to main page