Versions in this module Expand all Collapse all v0 v0.2.1 Mar 7, 2017 Changes in this version + var ErrInvalidCert = errors.New("invalid cert error") + func Write(client Client, writer Writer, msg message.Msg) error + type Client interface + Connect func() (Session, error) + type Closer interface + Close func() + type ConnectError struct + Reason string + func (e ConnectError) Error() string + type InvalidTimeoutError struct + Timeout string + func (e InvalidTimeoutError) Error() string + type InvalidURIError struct + Err string + URI string + func (e InvalidURIError) Error() string + type MessageChanFunc func(Session, chan struct{}) (chan message.Msg, error) + type Mock struct + Closed bool + func (c *Mock) Close() + func (c *Mock) Connect() (Session, error) + type MockErr struct + func (c *MockErr) Connect() (Session, error) + type MockSession struct + func (s *MockSession) Close() + type MockWriter struct + MsgCount int + func (w *MockWriter) Write(msg message.Msg) func(Session) error + type NsFilterFunc func(string) bool + type Reader interface + Read func(NsFilterFunc) MessageChanFunc + type Session interface + type VersionError struct + Err string + URI string + V string + func (e VersionError) Error() string + type Writer interface + Write func(message.Msg) func(Session) error