Documentation ¶
Index ¶
- func NewConcurrentMessageSource(source pubsub.ConcurrentMessageSource, counterOpts prometheus.CounterOpts, ...) pubsub.ConcurrentMessageSource
- func NewDefaultConcurrentMessageSource(source pubsub.ConcurrentMessageSource, topic string) pubsub.ConcurrentMessageSource
- func NewDefaultMessageSink(sink pubsub.MessageSink, topic string) pubsub.MessageSink
- func NewDefaultMessageSource(source pubsub.MessageSource, topic string) pubsub.MessageSource
- func NewMessageSink(sink pubsub.MessageSink, counterOpts prometheus.CounterOpts, topic string) pubsub.MessageSink
- func NewMessageSource(source pubsub.MessageSource, counterOpts prometheus.CounterOpts, topic string) pubsub.MessageSource
- type ConcurrentMessageSource
- func (ims *ConcurrentMessageSource) ConsumeMessages(ctx context.Context, handler pubsub.ConsumerMessageHandler, ...) error
- func (ims *ConcurrentMessageSource) ConsumeMessagesConcurrently(ctx context.Context, handler pubsub.ConsumerMessageHandler, ...) error
- func (ims *ConcurrentMessageSource) Status() (*pubsub.Status, error)
- type MessageSink
- type MessageSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConcurrentMessageSource ¶
func NewConcurrentMessageSource( source pubsub.ConcurrentMessageSource, counterOpts prometheus.CounterOpts, topic string) pubsub.ConcurrentMessageSource
NewConcurrentMessageSource returns a new MessageSource
func NewDefaultConcurrentMessageSource ¶
func NewDefaultConcurrentMessageSource(source pubsub.ConcurrentMessageSource, topic string) pubsub.ConcurrentMessageSource
NewDefaultConcurrentMessageSource returns a new pubsub MessageSource wrapped in default instrumentation
func NewDefaultMessageSink ¶
func NewDefaultMessageSink(sink pubsub.MessageSink, topic string) pubsub.MessageSink
NewDefaultMessageSink returns a new pubsub MessageSink wrapped in default instrumentation
func NewDefaultMessageSource ¶
func NewDefaultMessageSource(source pubsub.MessageSource, topic string) pubsub.MessageSource
NewDefaultMessageSource returns a new pubsub MessageSource wrapped in default instrumentation
func NewMessageSink ¶
func NewMessageSink(sink pubsub.MessageSink, counterOpts prometheus.CounterOpts, topic string) pubsub.MessageSink
NewMessageSink constructs a new pubsub MessageSink wrapped in instrumentation The counter vector will have the labels status and topic
func NewMessageSource ¶
func NewMessageSource( source pubsub.MessageSource, counterOpts prometheus.CounterOpts, topic string) pubsub.MessageSource
NewMessageSource returns a new MessageSource
Types ¶
type ConcurrentMessageSource ¶
type ConcurrentMessageSource struct {
// contains filtered or unexported fields
}
ConcurrentMessageSource is an an Instrumented pubsub MessageSource The counter vector will have the labels "status" and "topic"
func (*ConcurrentMessageSource) ConsumeMessages ¶
func (ims *ConcurrentMessageSource) ConsumeMessages( ctx context.Context, handler pubsub.ConsumerMessageHandler, onError pubsub.ConsumerErrorHandler) error
ConsumeMessages is an implementation of interface method, wrapping the call in instrumentation
func (*ConcurrentMessageSource) ConsumeMessagesConcurrently ¶
func (ims *ConcurrentMessageSource) ConsumeMessagesConcurrently(ctx context.Context, handler pubsub.ConsumerMessageHandler, onError pubsub.ConsumerErrorHandler) error
ConsumeMessagesConcurrently is an implementation of interface method, wrapping the call in instrumentation
type MessageSink ¶
type MessageSink struct {
// contains filtered or unexported fields
}
MessageSink is an instrumented implementation of the pubsub MessageSink
func (*MessageSink) PutMessage ¶
func (ims *MessageSink) PutMessage(m pubsub.ProducerMessage) error
PutMessage implements pubsub MessageSink interface method wrapped in instrumentation
type MessageSource ¶
type MessageSource struct {
// contains filtered or unexported fields
}
MessageSource is an an Instrumented pubsub MessageSource The counter vector will have the labels "status" and "topic"
func (*MessageSource) ConsumeMessages ¶
func (ims *MessageSource) ConsumeMessages( ctx context.Context, handler pubsub.ConsumerMessageHandler, onError pubsub.ConsumerErrorHandler) error
ConsumeMessages is an implementation of interface method, wrapping the call in instrumentation