Versions in this module Expand all Collapse all v0 v0.1.0 Feb 24, 2018 Changes in this version + type ConnectionManager interface + Close func(connectionID string) + CreateStreamClientConn func(connectionID string, ip string) error + SendStream func(data *pb.StreamMessage, successCallBack OnSuccess, errorCallBack OnError, ...) + SetOnConnectHandler func(onConnectionHandler OnConnectionHandler) + Size func() int + Stop func() + Stream func(stream pb.StreamService_StreamServer) error + Subscribe func(name string, subfunc func(message msg.OutterMessage)) + func NewConnectionManagerImpl(crpyto auth.Crypto) ConnectionManager + type ConnectionManagerImpl struct + func (comm *ConnectionManagerImpl) Close(connectionID string) + func (comm *ConnectionManagerImpl) CreateStreamClientConn(connectionID string, ip string) error + func (comm *ConnectionManagerImpl) SendStream(message *pb.StreamMessage, successCallBack OnSuccess, errorCallBack OnError, ...) + func (comm *ConnectionManagerImpl) SetOnConnectHandler(onConnectionHandler OnConnectionHandler) + func (comm *ConnectionManagerImpl) Size() int + func (comm *ConnectionManagerImpl) Stop() + func (comm *ConnectionManagerImpl) Stream(stream pb.StreamService_StreamServer) error + func (comm *ConnectionManagerImpl) Subscribe(name string, subfunc func(message msg.OutterMessage)) + type OnConnectionHandler func(conn conn.Connection, peer pb.Peer) + type OnError func(error) + type OnSuccess func(interface{})