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"
)

Jump to

Keyboard shortcuts

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