servicebuscli

package
v0.0.0-...-e73abb9 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetMessageForwardingTopologyProperties 

func SetMessageForwardingTopologyProperties(sender string, name string, domain string, tenantID string, version string) map[string]interface{}

SetMessageForwardingTopologyProperties sets the custom message properties for the forwarding topology

func SetMessageUnoProperties 

func SetMessageUnoProperties(serialization string, tenantID string) map[string]interface{}

SetMessageUnoProperties sets the custom message properties for the uno topology

Types

type ForwardEntity 

type ForwardEntity struct {
	To string
	In ForwardingDestination
}

ForwardEntity struct

type ForwardingDestination 

type ForwardingDestination int

ForwardingDestination Enum 

const (
	ForwardToTopic ForwardingDestination = iota
	ForwardToQueue
)

ForwardingDestination Enum definition

type MessageEntity 

type MessageEntity struct {
	Label      string                 `json:"label"`
	Message    map[string]interface{} `json:"message"`
	Properties map[string]interface{} `json:"properties"`
}

MessageEntity Entity

type QueueEntity 

type QueueEntity struct {
	Name                     string
	LockDuration             time.Duration
	AutoDeleteOnIdle         time.Duration
	DefaultMessageTimeToLive time.Duration
	MaxDeliveryCount         int32
	Forward                  ForwardEntity
	ForwardDeadLetter        ForwardEntity
}

QueueEntity structure

func NewQueue 

func NewQueue(name string) QueueEntity

NewQueue Creates a Queue entity

func (*QueueEntity) MapDeadLetterForwardFlag 

func (s *QueueEntity) MapDeadLetterForwardFlag(value string)

MapDeadLetterForwardFlag Maps a forward dead letter flag string into it's sub components

func (*QueueEntity) MapMessageForwardFlag 

func (s *QueueEntity) MapMessageForwardFlag(value string)

MapMessageForwardFlag Maps a forward flag string into it's sub components

type RuleEntity 

type RuleEntity struct {
	Name      string
	SQLFilter string
	SQLAction string
}

RuleEntity structure

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 Get 

func Get(connectionString string) *ServiceBusCli

Get 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 QueueEntity) error

CreateQueue Creates a queue in the service bus namespace

func (*ServiceBusCli) CreateSubscription 

func (s *ServiceBusCli) CreateSubscription(subscription SubscriptionEntity) error

CreateSubscription Creates a subscription to a topic in the service bus

func (*ServiceBusCli) CreateSubscriptionRule 

func (s *ServiceBusCli) CreateSubscriptionRule(subscription SubscriptionEntity, rule RuleEntity) error

CreateSubscriptionRule Creates a rule to a specific subscription

func (*ServiceBusCli) CreateTopic 

func (s *ServiceBusCli) CreateTopic(topicName string) 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) 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

GetQueue Gets a Queue object from the Service Bus Namespace

func (*ServiceBusCli) GetQueueManager 

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

GetQueueManager creates a Service Bus Queue manager

func (*ServiceBusCli) GetTopic 

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

GetTopic Gets a topic 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) SendQueueMessage 

func (s *ServiceBusCli) SendQueueMessage(queueName string, message map[string]interface{}, label string, userParameters map[string]interface{}) error

SendQueueMessage Sends a Service Bus Message to a Queue

func (*ServiceBusCli) SendTopicMessage 

func (s *ServiceBusCli) SendTopicMessage(topicName string, message map[string]interface{}, label string, userParameters map[string]interface{}) 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

type SubscriptionEntity 

type SubscriptionEntity struct {
	Name                     string
	TopicName                string
	LockDuration             time.Duration
	AutoDeleteOnIdle         time.Duration
	DefaultMessageTimeToLive time.Duration
	MaxDeliveryCount         int32
	Forward                  ForwardEntity
	ForwardDeadLetter        ForwardEntity
	Rules                    []RuleEntity
}

SubscriptionEntity structure

func NewSubscription 

func NewSubscription(topicName string, name string) SubscriptionEntity

NewSubscription Creates a new subscription entity

func (*SubscriptionEntity) AddSQLAction 

func (s *SubscriptionEntity) AddSQLAction(ruleName string, action string)

AddSQLAction Adds a Sql Action to a specific rule

func (*SubscriptionEntity) AddSQLFilter 

func (s *SubscriptionEntity) AddSQLFilter(ruleName string, filter string)

AddSQLFilter Adds a Sql filter to a specific Rule

func (*SubscriptionEntity) MapDeadLetterForwardFlag 

func (s *SubscriptionEntity) MapDeadLetterForwardFlag(value string)

MapDeadLetterForwardFlag Maps a forward dead letter flag string into it's sub components

func (*SubscriptionEntity) MapMessageForwardFlag 

func (s *SubscriptionEntity) MapMessageForwardFlag(value string)

MapMessageForwardFlag Maps a forward flag string into it's sub components

func (*SubscriptionEntity) MapRuleFlag 

func (s *SubscriptionEntity) MapRuleFlag(value string)

MapRuleFlag Maps a rule flag string into it's sub components

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.