Versions in this module Expand all Collapse all v1 v1.0.0 Aug 25, 2023 Changes in this version + type GripStream interface + Publish func(channel string, item *pubcontrol.Item) error + PublishHttpStream func(channel string, content interface{}, id string, prevID string) error + type StreamWorker struct + func NewStreamWorker(l log.Logger, gpc GripStream, reg *prometheus.Registry) StreamWorker + func (s StreamWorker) Pub(ctx context.Context, event stream.Event) (err error)
Go to main page