Skip to content
This repository was archived by the owner on Jan 11, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -0,0 +1,91 @@
# encoding: utf-8
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.

require 'uri'
require 'cgi'
require 'date'
require 'json'
require 'base64'
require 'erb'
require 'securerandom'
require 'time'
require 'timeliness'
require 'faraday'
require 'faraday-cookie_jar'
require 'concurrent'
require 'ms_rest'
require '2018-09-15-preview/generated/azure_mgmt_event_grid/module_definition'
require 'ms_rest_azure'

module Azure::EventGrid::Mgmt::V2018_09_15_preview
autoload :Domains, '2018-09-15-preview/generated/azure_mgmt_event_grid/domains.rb'
autoload :DomainTopics, '2018-09-15-preview/generated/azure_mgmt_event_grid/domain_topics.rb'
autoload :EventSubscriptions, '2018-09-15-preview/generated/azure_mgmt_event_grid/event_subscriptions.rb'
autoload :Operations, '2018-09-15-preview/generated/azure_mgmt_event_grid/operations.rb'
autoload :Topics, '2018-09-15-preview/generated/azure_mgmt_event_grid/topics.rb'
autoload :TopicTypes, '2018-09-15-preview/generated/azure_mgmt_event_grid/topic_types.rb'
autoload :EventGridManagementClient, '2018-09-15-preview/generated/azure_mgmt_event_grid/event_grid_management_client.rb'

module Models
autoload :TopicSharedAccessKeys, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic_shared_access_keys.rb'
autoload :InputSchemaMapping, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/input_schema_mapping.rb'
autoload :TopicsListResult, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topics_list_result.rb'
autoload :DomainUpdateParameters, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domain_update_parameters.rb'
autoload :EventSubscriptionFullUrl, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_subscription_full_url.rb'
autoload :DomainSharedAccessKeys, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domain_shared_access_keys.rb'
autoload :EventSubscriptionUpdateParameters, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_subscription_update_parameters.rb'
autoload :TopicRegenerateKeyRequest, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic_regenerate_key_request.rb'
autoload :DomainTopicsListResult, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domain_topics_list_result.rb'
autoload :TopicUpdateParameters, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic_update_parameters.rb'
autoload :AdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/advanced_filter.rb'
autoload :JsonFieldWithDefault, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/json_field_with_default.rb'
autoload :RetryPolicy, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/retry_policy.rb'
autoload :JsonField, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/json_field.rb'
autoload :Resource, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/resource.rb'
autoload :OperationsListResult, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/operations_list_result.rb'
autoload :DomainsListResult, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domains_list_result.rb'
autoload :Operation, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/operation.rb'
autoload :EventSubscriptionDestination, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_subscription_destination.rb'
autoload :OperationInfo, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/operation_info.rb'
autoload :DeadLetterDestination, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/dead_letter_destination.rb'
autoload :EventSubscriptionsListResult, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_subscriptions_list_result.rb'
autoload :DomainRegenerateKeyRequest, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domain_regenerate_key_request.rb'
autoload :EventTypesListResult, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_types_list_result.rb'
autoload :EventSubscriptionFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_subscription_filter.rb'
autoload :TopicTypesListResult, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic_types_list_result.rb'
autoload :Domain, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domain.rb'
autoload :DomainTopic, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domain_topic.rb'
autoload :NumberInAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/number_in_advanced_filter.rb'
autoload :StorageBlobDeadLetterDestination, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/storage_blob_dead_letter_destination.rb'
autoload :NumberNotInAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/number_not_in_advanced_filter.rb'
autoload :NumberLessThanAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/number_less_than_advanced_filter.rb'
autoload :NumberGreaterThanAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/number_greater_than_advanced_filter.rb'
autoload :NumberLessThanOrEqualsAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/number_less_than_or_equals_advanced_filter.rb'
autoload :NumberGreaterThanOrEqualsAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/number_greater_than_or_equals_advanced_filter.rb'
autoload :BoolEqualsAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/bool_equals_advanced_filter.rb'
autoload :StringInAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/string_in_advanced_filter.rb'
autoload :StringNotInAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/string_not_in_advanced_filter.rb'
autoload :StringBeginsWithAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/string_begins_with_advanced_filter.rb'
autoload :StringEndsWithAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/string_ends_with_advanced_filter.rb'
autoload :StringContainsAdvancedFilter, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/string_contains_advanced_filter.rb'
autoload :WebHookEventSubscriptionDestination, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/web_hook_event_subscription_destination.rb'
autoload :EventHubEventSubscriptionDestination, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_hub_event_subscription_destination.rb'
autoload :StorageQueueEventSubscriptionDestination, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/storage_queue_event_subscription_destination.rb'
autoload :HybridConnectionEventSubscriptionDestination, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/hybrid_connection_event_subscription_destination.rb'
autoload :EventSubscription, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_subscription.rb'
autoload :JsonInputSchemaMapping, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/json_input_schema_mapping.rb'
autoload :TrackedResource, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/tracked_resource.rb'
autoload :Topic, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic.rb'
autoload :EventType, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_type.rb'
autoload :TopicTypeInfo, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic_type_info.rb'
autoload :DomainProvisioningState, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/domain_provisioning_state.rb'
autoload :InputSchema, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/input_schema.rb'
autoload :EventSubscriptionProvisioningState, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_subscription_provisioning_state.rb'
autoload :EventDeliverySchema, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/event_delivery_schema.rb'
autoload :TopicProvisioningState, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic_provisioning_state.rb'
autoload :ResourceRegionType, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/resource_region_type.rb'
autoload :TopicTypeProvisioningState, '2018-09-15-preview/generated/azure_mgmt_event_grid/models/topic_type_provisioning_state.rb'
end
end
Original file line number Diff line number Diff line change
@@ -0,0 +1,229 @@
# encoding: utf-8
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.

module Azure::EventGrid::Mgmt::V2018_09_15_preview
#
# Azure EventGrid Management Client
#
class DomainTopics
include MsRestAzure

#
# Creates and initializes a new instance of the DomainTopics class.
# @param client service class for accessing basic functionality.
#
def initialize(client)
@client = client
end

# @return [EventGridManagementClient] reference to the EventGridManagementClient
attr_reader :client

#
# Get a domain topic
#
# Get properties of a domain topic
#
# @param resource_group_name [String] The name of the resource group within the
# user's subscription.
# @param domain_name [String] Name of the domain
# @param topic_name [String] Name of the topic
# @param custom_headers [Hash{String => String}] A hash of custom headers that
# will be added to the HTTP request.
#
# @return [DomainTopic] operation results.
#
def get(resource_group_name, domain_name, topic_name, custom_headers = nil)
response = get_async(resource_group_name, domain_name, topic_name, custom_headers).value!
response.body unless response.nil?
end

#
# Get a domain topic
#
# Get properties of a domain topic
#
# @param resource_group_name [String] The name of the resource group within the
# user's subscription.
# @param domain_name [String] Name of the domain
# @param topic_name [String] Name of the topic
# @param custom_headers [Hash{String => String}] A hash of custom headers that
# will be added to the HTTP request.
#
# @return [MsRestAzure::AzureOperationResponse] HTTP response information.
#
def get_with_http_info(resource_group_name, domain_name, topic_name, custom_headers = nil)
get_async(resource_group_name, domain_name, topic_name, custom_headers).value!
end

#
# Get a domain topic
#
# Get properties of a domain topic
#
# @param resource_group_name [String] The name of the resource group within the
# user's subscription.
# @param domain_name [String] Name of the domain
# @param topic_name [String] Name of the topic
# @param [Hash{String => String}] A hash of custom headers that will be added
# to the HTTP request.
#
# @return [Concurrent::Promise] Promise object which holds the HTTP response.
#
def get_async(resource_group_name, domain_name, topic_name, custom_headers = nil)
fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?
fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
fail ArgumentError, 'domain_name is nil' if domain_name.nil?
fail ArgumentError, 'topic_name is nil' if topic_name.nil?
fail ArgumentError, '@client.api_version is nil' if @client.api_version.nil?


request_headers = {}

# Set Headers
request_headers['x-ms-client-request-id'] = SecureRandom.uuid
request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?
path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventGrid/domains/{domainName}/topics/{topicName}'

request_url = @base_url || @client.base_url

options = {
middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
path_params: {'subscriptionId' => @client.subscription_id,'resourceGroupName' => resource_group_name,'domainName' => domain_name,'topicName' => topic_name},
query_params: {'api-version' => @client.api_version},
headers: request_headers.merge(custom_headers || {}),
base_url: request_url
}
promise = @client.make_request_async(:get, path_template, options)

promise = promise.then do |result|
http_response = result.response
status_code = http_response.status
response_content = http_response.body
unless status_code == 200
error_model = JSON.load(response_content)
fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
end

result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
# Deserialize Response
if status_code == 200
begin
parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
result_mapper = Azure::EventGrid::Mgmt::V2018_09_15_preview::Models::DomainTopic.mapper()
result.body = @client.deserialize(result_mapper, parsed_response)
rescue Exception => e
fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
end
end

result
end

promise.execute
end

#
# List domain topics.
#
# List all the topics in a domain.
#
# @param resource_group_name [String] The name of the resource group within the
# user's subscription.
# @param domain_name [String] Domain name.
# @param custom_headers [Hash{String => String}] A hash of custom headers that
# will be added to the HTTP request.
#
# @return [DomainTopicsListResult] operation results.
#
def list_by_domain(resource_group_name, domain_name, custom_headers = nil)
response = list_by_domain_async(resource_group_name, domain_name, custom_headers).value!
response.body unless response.nil?
end

#
# List domain topics.
#
# List all the topics in a domain.
#
# @param resource_group_name [String] The name of the resource group within the
# user's subscription.
# @param domain_name [String] Domain name.
# @param custom_headers [Hash{String => String}] A hash of custom headers that
# will be added to the HTTP request.
#
# @return [MsRestAzure::AzureOperationResponse] HTTP response information.
#
def list_by_domain_with_http_info(resource_group_name, domain_name, custom_headers = nil)
list_by_domain_async(resource_group_name, domain_name, custom_headers).value!
end

#
# List domain topics.
#
# List all the topics in a domain.
#
# @param resource_group_name [String] The name of the resource group within the
# user's subscription.
# @param domain_name [String] Domain name.
# @param [Hash{String => String}] A hash of custom headers that will be added
# to the HTTP request.
#
# @return [Concurrent::Promise] Promise object which holds the HTTP response.
#
def list_by_domain_async(resource_group_name, domain_name, custom_headers = nil)
fail ArgumentError, '@client.subscription_id is nil' if @client.subscription_id.nil?
fail ArgumentError, 'resource_group_name is nil' if resource_group_name.nil?
fail ArgumentError, 'domain_name is nil' if domain_name.nil?
fail ArgumentError, '@client.api_version is nil' if @client.api_version.nil?


request_headers = {}

# Set Headers
request_headers['x-ms-client-request-id'] = SecureRandom.uuid
request_headers['accept-language'] = @client.accept_language unless @client.accept_language.nil?
path_template = 'subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventGrid/domains/{domainName}/topics'

request_url = @base_url || @client.base_url

options = {
middlewares: [[MsRest::RetryPolicyMiddleware, times: 3, retry: 0.02], [:cookie_jar]],
path_params: {'subscriptionId' => @client.subscription_id,'resourceGroupName' => resource_group_name,'domainName' => domain_name},
query_params: {'api-version' => @client.api_version},
headers: request_headers.merge(custom_headers || {}),
base_url: request_url
}
promise = @client.make_request_async(:get, path_template, options)

promise = promise.then do |result|
http_response = result.response
status_code = http_response.status
response_content = http_response.body
unless status_code == 200
error_model = JSON.load(response_content)
fail MsRestAzure::AzureOperationError.new(result.request, http_response, error_model)
end

result.request_id = http_response['x-ms-request-id'] unless http_response['x-ms-request-id'].nil?
# Deserialize Response
if status_code == 200
begin
parsed_response = response_content.to_s.empty? ? nil : JSON.load(response_content)
result_mapper = Azure::EventGrid::Mgmt::V2018_09_15_preview::Models::DomainTopicsListResult.mapper()
result.body = @client.deserialize(result_mapper, parsed_response)
rescue Exception => e
fail MsRest::DeserializationError.new('Error occurred in deserializing the response', e.message, e.backtrace, result)
end
end

result
end

promise.execute
end

end
end
Loading