eventgrid

package
v31.2.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 26, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package eventgrid implements the Azure ARM Eventgrid service API version 2018-05-01-preview.

Azure EventGrid Management Client

Index

Constants

View Source
const (
	// DefaultBaseURI is the default URI used for the service Eventgrid
	DefaultBaseURI = "https://management.azure.com"
)

Variables

This section is empty.

Functions

func UserAgent

func UserAgent() string

UserAgent returns the UserAgent string to use when sending http.Requests.

func Version

func Version() string

Version returns the semantic version (see http://semver.org) of the client.

Types

type BaseClient

type BaseClient struct {
	autorest.Client
	BaseURI        string
	SubscriptionID string
}

BaseClient is the base client for Eventgrid.

func New

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client.

type BasicDeadLetterDestination

type BasicDeadLetterDestination interface {
	AsStorageBlobDeadLetterDestination() (*StorageBlobDeadLetterDestination, bool)
	AsDeadLetterDestination() (*DeadLetterDestination, bool)
}

BasicDeadLetterDestination information about the dead letter destination for an event subscription. To configure a deadletter destination, do not directly instantiate an object of this class. Instead, instantiate an object of a derived class. Currently, StorageBlobDeadLetterDestination is the only class that derives from this class.

type BasicEventSubscriptionDestination

type BasicEventSubscriptionDestination interface {
	AsWebHookEventSubscriptionDestination() (*WebHookEventSubscriptionDestination, bool)
	AsEventHubEventSubscriptionDestination() (*EventHubEventSubscriptionDestination, bool)
	AsStorageQueueEventSubscriptionDestination() (*StorageQueueEventSubscriptionDestination, bool)
	AsHybridConnectionEventSubscriptionDestination() (*HybridConnectionEventSubscriptionDestination, bool)
	AsEventSubscriptionDestination() (*EventSubscriptionDestination, bool)
}

BasicEventSubscriptionDestination information about the destination for an event subscription

type BasicInputSchemaMapping

type BasicInputSchemaMapping interface {
	AsJSONInputSchemaMapping() (*JSONInputSchemaMapping, bool)
	AsInputSchemaMapping() (*InputSchemaMapping, bool)
}

BasicInputSchemaMapping by default, Event Grid expects events to be in the Event Grid event schema. Specifying an input schema mapping enables publishing to Event Grid using a custom input schema. Currently, the only supported type of InputSchemaMapping is 'JsonInputSchemaMapping'.

type DeadLetterDestination

type DeadLetterDestination struct {
	// EndpointType - Possible values include: 'EndpointTypeDeadLetterDestination', 'EndpointTypeStorageBlob'
	EndpointType EndpointTypeBasicDeadLetterDestination `json:"endpointType,omitempty"`
}

DeadLetterDestination information about the dead letter destination for an event subscription. To configure a deadletter destination, do not directly instantiate an object of this class. Instead, instantiate an object of a derived class. Currently, StorageBlobDeadLetterDestination is the only class that derives from this class.

func (DeadLetterDestination) AsBasicDeadLetterDestination

func (dld DeadLetterDestination) AsBasicDeadLetterDestination() (BasicDeadLetterDestination, bool)

AsBasicDeadLetterDestination is the BasicDeadLetterDestination implementation for DeadLetterDestination.

func (DeadLetterDestination) AsDeadLetterDestination

func (dld DeadLetterDestination) AsDeadLetterDestination() (*DeadLetterDestination, bool)

AsDeadLetterDestination is the BasicDeadLetterDestination implementation for DeadLetterDestination.

func (DeadLetterDestination) AsStorageBlobDeadLetterDestination

func (dld DeadLetterDestination) AsStorageBlobDeadLetterDestination() (*StorageBlobDeadLetterDestination, bool)

AsStorageBlobDeadLetterDestination is the BasicDeadLetterDestination implementation for DeadLetterDestination.

func (DeadLetterDestination) MarshalJSON

func (dld DeadLetterDestination) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DeadLetterDestination.

type EndpointType

type EndpointType string

EndpointType enumerates the values for endpoint type.

const (
	// EndpointTypeEventHub ...
	EndpointTypeEventHub EndpointType = "EventHub"
	// EndpointTypeEventSubscriptionDestination ...
	EndpointTypeEventSubscriptionDestination EndpointType = "EventSubscriptionDestination"
	// EndpointTypeHybridConnection ...
	EndpointTypeHybridConnection EndpointType = "HybridConnection"
	// EndpointTypeStorageQueue ...
	EndpointTypeStorageQueue EndpointType = "StorageQueue"
	// EndpointTypeWebHook ...
	EndpointTypeWebHook EndpointType = "WebHook"
)

func PossibleEndpointTypeValues

func PossibleEndpointTypeValues() []EndpointType

PossibleEndpointTypeValues returns an array of possible values for the EndpointType const type.

type EndpointTypeBasicDeadLetterDestination

type EndpointTypeBasicDeadLetterDestination string

EndpointTypeBasicDeadLetterDestination enumerates the values for endpoint type basic dead letter destination.

const (
	// EndpointTypeDeadLetterDestination ...
	EndpointTypeDeadLetterDestination EndpointTypeBasicDeadLetterDestination = "DeadLetterDestination"
	// EndpointTypeStorageBlob ...
	EndpointTypeStorageBlob EndpointTypeBasicDeadLetterDestination = "StorageBlob"
)

func PossibleEndpointTypeBasicDeadLetterDestinationValues

func PossibleEndpointTypeBasicDeadLetterDestinationValues() []EndpointTypeBasicDeadLetterDestination

PossibleEndpointTypeBasicDeadLetterDestinationValues returns an array of possible values for the EndpointTypeBasicDeadLetterDestination const type.

type EventDeliverySchema

type EventDeliverySchema string

EventDeliverySchema enumerates the values for event delivery schema.

const (
	// CloudEventV01Schema ...
	CloudEventV01Schema EventDeliverySchema = "CloudEventV01Schema"
	// EventGridSchema ...
	EventGridSchema EventDeliverySchema = "EventGridSchema"
	// InputEventSchema ...
	InputEventSchema EventDeliverySchema = "InputEventSchema"
)

func PossibleEventDeliverySchemaValues

func PossibleEventDeliverySchemaValues() []EventDeliverySchema

PossibleEventDeliverySchemaValues returns an array of possible values for the EventDeliverySchema const type.

type EventHubEventSubscriptionDestination

type EventHubEventSubscriptionDestination struct {
	// EventHubEventSubscriptionDestinationProperties - Event Hub Properties of the event subscription destination
	*EventHubEventSubscriptionDestinationProperties `json:"properties,omitempty"`
	// EndpointType - Possible values include: 'EndpointTypeEventSubscriptionDestination', 'EndpointTypeWebHook', 'EndpointTypeEventHub', 'EndpointTypeStorageQueue', 'EndpointTypeHybridConnection'
	EndpointType EndpointType `json:"endpointType,omitempty"`
}

EventHubEventSubscriptionDestination information about the event hub destination for an event subscription

func (EventHubEventSubscriptionDestination) AsBasicEventSubscriptionDestination

func (ehesd EventHubEventSubscriptionDestination) AsBasicEventSubscriptionDestination() (BasicEventSubscriptionDestination, bool)

AsBasicEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventHubEventSubscriptionDestination.

func (EventHubEventSubscriptionDestination) AsEventHubEventSubscriptionDestination

func (ehesd EventHubEventSubscriptionDestination) AsEventHubEventSubscriptionDestination() (*EventHubEventSubscriptionDestination, bool)

AsEventHubEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventHubEventSubscriptionDestination.

func (EventHubEventSubscriptionDestination) AsEventSubscriptionDestination

func (ehesd EventHubEventSubscriptionDestination) AsEventSubscriptionDestination() (*EventSubscriptionDestination, bool)

AsEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventHubEventSubscriptionDestination.

func (EventHubEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination

func (ehesd EventHubEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination() (*HybridConnectionEventSubscriptionDestination, bool)

AsHybridConnectionEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventHubEventSubscriptionDestination.

func (EventHubEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination

func (ehesd EventHubEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination() (*StorageQueueEventSubscriptionDestination, bool)

AsStorageQueueEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventHubEventSubscriptionDestination.

func (EventHubEventSubscriptionDestination) AsWebHookEventSubscriptionDestination

func (ehesd EventHubEventSubscriptionDestination) AsWebHookEventSubscriptionDestination() (*WebHookEventSubscriptionDestination, bool)

AsWebHookEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventHubEventSubscriptionDestination.

func (EventHubEventSubscriptionDestination) MarshalJSON

func (ehesd EventHubEventSubscriptionDestination) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventHubEventSubscriptionDestination.

func (*EventHubEventSubscriptionDestination) UnmarshalJSON

func (ehesd *EventHubEventSubscriptionDestination) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventHubEventSubscriptionDestination struct.

type EventHubEventSubscriptionDestinationProperties

type EventHubEventSubscriptionDestinationProperties struct {
	// ResourceID - The Azure Resource Id that represents the endpoint of an Event Hub destination of an event subscription.
	ResourceID *string `json:"resourceId,omitempty"`
}

EventHubEventSubscriptionDestinationProperties the properties for a event hub destination.

type EventSubscription

type EventSubscription struct {
	autorest.Response `json:"-"`
	// EventSubscriptionProperties - Properties of the event subscription
	*EventSubscriptionProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Fully qualified identifier of the resource
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; Name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; Type of the resource
	Type *string `json:"type,omitempty"`
}

EventSubscription event Subscription

func (EventSubscription) MarshalJSON

func (es EventSubscription) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventSubscription.

func (*EventSubscription) UnmarshalJSON

func (es *EventSubscription) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventSubscription struct.

type EventSubscriptionDestination

type EventSubscriptionDestination struct {
	// EndpointType - Possible values include: 'EndpointTypeEventSubscriptionDestination', 'EndpointTypeWebHook', 'EndpointTypeEventHub', 'EndpointTypeStorageQueue', 'EndpointTypeHybridConnection'
	EndpointType EndpointType `json:"endpointType,omitempty"`
}

EventSubscriptionDestination information about the destination for an event subscription

func (EventSubscriptionDestination) AsBasicEventSubscriptionDestination

func (esd EventSubscriptionDestination) AsBasicEventSubscriptionDestination() (BasicEventSubscriptionDestination, bool)

AsBasicEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventSubscriptionDestination.

func (EventSubscriptionDestination) AsEventHubEventSubscriptionDestination

func (esd EventSubscriptionDestination) AsEventHubEventSubscriptionDestination() (*EventHubEventSubscriptionDestination, bool)

AsEventHubEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventSubscriptionDestination.

func (EventSubscriptionDestination) AsEventSubscriptionDestination

func (esd EventSubscriptionDestination) AsEventSubscriptionDestination() (*EventSubscriptionDestination, bool)

AsEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventSubscriptionDestination.

func (EventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination

func (esd EventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination() (*HybridConnectionEventSubscriptionDestination, bool)

AsHybridConnectionEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventSubscriptionDestination.

func (EventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination

func (esd EventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination() (*StorageQueueEventSubscriptionDestination, bool)

AsStorageQueueEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventSubscriptionDestination.

func (EventSubscriptionDestination) AsWebHookEventSubscriptionDestination

func (esd EventSubscriptionDestination) AsWebHookEventSubscriptionDestination() (*WebHookEventSubscriptionDestination, bool)

AsWebHookEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for EventSubscriptionDestination.

func (EventSubscriptionDestination) MarshalJSON

func (esd EventSubscriptionDestination) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventSubscriptionDestination.

type EventSubscriptionFilter

type EventSubscriptionFilter struct {
	// SubjectBeginsWith - An optional string to filter events for an event subscription based on a resource path prefix.
	// The format of this depends on the publisher of the events.
	// Wildcard characters are not supported in this path.
	SubjectBeginsWith *string `json:"subjectBeginsWith,omitempty"`
	// SubjectEndsWith - An optional string to filter events for an event subscription based on a resource path suffix.
	// Wildcard characters are not supported in this path.
	SubjectEndsWith *string `json:"subjectEndsWith,omitempty"`
	// IncludedEventTypes - A list of applicable event types that need to be part of the event subscription.
	// If it is desired to subscribe to all event types, the string "all" needs to be specified as an element in this list.
	IncludedEventTypes *[]string `json:"includedEventTypes,omitempty"`
	// IsSubjectCaseSensitive - Specifies if the SubjectBeginsWith and SubjectEndsWith properties of the filter
	// should be compared in a case sensitive manner.
	IsSubjectCaseSensitive *bool `json:"isSubjectCaseSensitive,omitempty"`
}

EventSubscriptionFilter filter for the Event Subscription

type EventSubscriptionFullURL

type EventSubscriptionFullURL struct {
	autorest.Response `json:"-"`
	// EndpointURL - The URL that represents the endpoint of the destination of an event subscription.
	EndpointURL *string `json:"endpointUrl,omitempty"`
}

EventSubscriptionFullURL full endpoint url of an event subscription

type EventSubscriptionProperties

type EventSubscriptionProperties struct {
	// Topic - READ-ONLY; Name of the topic of the event subscription.
	Topic *string `json:"topic,omitempty"`
	// ProvisioningState - READ-ONLY; Provisioning state of the event subscription. Possible values include: 'Creating', 'Updating', 'Deleting', 'Succeeded', 'Canceled', 'Failed', 'AwaitingManualAction'
	ProvisioningState EventSubscriptionProvisioningState `json:"provisioningState,omitempty"`
	// Destination - Information about the destination where events have to be delivered for the event subscription.
	Destination BasicEventSubscriptionDestination `json:"destination,omitempty"`
	// Filter - Information about the filter for the event subscription.
	Filter *EventSubscriptionFilter `json:"filter,omitempty"`
	// Labels - List of user defined labels.
	Labels *[]string `json:"labels,omitempty"`
	// EventDeliverySchema - The event delivery schema for the event subscription. Possible values include: 'EventGridSchema', 'InputEventSchema', 'CloudEventV01Schema'
	EventDeliverySchema EventDeliverySchema `json:"eventDeliverySchema,omitempty"`
	// RetryPolicy - The retry policy for events. This can be used to configure maximum number of delivery attempts and time to live for events.
	RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
	// DeadLetterDestination - The DeadLetter destination of the event subscription.
	DeadLetterDestination BasicDeadLetterDestination `json:"deadLetterDestination,omitempty"`
}

EventSubscriptionProperties properties of the Event Subscription

func (*EventSubscriptionProperties) UnmarshalJSON

func (esp *EventSubscriptionProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventSubscriptionProperties struct.

type EventSubscriptionProvisioningState

type EventSubscriptionProvisioningState string

EventSubscriptionProvisioningState enumerates the values for event subscription provisioning state.

const (
	// AwaitingManualAction ...
	AwaitingManualAction EventSubscriptionProvisioningState = "AwaitingManualAction"
	// Canceled ...
	Canceled EventSubscriptionProvisioningState = "Canceled"
	// Creating ...
	Creating EventSubscriptionProvisioningState = "Creating"
	// Deleting ...
	Deleting EventSubscriptionProvisioningState = "Deleting"
	// Failed ...
	Failed EventSubscriptionProvisioningState = "Failed"
	// Succeeded ...
	Succeeded EventSubscriptionProvisioningState = "Succeeded"
	// Updating ...
	Updating EventSubscriptionProvisioningState = "Updating"
)

func PossibleEventSubscriptionProvisioningStateValues

func PossibleEventSubscriptionProvisioningStateValues() []EventSubscriptionProvisioningState

PossibleEventSubscriptionProvisioningStateValues returns an array of possible values for the EventSubscriptionProvisioningState const type.

type EventSubscriptionUpdateParameters

type EventSubscriptionUpdateParameters struct {
	// Destination - Information about the destination where events have to be delivered for the event subscription.
	Destination BasicEventSubscriptionDestination `json:"destination,omitempty"`
	// Filter - Information about the filter for the event subscription.
	Filter *EventSubscriptionFilter `json:"filter,omitempty"`
	// Labels - List of user defined labels.
	Labels *[]string `json:"labels,omitempty"`
	// EventDeliverySchema - The event delivery schema for the event subscription. Possible values include: 'EventGridSchema', 'InputEventSchema', 'CloudEventV01Schema'
	EventDeliverySchema EventDeliverySchema `json:"eventDeliverySchema,omitempty"`
	// RetryPolicy - The retry policy for events. This can be used to configure maximum number of delivery attempts and time to live for events.
	RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
	// DeadLetterDestination - The DeadLetter destination of the event subscription.
	DeadLetterDestination BasicDeadLetterDestination `json:"deadLetterDestination,omitempty"`
}

EventSubscriptionUpdateParameters properties of the Event Subscription update

func (*EventSubscriptionUpdateParameters) UnmarshalJSON

func (esup *EventSubscriptionUpdateParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventSubscriptionUpdateParameters struct.

type EventSubscriptionsClient

type EventSubscriptionsClient struct {
	BaseClient
}

EventSubscriptionsClient is the azure EventGrid Management Client

func NewEventSubscriptionsClient

func NewEventSubscriptionsClient(subscriptionID string) EventSubscriptionsClient

NewEventSubscriptionsClient creates an instance of the EventSubscriptionsClient client.

func NewEventSubscriptionsClientWithBaseURI

func NewEventSubscriptionsClientWithBaseURI(baseURI string, subscriptionID string) EventSubscriptionsClient

NewEventSubscriptionsClientWithBaseURI creates an instance of the EventSubscriptionsClient client.

func (EventSubscriptionsClient) CreateOrUpdate

func (client EventSubscriptionsClient) CreateOrUpdate(ctx context.Context, scope string, eventSubscriptionName string, eventSubscriptionInfo EventSubscription) (result EventSubscriptionsCreateOrUpdateFuture, err error)

CreateOrUpdate asynchronously creates a new event subscription or updates an existing event subscription based on the specified scope. Parameters: scope - the identifier of the resource to which the event subscription needs to be created or updated. The scope can be a subscription, or a resource group, or a top level resource belonging to a resource provider namespace, or an EventGrid topic. For example, use '/subscriptions/{subscriptionId}/' for a subscription, '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}' for a resource group, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}' for a resource, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventGrid/topics/{topicName}' for an EventGrid topic. eventSubscriptionName - name of the event subscription. Event subscription names must be between 3 and 64 characters in length and should use alphanumeric letters only. eventSubscriptionInfo - event subscription properties containing the destination and filter information

func (EventSubscriptionsClient) CreateOrUpdatePreparer

func (client EventSubscriptionsClient) CreateOrUpdatePreparer(ctx context.Context, scope string, eventSubscriptionName string, eventSubscriptionInfo EventSubscription) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (EventSubscriptionsClient) CreateOrUpdateResponder

func (client EventSubscriptionsClient) CreateOrUpdateResponder(resp *http.Response) (result EventSubscription, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) CreateOrUpdateSender

func (client EventSubscriptionsClient) CreateOrUpdateSender(req *http.Request) (future EventSubscriptionsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) Delete

func (client EventSubscriptionsClient) Delete(ctx context.Context, scope string, eventSubscriptionName string) (result EventSubscriptionsDeleteFuture, err error)

Delete delete an existing event subscription Parameters: scope - the scope of the event subscription. The scope can be a subscription, or a resource group, or a top level resource belonging to a resource provider namespace, or an EventGrid topic. For example, use '/subscriptions/{subscriptionId}/' for a subscription, '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}' for a resource group, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}' for a resource, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventGrid/topics/{topicName}' for an EventGrid topic. eventSubscriptionName - name of the event subscription

func (EventSubscriptionsClient) DeletePreparer

func (client EventSubscriptionsClient) DeletePreparer(ctx context.Context, scope string, eventSubscriptionName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (EventSubscriptionsClient) DeleteResponder

func (client EventSubscriptionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) DeleteSender

func (client EventSubscriptionsClient) DeleteSender(req *http.Request) (future EventSubscriptionsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) Get

func (client EventSubscriptionsClient) Get(ctx context.Context, scope string, eventSubscriptionName string) (result EventSubscription, err error)

Get get properties of an event subscription Parameters: scope - the scope of the event subscription. The scope can be a subscription, or a resource group, or a top level resource belonging to a resource provider namespace, or an EventGrid topic. For example, use '/subscriptions/{subscriptionId}/' for a subscription, '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}' for a resource group, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}' for a resource, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventGrid/topics/{topicName}' for an EventGrid topic. eventSubscriptionName - name of the event subscription

func (EventSubscriptionsClient) GetFullURL

func (client EventSubscriptionsClient) GetFullURL(ctx context.Context, scope string, eventSubscriptionName string) (result EventSubscriptionFullURL, err error)

GetFullURL get the full endpoint URL for an event subscription Parameters: scope - the scope of the event subscription. The scope can be a subscription, or a resource group, or a top level resource belonging to a resource provider namespace, or an EventGrid topic. For example, use '/subscriptions/{subscriptionId}/' for a subscription, '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}' for a resource group, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}' for a resource, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventGrid/topics/{topicName}' for an EventGrid topic. eventSubscriptionName - name of the event subscription

func (EventSubscriptionsClient) GetFullURLPreparer

func (client EventSubscriptionsClient) GetFullURLPreparer(ctx context.Context, scope string, eventSubscriptionName string) (*http.Request, error)

GetFullURLPreparer prepares the GetFullURL request.

func (EventSubscriptionsClient) GetFullURLResponder

func (client EventSubscriptionsClient) GetFullURLResponder(resp *http.Response) (result EventSubscriptionFullURL, err error)

GetFullURLResponder handles the response to the GetFullURL request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) GetFullURLSender

func (client EventSubscriptionsClient) GetFullURLSender(req *http.Request) (*http.Response, error)

GetFullURLSender sends the GetFullURL request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) GetPreparer

func (client EventSubscriptionsClient) GetPreparer(ctx context.Context, scope string, eventSubscriptionName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (EventSubscriptionsClient) GetResponder

func (client EventSubscriptionsClient) GetResponder(resp *http.Response) (result EventSubscription, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) GetSender

func (client EventSubscriptionsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListByResource

func (client EventSubscriptionsClient) ListByResource(ctx context.Context, resourceGroupName string, providerNamespace string, resourceTypeName string, resourceName string) (result EventSubscriptionsListResult, err error)

ListByResource list all event subscriptions that have been created for a specific topic Parameters: resourceGroupName - the name of the resource group within the user's subscription. providerNamespace - namespace of the provider of the topic resourceTypeName - name of the resource type resourceName - name of the resource

func (EventSubscriptionsClient) ListByResourcePreparer

func (client EventSubscriptionsClient) ListByResourcePreparer(ctx context.Context, resourceGroupName string, providerNamespace string, resourceTypeName string, resourceName string) (*http.Request, error)

ListByResourcePreparer prepares the ListByResource request.

func (EventSubscriptionsClient) ListByResourceResponder

func (client EventSubscriptionsClient) ListByResourceResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListByResourceResponder handles the response to the ListByResource request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListByResourceSender

func (client EventSubscriptionsClient) ListByResourceSender(req *http.Request) (*http.Response, error)

ListByResourceSender sends the ListByResource request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListGlobalByResourceGroup

func (client EventSubscriptionsClient) ListGlobalByResourceGroup(ctx context.Context, resourceGroupName string) (result EventSubscriptionsListResult, err error)

ListGlobalByResourceGroup list all global event subscriptions under a specific Azure subscription and resource group Parameters: resourceGroupName - the name of the resource group within the user's subscription.

func (EventSubscriptionsClient) ListGlobalByResourceGroupForTopicType

func (client EventSubscriptionsClient) ListGlobalByResourceGroupForTopicType(ctx context.Context, resourceGroupName string, topicTypeName string) (result EventSubscriptionsListResult, err error)

ListGlobalByResourceGroupForTopicType list all global event subscriptions under a resource group for a specific topic type. Parameters: resourceGroupName - the name of the resource group within the user's subscription. topicTypeName - name of the topic type

func (EventSubscriptionsClient) ListGlobalByResourceGroupForTopicTypePreparer

func (client EventSubscriptionsClient) ListGlobalByResourceGroupForTopicTypePreparer(ctx context.Context, resourceGroupName string, topicTypeName string) (*http.Request, error)

ListGlobalByResourceGroupForTopicTypePreparer prepares the ListGlobalByResourceGroupForTopicType request.

func (EventSubscriptionsClient) ListGlobalByResourceGroupForTopicTypeResponder

func (client EventSubscriptionsClient) ListGlobalByResourceGroupForTopicTypeResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListGlobalByResourceGroupForTopicTypeResponder handles the response to the ListGlobalByResourceGroupForTopicType request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListGlobalByResourceGroupForTopicTypeSender

func (client EventSubscriptionsClient) ListGlobalByResourceGroupForTopicTypeSender(req *http.Request) (*http.Response, error)

ListGlobalByResourceGroupForTopicTypeSender sends the ListGlobalByResourceGroupForTopicType request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListGlobalByResourceGroupPreparer

func (client EventSubscriptionsClient) ListGlobalByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error)

ListGlobalByResourceGroupPreparer prepares the ListGlobalByResourceGroup request.

func (EventSubscriptionsClient) ListGlobalByResourceGroupResponder

func (client EventSubscriptionsClient) ListGlobalByResourceGroupResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListGlobalByResourceGroupResponder handles the response to the ListGlobalByResourceGroup request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListGlobalByResourceGroupSender

func (client EventSubscriptionsClient) ListGlobalByResourceGroupSender(req *http.Request) (*http.Response, error)

ListGlobalByResourceGroupSender sends the ListGlobalByResourceGroup request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListGlobalBySubscription

func (client EventSubscriptionsClient) ListGlobalBySubscription(ctx context.Context) (result EventSubscriptionsListResult, err error)

ListGlobalBySubscription list all aggregated global event subscriptions under a specific Azure subscription

func (EventSubscriptionsClient) ListGlobalBySubscriptionForTopicType

func (client EventSubscriptionsClient) ListGlobalBySubscriptionForTopicType(ctx context.Context, topicTypeName string) (result EventSubscriptionsListResult, err error)

ListGlobalBySubscriptionForTopicType list all global event subscriptions under an Azure subscription for a topic type. Parameters: topicTypeName - name of the topic type

func (EventSubscriptionsClient) ListGlobalBySubscriptionForTopicTypePreparer

func (client EventSubscriptionsClient) ListGlobalBySubscriptionForTopicTypePreparer(ctx context.Context, topicTypeName string) (*http.Request, error)

ListGlobalBySubscriptionForTopicTypePreparer prepares the ListGlobalBySubscriptionForTopicType request.

func (EventSubscriptionsClient) ListGlobalBySubscriptionForTopicTypeResponder

func (client EventSubscriptionsClient) ListGlobalBySubscriptionForTopicTypeResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListGlobalBySubscriptionForTopicTypeResponder handles the response to the ListGlobalBySubscriptionForTopicType request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListGlobalBySubscriptionForTopicTypeSender

func (client EventSubscriptionsClient) ListGlobalBySubscriptionForTopicTypeSender(req *http.Request) (*http.Response, error)

ListGlobalBySubscriptionForTopicTypeSender sends the ListGlobalBySubscriptionForTopicType request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListGlobalBySubscriptionPreparer

func (client EventSubscriptionsClient) ListGlobalBySubscriptionPreparer(ctx context.Context) (*http.Request, error)

ListGlobalBySubscriptionPreparer prepares the ListGlobalBySubscription request.

func (EventSubscriptionsClient) ListGlobalBySubscriptionResponder

func (client EventSubscriptionsClient) ListGlobalBySubscriptionResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListGlobalBySubscriptionResponder handles the response to the ListGlobalBySubscription request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListGlobalBySubscriptionSender

func (client EventSubscriptionsClient) ListGlobalBySubscriptionSender(req *http.Request) (*http.Response, error)

ListGlobalBySubscriptionSender sends the ListGlobalBySubscription request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListRegionalByResourceGroup

func (client EventSubscriptionsClient) ListRegionalByResourceGroup(ctx context.Context, resourceGroupName string, location string) (result EventSubscriptionsListResult, err error)

ListRegionalByResourceGroup list all event subscriptions from the given location under a specific Azure subscription and resource group Parameters: resourceGroupName - the name of the resource group within the user's subscription. location - name of the location

func (EventSubscriptionsClient) ListRegionalByResourceGroupForTopicType

func (client EventSubscriptionsClient) ListRegionalByResourceGroupForTopicType(ctx context.Context, resourceGroupName string, location string, topicTypeName string) (result EventSubscriptionsListResult, err error)

ListRegionalByResourceGroupForTopicType list all event subscriptions from the given location under a specific Azure subscription and resource group and topic type Parameters: resourceGroupName - the name of the resource group within the user's subscription. location - name of the location topicTypeName - name of the topic type

func (EventSubscriptionsClient) ListRegionalByResourceGroupForTopicTypePreparer

func (client EventSubscriptionsClient) ListRegionalByResourceGroupForTopicTypePreparer(ctx context.Context, resourceGroupName string, location string, topicTypeName string) (*http.Request, error)

ListRegionalByResourceGroupForTopicTypePreparer prepares the ListRegionalByResourceGroupForTopicType request.

func (EventSubscriptionsClient) ListRegionalByResourceGroupForTopicTypeResponder

func (client EventSubscriptionsClient) ListRegionalByResourceGroupForTopicTypeResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListRegionalByResourceGroupForTopicTypeResponder handles the response to the ListRegionalByResourceGroupForTopicType request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListRegionalByResourceGroupForTopicTypeSender

func (client EventSubscriptionsClient) ListRegionalByResourceGroupForTopicTypeSender(req *http.Request) (*http.Response, error)

ListRegionalByResourceGroupForTopicTypeSender sends the ListRegionalByResourceGroupForTopicType request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListRegionalByResourceGroupPreparer

func (client EventSubscriptionsClient) ListRegionalByResourceGroupPreparer(ctx context.Context, resourceGroupName string, location string) (*http.Request, error)

ListRegionalByResourceGroupPreparer prepares the ListRegionalByResourceGroup request.

func (EventSubscriptionsClient) ListRegionalByResourceGroupResponder

func (client EventSubscriptionsClient) ListRegionalByResourceGroupResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListRegionalByResourceGroupResponder handles the response to the ListRegionalByResourceGroup request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListRegionalByResourceGroupSender

func (client EventSubscriptionsClient) ListRegionalByResourceGroupSender(req *http.Request) (*http.Response, error)

ListRegionalByResourceGroupSender sends the ListRegionalByResourceGroup request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListRegionalBySubscription

func (client EventSubscriptionsClient) ListRegionalBySubscription(ctx context.Context, location string) (result EventSubscriptionsListResult, err error)

ListRegionalBySubscription list all event subscriptions from the given location under a specific Azure subscription Parameters: location - name of the location

func (EventSubscriptionsClient) ListRegionalBySubscriptionForTopicType

func (client EventSubscriptionsClient) ListRegionalBySubscriptionForTopicType(ctx context.Context, location string, topicTypeName string) (result EventSubscriptionsListResult, err error)

ListRegionalBySubscriptionForTopicType list all event subscriptions from the given location under a specific Azure subscription and topic type. Parameters: location - name of the location topicTypeName - name of the topic type

func (EventSubscriptionsClient) ListRegionalBySubscriptionForTopicTypePreparer

func (client EventSubscriptionsClient) ListRegionalBySubscriptionForTopicTypePreparer(ctx context.Context, location string, topicTypeName string) (*http.Request, error)

ListRegionalBySubscriptionForTopicTypePreparer prepares the ListRegionalBySubscriptionForTopicType request.

func (EventSubscriptionsClient) ListRegionalBySubscriptionForTopicTypeResponder

func (client EventSubscriptionsClient) ListRegionalBySubscriptionForTopicTypeResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListRegionalBySubscriptionForTopicTypeResponder handles the response to the ListRegionalBySubscriptionForTopicType request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListRegionalBySubscriptionForTopicTypeSender

func (client EventSubscriptionsClient) ListRegionalBySubscriptionForTopicTypeSender(req *http.Request) (*http.Response, error)

ListRegionalBySubscriptionForTopicTypeSender sends the ListRegionalBySubscriptionForTopicType request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) ListRegionalBySubscriptionPreparer

func (client EventSubscriptionsClient) ListRegionalBySubscriptionPreparer(ctx context.Context, location string) (*http.Request, error)

ListRegionalBySubscriptionPreparer prepares the ListRegionalBySubscription request.

func (EventSubscriptionsClient) ListRegionalBySubscriptionResponder

func (client EventSubscriptionsClient) ListRegionalBySubscriptionResponder(resp *http.Response) (result EventSubscriptionsListResult, err error)

ListRegionalBySubscriptionResponder handles the response to the ListRegionalBySubscription request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) ListRegionalBySubscriptionSender

func (client EventSubscriptionsClient) ListRegionalBySubscriptionSender(req *http.Request) (*http.Response, error)

ListRegionalBySubscriptionSender sends the ListRegionalBySubscription request. The method will close the http.Response Body if it receives an error.

func (EventSubscriptionsClient) Update

func (client EventSubscriptionsClient) Update(ctx context.Context, scope string, eventSubscriptionName string, eventSubscriptionUpdateParameters EventSubscriptionUpdateParameters) (result EventSubscriptionsUpdateFuture, err error)

Update asynchronously updates an existing event subscription. Parameters: scope - the scope of existing event subscription. The scope can be a subscription, or a resource group, or a top level resource belonging to a resource provider namespace, or an EventGrid topic. For example, use '/subscriptions/{subscriptionId}/' for a subscription, '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}' for a resource group, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}' for a resource, and '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventGrid/topics/{topicName}' for an EventGrid topic. eventSubscriptionName - name of the event subscription to be updated eventSubscriptionUpdateParameters - updated event subscription information

func (EventSubscriptionsClient) UpdatePreparer

func (client EventSubscriptionsClient) UpdatePreparer(ctx context.Context, scope string, eventSubscriptionName string, eventSubscriptionUpdateParameters EventSubscriptionUpdateParameters) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (EventSubscriptionsClient) UpdateResponder

func (client EventSubscriptionsClient) UpdateResponder(resp *http.Response) (result EventSubscription, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (EventSubscriptionsClient) UpdateSender

func (client EventSubscriptionsClient) UpdateSender(req *http.Request) (future EventSubscriptionsUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type EventSubscriptionsCreateOrUpdateFuture

type EventSubscriptionsCreateOrUpdateFuture struct {
	azure.Future
}

EventSubscriptionsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*EventSubscriptionsCreateOrUpdateFuture) Result

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type EventSubscriptionsDeleteFuture

type EventSubscriptionsDeleteFuture struct {
	azure.Future
}

EventSubscriptionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*EventSubscriptionsDeleteFuture) Result

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type EventSubscriptionsListResult

type EventSubscriptionsListResult struct {
	autorest.Response `json:"-"`
	// Value - A collection of EventSubscriptions
	Value *[]EventSubscription `json:"value,omitempty"`
}

EventSubscriptionsListResult result of the List EventSubscriptions operation

type EventSubscriptionsUpdateFuture

type EventSubscriptionsUpdateFuture struct {
	azure.Future
}

EventSubscriptionsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*EventSubscriptionsUpdateFuture) Result

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type EventType

type EventType struct {
	// EventTypeProperties - Properties of the event type.
	*EventTypeProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Fully qualified identifier of the resource
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; Name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; Type of the resource
	Type *string `json:"type,omitempty"`
}

EventType event Type for a subject under a topic

func (EventType) MarshalJSON

func (et EventType) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventType.

func (*EventType) UnmarshalJSON

func (et *EventType) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventType struct.

type EventTypeProperties

type EventTypeProperties struct {
	// DisplayName - Display name of the event type.
	DisplayName *string `json:"displayName,omitempty"`
	// Description - Description of the event type.
	Description *string `json:"description,omitempty"`
	// SchemaURL - Url of the schema for this event type.
	SchemaURL *string `json:"schemaUrl,omitempty"`
}

EventTypeProperties properties of the event type

type EventTypesListResult

type EventTypesListResult struct {
	autorest.Response `json:"-"`
	// Value - A collection of event types
	Value *[]EventType `json:"value,omitempty"`
}

EventTypesListResult result of the List Event Types operation

type HybridConnectionEventSubscriptionDestination

type HybridConnectionEventSubscriptionDestination struct {
	// HybridConnectionEventSubscriptionDestinationProperties - Hybrid connection Properties of the event subscription destination
	*HybridConnectionEventSubscriptionDestinationProperties `json:"properties,omitempty"`
	// EndpointType - Possible values include: 'EndpointTypeEventSubscriptionDestination', 'EndpointTypeWebHook', 'EndpointTypeEventHub', 'EndpointTypeStorageQueue', 'EndpointTypeHybridConnection'
	EndpointType EndpointType `json:"endpointType,omitempty"`
}

HybridConnectionEventSubscriptionDestination information about the HybridConnection destination for an event subscription.

func (HybridConnectionEventSubscriptionDestination) AsBasicEventSubscriptionDestination

func (hcesd HybridConnectionEventSubscriptionDestination) AsBasicEventSubscriptionDestination() (BasicEventSubscriptionDestination, bool)

AsBasicEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for HybridConnectionEventSubscriptionDestination.

func (HybridConnectionEventSubscriptionDestination) AsEventHubEventSubscriptionDestination

func (hcesd HybridConnectionEventSubscriptionDestination) AsEventHubEventSubscriptionDestination() (*EventHubEventSubscriptionDestination, bool)

AsEventHubEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for HybridConnectionEventSubscriptionDestination.

func (HybridConnectionEventSubscriptionDestination) AsEventSubscriptionDestination

func (hcesd HybridConnectionEventSubscriptionDestination) AsEventSubscriptionDestination() (*EventSubscriptionDestination, bool)

AsEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for HybridConnectionEventSubscriptionDestination.

func (HybridConnectionEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination

func (hcesd HybridConnectionEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination() (*HybridConnectionEventSubscriptionDestination, bool)

AsHybridConnectionEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for HybridConnectionEventSubscriptionDestination.

func (HybridConnectionEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination

func (hcesd HybridConnectionEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination() (*StorageQueueEventSubscriptionDestination, bool)

AsStorageQueueEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for HybridConnectionEventSubscriptionDestination.

func (HybridConnectionEventSubscriptionDestination) AsWebHookEventSubscriptionDestination

func (hcesd HybridConnectionEventSubscriptionDestination) AsWebHookEventSubscriptionDestination() (*WebHookEventSubscriptionDestination, bool)

AsWebHookEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for HybridConnectionEventSubscriptionDestination.

func (HybridConnectionEventSubscriptionDestination) MarshalJSON

func (hcesd HybridConnectionEventSubscriptionDestination) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for HybridConnectionEventSubscriptionDestination.

func (*HybridConnectionEventSubscriptionDestination) UnmarshalJSON

func (hcesd *HybridConnectionEventSubscriptionDestination) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for HybridConnectionEventSubscriptionDestination struct.

type HybridConnectionEventSubscriptionDestinationProperties

type HybridConnectionEventSubscriptionDestinationProperties struct {
	// ResourceID - The Azure Resource ID of an hybrid connection that is the destination of an event subscription.
	ResourceID *string `json:"resourceId,omitempty"`
}

HybridConnectionEventSubscriptionDestinationProperties the properties for a hybrid connection destination.

type InputSchema

type InputSchema string

InputSchema enumerates the values for input schema.

const (
	// InputSchemaCloudEventV01Schema ...
	InputSchemaCloudEventV01Schema InputSchema = "CloudEventV01Schema"
	// InputSchemaCustomEventSchema ...
	InputSchemaCustomEventSchema InputSchema = "CustomEventSchema"
	// InputSchemaEventGridSchema ...
	InputSchemaEventGridSchema InputSchema = "EventGridSchema"
)

func PossibleInputSchemaValues

func PossibleInputSchemaValues() []InputSchema

PossibleInputSchemaValues returns an array of possible values for the InputSchema const type.

type InputSchemaMapping

type InputSchemaMapping struct {
	// InputSchemaMappingType - Possible values include: 'InputSchemaMappingTypeInputSchemaMapping', 'InputSchemaMappingTypeJSON'
	InputSchemaMappingType InputSchemaMappingType `json:"inputSchemaMappingType,omitempty"`
}

InputSchemaMapping by default, Event Grid expects events to be in the Event Grid event schema. Specifying an input schema mapping enables publishing to Event Grid using a custom input schema. Currently, the only supported type of InputSchemaMapping is 'JsonInputSchemaMapping'.

func (InputSchemaMapping) AsBasicInputSchemaMapping

func (ism InputSchemaMapping) AsBasicInputSchemaMapping() (BasicInputSchemaMapping, bool)

AsBasicInputSchemaMapping is the BasicInputSchemaMapping implementation for InputSchemaMapping.

func (InputSchemaMapping) AsInputSchemaMapping

func (ism InputSchemaMapping) AsInputSchemaMapping() (*InputSchemaMapping, bool)

AsInputSchemaMapping is the BasicInputSchemaMapping implementation for InputSchemaMapping.

func (InputSchemaMapping) AsJSONInputSchemaMapping

func (ism InputSchemaMapping) AsJSONInputSchemaMapping() (*JSONInputSchemaMapping, bool)

AsJSONInputSchemaMapping is the BasicInputSchemaMapping implementation for InputSchemaMapping.

func (InputSchemaMapping) MarshalJSON

func (ism InputSchemaMapping) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for InputSchemaMapping.

type InputSchemaMappingType

type InputSchemaMappingType string

InputSchemaMappingType enumerates the values for input schema mapping type.

const (
	// InputSchemaMappingTypeInputSchemaMapping ...
	InputSchemaMappingTypeInputSchemaMapping InputSchemaMappingType = "InputSchemaMapping"
	// InputSchemaMappingTypeJSON ...
	InputSchemaMappingTypeJSON InputSchemaMappingType = "Json"
)

func PossibleInputSchemaMappingTypeValues

func PossibleInputSchemaMappingTypeValues() []InputSchemaMappingType

PossibleInputSchemaMappingTypeValues returns an array of possible values for the InputSchemaMappingType const type.

type JSONField

type JSONField struct {
	// SourceField - Name of a field in the input event schema that's to be used as the source of a mapping.
	SourceField *string `json:"sourceField,omitempty"`
}

JSONField this is used to express the source of an input schema mapping for a single target field in the Event Grid Event schema. This is currently used in the mappings for the 'id','topic' and 'eventTime' properties. This represents a field in the input event schema.

type JSONFieldWithDefault

type JSONFieldWithDefault struct {
	// SourceField - Name of a field in the input event schema that's to be used as the source of a mapping.
	SourceField *string `json:"sourceField,omitempty"`
	// DefaultValue - The default value to be used for mapping when a SourceField is not provided or if there's no property with the specified name in the published JSON event payload.
	DefaultValue *string `json:"defaultValue,omitempty"`
}

JSONFieldWithDefault this is used to express the source of an input schema mapping for a single target field in the Event Grid Event schema. This is currently used in the mappings for the 'subject','eventType' and 'dataVersion' properties. This represents a field in the input event schema along with a default value to be used, and at least one of these two properties should be provided.

type JSONInputSchemaMapping

type JSONInputSchemaMapping struct {
	// JSONInputSchemaMappingProperties - JSON Properties of the input schema mapping
	*JSONInputSchemaMappingProperties `json:"properties,omitempty"`
	// InputSchemaMappingType - Possible values include: 'InputSchemaMappingTypeInputSchemaMapping', 'InputSchemaMappingTypeJSON'
	InputSchemaMappingType InputSchemaMappingType `json:"inputSchemaMappingType,omitempty"`
}

JSONInputSchemaMapping this enables publishing to Event Grid using a custom input schema. This can be used to map properties from a custom input JSON schema to the Event Grid event schema.

func (JSONInputSchemaMapping) AsBasicInputSchemaMapping

func (jism JSONInputSchemaMapping) AsBasicInputSchemaMapping() (BasicInputSchemaMapping, bool)

AsBasicInputSchemaMapping is the BasicInputSchemaMapping implementation for JSONInputSchemaMapping.

func (JSONInputSchemaMapping) AsInputSchemaMapping

func (jism JSONInputSchemaMapping) AsInputSchemaMapping() (*InputSchemaMapping, bool)

AsInputSchemaMapping is the BasicInputSchemaMapping implementation for JSONInputSchemaMapping.

func (JSONInputSchemaMapping) AsJSONInputSchemaMapping

func (jism JSONInputSchemaMapping) AsJSONInputSchemaMapping() (*JSONInputSchemaMapping, bool)

AsJSONInputSchemaMapping is the BasicInputSchemaMapping implementation for JSONInputSchemaMapping.

func (JSONInputSchemaMapping) MarshalJSON

func (jism JSONInputSchemaMapping) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for JSONInputSchemaMapping.

func (*JSONInputSchemaMapping) UnmarshalJSON

func (jism *JSONInputSchemaMapping) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for JSONInputSchemaMapping struct.

type JSONInputSchemaMappingProperties

type JSONInputSchemaMappingProperties struct {
	// ID - The mapping information for the Id property of the Event Grid Event.
	ID *JSONField `json:"id,omitempty"`
	// Topic - The mapping information for the Topic property of the Event Grid Event.
	Topic *JSONField `json:"topic,omitempty"`
	// EventTime - The mapping information for the EventTime property of the Event Grid Event.
	EventTime *JSONField `json:"eventTime,omitempty"`
	// EventType - The mapping information for the EventType property of the Event Grid Event.
	EventType *JSONFieldWithDefault `json:"eventType,omitempty"`
	// Subject - The mapping information for the Subject property of the Event Grid Event.
	Subject *JSONFieldWithDefault `json:"subject,omitempty"`
	// DataVersion - The mapping information for the DataVersion property of the Event Grid Event.
	DataVersion *JSONFieldWithDefault `json:"dataVersion,omitempty"`
}

JSONInputSchemaMappingProperties this can be used to map properties of a source schema (or default values, for certain supported properties) to properties of the EventGridEvent schema.

type Operation

type Operation struct {
	// Name - Name of the operation
	Name *string `json:"name,omitempty"`
	// Display - Display name of the operation
	Display *OperationInfo `json:"display,omitempty"`
	// Origin - Origin of the operation
	Origin *string `json:"origin,omitempty"`
	// Properties - Properties of the operation
	Properties interface{} `json:"properties,omitempty"`
}

Operation represents an operation returned by the GetOperations request

type OperationInfo

type OperationInfo struct {
	// Provider - Name of the provider
	Provider *string `json:"provider,omitempty"`
	// Resource - Name of the resource type
	Resource *string `json:"resource,omitempty"`
	// Operation - Name of the operation
	Operation *string `json:"operation,omitempty"`
	// Description - Description of the operation
	Description *string `json:"description,omitempty"`
}

OperationInfo information about an operation

type OperationsClient

type OperationsClient struct {
	BaseClient
}

OperationsClient is the azure EventGrid Management Client

func NewOperationsClient

func NewOperationsClient(subscriptionID string) OperationsClient

NewOperationsClient creates an instance of the OperationsClient client.

func NewOperationsClientWithBaseURI

func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient

NewOperationsClientWithBaseURI creates an instance of the OperationsClient client.

func (OperationsClient) List

func (client OperationsClient) List(ctx context.Context) (result OperationsListResult, err error)

List list the available operations supported by the Microsoft.EventGrid resource provider

func (OperationsClient) ListPreparer

func (client OperationsClient) ListPreparer(ctx context.Context) (*http.Request, error)

ListPreparer prepares the List request.

func (OperationsClient) ListResponder

func (client OperationsClient) ListResponder(resp *http.Response) (result OperationsListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (OperationsClient) ListSender

func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type OperationsListResult

type OperationsListResult struct {
	autorest.Response `json:"-"`
	// Value - A collection of operations
	Value *[]Operation `json:"value,omitempty"`
}

OperationsListResult result of the List Operations operation

type Resource

type Resource struct {
	// ID - READ-ONLY; Fully qualified identifier of the resource
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; Name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; Type of the resource
	Type *string `json:"type,omitempty"`
}

Resource definition of a Resource

type ResourceRegionType

type ResourceRegionType string

ResourceRegionType enumerates the values for resource region type.

const (
	// GlobalResource ...
	GlobalResource ResourceRegionType = "GlobalResource"
	// RegionalResource ...
	RegionalResource ResourceRegionType = "RegionalResource"
)

func PossibleResourceRegionTypeValues

func PossibleResourceRegionTypeValues() []ResourceRegionType

PossibleResourceRegionTypeValues returns an array of possible values for the ResourceRegionType const type.

type RetryPolicy

type RetryPolicy struct {
	// MaxDeliveryAttempts - Maximum number of delivery retry attempts for events.
	MaxDeliveryAttempts *int32 `json:"maxDeliveryAttempts,omitempty"`
	// EventTimeToLiveInMinutes - Time To Live (in minutes) for events.
	EventTimeToLiveInMinutes *int32 `json:"eventTimeToLiveInMinutes,omitempty"`
}

RetryPolicy information about the retry policy for an event subscription

type StorageBlobDeadLetterDestination

type StorageBlobDeadLetterDestination struct {
	// StorageBlobDeadLetterDestinationProperties - The properties of the Storage Blob based deadletter destination
	*StorageBlobDeadLetterDestinationProperties `json:"properties,omitempty"`
	// EndpointType - Possible values include: 'EndpointTypeDeadLetterDestination', 'EndpointTypeStorageBlob'
	EndpointType EndpointTypeBasicDeadLetterDestination `json:"endpointType,omitempty"`
}

StorageBlobDeadLetterDestination information about the storage blob based dead letter destination.

func (StorageBlobDeadLetterDestination) AsBasicDeadLetterDestination

func (sbdld StorageBlobDeadLetterDestination) AsBasicDeadLetterDestination() (BasicDeadLetterDestination, bool)

AsBasicDeadLetterDestination is the BasicDeadLetterDestination implementation for StorageBlobDeadLetterDestination.

func (StorageBlobDeadLetterDestination) AsDeadLetterDestination

func (sbdld StorageBlobDeadLetterDestination) AsDeadLetterDestination() (*DeadLetterDestination, bool)

AsDeadLetterDestination is the BasicDeadLetterDestination implementation for StorageBlobDeadLetterDestination.

func (StorageBlobDeadLetterDestination) AsStorageBlobDeadLetterDestination

func (sbdld StorageBlobDeadLetterDestination) AsStorageBlobDeadLetterDestination() (*StorageBlobDeadLetterDestination, bool)

AsStorageBlobDeadLetterDestination is the BasicDeadLetterDestination implementation for StorageBlobDeadLetterDestination.

func (StorageBlobDeadLetterDestination) MarshalJSON

func (sbdld StorageBlobDeadLetterDestination) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for StorageBlobDeadLetterDestination.

func (*StorageBlobDeadLetterDestination) UnmarshalJSON

func (sbdld *StorageBlobDeadLetterDestination) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for StorageBlobDeadLetterDestination struct.

type StorageBlobDeadLetterDestinationProperties

type StorageBlobDeadLetterDestinationProperties struct {
	// ResourceID - The Azure Resource ID of the storage account that is the destination of the deadletter events
	ResourceID *string `json:"resourceId,omitempty"`
	// BlobContainerName - The name of the Storage blob container that is the destination of the deadletter events
	BlobContainerName *string `json:"blobContainerName,omitempty"`
}

StorageBlobDeadLetterDestinationProperties properties of the storage blob based dead letter destination.

type StorageQueueEventSubscriptionDestination

type StorageQueueEventSubscriptionDestination struct {
	// StorageQueueEventSubscriptionDestinationProperties - Storage Queue Properties of the event subscription destination
	*StorageQueueEventSubscriptionDestinationProperties `json:"properties,omitempty"`
	// EndpointType - Possible values include: 'EndpointTypeEventSubscriptionDestination', 'EndpointTypeWebHook', 'EndpointTypeEventHub', 'EndpointTypeStorageQueue', 'EndpointTypeHybridConnection'
	EndpointType EndpointType `json:"endpointType,omitempty"`
}

StorageQueueEventSubscriptionDestination information about the storage queue destination for an event subscription.

func (StorageQueueEventSubscriptionDestination) AsBasicEventSubscriptionDestination

func (sqesd StorageQueueEventSubscriptionDestination) AsBasicEventSubscriptionDestination() (BasicEventSubscriptionDestination, bool)

AsBasicEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for StorageQueueEventSubscriptionDestination.

func (StorageQueueEventSubscriptionDestination) AsEventHubEventSubscriptionDestination

func (sqesd StorageQueueEventSubscriptionDestination) AsEventHubEventSubscriptionDestination() (*EventHubEventSubscriptionDestination, bool)

AsEventHubEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for StorageQueueEventSubscriptionDestination.

func (StorageQueueEventSubscriptionDestination) AsEventSubscriptionDestination

func (sqesd StorageQueueEventSubscriptionDestination) AsEventSubscriptionDestination() (*EventSubscriptionDestination, bool)

AsEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for StorageQueueEventSubscriptionDestination.

func (StorageQueueEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination

func (sqesd StorageQueueEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination() (*HybridConnectionEventSubscriptionDestination, bool)

AsHybridConnectionEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for StorageQueueEventSubscriptionDestination.

func (StorageQueueEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination

func (sqesd StorageQueueEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination() (*StorageQueueEventSubscriptionDestination, bool)

AsStorageQueueEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for StorageQueueEventSubscriptionDestination.

func (StorageQueueEventSubscriptionDestination) AsWebHookEventSubscriptionDestination

func (sqesd StorageQueueEventSubscriptionDestination) AsWebHookEventSubscriptionDestination() (*WebHookEventSubscriptionDestination, bool)

AsWebHookEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for StorageQueueEventSubscriptionDestination.

func (StorageQueueEventSubscriptionDestination) MarshalJSON

func (sqesd StorageQueueEventSubscriptionDestination) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for StorageQueueEventSubscriptionDestination.

func (*StorageQueueEventSubscriptionDestination) UnmarshalJSON

func (sqesd *StorageQueueEventSubscriptionDestination) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for StorageQueueEventSubscriptionDestination struct.

type StorageQueueEventSubscriptionDestinationProperties

type StorageQueueEventSubscriptionDestinationProperties struct {
	// ResourceID - The Azure Resource ID of the storage account that contains the queue that is the destination of an event subscription.
	ResourceID *string `json:"resourceId,omitempty"`
	// QueueName - The name of the Storage queue under a storage account that is the destination of an event subscription.
	QueueName *string `json:"queueName,omitempty"`
}

StorageQueueEventSubscriptionDestinationProperties the properties for a storage queue destination.

type Topic

type Topic struct {
	autorest.Response `json:"-"`
	// TopicProperties - Properties of the topic
	*TopicProperties `json:"properties,omitempty"`
	// Location - Location of the resource
	Location *string `json:"location,omitempty"`
	// Tags - Tags of the resource
	Tags map[string]*string `json:"tags"`
	// ID - READ-ONLY; Fully qualified identifier of the resource
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; Name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; Type of the resource
	Type *string `json:"type,omitempty"`
}

Topic eventGrid Topic

func (Topic) MarshalJSON

func (t Topic) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Topic.

func (*Topic) UnmarshalJSON

func (t *Topic) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for Topic struct.

type TopicProperties

type TopicProperties struct {
	// ProvisioningState - READ-ONLY; Provisioning state of the topic. Possible values include: 'TopicProvisioningStateCreating', 'TopicProvisioningStateUpdating', 'TopicProvisioningStateDeleting', 'TopicProvisioningStateSucceeded', 'TopicProvisioningStateCanceled', 'TopicProvisioningStateFailed'
	ProvisioningState TopicProvisioningState `json:"provisioningState,omitempty"`
	// Endpoint - READ-ONLY; Endpoint for the topic.
	Endpoint *string `json:"endpoint,omitempty"`
	// InputSchema - This determines the format that Event Grid should expect for incoming events published to the topic. Possible values include: 'InputSchemaEventGridSchema', 'InputSchemaCustomEventSchema', 'InputSchemaCloudEventV01Schema'
	InputSchema InputSchema `json:"inputSchema,omitempty"`
	// InputSchemaMapping - This enables publishing using custom event schemas. An InputSchemaMapping can be specified to map various properties of a source schema to various required properties of the EventGridEvent schema.
	InputSchemaMapping BasicInputSchemaMapping `json:"inputSchemaMapping,omitempty"`
}

TopicProperties properties of the Topic

func (*TopicProperties) UnmarshalJSON

func (tp *TopicProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for TopicProperties struct.

type TopicProvisioningState

type TopicProvisioningState string

TopicProvisioningState enumerates the values for topic provisioning state.

const (
	// TopicProvisioningStateCanceled ...
	TopicProvisioningStateCanceled TopicProvisioningState = "Canceled"
	// TopicProvisioningStateCreating ...
	TopicProvisioningStateCreating TopicProvisioningState = "Creating"
	// TopicProvisioningStateDeleting ...
	TopicProvisioningStateDeleting TopicProvisioningState = "Deleting"
	// TopicProvisioningStateFailed ...
	TopicProvisioningStateFailed TopicProvisioningState = "Failed"
	// TopicProvisioningStateSucceeded ...
	TopicProvisioningStateSucceeded TopicProvisioningState = "Succeeded"
	// TopicProvisioningStateUpdating ...
	TopicProvisioningStateUpdating TopicProvisioningState = "Updating"
)

func PossibleTopicProvisioningStateValues

func PossibleTopicProvisioningStateValues() []TopicProvisioningState

PossibleTopicProvisioningStateValues returns an array of possible values for the TopicProvisioningState const type.

type TopicRegenerateKeyRequest

type TopicRegenerateKeyRequest struct {
	// KeyName - Key name to regenerate key1 or key2
	KeyName *string `json:"keyName,omitempty"`
}

TopicRegenerateKeyRequest topic regenerate share access key request

type TopicSharedAccessKeys

type TopicSharedAccessKeys struct {
	autorest.Response `json:"-"`
	// Key1 - Shared access key1 for the topic.
	Key1 *string `json:"key1,omitempty"`
	// Key2 - Shared access key2 for the topic.
	Key2 *string `json:"key2,omitempty"`
}

TopicSharedAccessKeys shared access keys of the Topic

type TopicTypeInfo

type TopicTypeInfo struct {
	autorest.Response `json:"-"`
	// TopicTypeProperties - Properties of the topic type info
	*TopicTypeProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Fully qualified identifier of the resource
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; Name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; Type of the resource
	Type *string `json:"type,omitempty"`
}

TopicTypeInfo properties of a topic type info.

func (TopicTypeInfo) MarshalJSON

func (tti TopicTypeInfo) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TopicTypeInfo.

func (*TopicTypeInfo) UnmarshalJSON

func (tti *TopicTypeInfo) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for TopicTypeInfo struct.

type TopicTypeProperties

type TopicTypeProperties struct {
	// Provider - Namespace of the provider of the topic type.
	Provider *string `json:"provider,omitempty"`
	// DisplayName - Display Name for the topic type.
	DisplayName *string `json:"displayName,omitempty"`
	// Description - Description of the topic type.
	Description *string `json:"description,omitempty"`
	// ResourceRegionType - Region type of the resource. Possible values include: 'RegionalResource', 'GlobalResource'
	ResourceRegionType ResourceRegionType `json:"resourceRegionType,omitempty"`
	// ProvisioningState - Provisioning state of the topic type. Possible values include: 'TopicTypeProvisioningStateCreating', 'TopicTypeProvisioningStateUpdating', 'TopicTypeProvisioningStateDeleting', 'TopicTypeProvisioningStateSucceeded', 'TopicTypeProvisioningStateCanceled', 'TopicTypeProvisioningStateFailed'
	ProvisioningState TopicTypeProvisioningState `json:"provisioningState,omitempty"`
	// SupportedLocations - List of locations supported by this topic type.
	SupportedLocations *[]string `json:"supportedLocations,omitempty"`
}

TopicTypeProperties properties of a topic type.

type TopicTypeProvisioningState

type TopicTypeProvisioningState string

TopicTypeProvisioningState enumerates the values for topic type provisioning state.

const (
	// TopicTypeProvisioningStateCanceled ...
	TopicTypeProvisioningStateCanceled TopicTypeProvisioningState = "Canceled"
	// TopicTypeProvisioningStateCreating ...
	TopicTypeProvisioningStateCreating TopicTypeProvisioningState = "Creating"
	// TopicTypeProvisioningStateDeleting ...
	TopicTypeProvisioningStateDeleting TopicTypeProvisioningState = "Deleting"
	// TopicTypeProvisioningStateFailed ...
	TopicTypeProvisioningStateFailed TopicTypeProvisioningState = "Failed"
	// TopicTypeProvisioningStateSucceeded ...
	TopicTypeProvisioningStateSucceeded TopicTypeProvisioningState = "Succeeded"
	// TopicTypeProvisioningStateUpdating ...
	TopicTypeProvisioningStateUpdating TopicTypeProvisioningState = "Updating"
)

func PossibleTopicTypeProvisioningStateValues

func PossibleTopicTypeProvisioningStateValues() []TopicTypeProvisioningState

PossibleTopicTypeProvisioningStateValues returns an array of possible values for the TopicTypeProvisioningState const type.

type TopicTypesClient

type TopicTypesClient struct {
	BaseClient
}

TopicTypesClient is the azure EventGrid Management Client

func NewTopicTypesClient

func NewTopicTypesClient(subscriptionID string) TopicTypesClient

NewTopicTypesClient creates an instance of the TopicTypesClient client.

func NewTopicTypesClientWithBaseURI

func NewTopicTypesClientWithBaseURI(baseURI string, subscriptionID string) TopicTypesClient

NewTopicTypesClientWithBaseURI creates an instance of the TopicTypesClient client.

func (TopicTypesClient) Get

func (client TopicTypesClient) Get(ctx context.Context, topicTypeName string) (result TopicTypeInfo, err error)

Get get information about a topic type Parameters: topicTypeName - name of the topic type

func (TopicTypesClient) GetPreparer

func (client TopicTypesClient) GetPreparer(ctx context.Context, topicTypeName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (TopicTypesClient) GetResponder

func (client TopicTypesClient) GetResponder(resp *http.Response) (result TopicTypeInfo, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (TopicTypesClient) GetSender

func (client TopicTypesClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (TopicTypesClient) List

func (client TopicTypesClient) List(ctx context.Context) (result TopicTypesListResult, err error)

List list all registered topic types

func (TopicTypesClient) ListEventTypes

func (client TopicTypesClient) ListEventTypes(ctx context.Context, topicTypeName string) (result EventTypesListResult, err error)

ListEventTypes list event types for a topic type Parameters: topicTypeName - name of the topic type

func (TopicTypesClient) ListEventTypesPreparer

func (client TopicTypesClient) ListEventTypesPreparer(ctx context.Context, topicTypeName string) (*http.Request, error)

ListEventTypesPreparer prepares the ListEventTypes request.

func (TopicTypesClient) ListEventTypesResponder

func (client TopicTypesClient) ListEventTypesResponder(resp *http.Response) (result EventTypesListResult, err error)

ListEventTypesResponder handles the response to the ListEventTypes request. The method always closes the http.Response Body.

func (TopicTypesClient) ListEventTypesSender

func (client TopicTypesClient) ListEventTypesSender(req *http.Request) (*http.Response, error)

ListEventTypesSender sends the ListEventTypes request. The method will close the http.Response Body if it receives an error.

func (TopicTypesClient) ListPreparer

func (client TopicTypesClient) ListPreparer(ctx context.Context) (*http.Request, error)

ListPreparer prepares the List request.

func (TopicTypesClient) ListResponder

func (client TopicTypesClient) ListResponder(resp *http.Response) (result TopicTypesListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (TopicTypesClient) ListSender

func (client TopicTypesClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type TopicTypesListResult

type TopicTypesListResult struct {
	autorest.Response `json:"-"`
	// Value - A collection of topic types
	Value *[]TopicTypeInfo `json:"value,omitempty"`
}

TopicTypesListResult result of the List Topic Types operation

type TopicUpdateParameters

type TopicUpdateParameters struct {
	// Tags - Tags of the resource
	Tags map[string]*string `json:"tags"`
}

TopicUpdateParameters properties of the Topic update

func (TopicUpdateParameters) MarshalJSON

func (tup TopicUpdateParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TopicUpdateParameters.

type TopicsClient

type TopicsClient struct {
	BaseClient
}

TopicsClient is the azure EventGrid Management Client

func NewTopicsClient

func NewTopicsClient(subscriptionID string) TopicsClient

NewTopicsClient creates an instance of the TopicsClient client.

func NewTopicsClientWithBaseURI

func NewTopicsClientWithBaseURI(baseURI string, subscriptionID string) TopicsClient

NewTopicsClientWithBaseURI creates an instance of the TopicsClient client.

func (TopicsClient) CreateOrUpdate

func (client TopicsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, topicName string, topicInfo Topic) (result TopicsCreateOrUpdateFuture, err error)

CreateOrUpdate asynchronously creates a new topic with the specified parameters. Parameters: resourceGroupName - the name of the resource group within the user's subscription. topicName - name of the topic topicInfo - topic information

func (TopicsClient) CreateOrUpdatePreparer

func (client TopicsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, topicName string, topicInfo Topic) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (TopicsClient) CreateOrUpdateResponder

func (client TopicsClient) CreateOrUpdateResponder(resp *http.Response) (result Topic, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (TopicsClient) CreateOrUpdateSender

func (client TopicsClient) CreateOrUpdateSender(req *http.Request) (future TopicsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) Delete

func (client TopicsClient) Delete(ctx context.Context, resourceGroupName string, topicName string) (result TopicsDeleteFuture, err error)

Delete delete existing topic Parameters: resourceGroupName - the name of the resource group within the user's subscription. topicName - name of the topic

func (TopicsClient) DeletePreparer

func (client TopicsClient) DeletePreparer(ctx context.Context, resourceGroupName string, topicName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (TopicsClient) DeleteResponder

func (client TopicsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (TopicsClient) DeleteSender

func (client TopicsClient) DeleteSender(req *http.Request) (future TopicsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) Get

func (client TopicsClient) Get(ctx context.Context, resourceGroupName string, topicName string) (result Topic, err error)

Get get properties of a topic Parameters: resourceGroupName - the name of the resource group within the user's subscription. topicName - name of the topic

func (TopicsClient) GetPreparer

func (client TopicsClient) GetPreparer(ctx context.Context, resourceGroupName string, topicName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (TopicsClient) GetResponder

func (client TopicsClient) GetResponder(resp *http.Response) (result Topic, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (TopicsClient) GetSender

func (client TopicsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) ListByResourceGroup

func (client TopicsClient) ListByResourceGroup(ctx context.Context, resourceGroupName string) (result TopicsListResult, err error)

ListByResourceGroup list all the topics under a resource group Parameters: resourceGroupName - the name of the resource group within the user's subscription.

func (TopicsClient) ListByResourceGroupPreparer

func (client TopicsClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error)

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (TopicsClient) ListByResourceGroupResponder

func (client TopicsClient) ListByResourceGroupResponder(resp *http.Response) (result TopicsListResult, err error)

ListByResourceGroupResponder handles the response to the ListByResourceGroup request. The method always closes the http.Response Body.

func (TopicsClient) ListByResourceGroupSender

func (client TopicsClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)

ListByResourceGroupSender sends the ListByResourceGroup request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) ListBySubscription

func (client TopicsClient) ListBySubscription(ctx context.Context) (result TopicsListResult, err error)

ListBySubscription list all the topics under an Azure subscription

func (TopicsClient) ListBySubscriptionPreparer

func (client TopicsClient) ListBySubscriptionPreparer(ctx context.Context) (*http.Request, error)

ListBySubscriptionPreparer prepares the ListBySubscription request.

func (TopicsClient) ListBySubscriptionResponder

func (client TopicsClient) ListBySubscriptionResponder(resp *http.Response) (result TopicsListResult, err error)

ListBySubscriptionResponder handles the response to the ListBySubscription request. The method always closes the http.Response Body.

func (TopicsClient) ListBySubscriptionSender

func (client TopicsClient) ListBySubscriptionSender(req *http.Request) (*http.Response, error)

ListBySubscriptionSender sends the ListBySubscription request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) ListEventTypes

func (client TopicsClient) ListEventTypes(ctx context.Context, resourceGroupName string, providerNamespace string, resourceTypeName string, resourceName string) (result EventTypesListResult, err error)

ListEventTypes list event types for a topic Parameters: resourceGroupName - the name of the resource group within the user's subscription. providerNamespace - namespace of the provider of the topic resourceTypeName - name of the topic type resourceName - name of the topic

func (TopicsClient) ListEventTypesPreparer

func (client TopicsClient) ListEventTypesPreparer(ctx context.Context, resourceGroupName string, providerNamespace string, resourceTypeName string, resourceName string) (*http.Request, error)

ListEventTypesPreparer prepares the ListEventTypes request.

func (TopicsClient) ListEventTypesResponder

func (client TopicsClient) ListEventTypesResponder(resp *http.Response) (result EventTypesListResult, err error)

ListEventTypesResponder handles the response to the ListEventTypes request. The method always closes the http.Response Body.

func (TopicsClient) ListEventTypesSender

func (client TopicsClient) ListEventTypesSender(req *http.Request) (*http.Response, error)

ListEventTypesSender sends the ListEventTypes request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) ListSharedAccessKeys

func (client TopicsClient) ListSharedAccessKeys(ctx context.Context, resourceGroupName string, topicName string) (result TopicSharedAccessKeys, err error)

ListSharedAccessKeys list the two keys used to publish to a topic Parameters: resourceGroupName - the name of the resource group within the user's subscription. topicName - name of the topic

func (TopicsClient) ListSharedAccessKeysPreparer

func (client TopicsClient) ListSharedAccessKeysPreparer(ctx context.Context, resourceGroupName string, topicName string) (*http.Request, error)

ListSharedAccessKeysPreparer prepares the ListSharedAccessKeys request.

func (TopicsClient) ListSharedAccessKeysResponder

func (client TopicsClient) ListSharedAccessKeysResponder(resp *http.Response) (result TopicSharedAccessKeys, err error)

ListSharedAccessKeysResponder handles the response to the ListSharedAccessKeys request. The method always closes the http.Response Body.

func (TopicsClient) ListSharedAccessKeysSender

func (client TopicsClient) ListSharedAccessKeysSender(req *http.Request) (*http.Response, error)

ListSharedAccessKeysSender sends the ListSharedAccessKeys request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) RegenerateKey

func (client TopicsClient) RegenerateKey(ctx context.Context, resourceGroupName string, topicName string, regenerateKeyRequest TopicRegenerateKeyRequest) (result TopicSharedAccessKeys, err error)

RegenerateKey regenerate a shared access key for a topic Parameters: resourceGroupName - the name of the resource group within the user's subscription. topicName - name of the topic regenerateKeyRequest - request body to regenerate key

func (TopicsClient) RegenerateKeyPreparer

func (client TopicsClient) RegenerateKeyPreparer(ctx context.Context, resourceGroupName string, topicName string, regenerateKeyRequest TopicRegenerateKeyRequest) (*http.Request, error)

RegenerateKeyPreparer prepares the RegenerateKey request.

func (TopicsClient) RegenerateKeyResponder

func (client TopicsClient) RegenerateKeyResponder(resp *http.Response) (result TopicSharedAccessKeys, err error)

RegenerateKeyResponder handles the response to the RegenerateKey request. The method always closes the http.Response Body.

func (TopicsClient) RegenerateKeySender

func (client TopicsClient) RegenerateKeySender(req *http.Request) (*http.Response, error)

RegenerateKeySender sends the RegenerateKey request. The method will close the http.Response Body if it receives an error.

func (TopicsClient) Update

func (client TopicsClient) Update(ctx context.Context, resourceGroupName string, topicName string, topicUpdateParameters TopicUpdateParameters) (result TopicsUpdateFuture, err error)

Update asynchronously updates a topic with the specified parameters. Parameters: resourceGroupName - the name of the resource group within the user's subscription. topicName - name of the topic topicUpdateParameters - topic update information

func (TopicsClient) UpdatePreparer

func (client TopicsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, topicName string, topicUpdateParameters TopicUpdateParameters) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (TopicsClient) UpdateResponder

func (client TopicsClient) UpdateResponder(resp *http.Response) (result Topic, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (TopicsClient) UpdateSender

func (client TopicsClient) UpdateSender(req *http.Request) (future TopicsUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type TopicsCreateOrUpdateFuture

type TopicsCreateOrUpdateFuture struct {
	azure.Future
}

TopicsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*TopicsCreateOrUpdateFuture) Result

func (future *TopicsCreateOrUpdateFuture) Result(client TopicsClient) (t Topic, err error)

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type TopicsDeleteFuture

type TopicsDeleteFuture struct {
	azure.Future
}

TopicsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*TopicsDeleteFuture) Result

func (future *TopicsDeleteFuture) Result(client TopicsClient) (ar autorest.Response, err error)

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type TopicsListResult

type TopicsListResult struct {
	autorest.Response `json:"-"`
	// Value - A collection of Topics
	Value *[]Topic `json:"value,omitempty"`
}

TopicsListResult result of the List Topics operation

type TopicsUpdateFuture

type TopicsUpdateFuture struct {
	azure.Future
}

TopicsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*TopicsUpdateFuture) Result

func (future *TopicsUpdateFuture) Result(client TopicsClient) (t Topic, err error)

Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.

type TrackedResource

type TrackedResource struct {
	// Location - Location of the resource
	Location *string `json:"location,omitempty"`
	// Tags - Tags of the resource
	Tags map[string]*string `json:"tags"`
	// ID - READ-ONLY; Fully qualified identifier of the resource
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; Name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; Type of the resource
	Type *string `json:"type,omitempty"`
}

TrackedResource definition of a Tracked Resource

func (TrackedResource) MarshalJSON

func (tr TrackedResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TrackedResource.

type WebHookEventSubscriptionDestination

type WebHookEventSubscriptionDestination struct {
	// WebHookEventSubscriptionDestinationProperties - WebHook Properties of the event subscription destination
	*WebHookEventSubscriptionDestinationProperties `json:"properties,omitempty"`
	// EndpointType - Possible values include: 'EndpointTypeEventSubscriptionDestination', 'EndpointTypeWebHook', 'EndpointTypeEventHub', 'EndpointTypeStorageQueue', 'EndpointTypeHybridConnection'
	EndpointType EndpointType `json:"endpointType,omitempty"`
}

WebHookEventSubscriptionDestination information about the webhook destination for an event subscription

func (WebHookEventSubscriptionDestination) AsBasicEventSubscriptionDestination

func (whesd WebHookEventSubscriptionDestination) AsBasicEventSubscriptionDestination() (BasicEventSubscriptionDestination, bool)

AsBasicEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for WebHookEventSubscriptionDestination.

func (WebHookEventSubscriptionDestination) AsEventHubEventSubscriptionDestination

func (whesd WebHookEventSubscriptionDestination) AsEventHubEventSubscriptionDestination() (*EventHubEventSubscriptionDestination, bool)

AsEventHubEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for WebHookEventSubscriptionDestination.

func (WebHookEventSubscriptionDestination) AsEventSubscriptionDestination

func (whesd WebHookEventSubscriptionDestination) AsEventSubscriptionDestination() (*EventSubscriptionDestination, bool)

AsEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for WebHookEventSubscriptionDestination.

func (WebHookEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination

func (whesd WebHookEventSubscriptionDestination) AsHybridConnectionEventSubscriptionDestination() (*HybridConnectionEventSubscriptionDestination, bool)

AsHybridConnectionEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for WebHookEventSubscriptionDestination.

func (WebHookEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination

func (whesd WebHookEventSubscriptionDestination) AsStorageQueueEventSubscriptionDestination() (*StorageQueueEventSubscriptionDestination, bool)

AsStorageQueueEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for WebHookEventSubscriptionDestination.

func (WebHookEventSubscriptionDestination) AsWebHookEventSubscriptionDestination

func (whesd WebHookEventSubscriptionDestination) AsWebHookEventSubscriptionDestination() (*WebHookEventSubscriptionDestination, bool)

AsWebHookEventSubscriptionDestination is the BasicEventSubscriptionDestination implementation for WebHookEventSubscriptionDestination.

func (WebHookEventSubscriptionDestination) MarshalJSON

func (whesd WebHookEventSubscriptionDestination) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for WebHookEventSubscriptionDestination.

func (*WebHookEventSubscriptionDestination) UnmarshalJSON

func (whesd *WebHookEventSubscriptionDestination) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for WebHookEventSubscriptionDestination struct.

type WebHookEventSubscriptionDestinationProperties

type WebHookEventSubscriptionDestinationProperties struct {
	// EndpointURL - The URL that represents the endpoint of the destination of an event subscription.
	EndpointURL *string `json:"endpointUrl,omitempty"`
	// EndpointBaseURL - READ-ONLY; The base URL that represents the endpoint of the destination of an event subscription.
	EndpointBaseURL *string `json:"endpointBaseUrl,omitempty"`
}

WebHookEventSubscriptionDestinationProperties information about the webhook destination properties for an event subscription.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL