dapr

Documentation

Index

• Constants
• type Consumer
• type ConsumerManager
  • 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

Constants

const (
	// SubscriptionResponseStatusSuccess means message is processed successfully.
	SubscriptionResponseStatusSuccess = "SUCCESS"
	// SubscriptionResponseStatusRetry means message to be retried by Dapr.
	SubscriptionResponseStatusRetry = "RETRY"
	// SubscriptionResponseStatusDrop means warning is logged and message is dropped.
	SubscriptionResponseStatusDrop = "DROP"
)

Types

type Consumer

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

type ConsumerManager

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

func Get

func Get() *ConsumerManager

func (*ConsumerManager) DeliveredEvent

func (cm *ConsumerManager) DeliveredEvent(ctx context.Context, ev cloudevents.Event) (out *pb.TopicEventResponse, err error)

func (*ConsumerManager) Register

func (cm *ConsumerManager) Register(consumerType, pubsubName, topicName string, consumer *Consumer) error

func (*ConsumerManager) Unregister

func (cm *ConsumerManager) Unregister(consumerType, pubsubName, topicName string, consumer *Consumer) error