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 ¶
type SubscriptionAction int
const ( Subscribe SubscriptionAction = iota Unsubscribe )
type SubscriptionManagement ¶
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 ¶
func NewSubscriptionMgmt(log logger.Logger) SubscriptionManagement
type SubscriptionManager ¶
type SubscriptionManager struct {
// contains filtered or unexported fields
}
func (*SubscriptionManager) Close ¶
func (sm *SubscriptionManager) Close()
func (*SubscriptionManager) GetSubscriptionTopicHandler ¶
func (sm *SubscriptionManager) GetSubscriptionTopicHandler(topic string) (*SubscriptionTopicHandler, bool)
func (*SubscriptionManager) Init ¶
func (sm *SubscriptionManager) Init(queueInfo *sqsQueueInfo, dlqInfo *sqsQueueInfo, cbk func(context.Context, *sqsQueueInfo, *sqsQueueInfo))
func (*SubscriptionManager) Subscribe ¶
func (sm *SubscriptionManager) Subscribe(topicHandler *SubscriptionTopicHandler)
type SubscriptionTopicHandler ¶
type SubscriptionTopicHandler struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.