streamanalytics

package
v11.1.0-beta+incompatible Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package streamanalytics implements the Azure ARM Streamanalytics service API version 2016-03-01.

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 {
	Type       Type                    `json:"type,omitempty"`
	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.

func (AvroSerialization) AsAvroSerialization 

func (as AvroSerialization) AsAvroSerialization() (*AvroSerialization, bool)

AsAvroSerialization is the Serialization implementation for AvroSerialization.

func (AvroSerialization) AsCsvSerialization 

func (as AvroSerialization) AsCsvSerialization() (*CsvSerialization, bool)

AsCsvSerialization is the Serialization implementation for AvroSerialization.

func (AvroSerialization) AsJSONSerialization 

func (as AvroSerialization) AsJSONSerialization() (*JSONSerialization, bool)

AsJSONSerialization is the Serialization implementation for AvroSerialization.

func (AvroSerialization) MarshalJSON 

func (as AvroSerialization) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AvroSerialization.

type AzureDataLakeStoreOutputDataSource 

type AzureDataLakeStoreOutputDataSource struct {
	Type                                          TypeOutputDataSource `json:"type,omitempty"`
	*AzureDataLakeStoreOutputDataSourceProperties `json:"properties,omitempty"`
}

AzureDataLakeStoreOutputDataSource is describes an Azure Data Lake Store output data source.

func (AzureDataLakeStoreOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureTableOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsBlobOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsDocumentDbOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsEventHubOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsPowerBIOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusQueueOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusTopicOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) MarshalJSON 

func (adlsods AzureDataLakeStoreOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureDataLakeStoreOutputDataSource.

type AzureDataLakeStoreOutputDataSourceProperties 

type AzureDataLakeStoreOutputDataSourceProperties struct {
	RefreshToken           *string `json:"refreshToken,omitempty"`
	TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty"`
	TokenUserDisplayName   *string `json:"tokenUserDisplayName,omitempty"`
	AccountName            *string `json:"accountName,omitempty"`
	TenantID               *string `json:"tenantId,omitempty"`
	FilePathPrefix         *string `json:"filePathPrefix,omitempty"`
	DateFormat             *string `json:"dateFormat,omitempty"`
	TimeFormat             *string `json:"timeFormat,omitempty"`
}

AzureDataLakeStoreOutputDataSourceProperties is the properties that are associated with an Azure Data Lake Store.

type AzureMachineLearningWebServiceFunctionBinding 

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

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

func (AzureMachineLearningWebServiceFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding 

func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding() (*AzureMachineLearningWebServiceFunctionBinding, bool)

AsAzureMachineLearningWebServiceFunctionBinding is the FunctionBinding implementation for AzureMachineLearningWebServiceFunctionBinding.

func (AzureMachineLearningWebServiceFunctionBinding) AsJavaScriptFunctionBinding 

func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)

AsJavaScriptFunctionBinding is the FunctionBinding implementation for AzureMachineLearningWebServiceFunctionBinding.

func (AzureMachineLearningWebServiceFunctionBinding) MarshalJSON 

func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureMachineLearningWebServiceFunctionBinding.

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 {
	BindingType                                                       BindingType `json:"bindingType,omitempty"`
	*AzureMachineLearningWebServiceFunctionBindingRetrievalProperties `json:"bindingRetrievalProperties,omitempty"`
}

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

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters 

func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters is the FunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters 

func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the FunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON 

func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

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 {
	Type                                        TypeOutputDataSource `json:"type,omitempty"`
	*AzureSQLDatabaseOutputDataSourceProperties `json:"properties,omitempty"`
}

AzureSQLDatabaseOutputDataSource is describes an Azure SQL database output data source.

func (AzureSQLDatabaseOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureTableOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsBlobOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsDocumentDbOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsEventHubOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsPowerBIOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusQueueOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusTopicOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) MarshalJSON 

func (asdods AzureSQLDatabaseOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureSQLDatabaseOutputDataSource.

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 {
	Type                                  TypeOutputDataSource `json:"type,omitempty"`
	*AzureTableOutputDataSourceProperties `json:"properties,omitempty"`
}

AzureTableOutputDataSource is describes an Azure Table output data source.

func (AzureTableOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (atods AzureTableOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (atods AzureTableOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureTableOutputDataSource 

func (atods AzureTableOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsBlobOutputDataSource 

func (atods AzureTableOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsDocumentDbOutputDataSource 

func (atods AzureTableOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsEventHubOutputDataSource 

func (atods AzureTableOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsPowerBIOutputDataSource 

func (atods AzureTableOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusQueueOutputDataSource 

func (atods AzureTableOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusTopicOutputDataSource 

func (atods AzureTableOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) MarshalJSON 

func (atods AzureTableOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureTableOutputDataSource.

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 BindingType 

type BindingType string

BindingType enumerates the values for binding type. 

const (
	// BindingTypeMicrosoftMachineLearningWebService specifies the binding type microsoft machine learning web service
	// state for binding type.
	BindingTypeMicrosoftMachineLearningWebService BindingType = "Microsoft.MachineLearning/WebService"
	// BindingTypeMicrosoftStreamAnalyticsJavascriptUdf specifies the binding type microsoft stream analytics javascript
	// udf state for binding type.
	BindingTypeMicrosoftStreamAnalyticsJavascriptUdf BindingType = "Microsoft.StreamAnalytics/JavascriptUdf"
)

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 {
	Type                            TypeOutputDataSource `json:"type,omitempty"`
	*BlobOutputDataSourceProperties `json:"properties,omitempty"`
}

BlobOutputDataSource is describes a blob output data source.

func (BlobOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (bods BlobOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (bods BlobOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureTableOutputDataSource 

func (bods BlobOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsBlobOutputDataSource 

func (bods BlobOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsDocumentDbOutputDataSource 

func (bods BlobOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsEventHubOutputDataSource 

func (bods BlobOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsPowerBIOutputDataSource 

func (bods BlobOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusQueueOutputDataSource 

func (bods BlobOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusTopicOutputDataSource 

func (bods BlobOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) MarshalJSON 

func (bods BlobOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for BlobOutputDataSource.

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 {
	Type                                    TypeReferenceInputDataSource `json:"type,omitempty"`
	*BlobReferenceInputDataSourceProperties `json:"properties,omitempty"`
}

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

func (BlobReferenceInputDataSource) AsBlobReferenceInputDataSource 

func (brids BlobReferenceInputDataSource) AsBlobReferenceInputDataSource() (*BlobReferenceInputDataSource, bool)

AsBlobReferenceInputDataSource is the ReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) MarshalJSON 

func (brids BlobReferenceInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for BlobReferenceInputDataSource.

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 {
	Type                                 TypeStreamInputDataSource `json:"type,omitempty"`
	*BlobStreamInputDataSourceProperties `json:"properties,omitempty"`
}

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

func (BlobStreamInputDataSource) AsBlobStreamInputDataSource 

func (bsids BlobStreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool)

AsBlobStreamInputDataSource is the StreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsEventHubStreamInputDataSource 

func (bsids BlobStreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool)

AsEventHubStreamInputDataSource is the StreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsIoTHubStreamInputDataSource 

func (bsids BlobStreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool)

AsIoTHubStreamInputDataSource is the StreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) MarshalJSON 

func (bsids BlobStreamInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for BlobStreamInputDataSource.

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 {
	Type                        Type `json:"type,omitempty"`
	*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.

func (CsvSerialization) AsAvroSerialization 

func (cs CsvSerialization) AsAvroSerialization() (*AvroSerialization, bool)

AsAvroSerialization is the Serialization implementation for CsvSerialization.

func (CsvSerialization) AsCsvSerialization 

func (cs CsvSerialization) AsCsvSerialization() (*CsvSerialization, bool)

AsCsvSerialization is the Serialization implementation for CsvSerialization.

func (CsvSerialization) AsJSONSerialization 

func (cs CsvSerialization) AsJSONSerialization() (*JSONSerialization, bool)

AsJSONSerialization is the Serialization implementation for CsvSerialization.

func (CsvSerialization) MarshalJSON 

func (cs CsvSerialization) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for CsvSerialization.

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 {
	Type                                  TypeOutputDataSource `json:"type,omitempty"`
	*DocumentDbOutputDataSourceProperties `json:"properties,omitempty"`
}

DocumentDbOutputDataSource is describes a DocumentDB output data source.

func (DocumentDbOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureTableOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsBlobOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsDocumentDbOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsEventHubOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsPowerBIOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusQueueOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusTopicOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) MarshalJSON 

func (ddods DocumentDbOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DocumentDbOutputDataSource.

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 {
	Type                                TypeOutputDataSource `json:"type,omitempty"`
	*EventHubOutputDataSourceProperties `json:"properties,omitempty"`
}

EventHubOutputDataSource is describes an Event Hub output data source.

func (EventHubOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (ehods EventHubOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (ehods EventHubOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureTableOutputDataSource 

func (ehods EventHubOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsBlobOutputDataSource 

func (ehods EventHubOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsDocumentDbOutputDataSource 

func (ehods EventHubOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsEventHubOutputDataSource 

func (ehods EventHubOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsPowerBIOutputDataSource 

func (ehods EventHubOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusQueueOutputDataSource 

func (ehods EventHubOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusTopicOutputDataSource 

func (ehods EventHubOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) MarshalJSON 

func (ehods EventHubOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventHubOutputDataSource.

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 {
	Type                                     TypeStreamInputDataSource `json:"type,omitempty"`
	*EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`
}

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

func (EventHubStreamInputDataSource) AsBlobStreamInputDataSource 

func (ehsids EventHubStreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool)

AsBlobStreamInputDataSource is the StreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsEventHubStreamInputDataSource 

func (ehsids EventHubStreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool)

AsEventHubStreamInputDataSource is the StreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsIoTHubStreamInputDataSource 

func (ehsids EventHubStreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool)

AsIoTHubStreamInputDataSource is the StreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) MarshalJSON 

func (ehsids EventHubStreamInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventHubStreamInputDataSource.

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.

func (*Function) UnmarshalJSON 

func (f *Function) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for Function struct.

type FunctionBinding 

type FunctionBinding interface {
	AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)
	AsAzureMachineLearningWebServiceFunctionBinding() (*AzureMachineLearningWebServiceFunctionBinding, bool)
}

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 interface {
	AsScalarFunctionProperties() (*ScalarFunctionProperties, bool)
}

FunctionProperties is the properties that are associated with a function.

type FunctionRetrieveDefaultDefinitionParameters 

type FunctionRetrieveDefaultDefinitionParameters interface {
	AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)
	AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, bool)
}

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 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.

func (*Input) UnmarshalJSON 

func (i *Input) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for Input struct.

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 interface {
	AsReferenceInputProperties() (*ReferenceInputProperties, bool)
	AsStreamInputProperties() (*StreamInputProperties, bool)
}

InputProperties is the properties that are associated with an input.

type InputsClient 

type InputsClient struct {
	ManagementClient
}

InputsClient is the 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 {
	Type                                   TypeStreamInputDataSource `json:"type,omitempty"`
	*IoTHubStreamInputDataSourceProperties `json:"properties,omitempty"`
}

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

func (IoTHubStreamInputDataSource) AsBlobStreamInputDataSource 

func (ithsids IoTHubStreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool)

AsBlobStreamInputDataSource is the StreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsEventHubStreamInputDataSource 

func (ithsids IoTHubStreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool)

AsEventHubStreamInputDataSource is the StreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsIoTHubStreamInputDataSource 

func (ithsids IoTHubStreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool)

AsIoTHubStreamInputDataSource is the StreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) MarshalJSON 

func (ithsids IoTHubStreamInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for IoTHubStreamInputDataSource.

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 {
	Type                         Type `json:"type,omitempty"`
	*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.

func (JSONSerialization) AsAvroSerialization 

func (js JSONSerialization) AsAvroSerialization() (*AvroSerialization, bool)

AsAvroSerialization is the Serialization implementation for JSONSerialization.

func (JSONSerialization) AsCsvSerialization 

func (js JSONSerialization) AsCsvSerialization() (*CsvSerialization, bool)

AsCsvSerialization is the Serialization implementation for JSONSerialization.

func (JSONSerialization) AsJSONSerialization 

func (js JSONSerialization) AsJSONSerialization() (*JSONSerialization, bool)

AsJSONSerialization is the Serialization implementation for JSONSerialization.

func (JSONSerialization) MarshalJSON 

func (js JSONSerialization) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for JSONSerialization.

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 {
	Type                                 TypeFunctionBinding `json:"type,omitempty"`
	*JavaScriptFunctionBindingProperties `json:"properties,omitempty"`
}

JavaScriptFunctionBinding is the binding to a JavaScript function.

func (JavaScriptFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding 

func (jsfb JavaScriptFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding() (*AzureMachineLearningWebServiceFunctionBinding, bool)

AsAzureMachineLearningWebServiceFunctionBinding is the FunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsJavaScriptFunctionBinding 

func (jsfb JavaScriptFunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)

AsJavaScriptFunctionBinding is the FunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) MarshalJSON 

func (jsfb JavaScriptFunctionBinding) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for JavaScriptFunctionBinding.

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 {
	BindingType                                   BindingType `json:"bindingType,omitempty"`
	*JavaScriptFunctionBindingRetrievalProperties `json:"bindingRetrievalProperties,omitempty"`
}

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

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters 

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters is the FunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters 

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the FunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) MarshalJSON 

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

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 OAuthBasedDataSourceProperties 

type OAuthBasedDataSourceProperties struct {
	RefreshToken           *string `json:"refreshToken,omitempty"`
	TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty"`
	TokenUserDisplayName   *string `json:"tokenUserDisplayName,omitempty"`
}

OAuthBasedDataSourceProperties is the properties that are associated with data sources that use OAuth as their authentication model.

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 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 interface {
	AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)
	AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)
	AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)
	AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)
	AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)
	AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)
	AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)
	AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)
	AsBlobOutputDataSource() (*BlobOutputDataSource, bool)
}

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.

func (*OutputProperties) UnmarshalJSON 

func (op *OutputProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for OutputProperties struct.

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 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 PowerBIOutputDataSource 

type PowerBIOutputDataSource struct {
	Type                               TypeOutputDataSource `json:"type,omitempty"`
	*PowerBIOutputDataSourceProperties `json:"properties,omitempty"`
}

PowerBIOutputDataSource is describes a Power BI output data source.

func (PowerBIOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (pbods PowerBIOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (pbods PowerBIOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureTableOutputDataSource 

func (pbods PowerBIOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsBlobOutputDataSource 

func (pbods PowerBIOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsDocumentDbOutputDataSource 

func (pbods PowerBIOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsEventHubOutputDataSource 

func (pbods PowerBIOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsPowerBIOutputDataSource 

func (pbods PowerBIOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsServiceBusQueueOutputDataSource 

func (pbods PowerBIOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsServiceBusTopicOutputDataSource 

func (pbods PowerBIOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) MarshalJSON 

func (pbods PowerBIOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PowerBIOutputDataSource.

type PowerBIOutputDataSourceProperties 

type PowerBIOutputDataSourceProperties struct {
	RefreshToken           *string `json:"refreshToken,omitempty"`
	TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty"`
	TokenUserDisplayName   *string `json:"tokenUserDisplayName,omitempty"`
	Dataset                *string `json:"dataset,omitempty"`
	Table                  *string `json:"table,omitempty"`
	GroupID                *string `json:"groupId,omitempty"`
	GroupName              *string `json:"groupName,omitempty"`
}

PowerBIOutputDataSourceProperties is the properties that are associated with a Power BI output.

type ReferenceInputDataSource 

type ReferenceInputDataSource interface {
	AsBlobReferenceInputDataSource() (*BlobReferenceInputDataSource, bool)
}

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"`
	Type          TypeInputProperties      `json:"type,omitempty"`
	Datasource    ReferenceInputDataSource `json:"datasource,omitempty"`
}

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

func (ReferenceInputProperties) AsReferenceInputProperties 

func (rip ReferenceInputProperties) AsReferenceInputProperties() (*ReferenceInputProperties, bool)

AsReferenceInputProperties is the InputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) AsStreamInputProperties 

func (rip ReferenceInputProperties) AsStreamInputProperties() (*StreamInputProperties, bool)

AsStreamInputProperties is the InputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) MarshalJSON 

func (rip ReferenceInputProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ReferenceInputProperties.

func (*ReferenceInputProperties) UnmarshalJSON 

func (rip *ReferenceInputProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ReferenceInputProperties struct.

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.

func (*ScalarFunctionConfiguration) UnmarshalJSON 

func (sfc *ScalarFunctionConfiguration) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ScalarFunctionConfiguration struct.

type ScalarFunctionProperties 

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

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

func (ScalarFunctionProperties) AsScalarFunctionProperties 

func (sfp ScalarFunctionProperties) AsScalarFunctionProperties() (*ScalarFunctionProperties, bool)

AsScalarFunctionProperties is the FunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) MarshalJSON 

func (sfp ScalarFunctionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ScalarFunctionProperties.

type Serialization 

type Serialization interface {
	AsAvroSerialization() (*AvroSerialization, bool)
	AsJSONSerialization() (*JSONSerialization, bool)
	AsCsvSerialization() (*CsvSerialization, bool)
}

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 {
	Type                                       TypeOutputDataSource `json:"type,omitempty"`
	*ServiceBusQueueOutputDataSourceProperties `json:"properties,omitempty"`
}

ServiceBusQueueOutputDataSource is describes a Service Bus Queue output data source.

func (ServiceBusQueueOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureTableOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsBlobOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsDocumentDbOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsEventHubOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsPowerBIOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsServiceBusQueueOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsServiceBusTopicOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) MarshalJSON 

func (sbqods ServiceBusQueueOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ServiceBusQueueOutputDataSource.

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 {
	Type                                       TypeOutputDataSource `json:"type,omitempty"`
	*ServiceBusTopicOutputDataSourceProperties `json:"properties,omitempty"`
}

ServiceBusTopicOutputDataSource is describes a Service Bus Topic output data source.

func (ServiceBusTopicOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureTableOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsBlobOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsDocumentDbOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsEventHubOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsPowerBIOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsServiceBusQueueOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsServiceBusTopicOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the OutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) MarshalJSON 

func (sbtods ServiceBusTopicOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ServiceBusTopicOutputDataSource.

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 interface {
	AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool)
	AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool)
	AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool)
}

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"`
	Type          TypeInputProperties   `json:"type,omitempty"`
	Datasource    StreamInputDataSource `json:"datasource,omitempty"`
}

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

func (StreamInputProperties) AsReferenceInputProperties 

func (sip StreamInputProperties) AsReferenceInputProperties() (*ReferenceInputProperties, bool)

AsReferenceInputProperties is the InputProperties implementation for StreamInputProperties.

func (StreamInputProperties) AsStreamInputProperties 

func (sip StreamInputProperties) AsStreamInputProperties() (*StreamInputProperties, bool)

AsStreamInputProperties is the InputProperties implementation for StreamInputProperties.

func (StreamInputProperties) MarshalJSON 

func (sip StreamInputProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for StreamInputProperties.

func (*StreamInputProperties) UnmarshalJSON 

func (sip *StreamInputProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for StreamInputProperties struct.

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 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 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 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 Type 

type Type string

Type enumerates the values for type. 

const (
	// TypeAvro specifies the type avro state for type.
	TypeAvro Type = "Avro"
	// TypeCsv specifies the type csv state for type.
	TypeCsv Type = "Csv"
	// TypeJSON specifies the type json state for type.
	TypeJSON Type = "Json"
)

type TypeFunctionBinding 

type TypeFunctionBinding string

TypeFunctionBinding enumerates the values for type function binding. 

const (
	// TypeMicrosoftMachineLearningWebService specifies the type microsoft machine learning web service state for type
	// function binding.
	TypeMicrosoftMachineLearningWebService TypeFunctionBinding = "Microsoft.MachineLearning/WebService"
	// TypeMicrosoftStreamAnalyticsJavascriptUdf specifies the type microsoft stream analytics javascript udf state for
	// type function binding.
	TypeMicrosoftStreamAnalyticsJavascriptUdf TypeFunctionBinding = "Microsoft.StreamAnalytics/JavascriptUdf"
)

type TypeFunctionProperties 

type TypeFunctionProperties string

TypeFunctionProperties enumerates the values for type function properties. 

const (
	// TypeScalar specifies the type scalar state for type function properties.
	TypeScalar TypeFunctionProperties = "Scalar"
)

type TypeInputProperties 

type TypeInputProperties string

TypeInputProperties enumerates the values for type input properties. 

const (
	// TypeReference specifies the type reference state for type input properties.
	TypeReference TypeInputProperties = "Reference"
	// TypeStream specifies the type stream state for type input properties.
	TypeStream TypeInputProperties = "Stream"
)

type TypeOutputDataSource 

type TypeOutputDataSource string

TypeOutputDataSource enumerates the values for type output data source. 

const (
	// TypeMicrosoftDataLakeAccounts specifies the type microsoft data lake accounts state for type output data source.
	TypeMicrosoftDataLakeAccounts TypeOutputDataSource = "Microsoft.DataLake/Accounts"
	// TypeMicrosoftServiceBusEventHub specifies the type microsoft service bus event hub state for type output data
	// source.
	TypeMicrosoftServiceBusEventHub TypeOutputDataSource = "Microsoft.ServiceBus/EventHub"
	// TypeMicrosoftServiceBusQueue specifies the type microsoft service bus queue state for type output data source.
	TypeMicrosoftServiceBusQueue TypeOutputDataSource = "Microsoft.ServiceBus/Queue"
	// TypeMicrosoftServiceBusTopic specifies the type microsoft service bus topic state for type output data source.
	TypeMicrosoftServiceBusTopic TypeOutputDataSource = "Microsoft.ServiceBus/Topic"
	// TypeMicrosoftSQLServerDatabase specifies the type microsoft sql server database state for type output data source.
	TypeMicrosoftSQLServerDatabase TypeOutputDataSource = "Microsoft.Sql/Server/Database"
	// TypeMicrosoftStorageBlob specifies the type microsoft storage blob state for type output data source.
	TypeMicrosoftStorageBlob TypeOutputDataSource = "Microsoft.Storage/Blob"
	// TypeMicrosoftStorageDocumentDB specifies the type microsoft storage document db state for type output data source.
	TypeMicrosoftStorageDocumentDB TypeOutputDataSource = "Microsoft.Storage/DocumentDB"
	// TypeMicrosoftStorageTable specifies the type microsoft storage table state for type output data source.
	TypeMicrosoftStorageTable TypeOutputDataSource = "Microsoft.Storage/Table"
	// TypePowerBI specifies the type power bi state for type output data source.
	TypePowerBI TypeOutputDataSource = "PowerBI"
)

type TypeReferenceInputDataSource 

type TypeReferenceInputDataSource string

TypeReferenceInputDataSource enumerates the values for type reference input data source. 

const (
	// TypeReferenceInputDataSourceTypeMicrosoftStorageBlob specifies the type reference input data source type microsoft
	// storage blob state for type reference input data source.
	TypeReferenceInputDataSourceTypeMicrosoftStorageBlob TypeReferenceInputDataSource = "Microsoft.Storage/Blob"
)

type TypeStreamInputDataSource 

type TypeStreamInputDataSource string

TypeStreamInputDataSource enumerates the values for type stream input data source. 

const (
	// TypeStreamInputDataSourceTypeMicrosoftDevicesIotHubs specifies the type stream input data source type microsoft
	// devices iot hubs state for type stream input data source.
	TypeStreamInputDataSourceTypeMicrosoftDevicesIotHubs TypeStreamInputDataSource = "Microsoft.Devices/IotHubs"
	// TypeStreamInputDataSourceTypeMicrosoftServiceBusEventHub specifies the type stream input data source type microsoft
	// service bus event hub state for type stream input data source.
	TypeStreamInputDataSourceTypeMicrosoftServiceBusEventHub TypeStreamInputDataSource = "Microsoft.ServiceBus/EventHub"
	// TypeStreamInputDataSourceTypeMicrosoftStorageBlob specifies the type stream input data source type microsoft storage
	// blob state for type stream input data source.
	TypeStreamInputDataSourceTypeMicrosoftStorageBlob TypeStreamInputDataSource = "Microsoft.Storage/Blob"
)

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.