Versions in this module Expand all Collapse all v0 v0.4.1 Mar 7, 2022 Changes in this version + const SubscriptionResponseStatusDrop + const SubscriptionResponseStatusRetry + const SubscriptionResponseStatusSuccess + type Consumer struct + type ConsumerManager struct + func Get() *ConsumerManager + func (cm *ConsumerManager) DeliveredEvent(ctx context.Context, ev cloudevents.Event) (out *pb.TopicEventResponse, err error) + func (cm *ConsumerManager) Register(consumerType, pubsubName, topicName string, consumer *Consumer) error + func (cm *ConsumerManager) Unregister(consumerType, pubsubName, topicName string, consumer *Consumer) error
Go to main page