Documentation
¶
Index ¶
- func NewWebsocket(logMessageGenerator marshaller.MessageGenerator, ...) *websocketListener
- type FakeListener
- func (listener *FakeListener) Close()
- func (listener *FakeListener) ConnectedHost() string
- func (listener *FakeListener) IsClosed() bool
- func (listener *FakeListener) IsStarted() bool
- func (listener *FakeListener) IsStopped() bool
- func (listener *FakeListener) SetReadError(err error)
- func (listener *FakeListener) Start(host string, appId string, outChan OutputChannel, stopChan StopChannel) error
- func (listener *FakeListener) StartCount() int
- type Listener
- type MessageConverter
- type OutputChannel
- type StopChannel
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWebsocket ¶
func NewWebsocket(logMessageGenerator marshaller.MessageGenerator, messageConverter MessageConverter, timeout time.Duration, logger *gosteno.Logger) *websocketListener
Types ¶
type FakeListener ¶
func NewFakeListener ¶
func NewFakeListener(messageChan chan []byte, startError error) *FakeListener
func (*FakeListener) Close ¶
func (listener *FakeListener) Close()
func (*FakeListener) ConnectedHost ¶
func (listener *FakeListener) ConnectedHost() string
func (*FakeListener) IsClosed ¶
func (listener *FakeListener) IsClosed() bool
func (*FakeListener) IsStarted ¶
func (listener *FakeListener) IsStarted() bool
func (*FakeListener) IsStopped ¶
func (listener *FakeListener) IsStopped() bool
func (*FakeListener) SetReadError ¶
func (listener *FakeListener) SetReadError(err error)
func (*FakeListener) Start ¶
func (listener *FakeListener) Start(host string, appId string, outChan OutputChannel, stopChan StopChannel) error
func (*FakeListener) StartCount ¶
func (listener *FakeListener) StartCount() int
type Listener ¶
type Listener interface {
Start(string, string, OutputChannel, StopChannel) error
}
type MessageConverter ¶
type OutputChannel ¶
type OutputChannel chan<- []byte
type StopChannel ¶
type StopChannel <-chan struct{}
Source Files
Click to show internal directories.
Click to hide internal directories.