instrumented

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
  • func (ims *MessageSink) Close() error
  • func (ims *MessageSink) PutMessage(m pubsub.ProducerMessage) error
  • func (ims *MessageSink) Status() (*pubsub.Status, error)
• type MessageSource
  • func (ims *MessageSource) ConsumeMessages(ctx context.Context, handler pubsub.ConsumerMessageHandler, ...) error
  • func (ims *MessageSource) Status() (*pubsub.Status, error)

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

func (*ConcurrentMessageSource) Status

func (ims *ConcurrentMessageSource) Status() (*pubsub.Status, error)

Status returns the status of this source, or an error if the status could not be determined.

type MessageSink

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

MessageSink is an instrumented implementation of the pubsub MessageSink

func (*MessageSink) Close

func (ims *MessageSink) Close() error

Close closes the message sink

func (*MessageSink) PutMessage

func (ims *MessageSink) PutMessage(m pubsub.ProducerMessage) error

PutMessage implements pubsub MessageSink interface method wrapped in instrumentation

func (*MessageSink) Status

func (ims *MessageSink) Status() (*pubsub.Status, error)

Status returns the status of this sink, or an error if the status could not be determined.

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

func (*MessageSource) Status

func (ims *MessageSource) Status() (*pubsub.Status, error)

Status returns the status of this source, or an error if the status could not be determined.