NewConcurrentMessageSource returns a new MessageSource.

NewDefaultConcurrentMessageSource returns a new pubsub MessageSource wrapped in default instrumentation.

NewDefaultMessageSink returns a new pubsub MessageSink wrapped in default instrumentation.

NewDefaultMessageSource returns a new pubsub MessageSource wrapped in default instrumentation.

NewMessageSink constructs a new pubsub MessageSink wrapped in instrumentation The counter vector will have the labels status and topic.

NewMessageSource returns a new MessageSource.

ConcurrentMessageSource is an an Instrumented pubsub MessageSource The counter vector will have the labels "status" and "topic".

MessageSink is an instrumented implementation of the pubsub MessageSink.

MessageSource is an an Instrumented pubsub MessageSource The counter vector will have the labels "status" and "topic".