go-split-commons: github.com/splitio/go-split-commons/service/api/sse Index | Files

package sse

import "github.com/splitio/go-split-commons/service/api/sse"


Package Files


type StreamingClient Uses

type StreamingClient struct {
    // contains filtered or unexported fields

StreamingClient struct

func NewStreamingClient Uses

func NewStreamingClient(cfg *conf.AdvancedConfig, streamingStatus chan int, logger logging.LoggerInterface) *StreamingClient

NewStreamingClient creates new SSE Client

func (*StreamingClient) ConnectStreaming Uses

func (s *StreamingClient) ConnectStreaming(token string, channelList []string, handleIncomingMessage func(e map[string]interface{}))

ConnectStreaming connects to streaming

func (*StreamingClient) IsRunning Uses

func (s *StreamingClient) IsRunning() bool

IsRunning returns true if it's running

func (*StreamingClient) StopStreaming Uses

func (s *StreamingClient) StopStreaming(blocking bool)

StopStreaming stops streaming

Package sse imports 6 packages (graph) and is imported by 1 packages. Updated 2020-11-24. Refresh now. Tools for package owners.