snssqs

Documentation

Index

• func NewSnsSqs(l logger.Logger) pubsub.PubSub
• type SubscriptionAction
• type SubscriptionManagement
  • func NewSubscriptionMgmt(log logger.Logger) 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
• type TopicsLockManager
  • func NewLockManager() *TopicsLockManager
  • func (lm *TopicsLockManager) Lock(key string) *sync.Mutex
  • func (lm *TopicsLockManager) Unlock(key string)
• type TopicsLocker

Functions

func NewSnsSqs

func NewSnsSqs(l logger.Logger) pubsub.PubSub

NewSnsSqs - constructor for a new snssqs dapr component.

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
}

type TopicsLockManager

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

TopicsLockManager is a singleton for fine-grained locking, to prevent the component r/w operations from locking the entire component out when performing operations on different topics.

func NewLockManager

func NewLockManager() *TopicsLockManager

func (*TopicsLockManager) Lock

func (lm *TopicsLockManager) Lock(key string) *sync.Mutex

func (*TopicsLockManager) Unlock

func (lm *TopicsLockManager) Unlock(key string)

type TopicsLocker

type TopicsLocker interface {
	Lock(topic string) *sync.Mutex
	Unlock(topic string)
}