servicebus

package
v0.0.15 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 15, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ServiceBusCli 

type ServiceBusCli struct {
	ConnectionString          string
	Namespace                 *servicebus.Namespace
	TopicManager              *servicebus.TopicManager
	QueueManager              *servicebus.QueueManager
	ActiveTopic               *servicebus.Topic
	ActiveSubscription        *servicebus.Subscription
	ActiveQueue               *servicebus.Queue
	ActiveQueueListenerHandle *servicebus.ListenerHandle
	ActiveTopicListenerHandle *servicebus.ListenerHandle
	Peek                      bool
	UseWiretap                bool
	DeleteWiretap             bool
	CloseTopicListener        chan bool
	CloseQueueListener        chan bool
}

ServiceBusCli Entity

func NewCli 

func NewCli(connectionString string) *ServiceBusCli

NewCli creates a new ServiceBusCli

func (*ServiceBusCli) CloseQueueSubscription 

func (s *ServiceBusCli) CloseQueueSubscription() error

CloseQueueSubscription closes the subscription to a queue

func (*ServiceBusCli) CloseTopicSubscription 

func (s *ServiceBusCli) CloseTopicSubscription() error

CloseTopicSubscription closes the subscription to a topic

func (*ServiceBusCli) CreateQueue 

func (s *ServiceBusCli) CreateQueue(queue entities.QueueRequest) error

CreateQueue Creates a queue in the service bus namespace

func (*ServiceBusCli) CreateSubscription 

func (s *ServiceBusCli) CreateSubscription(subscription entities.SubscriptionRequest, upsert bool) error

CreateSubscription Creates a subscription to a topic in the service bus

func (*ServiceBusCli) CreateSubscriptionRule 

func (s *ServiceBusCli) CreateSubscriptionRule(subscription entities.SubscriptionRequest, rule entities.RuleRequest) error

CreateSubscriptionRule Creates a rule to a specific subscription

func (*ServiceBusCli) CreateTopic 

func (s *ServiceBusCli) CreateTopic(topicName string, opts ...servicebus.TopicManagementOption) (*servicebus.TopicEntity, error)

CreateTopic Creates a topic in the service bus namespace

func (*ServiceBusCli) DeleteQueue 

func (s *ServiceBusCli) DeleteQueue(queueName string) error

DeleteQueue Deletes a queue in the service bus namespace

func (*ServiceBusCli) DeleteSubscription 

func (s *ServiceBusCli) DeleteSubscription(topicName string, subscriptionName string) error

DeleteSubscription Deletes a subscription from a topic in the service bus

func (*ServiceBusCli) DeleteSubscriptionRule added in v0.0.6 

func (s *ServiceBusCli) DeleteSubscriptionRule(topicName string, subscriptionName string, ruleName string) (*servicebus.RuleEntity, error)

func (*ServiceBusCli) DeleteTopic 

func (s *ServiceBusCli) DeleteTopic(topicName string) error

DeleteTopic Deletes a topic in the service bus namespace

func (*ServiceBusCli) GetNamespace 

func (s *ServiceBusCli) GetNamespace() (*servicebus.Namespace, error)

GetNamespace gets a new Service Bus connection namespace

func (*ServiceBusCli) GetQueue 

func (s *ServiceBusCli) GetQueue(queueName string) (*servicebus.Queue, error)

GetQueue Gets a Queue object from the Service Bus Namespace

func (*ServiceBusCli) GetQueueActiveMessages added in v0.0.6 

func (s *ServiceBusCli) GetQueueActiveMessages(queueName string, qty int, peek bool) ([]servicebus.Message, error)

GetSubscriptionActiveMessages Gets messages from a subscription

func (*ServiceBusCli) GetQueueDeadLetterMessages added in v0.0.6 

func (s *ServiceBusCli) GetQueueDeadLetterMessages(queueName string, qty int, peek bool) ([]servicebus.Message, error)

func (*ServiceBusCli) GetQueueDetails added in v0.0.6 

func (s *ServiceBusCli) GetQueueDetails(queueName string) (*servicebus.QueueEntity, error)

GetQueueDetails Gets a Namespace Queue Entity with details

func (*ServiceBusCli) GetQueueManager 

func (s *ServiceBusCli) GetQueueManager() *servicebus.QueueManager

GetQueueManager creates a Service Bus Queue manager

func (*ServiceBusCli) GetSubscription added in v0.0.6 

func (s *ServiceBusCli) GetSubscription(topicName string, subscriptionName string) (*servicebus.SubscriptionEntity, error)

GetSubscription Gets a subscription from a topic in the namespace

func (*ServiceBusCli) GetSubscriptionActiveMessages added in v0.0.6 

func (s *ServiceBusCli) GetSubscriptionActiveMessages(topicName string, subscriptionName string, qty int, peek bool) ([]servicebus.Message, error)

GetSubscriptionActiveMessages Gets messages from a subscription

func (*ServiceBusCli) GetSubscriptionDeadLetterMessages added in v0.0.6 

func (s *ServiceBusCli) GetSubscriptionDeadLetterMessages(topicName string, subscriptionName string, qty int, peek bool) ([]servicebus.Message, error)

func (*ServiceBusCli) GetSubscriptionRule added in v0.0.6 

func (s *ServiceBusCli) GetSubscriptionRule(topicName string, subscriptionName string, ruleName string) (*servicebus.RuleEntity, error)

func (*ServiceBusCli) GetSubscriptionRules added in v0.0.6 

func (s *ServiceBusCli) GetSubscriptionRules(topicName string, subscriptionName string) ([]*servicebus.RuleEntity, error)

func (*ServiceBusCli) GetTopic 

func (s *ServiceBusCli) GetTopic(name string) *servicebus.Topic

GetTopic Gets a topic from the service bus

func (*ServiceBusCli) GetTopicDetails added in v0.0.6 

func (s *ServiceBusCli) GetTopicDetails(name string) *servicebus.TopicEntity

GetTopicDetails Gets a topic details from the service bus

func (*ServiceBusCli) GetTopicManager 

func (s *ServiceBusCli) GetTopicManager() *servicebus.TopicManager

GetTopicManager creates a servicebus topic manager

func (*ServiceBusCli) ListQueues 

func (s *ServiceBusCli) ListQueues() ([]*servicebus.QueueEntity, error)

ListQueues Lists all the Queues in a Service Bus

func (*ServiceBusCli) ListSubscriptions 

func (s *ServiceBusCli) ListSubscriptions(topicName string) ([]*servicebus.SubscriptionEntity, error)

ListSubscriptions Lists all the topics in a service bus

func (*ServiceBusCli) ListTopics 

func (s *ServiceBusCli) ListTopics() ([]*servicebus.TopicEntity, error)

ListTopics Lists all the topics in a service bus

func (*ServiceBusCli) SendBulkQueueMessage added in v0.0.7 

func (s *ServiceBusCli) SendBulkQueueMessage(queueName string, messages ...entities.MessageRequest) error

SendQueueMessage Sends a Service Bus Message to a Queue

func (*ServiceBusCli) SendBulkTopicMessage added in v0.0.7 

func (s *ServiceBusCli) SendBulkTopicMessage(topicName string, messages ...entities.MessageRequest) error

func (*ServiceBusCli) SendParallelBulkQueueMessage added in v0.0.7 

func (s *ServiceBusCli) SendParallelBulkQueueMessage(wg *sync.WaitGroup, queueName string, messages ...entities.MessageRequest)

func (*ServiceBusCli) SendParallelBulkTopicMessage added in v0.0.7 

func (s *ServiceBusCli) SendParallelBulkTopicMessage(wg *sync.WaitGroup, topicName string, messages ...entities.MessageRequest)

func (*ServiceBusCli) SendQueueMessage 

func (s *ServiceBusCli) SendQueueMessage(queueName string, message entities.MessageRequest) error

SendQueueMessage Sends a Service Bus Message to a Queue

func (*ServiceBusCli) SendQueueServiceBusMessage added in v0.0.6 

func (s *ServiceBusCli) SendQueueServiceBusMessage(queueName string, sbMessage *servicebus.Message) error

SendQueueServiceBusMessage Sends a Service Bus Message to a Queue

func (*ServiceBusCli) SendTopicMessage 

func (s *ServiceBusCli) SendTopicMessage(topicName string, message entities.MessageRequest) error

SendTopicMessage sends a message to a specific topic

func (*ServiceBusCli) SendTopicServiceBusMessage added in v0.0.6 

func (s *ServiceBusCli) SendTopicServiceBusMessage(topicName string, sbMessage *servicebus.Message) error

SendTopicMessage sends a message to a specific topic

func (*ServiceBusCli) SubscribeToQueue 

func (s *ServiceBusCli) SubscribeToQueue(queueName string) error

SubscribeToQueue Subscribes to a queue and listen to the messages

func (*ServiceBusCli) SubscribeToTopic 

func (s *ServiceBusCli) SubscribeToTopic(topicName string, subscriptionName string) error

SubscribeToTopic Subscribes to a topic and listen to the messages

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.