The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamingClient ¶
type StreamingClient struct {
// contains filtered or unexported fields
}
StreamingClient struct
func NewStreamingClient ¶
func NewStreamingClient(cfg *conf.AdvancedConfig, streamingStatus chan int, logger logging.LoggerInterface) *StreamingClient
NewStreamingClient creates new SSE Client
func (*StreamingClient) ConnectStreaming ¶
func (s *StreamingClient) ConnectStreaming(token string, channelList []string, handleIncomingMessage func(e map[string]interface{}))
ConnectStreaming connects to streaming
func (*StreamingClient) IsRunning ¶
func (s *StreamingClient) IsRunning() bool
IsRunning returns true if it's running
func (*StreamingClient) StopStreaming ¶
func (s *StreamingClient) StopStreaming(blocking bool)
StopStreaming stops streaming
Source Files
Click to show internal directories.
Click to hide internal directories.