streamanalytics

package
v10.1.1-beta+incompatible Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2017 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package streamanalytics implements the Azure ARM Streamanalytics service API version .

Composite Swagger for Stream Analytics Client

Index

Constants

View Source 
const (
	// DefaultBaseURI is the default URI used for the service Streamanalytics
	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 AvroSerialization 

type AvroSerialization struct {
	Properties *map[string]interface{} `json:"properties,omitempty"`
}

AvroSerialization is describes how data from an input is serialized or how data is serialized when written to an output in Avro format.

type AzureMachineLearningWebServiceFunctionBinding 

type AzureMachineLearningWebServiceFunctionBinding struct {
	*AzureMachineLearningWebServiceFunctionBindingProperties `json:"properties,omitempty"`
}

AzureMachineLearningWebServiceFunctionBinding is the binding to an Azure Machine Learning web service.

type AzureMachineLearningWebServiceFunctionBindingProperties 

type AzureMachineLearningWebServiceFunctionBindingProperties struct {
	Endpoint  *string                                       `json:"endpoint,omitempty"`
	APIKey    *string                                       `json:"apiKey,omitempty"`
	Inputs    *AzureMachineLearningWebServiceInputs         `json:"inputs,omitempty"`
	Outputs   *[]AzureMachineLearningWebServiceOutputColumn `json:"outputs,omitempty"`
	BatchSize *int32                                        `json:"batchSize,omitempty"`
}

AzureMachineLearningWebServiceFunctionBindingProperties is the binding properties associated with an Azure Machine learning web service.

type AzureMachineLearningWebServiceFunctionBindingRetrievalProperties 

type AzureMachineLearningWebServiceFunctionBindingRetrievalProperties struct {
	ExecuteEndpoint *string `json:"executeEndpoint,omitempty"`
	UdfType         UdfType `json:"udfType,omitempty"`
}

AzureMachineLearningWebServiceFunctionBindingRetrievalProperties is the binding retrieval properties associated with an Azure Machine learning web service.

type AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters 

type AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters struct {
	*AzureMachineLearningWebServiceFunctionBindingRetrievalProperties `json:"bindingRetrievalProperties,omitempty"`
}

AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters is the parameters needed to retrieve the default function definition for an Azure Machine Learning web service function.

type AzureMachineLearningWebServiceInputColumn 

type AzureMachineLearningWebServiceInputColumn struct {
	Name     *string `json:"name,omitempty"`
	DataType *string `json:"dataType,omitempty"`
	MapTo    *int32  `json:"mapTo,omitempty"`
}

AzureMachineLearningWebServiceInputColumn is describes an input column for the Azure Machine Learning web service endpoint.

type AzureMachineLearningWebServiceInputs 

type AzureMachineLearningWebServiceInputs struct {
	Name        *string                                      `json:"name,omitempty"`
	ColumnNames *[]AzureMachineLearningWebServiceInputColumn `json:"columnNames,omitempty"`
}

AzureMachineLearningWebServiceInputs is the inputs for the Azure Machine Learning web service endpoint.

type AzureMachineLearningWebServiceOutputColumn 

type AzureMachineLearningWebServiceOutputColumn struct {
	Name     *string `json:"name,omitempty"`
	DataType *string `json:"dataType,omitempty"`
}

AzureMachineLearningWebServiceOutputColumn is describes an output column for the Azure Machine Learning web service endpoint.

type AzureSQLDatabaseDataSourceProperties 

type AzureSQLDatabaseDataSourceProperties struct {
	Server   *string `json:"server,omitempty"`
	Database *string `json:"database,omitempty"`
	User     *string `json:"user,omitempty"`
	Password *string `json:"password,omitempty"`
	Table    *string `json:"table,omitempty"`
}

AzureSQLDatabaseDataSourceProperties is the properties that are associated with an Azure SQL database data source.

type AzureSQLDatabaseOutputDataSource 

type AzureSQLDatabaseOutputDataSource struct {
	*AzureSQLDatabaseOutputDataSourceProperties `json:"properties,omitempty"`
}

AzureSQLDatabaseOutputDataSource is describes an Azure SQL database output data source.

type AzureSQLDatabaseOutputDataSourceProperties 

type AzureSQLDatabaseOutputDataSourceProperties struct {
	Server   *string `json:"server,omitempty"`
	Database *string `json:"database,omitempty"`
	User     *string `json:"user,omitempty"`
	Password *string `json:"password,omitempty"`
	Table    *string `json:"table,omitempty"`
}

AzureSQLDatabaseOutputDataSourceProperties is the properties that are associated with an Azure SQL database output.

type AzureTableOutputDataSource 

type AzureTableOutputDataSource struct {
	*AzureTableOutputDataSourceProperties `json:"properties,omitempty"`
}

AzureTableOutputDataSource is describes an Azure Table data source.

type AzureTableOutputDataSourceProperties 

type AzureTableOutputDataSourceProperties struct {
	AccountName     *string   `json:"accountName,omitempty"`
	AccountKey      *string   `json:"accountKey,omitempty"`
	Table           *string   `json:"table,omitempty"`
	PartitionKey    *string   `json:"partitionKey,omitempty"`
	RowKey          *string   `json:"rowKey,omitempty"`
	ColumnsToRemove *[]string `json:"columnsToRemove,omitempty"`
	BatchSize       *int32    `json:"batchSize,omitempty"`
}

AzureTableOutputDataSourceProperties is the properties that are associated with an Azure Table output.

type BlobDataSourceProperties 

type BlobDataSourceProperties struct {
	StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"`
	Container       *string           `json:"container,omitempty"`
	PathPattern     *string           `json:"pathPattern,omitempty"`
	DateFormat      *string           `json:"dateFormat,omitempty"`
	TimeFormat      *string           `json:"timeFormat,omitempty"`
}

BlobDataSourceProperties is the properties that are associated with a blob data source.

type BlobOutputDataSource 

type BlobOutputDataSource struct {
	*BlobOutputDataSourceProperties `json:"properties,omitempty"`
}

BlobOutputDataSource is describes a blob output data source.

type BlobOutputDataSourceProperties 

type BlobOutputDataSourceProperties struct {
	StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"`
	Container       *string           `json:"container,omitempty"`
	PathPattern     *string           `json:"pathPattern,omitempty"`
	DateFormat      *string           `json:"dateFormat,omitempty"`
	TimeFormat      *string           `json:"timeFormat,omitempty"`
}

BlobOutputDataSourceProperties is the properties that are associated with a blob output.

type BlobReferenceInputDataSource 

type BlobReferenceInputDataSource struct {
	*BlobReferenceInputDataSourceProperties `json:"properties,omitempty"`
}

BlobReferenceInputDataSource is describes a blob input data source that contains reference data.

type BlobReferenceInputDataSourceProperties 

type BlobReferenceInputDataSourceProperties struct {
	StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"`
	Container       *string           `json:"container,omitempty"`
	PathPattern     *string           `json:"pathPattern,omitempty"`
	DateFormat      *string           `json:"dateFormat,omitempty"`
	TimeFormat      *string           `json:"timeFormat,omitempty"`
}

BlobReferenceInputDataSourceProperties is the properties that are associated with a blob input containing reference data.

type BlobStreamInputDataSource 

type BlobStreamInputDataSource struct {
	*BlobStreamInputDataSourceProperties `json:"properties,omitempty"`
}

BlobStreamInputDataSource is describes a blob input data source that contains stream data.

type BlobStreamInputDataSourceProperties 

type BlobStreamInputDataSourceProperties struct {
	StorageAccounts      *[]StorageAccount `json:"storageAccounts,omitempty"`
	Container            *string           `json:"container,omitempty"`
	PathPattern          *string           `json:"pathPattern,omitempty"`
	DateFormat           *string           `json:"dateFormat,omitempty"`
	TimeFormat           *string           `json:"timeFormat,omitempty"`
	SourcePartitionCount *int32            `json:"sourcePartitionCount,omitempty"`
}

BlobStreamInputDataSourceProperties is the properties that are associated with a blob input containing stream data.

type CompatibilityLevel 

type CompatibilityLevel string

CompatibilityLevel enumerates the values for compatibility level. 

const (
	// OneFullStopZero specifies the one full stop zero state for compatibility
	// level.
	OneFullStopZero CompatibilityLevel = "1.0"
)

type CsvSerialization 

type CsvSerialization struct {
	*CsvSerializationProperties `json:"properties,omitempty"`
}

CsvSerialization is describes how data from an input is serialized or how data is serialized when written to an output in CSV format.

type CsvSerializationProperties 

type CsvSerializationProperties struct {
	FieldDelimiter *string  `json:"fieldDelimiter,omitempty"`
	Encoding       Encoding `json:"encoding,omitempty"`
}

CsvSerializationProperties is the properties that are associated with the CSV serialization type.

type DiagnosticCondition 

type DiagnosticCondition struct {
	Since   *string `json:"since,omitempty"`
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
}

DiagnosticCondition is condition applicable to the resource, or to the job overall, that warrant customer attention.

type Diagnostics 

type Diagnostics struct {
	Conditions *[]DiagnosticCondition `json:"conditions,omitempty"`
}

Diagnostics is describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention.

type DocumentDbOutputDataSource 

type DocumentDbOutputDataSource struct {
	*DocumentDbOutputDataSourceProperties `json:"properties,omitempty"`
}

DocumentDbOutputDataSource is describes a DocumentDB data source.

type DocumentDbOutputDataSourceProperties 

type DocumentDbOutputDataSourceProperties struct {
	AccountID             *string `json:"accountId,omitempty"`
	AccountKey            *string `json:"accountKey,omitempty"`
	Database              *string `json:"database,omitempty"`
	CollectionNamePattern *string `json:"collectionNamePattern,omitempty"`
	PartitionKey          *string `json:"partitionKey,omitempty"`
	DocumentID            *string `json:"documentId,omitempty"`
}

DocumentDbOutputDataSourceProperties is the properties that are associated with a DocumentDB output.

type Encoding 

type Encoding string

Encoding enumerates the values for encoding. 

const (
	// UTF8 specifies the utf8 state for encoding.
	UTF8 Encoding = "UTF8"
)

type ErrorResponse 

type ErrorResponse struct {
	Code    *string `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
}

ErrorResponse is describes the error that occurred.

type EventHubDataSourceProperties 

type EventHubDataSourceProperties struct {
	ServiceBusNamespace    *string `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
	SharedAccessPolicyKey  *string `json:"sharedAccessPolicyKey,omitempty"`
	EventHubName           *string `json:"eventHubName,omitempty"`
}

EventHubDataSourceProperties is the common properties that are associated with Event Hub data sources.

type EventHubOutputDataSource 

type EventHubOutputDataSource struct {
	*EventHubOutputDataSourceProperties `json:"properties,omitempty"`
}

EventHubOutputDataSource is describes an Event Hub output data source.

type EventHubOutputDataSourceProperties 

type EventHubOutputDataSourceProperties struct {
	ServiceBusNamespace    *string `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
	SharedAccessPolicyKey  *string `json:"sharedAccessPolicyKey,omitempty"`
	EventHubName           *string `json:"eventHubName,omitempty"`
	PartitionKey           *string `json:"partitionKey,omitempty"`
}

EventHubOutputDataSourceProperties is the properties that are associated with an Event Hub output.

type EventHubStreamInputDataSource 

type EventHubStreamInputDataSource struct {
	*EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`
}

EventHubStreamInputDataSource is describes an Event Hub input data source that contains stream data.

type EventHubStreamInputDataSourceProperties 

type EventHubStreamInputDataSourceProperties struct {
	ServiceBusNamespace    *string `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
	SharedAccessPolicyKey  *string `json:"sharedAccessPolicyKey,omitempty"`
	EventHubName           *string `json:"eventHubName,omitempty"`
	ConsumerGroupName      *string `json:"consumerGroupName,omitempty"`
}

EventHubStreamInputDataSourceProperties is the properties that are associated with a Event Hub input containing stream data.

type EventsOutOfOrderPolicy 

type EventsOutOfOrderPolicy string

EventsOutOfOrderPolicy enumerates the values for events out of order policy. 

const (
	// Adjust specifies the adjust state for events out of order policy.
	Adjust EventsOutOfOrderPolicy = "Adjust"
	// Drop specifies the drop state for events out of order policy.
	Drop EventsOutOfOrderPolicy = "Drop"
)

type Function 

type Function struct {
	autorest.Response `json:"-"`
	ID                *string             `json:"id,omitempty"`
	Name              *string             `json:"name,omitempty"`
	Type              *string             `json:"type,omitempty"`
	Properties        *FunctionProperties `json:"properties,omitempty"`
}

Function is a function object, containing all information associated with the named function. All functions are contained under a streaming job.

type FunctionBinding 

type FunctionBinding struct {
}

FunctionBinding is the physical binding of the function. For example, in the Azure Machine Learning web service’s case, this describes the endpoint.

type FunctionInput 

type FunctionInput struct {
	DataType                 *string `json:"dataType,omitempty"`
	IsConfigurationParameter *bool   `json:"isConfigurationParameter,omitempty"`
}

FunctionInput is describes one input parameter of a function.

type FunctionListResult 

type FunctionListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Function `json:"value,omitempty"`
	NextLink          *string     `json:"nextLink,omitempty"`
}

FunctionListResult is object containing a list of functions under a streaming job.

func (FunctionListResult) FunctionListResultPreparer 

func (client FunctionListResult) FunctionListResultPreparer() (*http.Request, error)

FunctionListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type FunctionOutput 

type FunctionOutput struct {
	DataType *string `json:"dataType,omitempty"`
}

FunctionOutput is describes the output of a function.

type FunctionProperties 

type FunctionProperties struct {
	Etag *string `json:"etag,omitempty"`
}

FunctionProperties is the properties that are associated with a function.

type FunctionRetrieveDefaultDefinitionParameters 

type FunctionRetrieveDefaultDefinitionParameters struct {
}

FunctionRetrieveDefaultDefinitionParameters is parameters used to specify the type of function to retrieve the default definition for.

type FunctionsClient 

type FunctionsClient struct {
	ManagementClient
}

FunctionsClient is the composite Swagger for Stream Analytics Client

func NewFunctionsClient 

func NewFunctionsClient(subscriptionID string) FunctionsClient

NewFunctionsClient creates an instance of the FunctionsClient client.

func NewFunctionsClientWithBaseURI 

func NewFunctionsClientWithBaseURI(baseURI string, subscriptionID string) FunctionsClient

NewFunctionsClientWithBaseURI creates an instance of the FunctionsClient client.

func (FunctionsClient) CreateOrReplace 

func (client FunctionsClient) CreateOrReplace(function Function, resourceGroupName string, jobName string, functionName string, ifMatch string, ifNoneMatch string) (result Function, err error)

CreateOrReplace creates a function or replaces an already existing function under an existing streaming job.

function is the definition of the function that will be used to create a new function or replace the existing one under the streaming job. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. functionName is the name of the function. ifMatch is the ETag of the function. Omit this value to always overwrite the current function. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes. ifNoneMatch is set to '*' to allow a new function to be created, but to prevent updating an existing function. Other values will result in a 412 Pre-condition Failed response.

func (FunctionsClient) CreateOrReplacePreparer 

func (client FunctionsClient) CreateOrReplacePreparer(function Function, resourceGroupName string, jobName string, functionName string, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (FunctionsClient) CreateOrReplaceResponder 

func (client FunctionsClient) CreateOrReplaceResponder(resp *http.Response) (result Function, err error)

CreateOrReplaceResponder handles the response to the CreateOrReplace request. The method always closes the http.Response Body.

func (FunctionsClient) CreateOrReplaceSender 

func (client FunctionsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error)

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

func (FunctionsClient) Delete 

func (client FunctionsClient) Delete(resourceGroupName string, jobName string, functionName string) (result autorest.Response, err error)

Delete deletes a function from the streaming job.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. functionName is the name of the function.

func (FunctionsClient) DeletePreparer 

func (client FunctionsClient) DeletePreparer(resourceGroupName string, jobName string, functionName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (FunctionsClient) DeleteResponder 

func (client FunctionsClient) 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 (FunctionsClient) DeleteSender 

func (client FunctionsClient) DeleteSender(req *http.Request) (*http.Response, error)

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

func (FunctionsClient) Get 

func (client FunctionsClient) Get(resourceGroupName string, jobName string, functionName string) (result Function, err error)

Get gets details about the specified function.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. functionName is the name of the function.

func (FunctionsClient) GetPreparer 

func (client FunctionsClient) GetPreparer(resourceGroupName string, jobName string, functionName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (FunctionsClient) GetResponder 

func (client FunctionsClient) GetResponder(resp *http.Response) (result Function, err error)

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

func (FunctionsClient) GetSender 

func (client FunctionsClient) 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 (FunctionsClient) ListByStreamingJob 

func (client FunctionsClient) ListByStreamingJob(resourceGroupName string, jobName string, selectParameter string) (result FunctionListResult, err error)

ListByStreamingJob lists all of the functions under the specified streaming job.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. selectParameter is the $select OData query parameter. This is a comma-separated list of structural properties to include in the response, or “*” to include all properties. By default, all properties are returned except diagnostics. Currently only accepts '*' as a valid value.

func (FunctionsClient) ListByStreamingJobComplete 

func (client FunctionsClient) ListByStreamingJobComplete(resourceGroupName string, jobName string, selectParameter string, cancel <-chan struct{}) (<-chan Function, <-chan error)

ListByStreamingJobComplete gets all elements from the list without paging.

func (FunctionsClient) ListByStreamingJobNextResults 

func (client FunctionsClient) ListByStreamingJobNextResults(lastResults FunctionListResult) (result FunctionListResult, err error)

ListByStreamingJobNextResults retrieves the next set of results, if any.

func (FunctionsClient) ListByStreamingJobPreparer 

func (client FunctionsClient) ListByStreamingJobPreparer(resourceGroupName string, jobName string, selectParameter string) (*http.Request, error)

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (FunctionsClient) ListByStreamingJobResponder 

func (client FunctionsClient) ListByStreamingJobResponder(resp *http.Response) (result FunctionListResult, err error)

ListByStreamingJobResponder handles the response to the ListByStreamingJob request. The method always closes the http.Response Body.

func (FunctionsClient) ListByStreamingJobSender 

func (client FunctionsClient) ListByStreamingJobSender(req *http.Request) (*http.Response, error)

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

func (FunctionsClient) RetrieveDefaultDefinition 

func (client FunctionsClient) RetrieveDefaultDefinition(resourceGroupName string, jobName string, functionName string, functionRetrieveDefaultDefinitionParameters *FunctionRetrieveDefaultDefinitionParameters) (result Function, err error)

RetrieveDefaultDefinition retrieves the default definition of a function based on the parameters specified.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. functionName is the name of the function. functionRetrieveDefaultDefinitionParameters is parameters used to specify the type of function to retrieve the default definition for.

func (FunctionsClient) RetrieveDefaultDefinitionPreparer 

func (client FunctionsClient) RetrieveDefaultDefinitionPreparer(resourceGroupName string, jobName string, functionName string, functionRetrieveDefaultDefinitionParameters *FunctionRetrieveDefaultDefinitionParameters) (*http.Request, error)

RetrieveDefaultDefinitionPreparer prepares the RetrieveDefaultDefinition request.

func (FunctionsClient) RetrieveDefaultDefinitionResponder 

func (client FunctionsClient) RetrieveDefaultDefinitionResponder(resp *http.Response) (result Function, err error)

RetrieveDefaultDefinitionResponder handles the response to the RetrieveDefaultDefinition request. The method always closes the http.Response Body.

func (FunctionsClient) RetrieveDefaultDefinitionSender 

func (client FunctionsClient) RetrieveDefaultDefinitionSender(req *http.Request) (*http.Response, error)

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

func (FunctionsClient) Test 

func (client FunctionsClient) Test(resourceGroupName string, jobName string, functionName string, function *Function, cancel <-chan struct{}) (<-chan ResourceTestStatus, <-chan error)

Test tests if the information provided for a function is valid. This can range from testing the connection to the underlying web service behind the function or making sure the function code provided is syntactically correct. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. functionName is the name of the function. function is if the function specified does not already exist, this parameter must contain the full function definition intended to be tested. If the function specified already exists, this parameter can be left null to test the existing function as is or if specified, the properties specified will overwrite the corresponding properties in the existing function (exactly like a PATCH operation) and the resulting function will be tested.

func (FunctionsClient) TestPreparer 

func (client FunctionsClient) TestPreparer(resourceGroupName string, jobName string, functionName string, function *Function, cancel <-chan struct{}) (*http.Request, error)

TestPreparer prepares the Test request.

func (FunctionsClient) TestResponder 

func (client FunctionsClient) TestResponder(resp *http.Response) (result ResourceTestStatus, err error)

TestResponder handles the response to the Test request. The method always closes the http.Response Body.

func (FunctionsClient) TestSender 

func (client FunctionsClient) TestSender(req *http.Request) (*http.Response, error)

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

func (FunctionsClient) Update 

func (client FunctionsClient) Update(function Function, resourceGroupName string, jobName string, functionName string, ifMatch string) (result Function, err error)

Update updates an existing function under an existing streaming job. This can be used to partially update (ie. update one or two properties) a function without affecting the rest the job or function definition.

function is a function object. The properties specified here will overwrite the corresponding properties in the existing function (ie. Those properties will be updated). Any properties that are set to null here will mean that the corresponding property in the existing function will remain the same and not change as a result of this PATCH operation. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. functionName is the name of the function. ifMatch is the ETag of the function. Omit this value to always overwrite the current function. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes.

func (FunctionsClient) UpdatePreparer 

func (client FunctionsClient) UpdatePreparer(function Function, resourceGroupName string, jobName string, functionName string, ifMatch string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (FunctionsClient) UpdateResponder 

func (client FunctionsClient) UpdateResponder(resp *http.Response) (result Function, err error)

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

func (FunctionsClient) UpdateSender 

func (client FunctionsClient) UpdateSender(req *http.Request) (*http.Response, error)

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

type Input 

type Input struct {
	autorest.Response `json:"-"`
	ID                *string          `json:"id,omitempty"`
	Name              *string          `json:"name,omitempty"`
	Type              *string          `json:"type,omitempty"`
	Properties        *InputProperties `json:"properties,omitempty"`
}

Input is an input object, containing all information associated with the named input. All inputs are contained under a streaming job.

type InputListResult 

type InputListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Input `json:"value,omitempty"`
	NextLink          *string  `json:"nextLink,omitempty"`
}

InputListResult is object containing a list of inputs under a streaming job.

func (InputListResult) InputListResultPreparer 

func (client InputListResult) InputListResultPreparer() (*http.Request, error)

InputListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type InputProperties 

type InputProperties struct {
	Serialization *Serialization `json:"serialization,omitempty"`
	Diagnostics   *Diagnostics   `json:"diagnostics,omitempty"`
	Etag          *string        `json:"etag,omitempty"`
}

InputProperties is the properties that are associated with an input.

type InputsClient 

type InputsClient struct {
	ManagementClient
}

InputsClient is the composite Swagger for Stream Analytics Client

func NewInputsClient 

func NewInputsClient(subscriptionID string) InputsClient

NewInputsClient creates an instance of the InputsClient client.

func NewInputsClientWithBaseURI 

func NewInputsClientWithBaseURI(baseURI string, subscriptionID string) InputsClient

NewInputsClientWithBaseURI creates an instance of the InputsClient client.

func (InputsClient) CreateOrReplace 

func (client InputsClient) CreateOrReplace(input Input, resourceGroupName string, jobName string, inputName string, ifMatch string, ifNoneMatch string) (result Input, err error)

CreateOrReplace creates an input or replaces an already existing input under an existing streaming job.

input is the definition of the input that will be used to create a new input or replace the existing one under the streaming job. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. inputName is the name of the input. ifMatch is the ETag of the input. Omit this value to always overwrite the current input. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes. ifNoneMatch is set to '*' to allow a new input to be created, but to prevent updating an existing input. Other values will result in a 412 Pre-condition Failed response.

func (InputsClient) CreateOrReplacePreparer 

func (client InputsClient) CreateOrReplacePreparer(input Input, resourceGroupName string, jobName string, inputName string, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (InputsClient) CreateOrReplaceResponder 

func (client InputsClient) CreateOrReplaceResponder(resp *http.Response) (result Input, err error)

CreateOrReplaceResponder handles the response to the CreateOrReplace request. The method always closes the http.Response Body.

func (InputsClient) CreateOrReplaceSender 

func (client InputsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error)

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

func (InputsClient) Delete 

func (client InputsClient) Delete(resourceGroupName string, jobName string, inputName string) (result autorest.Response, err error)

Delete deletes an input from the streaming job.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. inputName is the name of the input.

func (InputsClient) DeletePreparer 

func (client InputsClient) DeletePreparer(resourceGroupName string, jobName string, inputName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (InputsClient) DeleteResponder 

func (client InputsClient) 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 (InputsClient) DeleteSender 

func (client InputsClient) DeleteSender(req *http.Request) (*http.Response, error)

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

func (InputsClient) Get 

func (client InputsClient) Get(resourceGroupName string, jobName string, inputName string) (result Input, err error)

Get gets details about the specified input.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. inputName is the name of the input.

func (InputsClient) GetPreparer 

func (client InputsClient) GetPreparer(resourceGroupName string, jobName string, inputName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (InputsClient) GetResponder 

func (client InputsClient) GetResponder(resp *http.Response) (result Input, err error)

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

func (InputsClient) GetSender 

func (client InputsClient) 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 (InputsClient) ListByStreamingJob 

func (client InputsClient) ListByStreamingJob(resourceGroupName string, jobName string, selectParameter string) (result InputListResult, err error)

ListByStreamingJob lists all of the inputs under the specified streaming job.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. selectParameter is the $select OData query parameter. This is a comma-separated list of structural properties to include in the response, or “*” to include all properties. By default, all properties are returned except diagnostics. Currently only accepts '*' as a valid value.

func (InputsClient) ListByStreamingJobComplete 

func (client InputsClient) ListByStreamingJobComplete(resourceGroupName string, jobName string, selectParameter string, cancel <-chan struct{}) (<-chan Input, <-chan error)

ListByStreamingJobComplete gets all elements from the list without paging.

func (InputsClient) ListByStreamingJobNextResults 

func (client InputsClient) ListByStreamingJobNextResults(lastResults InputListResult) (result InputListResult, err error)

ListByStreamingJobNextResults retrieves the next set of results, if any.

func (InputsClient) ListByStreamingJobPreparer 

func (client InputsClient) ListByStreamingJobPreparer(resourceGroupName string, jobName string, selectParameter string) (*http.Request, error)

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (InputsClient) ListByStreamingJobResponder 

func (client InputsClient) ListByStreamingJobResponder(resp *http.Response) (result InputListResult, err error)

ListByStreamingJobResponder handles the response to the ListByStreamingJob request. The method always closes the http.Response Body.

func (InputsClient) ListByStreamingJobSender 

func (client InputsClient) ListByStreamingJobSender(req *http.Request) (*http.Response, error)

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

func (InputsClient) Test 

func (client InputsClient) Test(resourceGroupName string, jobName string, inputName string, input *Input, cancel <-chan struct{}) (<-chan ResourceTestStatus, <-chan error)

Test tests whether an input’s datasource is reachable and usable by the Azure Stream Analytics service. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. inputName is the name of the input. input is if the input specified does not already exist, this parameter must contain the full input definition intended to be tested. If the input specified already exists, this parameter can be left null to test the existing input as is or if specified, the properties specified will overwrite the corresponding properties in the existing input (exactly like a PATCH operation) and the resulting input will be tested.

func (InputsClient) TestPreparer 

func (client InputsClient) TestPreparer(resourceGroupName string, jobName string, inputName string, input *Input, cancel <-chan struct{}) (*http.Request, error)

TestPreparer prepares the Test request.

func (InputsClient) TestResponder 

func (client InputsClient) TestResponder(resp *http.Response) (result ResourceTestStatus, err error)

TestResponder handles the response to the Test request. The method always closes the http.Response Body.

func (InputsClient) TestSender 

func (client InputsClient) TestSender(req *http.Request) (*http.Response, error)

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

func (InputsClient) Update 

func (client InputsClient) Update(input Input, resourceGroupName string, jobName string, inputName string, ifMatch string) (result Input, err error)

Update updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.

input is an Input object. The properties specified here will overwrite the corresponding properties in the existing input (ie. Those properties will be updated). Any properties that are set to null here will mean that the corresponding property in the existing input will remain the same and not change as a result of this PATCH operation. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. inputName is the name of the input. ifMatch is the ETag of the input. Omit this value to always overwrite the current input. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes.

func (InputsClient) UpdatePreparer 

func (client InputsClient) UpdatePreparer(input Input, resourceGroupName string, jobName string, inputName string, ifMatch string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (InputsClient) UpdateResponder 

func (client InputsClient) UpdateResponder(resp *http.Response) (result Input, err error)

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

func (InputsClient) UpdateSender 

func (client InputsClient) UpdateSender(req *http.Request) (*http.Response, error)

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

type IoTHubStreamInputDataSource 

type IoTHubStreamInputDataSource struct {
	*IoTHubStreamInputDataSourceProperties `json:"properties,omitempty"`
}

IoTHubStreamInputDataSource is describes an IoT Hub input data source that contains stream data.

type IoTHubStreamInputDataSourceProperties 

type IoTHubStreamInputDataSourceProperties struct {
	IotHubNamespace        *string `json:"iotHubNamespace,omitempty"`
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
	SharedAccessPolicyKey  *string `json:"sharedAccessPolicyKey,omitempty"`
	ConsumerGroupName      *string `json:"consumerGroupName,omitempty"`
	Endpoint               *string `json:"endpoint,omitempty"`
}

IoTHubStreamInputDataSourceProperties is the properties that are associated with a IoT Hub input containing stream data.

type JSONOutputSerializationFormat 

type JSONOutputSerializationFormat string

JSONOutputSerializationFormat enumerates the values for json output serialization format. 

const (
	// Array specifies the array state for json output serialization format.
	Array JSONOutputSerializationFormat = "Array"
	// LineSeparated specifies the line separated state for json output
	// serialization format.
	LineSeparated JSONOutputSerializationFormat = "LineSeparated"
)

type JSONSerialization 

type JSONSerialization struct {
	*JSONSerializationProperties `json:"properties,omitempty"`
}

JSONSerialization is describes how data from an input is serialized or how data is serialized when written to an output in JSON format.

type JSONSerializationProperties 

type JSONSerializationProperties struct {
	Encoding Encoding                      `json:"encoding,omitempty"`
	Format   JSONOutputSerializationFormat `json:"format,omitempty"`
}

JSONSerializationProperties is the properties that are associated with the JSON serialization type.

type JavaScriptFunctionBinding 

type JavaScriptFunctionBinding struct {
	*JavaScriptFunctionBindingProperties `json:"properties,omitempty"`
}

JavaScriptFunctionBinding is the binding to a JavaScript function.

type JavaScriptFunctionBindingProperties 

type JavaScriptFunctionBindingProperties struct {
	Script *string `json:"script,omitempty"`
}

JavaScriptFunctionBindingProperties is the binding properties associated with a JavaScript function.

type JavaScriptFunctionBindingRetrievalProperties 

type JavaScriptFunctionBindingRetrievalProperties struct {
	Script  *string `json:"script,omitempty"`
	UdfType UdfType `json:"udfType,omitempty"`
}

JavaScriptFunctionBindingRetrievalProperties is the binding retrieval properties associated with a JavaScript function.

type JavaScriptFunctionRetrieveDefaultDefinitionParameters 

type JavaScriptFunctionRetrieveDefaultDefinitionParameters struct {
	*JavaScriptFunctionBindingRetrievalProperties `json:"bindingRetrievalProperties,omitempty"`
}

JavaScriptFunctionRetrieveDefaultDefinitionParameters is the parameters needed to retrieve the default function definition for a JavaScript function.

type ManagementClient 

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

ManagementClient is the base client for Streamanalytics.

func New 

func New(subscriptionID string) ManagementClient

New creates an instance of the ManagementClient client.

func NewWithBaseURI 

func NewWithBaseURI(baseURI string, subscriptionID string) ManagementClient

NewWithBaseURI creates an instance of the ManagementClient client.

type Operation 

type Operation struct {
	Name    *string           `json:"name,omitempty"`
	Display *OperationDisplay `json:"display,omitempty"`
}

Operation is a Stream Analytics REST API operation

type OperationDisplay 

type OperationDisplay struct {
	Provider    *string `json:"provider,omitempty"`
	Resource    *string `json:"resource,omitempty"`
	Operation   *string `json:"operation,omitempty"`
	Description *string `json:"description,omitempty"`
}

OperationDisplay is contains the localized display information for this particular operation / action.

type OperationListResult 

type OperationListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Operation `json:"value,omitempty"`
	NextLink          *string      `json:"nextLink,omitempty"`
}

OperationListResult is result of the request to list Stream Analytics operations. It contains a list of operations and a URL link to get the next set of results.

func (OperationListResult) OperationListResultPreparer 

func (client OperationListResult) OperationListResultPreparer() (*http.Request, error)

OperationListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type OperationsClient 

type OperationsClient struct {
	ManagementClient
}

OperationsClient is the composite Swagger for Stream Analytics 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() (result OperationListResult, err error)

List lists all of the available Stream Analytics related operations.

func (OperationsClient) ListComplete 

func (client OperationsClient) ListComplete(cancel <-chan struct{}) (<-chan Operation, <-chan error)

ListComplete gets all elements from the list without paging.

func (OperationsClient) ListNextResults 

func (client OperationsClient) ListNextResults(lastResults OperationListResult) (result OperationListResult, err error)

ListNextResults retrieves the next set of results, if any.

func (OperationsClient) ListPreparer 

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

ListPreparer prepares the List request.

func (OperationsClient) ListResponder 

func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, 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 Output 

type Output struct {
	autorest.Response `json:"-"`
	ID                *string `json:"id,omitempty"`
	Name              *string `json:"name,omitempty"`
	Type              *string `json:"type,omitempty"`
	*OutputProperties `json:"properties,omitempty"`
}

Output is an output object, containing all information associated with the named output. All outputs are contained under a streaming job.

type OutputDataSource 

type OutputDataSource struct {
}

OutputDataSource is describes the data source that output will be written to.

type OutputErrorPolicy 

type OutputErrorPolicy string

OutputErrorPolicy enumerates the values for output error policy. 

const (
	// OutputErrorPolicyDrop specifies the output error policy drop state for
	// output error policy.
	OutputErrorPolicyDrop OutputErrorPolicy = "Drop"
	// OutputErrorPolicyStop specifies the output error policy stop state for
	// output error policy.
	OutputErrorPolicyStop OutputErrorPolicy = "Stop"
)

type OutputListResult 

type OutputListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Output `json:"value,omitempty"`
	NextLink          *string   `json:"nextLink,omitempty"`
}

OutputListResult is object containing a list of outputs under a streaming job.

func (OutputListResult) OutputListResultPreparer 

func (client OutputListResult) OutputListResultPreparer() (*http.Request, error)

OutputListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type OutputProperties 

type OutputProperties struct {
	Datasource    *OutputDataSource `json:"datasource,omitempty"`
	Serialization *Serialization    `json:"serialization,omitempty"`
	Diagnostics   *Diagnostics      `json:"diagnostics,omitempty"`
	Etag          *string           `json:"etag,omitempty"`
}

OutputProperties is the properties that are associated with an output.

type OutputStartMode 

type OutputStartMode string

OutputStartMode enumerates the values for output start mode. 

const (
	// CustomTime specifies the custom time state for output start mode.
	CustomTime OutputStartMode = "CustomTime"
	// JobStartTime specifies the job start time state for output start mode.
	JobStartTime OutputStartMode = "JobStartTime"
	// LastOutputEventTime specifies the last output event time state for
	// output start mode.
	LastOutputEventTime OutputStartMode = "LastOutputEventTime"
)

type OutputsClient 

type OutputsClient struct {
	ManagementClient
}

OutputsClient is the composite Swagger for Stream Analytics Client

func NewOutputsClient 

func NewOutputsClient(subscriptionID string) OutputsClient

NewOutputsClient creates an instance of the OutputsClient client.

func NewOutputsClientWithBaseURI 

func NewOutputsClientWithBaseURI(baseURI string, subscriptionID string) OutputsClient

NewOutputsClientWithBaseURI creates an instance of the OutputsClient client.

func (OutputsClient) CreateOrReplace 

func (client OutputsClient) CreateOrReplace(output Output, resourceGroupName string, jobName string, outputName string, ifMatch string, ifNoneMatch string) (result Output, err error)

CreateOrReplace creates an output or replaces an already existing output under an existing streaming job.

output is the definition of the output that will be used to create a new output or replace the existing one under the streaming job. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. outputName is the name of the output. ifMatch is the ETag of the output. Omit this value to always overwrite the current output. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes. ifNoneMatch is set to '*' to allow a new output to be created, but to prevent updating an existing output. Other values will result in a 412 Pre-condition Failed response.

func (OutputsClient) CreateOrReplacePreparer 

func (client OutputsClient) CreateOrReplacePreparer(output Output, resourceGroupName string, jobName string, outputName string, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (OutputsClient) CreateOrReplaceResponder 

func (client OutputsClient) CreateOrReplaceResponder(resp *http.Response) (result Output, err error)

CreateOrReplaceResponder handles the response to the CreateOrReplace request. The method always closes the http.Response Body.

func (OutputsClient) CreateOrReplaceSender 

func (client OutputsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error)

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

func (OutputsClient) Delete 

func (client OutputsClient) Delete(resourceGroupName string, jobName string, outputName string) (result autorest.Response, err error)

Delete deletes an output from the streaming job.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. outputName is the name of the output.

func (OutputsClient) DeletePreparer 

func (client OutputsClient) DeletePreparer(resourceGroupName string, jobName string, outputName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (OutputsClient) DeleteResponder 

func (client OutputsClient) 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 (OutputsClient) DeleteSender 

func (client OutputsClient) DeleteSender(req *http.Request) (*http.Response, error)

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

func (OutputsClient) Get 

func (client OutputsClient) Get(resourceGroupName string, jobName string, outputName string) (result Output, err error)

Get gets details about the specified output.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. outputName is the name of the output.

func (OutputsClient) GetPreparer 

func (client OutputsClient) GetPreparer(resourceGroupName string, jobName string, outputName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (OutputsClient) GetResponder 

func (client OutputsClient) GetResponder(resp *http.Response) (result Output, err error)

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

func (OutputsClient) GetSender 

func (client OutputsClient) 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 (OutputsClient) ListByStreamingJob 

func (client OutputsClient) ListByStreamingJob(resourceGroupName string, jobName string, selectParameter string) (result OutputListResult, err error)

ListByStreamingJob lists all of the outputs under the specified streaming job.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. selectParameter is the $select OData query parameter. This is a comma-separated list of structural properties to include in the response, or “*” to include all properties. By default, all properties are returned except diagnostics. Currently only accepts '*' as a valid value.

func (OutputsClient) ListByStreamingJobComplete 

func (client OutputsClient) ListByStreamingJobComplete(resourceGroupName string, jobName string, selectParameter string, cancel <-chan struct{}) (<-chan Output, <-chan error)

ListByStreamingJobComplete gets all elements from the list without paging.

func (OutputsClient) ListByStreamingJobNextResults 

func (client OutputsClient) ListByStreamingJobNextResults(lastResults OutputListResult) (result OutputListResult, err error)

ListByStreamingJobNextResults retrieves the next set of results, if any.

func (OutputsClient) ListByStreamingJobPreparer 

func (client OutputsClient) ListByStreamingJobPreparer(resourceGroupName string, jobName string, selectParameter string) (*http.Request, error)

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (OutputsClient) ListByStreamingJobResponder 

func (client OutputsClient) ListByStreamingJobResponder(resp *http.Response) (result OutputListResult, err error)

ListByStreamingJobResponder handles the response to the ListByStreamingJob request. The method always closes the http.Response Body.

func (OutputsClient) ListByStreamingJobSender 

func (client OutputsClient) ListByStreamingJobSender(req *http.Request) (*http.Response, error)

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

func (OutputsClient) Test 

func (client OutputsClient) Test(resourceGroupName string, jobName string, outputName string, output *Output, cancel <-chan struct{}) (<-chan ResourceTestStatus, <-chan error)

Test tests whether an output’s datasource is reachable and usable by the Azure Stream Analytics service. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. outputName is the name of the output. output is if the output specified does not already exist, this parameter must contain the full output definition intended to be tested. If the output specified already exists, this parameter can be left null to test the existing output as is or if specified, the properties specified will overwrite the corresponding properties in the existing output (exactly like a PATCH operation) and the resulting output will be tested.

func (OutputsClient) TestPreparer 

func (client OutputsClient) TestPreparer(resourceGroupName string, jobName string, outputName string, output *Output, cancel <-chan struct{}) (*http.Request, error)

TestPreparer prepares the Test request.

func (OutputsClient) TestResponder 

func (client OutputsClient) TestResponder(resp *http.Response) (result ResourceTestStatus, err error)

TestResponder handles the response to the Test request. The method always closes the http.Response Body.

func (OutputsClient) TestSender 

func (client OutputsClient) TestSender(req *http.Request) (*http.Response, error)

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

func (OutputsClient) Update 

func (client OutputsClient) Update(output Output, resourceGroupName string, jobName string, outputName string, ifMatch string) (result Output, err error)

Update updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.

output is an Output object. The properties specified here will overwrite the corresponding properties in the existing output (ie. Those properties will be updated). Any properties that are set to null here will mean that the corresponding property in the existing output will remain the same and not change as a result of this PATCH operation. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. outputName is the name of the output. ifMatch is the ETag of the output. Omit this value to always overwrite the current output. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes.

func (OutputsClient) UpdatePreparer 

func (client OutputsClient) UpdatePreparer(output Output, resourceGroupName string, jobName string, outputName string, ifMatch string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (OutputsClient) UpdateResponder 

func (client OutputsClient) UpdateResponder(resp *http.Response) (result Output, err error)

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

func (OutputsClient) UpdateSender 

func (client OutputsClient) UpdateSender(req *http.Request) (*http.Response, error)

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

type ReferenceInputDataSource 

type ReferenceInputDataSource struct {
}

ReferenceInputDataSource is describes an input data source that contains reference data.

type ReferenceInputProperties 

type ReferenceInputProperties struct {
	Serialization *Serialization            `json:"serialization,omitempty"`
	Diagnostics   *Diagnostics              `json:"diagnostics,omitempty"`
	Etag          *string                   `json:"etag,omitempty"`
	Datasource    *ReferenceInputDataSource `json:"datasource,omitempty"`
}

ReferenceInputProperties is the properties that are associated with an input containing reference data.

type Resource 

type Resource struct {
	ID       *string             `json:"id,omitempty"`
	Name     *string             `json:"name,omitempty"`
	Type     *string             `json:"type,omitempty"`
	Location *string             `json:"location,omitempty"`
	Tags     *map[string]*string `json:"tags,omitempty"`
}

Resource is the base resource model definition.

type ResourceTestStatus 

type ResourceTestStatus struct {
	autorest.Response `json:"-"`
	Status            *string        `json:"status,omitempty"`
	Error             *ErrorResponse `json:"error,omitempty"`
}

ResourceTestStatus is describes the status of the test operation along with error information, if applicable.

type ScalarFunctionConfiguration 

type ScalarFunctionConfiguration struct {
	Inputs  *[]FunctionInput `json:"inputs,omitempty"`
	Output  *FunctionOutput  `json:"output,omitempty"`
	Binding *FunctionBinding `json:"binding,omitempty"`
}

ScalarFunctionConfiguration is describes the configuration of the scalar function.

type ScalarFunctionProperties 

type ScalarFunctionProperties struct {
	Etag                         *string `json:"etag,omitempty"`
	*ScalarFunctionConfiguration `json:"properties,omitempty"`
}

ScalarFunctionProperties is the properties that are associated with a scalar function.

type Serialization 

type Serialization struct {
}

Serialization is describes how data from an input is serialized or how data is serialized when written to an output.

type ServiceBusDataSourceProperties 

type ServiceBusDataSourceProperties struct {
	ServiceBusNamespace    *string `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
	SharedAccessPolicyKey  *string `json:"sharedAccessPolicyKey,omitempty"`
}

ServiceBusDataSourceProperties is the common properties that are associated with Service Bus data sources (Queues, Topics, Event Hubs, etc.).

type ServiceBusQueueOutputDataSource 

type ServiceBusQueueOutputDataSource struct {
	*ServiceBusQueueOutputDataSourceProperties `json:"properties,omitempty"`
}

ServiceBusQueueOutputDataSource is describes a Service Bus Queue data source.

type ServiceBusQueueOutputDataSourceProperties 

type ServiceBusQueueOutputDataSourceProperties struct {
	ServiceBusNamespace    *string   `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyName *string   `json:"sharedAccessPolicyName,omitempty"`
	SharedAccessPolicyKey  *string   `json:"sharedAccessPolicyKey,omitempty"`
	QueueName              *string   `json:"queueName,omitempty"`
	PropertyColumns        *[]string `json:"propertyColumns,omitempty"`
}

ServiceBusQueueOutputDataSourceProperties is the properties that are associated with a Service Bus Queue output.

type ServiceBusTopicOutputDataSource 

type ServiceBusTopicOutputDataSource struct {
	*ServiceBusTopicOutputDataSourceProperties `json:"properties,omitempty"`
}

ServiceBusTopicOutputDataSource is describes a Service Bus Topic data source.

type ServiceBusTopicOutputDataSourceProperties 

type ServiceBusTopicOutputDataSourceProperties struct {
	ServiceBusNamespace    *string   `json:"serviceBusNamespace,omitempty"`
	SharedAccessPolicyName *string   `json:"sharedAccessPolicyName,omitempty"`
	SharedAccessPolicyKey  *string   `json:"sharedAccessPolicyKey,omitempty"`
	TopicName              *string   `json:"topicName,omitempty"`
	PropertyColumns        *[]string `json:"propertyColumns,omitempty"`
}

ServiceBusTopicOutputDataSourceProperties is the properties that are associated with a Service Bus Topic output.

type Sku 

type Sku struct {
	Name SkuName `json:"name,omitempty"`
}

Sku is the properties that are associated with a SKU.

type SkuName 

type SkuName string

SkuName enumerates the values for sku name. 

const (
	// Standard specifies the standard state for sku name.
	Standard SkuName = "Standard"
)

type StartStreamingJobParameters 

type StartStreamingJobParameters struct {
	OutputStartMode OutputStartMode `json:"outputStartMode,omitempty"`
	OutputStartTime *date.Time      `json:"outputStartTime,omitempty"`
}

StartStreamingJobParameters is parameters supplied to the Start Streaming Job operation.

type StorageAccount 

type StorageAccount struct {
	AccountName *string `json:"accountName,omitempty"`
	AccountKey  *string `json:"accountKey,omitempty"`
}

StorageAccount is the properties that are associated with an Azure Storage account

type StreamInputDataSource 

type StreamInputDataSource struct {
}

StreamInputDataSource is describes an input data source that contains stream data.

type StreamInputProperties 

type StreamInputProperties struct {
	Serialization *Serialization         `json:"serialization,omitempty"`
	Diagnostics   *Diagnostics           `json:"diagnostics,omitempty"`
	Etag          *string                `json:"etag,omitempty"`
	Datasource    *StreamInputDataSource `json:"datasource,omitempty"`
}

StreamInputProperties is the properties that are associated with an input containing stream data.

type StreamingJob 

type StreamingJob struct {
	autorest.Response       `json:"-"`
	ID                      *string             `json:"id,omitempty"`
	Name                    *string             `json:"name,omitempty"`
	Type                    *string             `json:"type,omitempty"`
	Location                *string             `json:"location,omitempty"`
	Tags                    *map[string]*string `json:"tags,omitempty"`
	*StreamingJobProperties `json:"properties,omitempty"`
}

StreamingJob is a streamng job object, containing all information associated with the named streaming job.

type StreamingJobListResult 

type StreamingJobListResult struct {
	autorest.Response `json:"-"`
	Value             *[]StreamingJob `json:"value,omitempty"`
	NextLink          *string         `json:"nextLink,omitempty"`
}

StreamingJobListResult is object containing a list of streaming jobs.

func (StreamingJobListResult) StreamingJobListResultPreparer 

func (client StreamingJobListResult) StreamingJobListResultPreparer() (*http.Request, error)

StreamingJobListResultPreparer prepares a request to retrieve the next set of results. It returns nil if no more results exist.

type StreamingJobProperties 

type StreamingJobProperties struct {
	Sku                                *Sku                   `json:"sku,omitempty"`
	JobID                              *string                `json:"jobId,omitempty"`
	ProvisioningState                  *string                `json:"provisioningState,omitempty"`
	JobState                           *string                `json:"jobState,omitempty"`
	OutputStartMode                    OutputStartMode        `json:"outputStartMode,omitempty"`
	OutputStartTime                    *date.Time             `json:"outputStartTime,omitempty"`
	LastOutputEventTime                *date.Time             `json:"lastOutputEventTime,omitempty"`
	EventsOutOfOrderPolicy             EventsOutOfOrderPolicy `json:"eventsOutOfOrderPolicy,omitempty"`
	OutputErrorPolicy                  OutputErrorPolicy      `json:"outputErrorPolicy,omitempty"`
	EventsOutOfOrderMaxDelayInSeconds  *int32                 `json:"eventsOutOfOrderMaxDelayInSeconds,omitempty"`
	EventsLateArrivalMaxDelayInSeconds *int32                 `json:"eventsLateArrivalMaxDelayInSeconds,omitempty"`
	DataLocale                         *string                `json:"dataLocale,omitempty"`
	CompatibilityLevel                 CompatibilityLevel     `json:"compatibilityLevel,omitempty"`
	CreatedDate                        *date.Time             `json:"createdDate,omitempty"`
	Inputs                             *[]Input               `json:"inputs,omitempty"`
	Transformation                     *Transformation        `json:"transformation,omitempty"`
	Outputs                            *[]Output              `json:"outputs,omitempty"`
	Functions                          *[]Function            `json:"functions,omitempty"`
	Etag                               *string                `json:"etag,omitempty"`
}

StreamingJobProperties is the properties that are associated with a streaming job.

type StreamingJobsClient 

type StreamingJobsClient struct {
	ManagementClient
}

StreamingJobsClient is the composite Swagger for Stream Analytics Client

func NewStreamingJobsClient 

func NewStreamingJobsClient(subscriptionID string) StreamingJobsClient

NewStreamingJobsClient creates an instance of the StreamingJobsClient client.

func NewStreamingJobsClientWithBaseURI 

func NewStreamingJobsClientWithBaseURI(baseURI string, subscriptionID string) StreamingJobsClient

NewStreamingJobsClientWithBaseURI creates an instance of the StreamingJobsClient client.

func (StreamingJobsClient) CreateOrReplace 

func (client StreamingJobsClient) CreateOrReplace(streamingJob StreamingJob, resourceGroupName string, jobName string, ifMatch string, ifNoneMatch string, cancel <-chan struct{}) (<-chan StreamingJob, <-chan error)

CreateOrReplace creates a streaming job or replaces an already existing streaming job. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

streamingJob is the definition of the streaming job that will be used to create a new streaming job or replace the existing one. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. ifMatch is the ETag of the streaming job. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes. ifNoneMatch is set to '*' to allow a new streaming job to be created, but to prevent updating an existing record set. Other values will result in a 412 Pre-condition Failed response.

func (StreamingJobsClient) CreateOrReplacePreparer 

func (client StreamingJobsClient) CreateOrReplacePreparer(streamingJob StreamingJob, resourceGroupName string, jobName string, ifMatch string, ifNoneMatch string, cancel <-chan struct{}) (*http.Request, error)

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (StreamingJobsClient) CreateOrReplaceResponder 

func (client StreamingJobsClient) CreateOrReplaceResponder(resp *http.Response) (result StreamingJob, err error)

CreateOrReplaceResponder handles the response to the CreateOrReplace request. The method always closes the http.Response Body.

func (StreamingJobsClient) CreateOrReplaceSender 

func (client StreamingJobsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error)

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

func (StreamingJobsClient) Delete 

func (client StreamingJobsClient) Delete(resourceGroupName string, jobName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

Delete deletes a streaming job. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job.

func (StreamingJobsClient) DeletePreparer 

func (client StreamingJobsClient) DeletePreparer(resourceGroupName string, jobName string, cancel <-chan struct{}) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (StreamingJobsClient) DeleteResponder 

func (client StreamingJobsClient) 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 (StreamingJobsClient) DeleteSender 

func (client StreamingJobsClient) DeleteSender(req *http.Request) (*http.Response, error)

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

func (StreamingJobsClient) Get 

func (client StreamingJobsClient) Get(resourceGroupName string, jobName string, expand string) (result StreamingJob, err error)

Get gets details about the specified streaming job.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. expand is the $expand OData query parameter. This is a comma-separated list of additional streaming job properties to include in the response, beyond the default set returned when this parameter is absent. The default set is all streaming job properties other than 'inputs', 'transformation', 'outputs', and 'functions'.

func (StreamingJobsClient) GetPreparer 

func (client StreamingJobsClient) GetPreparer(resourceGroupName string, jobName string, expand string) (*http.Request, error)

GetPreparer prepares the Get request.

func (StreamingJobsClient) GetResponder 

func (client StreamingJobsClient) GetResponder(resp *http.Response) (result StreamingJob, err error)

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

func (StreamingJobsClient) GetSender 

func (client StreamingJobsClient) 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 (StreamingJobsClient) List 

func (client StreamingJobsClient) List(expand string) (result StreamingJobListResult, err error)

List lists all of the streaming jobs in the given subscription.

expand is the $expand OData query parameter. This is a comma-separated list of additional streaming job properties to include in the response, beyond the default set returned when this parameter is absent. The default set is all streaming job properties other than 'inputs', 'transformation', 'outputs', and 'functions'.

func (StreamingJobsClient) ListByResourceGroup 

func (client StreamingJobsClient) ListByResourceGroup(resourceGroupName string, expand string) (result StreamingJobListResult, err error)

ListByResourceGroup lists all of the streaming jobs in the specified resource group.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. expand is the $expand OData query parameter. This is a comma-separated list of additional streaming job properties to include in the response, beyond the default set returned when this parameter is absent. The default set is all streaming job properties other than 'inputs', 'transformation', 'outputs', and 'functions'.

func (StreamingJobsClient) ListByResourceGroupComplete 

func (client StreamingJobsClient) ListByResourceGroupComplete(resourceGroupName string, expand string, cancel <-chan struct{}) (<-chan StreamingJob, <-chan error)

ListByResourceGroupComplete gets all elements from the list without paging.

func (StreamingJobsClient) ListByResourceGroupNextResults 

func (client StreamingJobsClient) ListByResourceGroupNextResults(lastResults StreamingJobListResult) (result StreamingJobListResult, err error)

ListByResourceGroupNextResults retrieves the next set of results, if any.

func (StreamingJobsClient) ListByResourceGroupPreparer 

func (client StreamingJobsClient) ListByResourceGroupPreparer(resourceGroupName string, expand string) (*http.Request, error)

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (StreamingJobsClient) ListByResourceGroupResponder 

func (client StreamingJobsClient) ListByResourceGroupResponder(resp *http.Response) (result StreamingJobListResult, err error)

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

func (StreamingJobsClient) ListByResourceGroupSender 

func (client StreamingJobsClient) 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 (StreamingJobsClient) ListComplete 

func (client StreamingJobsClient) ListComplete(expand string, cancel <-chan struct{}) (<-chan StreamingJob, <-chan error)

ListComplete gets all elements from the list without paging.

func (StreamingJobsClient) ListNextResults 

func (client StreamingJobsClient) ListNextResults(lastResults StreamingJobListResult) (result StreamingJobListResult, err error)

ListNextResults retrieves the next set of results, if any.

func (StreamingJobsClient) ListPreparer 

func (client StreamingJobsClient) ListPreparer(expand string) (*http.Request, error)

ListPreparer prepares the List request.

func (StreamingJobsClient) ListResponder 

func (client StreamingJobsClient) ListResponder(resp *http.Response) (result StreamingJobListResult, err error)

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

func (StreamingJobsClient) ListSender 

func (client StreamingJobsClient) 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.

func (StreamingJobsClient) Start 

func (client StreamingJobsClient) Start(resourceGroupName string, jobName string, startJobParameters *StartStreamingJobParameters, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

Start starts a streaming job. Once a job is started it will start processing input events and produce output. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. startJobParameters is parameters applicable to a start streaming job operation.

func (StreamingJobsClient) StartPreparer 

func (client StreamingJobsClient) StartPreparer(resourceGroupName string, jobName string, startJobParameters *StartStreamingJobParameters, cancel <-chan struct{}) (*http.Request, error)

StartPreparer prepares the Start request.

func (StreamingJobsClient) StartResponder 

func (client StreamingJobsClient) StartResponder(resp *http.Response) (result autorest.Response, err error)

StartResponder handles the response to the Start request. The method always closes the http.Response Body.

func (StreamingJobsClient) StartSender 

func (client StreamingJobsClient) StartSender(req *http.Request) (*http.Response, error)

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

func (StreamingJobsClient) Stop 

func (client StreamingJobsClient) Stop(resourceGroupName string, jobName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

Stop stops a running streaming job. This will cause a running streaming job to stop processing input events and producing output. This method may poll for completion. Polling can be canceled by passing the cancel channel argument. The channel will be used to cancel polling and any outstanding HTTP requests.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job.

func (StreamingJobsClient) StopPreparer 

func (client StreamingJobsClient) StopPreparer(resourceGroupName string, jobName string, cancel <-chan struct{}) (*http.Request, error)

StopPreparer prepares the Stop request.

func (StreamingJobsClient) StopResponder 

func (client StreamingJobsClient) StopResponder(resp *http.Response) (result autorest.Response, err error)

StopResponder handles the response to the Stop request. The method always closes the http.Response Body.

func (StreamingJobsClient) StopSender 

func (client StreamingJobsClient) StopSender(req *http.Request) (*http.Response, error)

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

func (StreamingJobsClient) Update 

func (client StreamingJobsClient) Update(streamingJob StreamingJob, resourceGroupName string, jobName string, ifMatch string) (result StreamingJob, err error)

Update updates an existing streaming job. This can be used to partially update (ie. update one or two properties) a streaming job without affecting the rest the job definition.

streamingJob is a streaming job object. The properties specified here will overwrite the corresponding properties in the existing streaming job (ie. Those properties will be updated). Any properties that are set to null here will mean that the corresponding property in the existing input will remain the same and not change as a result of this PATCH operation. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. ifMatch is the ETag of the streaming job. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes.

func (StreamingJobsClient) UpdatePreparer 

func (client StreamingJobsClient) UpdatePreparer(streamingJob StreamingJob, resourceGroupName string, jobName string, ifMatch string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (StreamingJobsClient) UpdateResponder 

func (client StreamingJobsClient) UpdateResponder(resp *http.Response) (result StreamingJob, err error)

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

func (StreamingJobsClient) UpdateSender 

func (client StreamingJobsClient) UpdateSender(req *http.Request) (*http.Response, error)

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

type SubResource 

type SubResource struct {
	ID   *string `json:"id,omitempty"`
	Name *string `json:"name,omitempty"`
	Type *string `json:"type,omitempty"`
}

SubResource is the base sub-resource model definition.

type SubscriptionQuota 

type SubscriptionQuota struct {
	ID                           *string `json:"id,omitempty"`
	Name                         *string `json:"name,omitempty"`
	Type                         *string `json:"type,omitempty"`
	*SubscriptionQuotaProperties `json:"properties,omitempty"`
}

SubscriptionQuota is describes the current quota for the subscription.

type SubscriptionQuotaProperties 

type SubscriptionQuotaProperties struct {
	MaxCount     *int32 `json:"maxCount,omitempty"`
	CurrentCount *int32 `json:"currentCount,omitempty"`
}

SubscriptionQuotaProperties is describes the properties of the quota.

type SubscriptionQuotasListResult 

type SubscriptionQuotasListResult struct {
	autorest.Response `json:"-"`
	Value             *[]SubscriptionQuota `json:"value,omitempty"`
}

SubscriptionQuotasListResult is result of the GetQuotas operation. It contains a list of quotas for the subscription in a particular region.

type SubscriptionsClient 

type SubscriptionsClient struct {
	ManagementClient
}

SubscriptionsClient is the composite Swagger for Stream Analytics Client

func NewSubscriptionsClient 

func NewSubscriptionsClient(subscriptionID string) SubscriptionsClient

NewSubscriptionsClient creates an instance of the SubscriptionsClient client.

func NewSubscriptionsClientWithBaseURI 

func NewSubscriptionsClientWithBaseURI(baseURI string, subscriptionID string) SubscriptionsClient

NewSubscriptionsClientWithBaseURI creates an instance of the SubscriptionsClient client.

func (SubscriptionsClient) ListQuotas 

func (client SubscriptionsClient) ListQuotas(location string) (result SubscriptionQuotasListResult, err error)

ListQuotas retrieves the subscription's current quota information in a particular region.

location is the region in which to retrieve the subscription's quota information. You can find out which regions Azure Stream Analytics is supported in here: https://azure.microsoft.com/en-us/regions/

func (SubscriptionsClient) ListQuotasPreparer 

func (client SubscriptionsClient) ListQuotasPreparer(location string) (*http.Request, error)

ListQuotasPreparer prepares the ListQuotas request.

func (SubscriptionsClient) ListQuotasResponder 

func (client SubscriptionsClient) ListQuotasResponder(resp *http.Response) (result SubscriptionQuotasListResult, err error)

ListQuotasResponder handles the response to the ListQuotas request. The method always closes the http.Response Body.

func (SubscriptionsClient) ListQuotasSender 

func (client SubscriptionsClient) ListQuotasSender(req *http.Request) (*http.Response, error)

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

type Transformation 

type Transformation struct {
	autorest.Response         `json:"-"`
	ID                        *string `json:"id,omitempty"`
	Name                      *string `json:"name,omitempty"`
	Type                      *string `json:"type,omitempty"`
	*TransformationProperties `json:"properties,omitempty"`
}

Transformation is a transformation object, containing all information associated with the named transformation. All transformations are contained under a streaming job.

type TransformationProperties 

type TransformationProperties struct {
	StreamingUnits *int32  `json:"streamingUnits,omitempty"`
	Query          *string `json:"query,omitempty"`
	Etag           *string `json:"etag,omitempty"`
}

TransformationProperties is the properties that are associated with a transformation.

type TransformationsClient 

type TransformationsClient struct {
	ManagementClient
}

TransformationsClient is the composite Swagger for Stream Analytics Client

func NewTransformationsClient 

func NewTransformationsClient(subscriptionID string) TransformationsClient

NewTransformationsClient creates an instance of the TransformationsClient client.

func NewTransformationsClientWithBaseURI 

func NewTransformationsClientWithBaseURI(baseURI string, subscriptionID string) TransformationsClient

NewTransformationsClientWithBaseURI creates an instance of the TransformationsClient client.

func (TransformationsClient) CreateOrReplace 

func (client TransformationsClient) CreateOrReplace(transformation Transformation, resourceGroupName string, jobName string, transformationName string, ifMatch string, ifNoneMatch string) (result Transformation, err error)

CreateOrReplace creates a transformation or replaces an already existing transformation under an existing streaming job.

transformation is the definition of the transformation that will be used to create a new transformation or replace the existing one under the streaming job. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. transformationName is the name of the transformation. ifMatch is the ETag of the transformation. Omit this value to always overwrite the current transformation. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes. ifNoneMatch is set to '*' to allow a new transformation to be created, but to prevent updating an existing transformation. Other values will result in a 412 Pre-condition Failed response.

func (TransformationsClient) CreateOrReplacePreparer 

func (client TransformationsClient) CreateOrReplacePreparer(transformation Transformation, resourceGroupName string, jobName string, transformationName string, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (TransformationsClient) CreateOrReplaceResponder 

func (client TransformationsClient) CreateOrReplaceResponder(resp *http.Response) (result Transformation, err error)

CreateOrReplaceResponder handles the response to the CreateOrReplace request. The method always closes the http.Response Body.

func (TransformationsClient) CreateOrReplaceSender 

func (client TransformationsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error)

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

func (TransformationsClient) Get 

func (client TransformationsClient) Get(resourceGroupName string, jobName string, transformationName string) (result Transformation, err error)

Get gets details about the specified transformation.

resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. transformationName is the name of the transformation.

func (TransformationsClient) GetPreparer 

func (client TransformationsClient) GetPreparer(resourceGroupName string, jobName string, transformationName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (TransformationsClient) GetResponder 

func (client TransformationsClient) GetResponder(resp *http.Response) (result Transformation, err error)

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

func (TransformationsClient) GetSender 

func (client TransformationsClient) 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 (TransformationsClient) Update 

func (client TransformationsClient) Update(transformation Transformation, resourceGroupName string, jobName string, transformationName string, ifMatch string) (result Transformation, err error)

Update updates an existing transformation under an existing streaming job. This can be used to partially update (ie. update one or two properties) a transformation without affecting the rest the job or transformation definition.

transformation is a Transformation object. The properties specified here will overwrite the corresponding properties in the existing transformation (ie. Those properties will be updated). Any properties that are set to null here will mean that the corresponding property in the existing transformation will remain the same and not change as a result of this PATCH operation. resourceGroupName is the name of the resource group that contains the resource. You can obtain this value from the Azure Resource Manager API or the portal. jobName is the name of the streaming job. transformationName is the name of the transformation. ifMatch is the ETag of the transformation. Omit this value to always overwrite the current transformation. Specify the last-seen ETag value to prevent accidentally overwritting concurrent changes.

func (TransformationsClient) UpdatePreparer 

func (client TransformationsClient) UpdatePreparer(transformation Transformation, resourceGroupName string, jobName string, transformationName string, ifMatch string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (TransformationsClient) UpdateResponder 

func (client TransformationsClient) UpdateResponder(resp *http.Response) (result Transformation, err error)

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

func (TransformationsClient) UpdateSender 

func (client TransformationsClient) UpdateSender(req *http.Request) (*http.Response, error)

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

type UdfType 

type UdfType string

UdfType enumerates the values for udf type. 

const (
	// Scalar specifies the scalar state for udf type.
	Scalar UdfType = "Scalar"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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