Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var SubscribeCounter = prometheus.NewCounter(prometheus.CounterOpts{
Name: "subscriber_messages_received_total",
Help: "Total number of received messages",
})
SubscribeCounter is a metrics counter for received messages.
Functions ¶
This section is empty.
Types ¶
type SubscribeWorker ¶
type SubscribeWorker struct {
// contains filtered or unexported fields
}
SubscribeWorker is a worker to run pub/sub subscribers.
func NewSubscribeWorker ¶
func NewSubscribeWorker(config *config.Config, client *pubsub.Client) *SubscribeWorker
NewSubscribeWorker returns a new SubscribeWorker.
func (*SubscribeWorker) Name ¶
func (w *SubscribeWorker) Name() string
Name returns the worker name.
Source Files
Click to show internal directories.
Click to hide internal directories.