Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GripStream ¶
type GripStream interface { // PublishHttpStream publishes an HTTP stream format message to all of the configured PubControlClients // with a specified channel, message, and optional ID, previous ID, and callback. // Note that the 'http_stream' parameter can be provided as either an HttpStreamFormat // instance or a string / byte array (in which case an HttpStreamFormat instance will // automatically be created and have the 'content' field set to the specified value). PublishHttpStream(channel string, content interface{}, id string, prevID string) error Publish(channel string, item *pubcontrol.Item) error }
GripStream is the interface for publishing events to a grip channel
type StreamWorker ¶
type StreamWorker struct {
// contains filtered or unexported fields
}
StreamWorker is the type that subscribes to the SSEEvent Stream that the EventListener forwards SSEEvents from the embedded SDKs to and forwards them on to clients
func NewStreamWorker ¶
func NewStreamWorker(l log.Logger, gpc GripStream, reg *prometheus.Registry) StreamWorker
NewStreamWorker creates a StreamWorker
Click to show internal directories.
Click to hide internal directories.