Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
func NewFactory ¶
func NewFactory(params FactoryParams) (*Factory, error)
func (*Factory) CloseTransport ¶
func (f *Factory) CloseTransport(streamID identifiers.RoomID) error
func (*Factory) CreateTransport ¶
func (f *Factory) CreateTransport(streamID identifiers.RoomID) error
func (*Factory) TransportsChannel ¶
type FactoryParams ¶
type FactoryParams struct {
Log logger.Logger
// Conn is the net.Conn to use for creating transports.
Conn net.Conn
// Clock is used for creating a ticker. A Clock interface is used to allow
// easier mocking.
Clock clock.Clock
// PingTimeout is the timeout after which a Ping event will be sent.
PingTimeout time.Duration
InterceptorRegistry *interceptor.Registry
}
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func NewManager(params ManagerParams) *Manager
func (*Manager) FactoriesChannel ¶
FactoriesChannel contains factories created from incoming connections. Users must read from this channel to prevent deadlocks.
func (*Manager) GetFactory ¶
func (m *Manager) GetFactory(raddr net.Addr) <-chan NewFactoryResponse
type ManagerParams ¶
type NewFactoryResponse ¶
type NewFactoryResponse struct {
// contains filtered or unexported fields
}
func (NewFactoryResponse) Result ¶
func (r NewFactoryResponse) Result() (*Factory, error)
type Transport ¶
type Transport struct {
*servertransport.Transport
// contains filtered or unexported fields
}
func NewTransport ¶
func (*Transport) CloseWrite ¶
func (t *Transport) CloseWrite()
func (*Transport) StreamID ¶
func (t *Transport) StreamID() identifiers.RoomID
TODO rename to RoomID.
Click to show internal directories.
Click to hide internal directories.