streamanalytics

package
v12.1.1-beta+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 5, 2018 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

Deprecated: Please instead use github.com/Azure/azure-sdk-for-go/services/streamanalytics/mgmt/2016-03-01/streamanalytics

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the FunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON

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

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

Jump to

Keyboard shortcuts

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