Documentation
¶
Index ¶
- func NewSnsSqs(l logger.Logger) pubsub.PubSub
- type SubscriptionAction
- type SubscriptionManagement
- type SubscriptionManager
- func (sm *SubscriptionManager) Close()
- func (sm *SubscriptionManager) GetSubscriptionTopicHandler(topic string) (*SubscriptionTopicHandler, bool)
- func (sm *SubscriptionManager) Init(queueInfo *sqsQueueInfo, dlqInfo *sqsQueueInfo, ...)
- func (sm *SubscriptionManager) Subscribe(topicHandler *SubscriptionTopicHandler)
- type SubscriptionTopicHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type SubscriptionAction ¶ added in v1.13.0
type SubscriptionAction int
const ( Subscribe SubscriptionAction = iota Unsubscribe )
type SubscriptionManagement ¶ added in v1.13.0
type SubscriptionManagement interface {
Init(queueInfo *sqsQueueInfo, dlqInfo *sqsQueueInfo, cbk func(context.Context, *sqsQueueInfo, *sqsQueueInfo))
Subscribe(topicHandler *SubscriptionTopicHandler)
Close()
GetSubscriptionTopicHandler(topic string) (*SubscriptionTopicHandler, bool)
}
func NewSubscriptionMgmt ¶ added in v1.13.0
func NewSubscriptionMgmt(log logger.Logger) SubscriptionManagement
type SubscriptionManager ¶ added in v1.13.0
type SubscriptionManager struct {
// contains filtered or unexported fields
}
func (*SubscriptionManager) Close ¶ added in v1.13.0
func (sm *SubscriptionManager) Close()
func (*SubscriptionManager) GetSubscriptionTopicHandler ¶ added in v1.13.0
func (sm *SubscriptionManager) GetSubscriptionTopicHandler(topic string) (*SubscriptionTopicHandler, bool)
func (*SubscriptionManager) Init ¶ added in v1.13.0
func (sm *SubscriptionManager) Init(queueInfo *sqsQueueInfo, dlqInfo *sqsQueueInfo, cbk func(context.Context, *sqsQueueInfo, *sqsQueueInfo))
func (*SubscriptionManager) Subscribe ¶ added in v1.13.0
func (sm *SubscriptionManager) Subscribe(topicHandler *SubscriptionTopicHandler)
type SubscriptionTopicHandler ¶ added in v1.13.0
type SubscriptionTopicHandler struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.