sse

Documentation

Index

• Constants
• type IncomingMessage
• type StreamingClient
• type StreamingClientImpl
  • func NewStreamingClient(cfg *conf.AdvancedConfig, logger logging.LoggerInterface, ...) *StreamingClientImpl
  • func (s *StreamingClientImpl) ConnectStreaming(token string, streamingStatus chan int, channelList []string, ...)
  • func (s *StreamingClientImpl) IsRunning() bool
  • func (s *StreamingClientImpl) StopStreaming()

Constants

const (
	StatusConnectionFailed = iota
	StatusUnderlyingClientInUse
	StatusFirstEventOk
	StatusDisconnected
)

Status constants

Types

type IncomingMessage

type IncomingMessage = sse.RawEvent

IncomingMessage is an alias of sse.RawEvent

type StreamingClient

type StreamingClient interface {
	ConnectStreaming(token string, streamingStatus chan int, channelList []string, handleIncomingMessage func(IncomingMessage))
	StopStreaming()
	IsRunning() bool
}

StreamingClient interface

type StreamingClientImpl

type StreamingClientImpl struct {
	// contains filtered or unexported fields
}

StreamingClientImpl struct

func NewStreamingClient

func NewStreamingClient(cfg *conf.AdvancedConfig, logger logging.LoggerInterface, metadata dtos.Metadata, clientKey *string) *StreamingClientImpl

NewStreamingClient creates new SSE Client

func (*StreamingClientImpl) ConnectStreaming

func (s *StreamingClientImpl) ConnectStreaming(token string, streamingStatus chan int, channelList []string, handleIncomingMessage func(IncomingMessage))

ConnectStreaming connects to streaming

func (*StreamingClientImpl) IsRunning

func (s *StreamingClientImpl) IsRunning() bool

IsRunning returns true if the client is running

func (*StreamingClientImpl) StopStreaming

func (s *StreamingClientImpl) StopStreaming()

StopStreaming stops streaming