azure-sdk-for-go: github.com/Azure/azure-sdk-for-go/services/streamanalytics/mgmt/2016-03-01/streamanalytics Index | Files | Directories

package streamanalytics

import "github.com/Azure/azure-sdk-for-go/services/streamanalytics/mgmt/2016-03-01/streamanalytics"

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

Stream Analytics Client

Index

Package Files

client.go functions.go inputs.go models.go operations.go outputs.go streamingjobs.go subscriptions.go transformations.go version.go

Constants

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

func UserAgent Uses

func UserAgent() string

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

func Version Uses

func Version() string

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

type AvroSerialization Uses

type AvroSerialization struct {
    // Properties - The properties that are associated with the Avro serialization type. Required on PUT (CreateOrReplace) requests.
    Properties interface{} `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeSerialization', 'TypeAvro', 'TypeJSON', 'TypeCsv'
    Type Type `json:"type,omitempty"`
}

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

func (AvroSerialization) AsAvroSerialization Uses

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

AsAvroSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsBasicSerialization Uses

func (as AvroSerialization) AsBasicSerialization() (BasicSerialization, bool)

AsBasicSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsCsvSerialization Uses

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

AsCsvSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsJSONSerialization Uses

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

AsJSONSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsSerialization Uses

func (as AvroSerialization) AsSerialization() (*Serialization, bool)

AsSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AvroSerialization.

type AzureDataLakeStoreOutputDataSource Uses

type AzureDataLakeStoreOutputDataSource struct {
    // AzureDataLakeStoreOutputDataSourceProperties - The properties that are associated with an Azure Data Lake Store output. Required on PUT (CreateOrReplace) requests.
    *AzureDataLakeStoreOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

AzureDataLakeStoreOutputDataSource describes an Azure Data Lake Store output data source.

func (AzureDataLakeStoreOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsBasicOutputDataSource Uses

func (adlsods AzureDataLakeStoreOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsOutputDataSource Uses

func (adlsods AzureDataLakeStoreOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureDataLakeStoreOutputDataSource.

func (*AzureDataLakeStoreOutputDataSource) UnmarshalJSON Uses

func (adlsods *AzureDataLakeStoreOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureDataLakeStoreOutputDataSource struct.

type AzureDataLakeStoreOutputDataSourceProperties Uses

type AzureDataLakeStoreOutputDataSourceProperties struct {
    // AccountName - The name of the Azure Data Lake Store account. Required on PUT (CreateOrReplace) requests.
    AccountName *string `json:"accountName,omitempty"`
    // TenantID - The tenant id of the user used to obtain the refresh token. Required on PUT (CreateOrReplace) requests.
    TenantID *string `json:"tenantId,omitempty"`
    // FilePathPrefix - The location of the file to which the output should be written to. Required on PUT (CreateOrReplace) requests.
    FilePathPrefix *string `json:"filePathPrefix,omitempty"`
    // DateFormat - The date format. Wherever {date} appears in filePathPrefix, the value of this property is used as the date format instead.
    DateFormat *string `json:"dateFormat,omitempty"`
    // TimeFormat - The time format. Wherever {time} appears in filePathPrefix, the value of this property is used as the time format instead.
    TimeFormat *string `json:"timeFormat,omitempty"`
    // RefreshToken - A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.
    RefreshToken *string `json:"refreshToken,omitempty"`
    // TokenUserPrincipalName - The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.
    TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty"`
    // TokenUserDisplayName - The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.
    TokenUserDisplayName *string `json:"tokenUserDisplayName,omitempty"`
}

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

type AzureMachineLearningWebServiceFunctionBinding Uses

type AzureMachineLearningWebServiceFunctionBinding struct {
    // AzureMachineLearningWebServiceFunctionBindingProperties - The binding properties associated with an Azure Machine learning web service.
    *AzureMachineLearningWebServiceFunctionBindingProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeFunctionBinding', 'TypeMicrosoftStreamAnalyticsJavascriptUdf', 'TypeMicrosoftMachineLearningWebService'
    Type TypeBasicFunctionBinding `json:"type,omitempty"`
}

AzureMachineLearningWebServiceFunctionBinding the binding to an Azure Machine Learning web service.

func (AzureMachineLearningWebServiceFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding Uses

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

AsAzureMachineLearningWebServiceFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningWebServiceFunctionBinding.

func (AzureMachineLearningWebServiceFunctionBinding) AsBasicFunctionBinding Uses

func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool)

AsBasicFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningWebServiceFunctionBinding.

func (AzureMachineLearningWebServiceFunctionBinding) AsFunctionBinding Uses

func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsFunctionBinding() (*FunctionBinding, bool)

AsFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningWebServiceFunctionBinding.

func (AzureMachineLearningWebServiceFunctionBinding) AsJavaScriptFunctionBinding Uses

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningWebServiceFunctionBinding.

func (AzureMachineLearningWebServiceFunctionBinding) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureMachineLearningWebServiceFunctionBinding.

func (*AzureMachineLearningWebServiceFunctionBinding) UnmarshalJSON Uses

func (amlwsfb *AzureMachineLearningWebServiceFunctionBinding) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningWebServiceFunctionBinding struct.

type AzureMachineLearningWebServiceFunctionBindingProperties Uses

type AzureMachineLearningWebServiceFunctionBindingProperties struct {
    // Endpoint - The Request-Response execute endpoint of the Azure Machine Learning web service. Find out more here: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
    Endpoint *string `json:"endpoint,omitempty"`
    // APIKey - The API key used to authenticate with Request-Response endpoint.
    APIKey *string `json:"apiKey,omitempty"`
    // Inputs - The inputs for the Azure Machine Learning web service endpoint.
    Inputs *AzureMachineLearningWebServiceInputs `json:"inputs,omitempty"`
    // Outputs - A list of outputs from the Azure Machine Learning web service endpoint execution.
    Outputs *[]AzureMachineLearningWebServiceOutputColumn `json:"outputs,omitempty"`
    // BatchSize - Number between 1 and 10000 describing maximum number of rows for every Azure ML RRS execute request. Default is 1000.
    BatchSize *int32 `json:"batchSize,omitempty"`
}

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

type AzureMachineLearningWebServiceFunctionBindingRetrievalProperties Uses

type AzureMachineLearningWebServiceFunctionBindingRetrievalProperties struct {
    // ExecuteEndpoint - The Request-Response execute endpoint of the Azure Machine Learning web service. Find out more here: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
    ExecuteEndpoint *string `json:"executeEndpoint,omitempty"`
    // UdfType - The function type. Possible values include: 'Scalar'
    UdfType UdfType `json:"udfType,omitempty"`
}

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

type AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters Uses

type AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters struct {
    // AzureMachineLearningWebServiceFunctionBindingRetrievalProperties - The binding retrieval properties associated with an Azure Machine learning web service.
    *AzureMachineLearningWebServiceFunctionBindingRetrievalProperties `json:"bindingRetrievalProperties,omitempty"`
    // BindingType - Possible values include: 'BindingTypeFunctionRetrieveDefaultDefinitionParameters', 'BindingTypeMicrosoftMachineLearningWebService', 'BindingTypeMicrosoftStreamAnalyticsJavascriptUdf'
    BindingType BindingType `json:"bindingType,omitempty"`
}

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

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters Uses

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

AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters Uses

func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool)

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters Uses

func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool)

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters.

func (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON Uses

func (amlwsfrddp *AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters struct.

type AzureMachineLearningWebServiceInputColumn Uses

type AzureMachineLearningWebServiceInputColumn struct {
    // Name - The name of the input column.
    Name *string `json:"name,omitempty"`
    // DataType - The (Azure Machine Learning supported) data type of the input column. A list of valid  Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
    DataType *string `json:"dataType,omitempty"`
    // MapTo - The zero based index of the function parameter this input maps to.
    MapTo *int32 `json:"mapTo,omitempty"`
}

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

type AzureMachineLearningWebServiceInputs Uses

type AzureMachineLearningWebServiceInputs struct {
    // Name - The name of the input. This is the name provided while authoring the endpoint.
    Name *string `json:"name,omitempty"`
    // ColumnNames - A list of input columns for the Azure Machine Learning web service endpoint.
    ColumnNames *[]AzureMachineLearningWebServiceInputColumn `json:"columnNames,omitempty"`
}

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

type AzureMachineLearningWebServiceOutputColumn Uses

type AzureMachineLearningWebServiceOutputColumn struct {
    // Name - The name of the output column.
    Name *string `json:"name,omitempty"`
    // DataType - The (Azure Machine Learning supported) data type of the output column. A list of valid  Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
    DataType *string `json:"dataType,omitempty"`
}

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

type AzureSQLDatabaseDataSourceProperties Uses

type AzureSQLDatabaseDataSourceProperties struct {
    // Server - The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Server *string `json:"server,omitempty"`
    // Database - The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Database *string `json:"database,omitempty"`
    // User - The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    User *string `json:"user,omitempty"`
    // Password - The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Password *string `json:"password,omitempty"`
    // Table - The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Table *string `json:"table,omitempty"`
}

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

type AzureSQLDatabaseOutputDataSource Uses

type AzureSQLDatabaseOutputDataSource struct {
    // AzureSQLDatabaseOutputDataSourceProperties - The properties that are associated with an Azure SQL database output. Required on PUT (CreateOrReplace) requests.
    *AzureSQLDatabaseOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

AzureSQLDatabaseOutputDataSource describes an Azure SQL database output data source.

func (AzureSQLDatabaseOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsBasicOutputDataSource Uses

func (asdods AzureSQLDatabaseOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsOutputDataSource Uses

func (asdods AzureSQLDatabaseOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureSQLDatabaseOutputDataSource.

func (*AzureSQLDatabaseOutputDataSource) UnmarshalJSON Uses

func (asdods *AzureSQLDatabaseOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureSQLDatabaseOutputDataSource struct.

type AzureSQLDatabaseOutputDataSourceProperties Uses

type AzureSQLDatabaseOutputDataSourceProperties struct {
    // Server - The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Server *string `json:"server,omitempty"`
    // Database - The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Database *string `json:"database,omitempty"`
    // User - The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    User *string `json:"user,omitempty"`
    // Password - The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Password *string `json:"password,omitempty"`
    // Table - The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.
    Table *string `json:"table,omitempty"`
}

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

type AzureTableOutputDataSource Uses

type AzureTableOutputDataSource struct {
    // AzureTableOutputDataSourceProperties - The properties that are associated with an Azure Table output. Required on PUT (CreateOrReplace) requests.
    *AzureTableOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

AzureTableOutputDataSource describes an Azure Table output data source.

func (AzureTableOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsBasicOutputDataSource Uses

func (atods AzureTableOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsOutputDataSource Uses

func (atods AzureTableOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureTableOutputDataSource.

func (*AzureTableOutputDataSource) UnmarshalJSON Uses

func (atods *AzureTableOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureTableOutputDataSource struct.

type AzureTableOutputDataSourceProperties Uses

type AzureTableOutputDataSourceProperties struct {
    // AccountName - The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.
    AccountName *string `json:"accountName,omitempty"`
    // AccountKey - The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.
    AccountKey *string `json:"accountKey,omitempty"`
    // Table - The name of the Azure Table. Required on PUT (CreateOrReplace) requests.
    Table *string `json:"table,omitempty"`
    // PartitionKey - This element indicates the name of a column from the SELECT statement in the query that will be used as the partition key for the Azure Table. Required on PUT (CreateOrReplace) requests.
    PartitionKey *string `json:"partitionKey,omitempty"`
    // RowKey - This element indicates the name of a column from the SELECT statement in the query that will be used as the row key for the Azure Table. Required on PUT (CreateOrReplace) requests.
    RowKey *string `json:"rowKey,omitempty"`
    // ColumnsToRemove - If specified, each item in the array is the name of a column to remove (if present) from output event entities.
    ColumnsToRemove *[]string `json:"columnsToRemove,omitempty"`
    // BatchSize - The number of rows to write to the Azure Table at a time.
    BatchSize *int32 `json:"batchSize,omitempty"`
}

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

type BaseClient Uses

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

BaseClient is the base client for Streamanalytics.

func New Uses

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI Uses

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client.

type BasicFunctionBinding Uses

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

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

type BasicFunctionProperties Uses

type BasicFunctionProperties interface {
    AsScalarFunctionProperties() (*ScalarFunctionProperties, bool)
    AsFunctionProperties() (*FunctionProperties, bool)
}

BasicFunctionProperties the properties that are associated with a function.

type BasicFunctionRetrieveDefaultDefinitionParameters Uses

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

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

type BasicInputProperties Uses

type BasicInputProperties interface {
    AsReferenceInputProperties() (*ReferenceInputProperties, bool)
    AsStreamInputProperties() (*StreamInputProperties, bool)
    AsInputProperties() (*InputProperties, bool)
}

BasicInputProperties the properties that are associated with an input.

type BasicOutputDataSource Uses

type BasicOutputDataSource 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)
    AsOutputDataSource() (*OutputDataSource, bool)
}

BasicOutputDataSource describes the data source that output will be written to.

type BasicReferenceInputDataSource Uses

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

BasicReferenceInputDataSource describes an input data source that contains reference data.

type BasicSerialization Uses

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

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

type BasicStreamInputDataSource Uses

type BasicStreamInputDataSource interface {
    AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool)
    AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool)
    AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool)
    AsStreamInputDataSource() (*StreamInputDataSource, bool)
}

BasicStreamInputDataSource describes an input data source that contains stream data.

type BindingType Uses

type BindingType string

BindingType enumerates the values for binding type.

const (
    // BindingTypeFunctionRetrieveDefaultDefinitionParameters ...
    BindingTypeFunctionRetrieveDefaultDefinitionParameters BindingType = "FunctionRetrieveDefaultDefinitionParameters"
    // BindingTypeMicrosoftMachineLearningWebService ...
    BindingTypeMicrosoftMachineLearningWebService BindingType = "Microsoft.MachineLearning/WebService"
    // BindingTypeMicrosoftStreamAnalyticsJavascriptUdf ...
    BindingTypeMicrosoftStreamAnalyticsJavascriptUdf BindingType = "Microsoft.StreamAnalytics/JavascriptUdf"
)

func PossibleBindingTypeValues Uses

func PossibleBindingTypeValues() []BindingType

PossibleBindingTypeValues returns an array of possible values for the BindingType const type.

type BlobDataSourceProperties Uses

type BlobDataSourceProperties struct {
    // StorageAccounts - A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.
    StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"`
    // Container - The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.
    Container *string `json:"container,omitempty"`
    // PathPattern - The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input or https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.
    PathPattern *string `json:"pathPattern,omitempty"`
    // DateFormat - The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.
    DateFormat *string `json:"dateFormat,omitempty"`
    // TimeFormat - The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.
    TimeFormat *string `json:"timeFormat,omitempty"`
}

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

type BlobOutputDataSource Uses

type BlobOutputDataSource struct {
    // BlobOutputDataSourceProperties - The properties that are associated with a blob output. Required on PUT (CreateOrReplace) requests.
    *BlobOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

BlobOutputDataSource describes a blob output data source.

func (BlobOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsBasicOutputDataSource Uses

func (bods BlobOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsOutputDataSource Uses

func (bods BlobOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for BlobOutputDataSource.

func (*BlobOutputDataSource) UnmarshalJSON Uses

func (bods *BlobOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for BlobOutputDataSource struct.

type BlobOutputDataSourceProperties Uses

type BlobOutputDataSourceProperties struct {
    // StorageAccounts - A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.
    StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"`
    // Container - The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.
    Container *string `json:"container,omitempty"`
    // PathPattern - The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input or https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.
    PathPattern *string `json:"pathPattern,omitempty"`
    // DateFormat - The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.
    DateFormat *string `json:"dateFormat,omitempty"`
    // TimeFormat - The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.
    TimeFormat *string `json:"timeFormat,omitempty"`
}

BlobOutputDataSourceProperties the properties that are associated with a blob output.

type BlobReferenceInputDataSource Uses

type BlobReferenceInputDataSource struct {
    // BlobReferenceInputDataSourceProperties - The properties that are associated with a blob input containing reference data. Required on PUT (CreateOrReplace) requests.
    *BlobReferenceInputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource', 'TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob'
    Type TypeBasicReferenceInputDataSource `json:"type,omitempty"`
}

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

func (BlobReferenceInputDataSource) AsBasicReferenceInputDataSource Uses

func (brids BlobReferenceInputDataSource) AsBasicReferenceInputDataSource() (BasicReferenceInputDataSource, bool)

AsBasicReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsBlobReferenceInputDataSource Uses

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

AsBlobReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsReferenceInputDataSource Uses

func (brids BlobReferenceInputDataSource) AsReferenceInputDataSource() (*ReferenceInputDataSource, bool)

AsReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for BlobReferenceInputDataSource.

func (*BlobReferenceInputDataSource) UnmarshalJSON Uses

func (brids *BlobReferenceInputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for BlobReferenceInputDataSource struct.

type BlobReferenceInputDataSourceProperties Uses

type BlobReferenceInputDataSourceProperties struct {
    // StorageAccounts - A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.
    StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"`
    // Container - The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.
    Container *string `json:"container,omitempty"`
    // PathPattern - The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input or https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.
    PathPattern *string `json:"pathPattern,omitempty"`
    // DateFormat - The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.
    DateFormat *string `json:"dateFormat,omitempty"`
    // TimeFormat - The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.
    TimeFormat *string `json:"timeFormat,omitempty"`
}

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

type BlobStreamInputDataSource Uses

type BlobStreamInputDataSource struct {
    // BlobStreamInputDataSourceProperties - The properties that are associated with a blob input containing stream data. Required on PUT (CreateOrReplace) requests.
    *BlobStreamInputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeBasicStreamInputDataSourceTypeStreamInputDataSource', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob'
    Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

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

func (BlobStreamInputDataSource) AsBasicStreamInputDataSource Uses

func (bsids BlobStreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool)

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsBlobStreamInputDataSource Uses

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsEventHubStreamInputDataSource Uses

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsIoTHubStreamInputDataSource Uses

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsStreamInputDataSource Uses

func (bsids BlobStreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool)

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for BlobStreamInputDataSource.

func (*BlobStreamInputDataSource) UnmarshalJSON Uses

func (bsids *BlobStreamInputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for BlobStreamInputDataSource struct.

type BlobStreamInputDataSourceProperties Uses

type BlobStreamInputDataSourceProperties struct {
    // SourcePartitionCount - The partition count of the blob input data source. Range 1 - 256.
    SourcePartitionCount *int32 `json:"sourcePartitionCount,omitempty"`
    // StorageAccounts - A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.
    StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"`
    // Container - The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.
    Container *string `json:"container,omitempty"`
    // PathPattern - The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input or https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.
    PathPattern *string `json:"pathPattern,omitempty"`
    // DateFormat - The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.
    DateFormat *string `json:"dateFormat,omitempty"`
    // TimeFormat - The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.
    TimeFormat *string `json:"timeFormat,omitempty"`
}

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

type CompatibilityLevel Uses

type CompatibilityLevel string

CompatibilityLevel enumerates the values for compatibility level.

const (
    // OneFullStopZero ...
    OneFullStopZero CompatibilityLevel = "1.0"
)

func PossibleCompatibilityLevelValues Uses

func PossibleCompatibilityLevelValues() []CompatibilityLevel

PossibleCompatibilityLevelValues returns an array of possible values for the CompatibilityLevel const type.

type CsvSerialization Uses

type CsvSerialization struct {
    // CsvSerializationProperties - The properties that are associated with the CSV serialization type. Required on PUT (CreateOrReplace) requests.
    *CsvSerializationProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeSerialization', 'TypeAvro', 'TypeJSON', 'TypeCsv'
    Type Type `json:"type,omitempty"`
}

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

func (CsvSerialization) AsAvroSerialization Uses

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

AsAvroSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsBasicSerialization Uses

func (cs CsvSerialization) AsBasicSerialization() (BasicSerialization, bool)

AsBasicSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsCsvSerialization Uses

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

AsCsvSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsJSONSerialization Uses

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

AsJSONSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsSerialization Uses

func (cs CsvSerialization) AsSerialization() (*Serialization, bool)

AsSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for CsvSerialization.

func (*CsvSerialization) UnmarshalJSON Uses

func (cs *CsvSerialization) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for CsvSerialization struct.

type CsvSerializationProperties Uses

type CsvSerializationProperties struct {
    // FieldDelimiter - Specifies the delimiter that will be used to separate comma-separated value (CSV) records. See https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input or https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for a list of supported values. Required on PUT (CreateOrReplace) requests.
    FieldDelimiter *string `json:"fieldDelimiter,omitempty"`
    // Encoding - Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests. Possible values include: 'UTF8'
    Encoding Encoding `json:"encoding,omitempty"`
}

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

type DiagnosticCondition Uses

type DiagnosticCondition struct {
    // Since - READ-ONLY; The UTC timestamp of when the condition started. Customers should be able to find a corresponding event in the ops log around this time.
    Since *string `json:"since,omitempty"`
    // Code - READ-ONLY; The opaque diagnostic code.
    Code *string `json:"code,omitempty"`
    // Message - READ-ONLY; The human-readable message describing the condition in detail. Localized in the Accept-Language of the client request.
    Message *string `json:"message,omitempty"`
}

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

type Diagnostics Uses

type Diagnostics struct {
    // Conditions - READ-ONLY; A collection of zero or more conditions applicable to the resource, or to the job overall, that warrant customer attention.
    Conditions *[]DiagnosticCondition `json:"conditions,omitempty"`
}

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

type DocumentDbOutputDataSource Uses

type DocumentDbOutputDataSource struct {
    // DocumentDbOutputDataSourceProperties - The properties that are associated with a DocumentDB output. Required on PUT (CreateOrReplace) requests.
    *DocumentDbOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

DocumentDbOutputDataSource describes a DocumentDB output data source.

func (DocumentDbOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsBasicOutputDataSource Uses

func (ddods DocumentDbOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsOutputDataSource Uses

func (ddods DocumentDbOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for DocumentDbOutputDataSource.

func (*DocumentDbOutputDataSource) UnmarshalJSON Uses

func (ddods *DocumentDbOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for DocumentDbOutputDataSource struct.

type DocumentDbOutputDataSourceProperties Uses

type DocumentDbOutputDataSourceProperties struct {
    // AccountID - The DocumentDB account name or ID. Required on PUT (CreateOrReplace) requests.
    AccountID *string `json:"accountId,omitempty"`
    // AccountKey - The account key for the DocumentDB account. Required on PUT (CreateOrReplace) requests.
    AccountKey *string `json:"accountKey,omitempty"`
    // Database - The name of the DocumentDB database. Required on PUT (CreateOrReplace) requests.
    Database *string `json:"database,omitempty"`
    // CollectionNamePattern - The collection name pattern for the collections to be used. The collection name format can be constructed using the optional {partition} token, where partitions start from 0. See the DocumentDB section of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for more information. Required on PUT (CreateOrReplace) requests.
    CollectionNamePattern *string `json:"collectionNamePattern,omitempty"`
    // PartitionKey - The name of the field in output events used to specify the key for partitioning output across collections. If 'collectionNamePattern' contains the {partition} token, this property is required to be specified.
    PartitionKey *string `json:"partitionKey,omitempty"`
    // DocumentID - The name of the field in output events used to specify the primary key which insert or update operations are based on.
    DocumentID *string `json:"documentId,omitempty"`
}

DocumentDbOutputDataSourceProperties the properties that are associated with a DocumentDB output.

type Encoding Uses

type Encoding string

Encoding enumerates the values for encoding.

const (
    // UTF8 ...
    UTF8 Encoding = "UTF8"
)

func PossibleEncodingValues Uses

func PossibleEncodingValues() []Encoding

PossibleEncodingValues returns an array of possible values for the Encoding const type.

type ErrorResponse Uses

type ErrorResponse struct {
    // Code - READ-ONLY; Error code associated with the error that occurred.
    Code *string `json:"code,omitempty"`
    // Message - READ-ONLY; Describes the error in detail.
    Message *string `json:"message,omitempty"`
}

ErrorResponse describes the error that occurred.

type EventHubDataSourceProperties Uses

type EventHubDataSourceProperties struct {
    // EventHubName - The name of the Event Hub. Required on PUT (CreateOrReplace) requests.
    EventHubName *string `json:"eventHubName,omitempty"`
    // ServiceBusNamespace - The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    ServiceBusNamespace *string `json:"serviceBusNamespace,omitempty"`
    // SharedAccessPolicyName - The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
    // SharedAccessPolicyKey - The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyKey *string `json:"sharedAccessPolicyKey,omitempty"`
}

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

type EventHubOutputDataSource Uses

type EventHubOutputDataSource struct {
    // EventHubOutputDataSourceProperties - The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.
    *EventHubOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

EventHubOutputDataSource describes an Event Hub output data source.

func (EventHubOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsBasicOutputDataSource Uses

func (ehods EventHubOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsOutputDataSource Uses

func (ehods EventHubOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for EventHubOutputDataSource.

func (*EventHubOutputDataSource) UnmarshalJSON Uses

func (ehods *EventHubOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventHubOutputDataSource struct.

type EventHubOutputDataSourceProperties Uses

type EventHubOutputDataSourceProperties struct {
    // PartitionKey - The key/column that is used to determine to which partition to send event data.
    PartitionKey *string `json:"partitionKey,omitempty"`
    // EventHubName - The name of the Event Hub. Required on PUT (CreateOrReplace) requests.
    EventHubName *string `json:"eventHubName,omitempty"`
    // ServiceBusNamespace - The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    ServiceBusNamespace *string `json:"serviceBusNamespace,omitempty"`
    // SharedAccessPolicyName - The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
    // SharedAccessPolicyKey - The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyKey *string `json:"sharedAccessPolicyKey,omitempty"`
}

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

type EventHubStreamInputDataSource Uses

type EventHubStreamInputDataSource struct {
    // EventHubStreamInputDataSourceProperties - The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.
    *EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeBasicStreamInputDataSourceTypeStreamInputDataSource', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob'
    Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

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

func (EventHubStreamInputDataSource) AsBasicStreamInputDataSource Uses

func (ehsids EventHubStreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool)

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsBlobStreamInputDataSource Uses

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsEventHubStreamInputDataSource Uses

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsIoTHubStreamInputDataSource Uses

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsStreamInputDataSource Uses

func (ehsids EventHubStreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool)

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for EventHubStreamInputDataSource.

func (*EventHubStreamInputDataSource) UnmarshalJSON Uses

func (ehsids *EventHubStreamInputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventHubStreamInputDataSource struct.

type EventHubStreamInputDataSourceProperties Uses

type EventHubStreamInputDataSourceProperties struct {
    // ConsumerGroupName - The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not specified, the input uses the Event Hub’s default consumer group.
    ConsumerGroupName *string `json:"consumerGroupName,omitempty"`
    // EventHubName - The name of the Event Hub. Required on PUT (CreateOrReplace) requests.
    EventHubName *string `json:"eventHubName,omitempty"`
    // ServiceBusNamespace - The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    ServiceBusNamespace *string `json:"serviceBusNamespace,omitempty"`
    // SharedAccessPolicyName - The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
    // SharedAccessPolicyKey - The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyKey *string `json:"sharedAccessPolicyKey,omitempty"`
}

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

type EventsOutOfOrderPolicy Uses

type EventsOutOfOrderPolicy string

EventsOutOfOrderPolicy enumerates the values for events out of order policy.

const (
    // Adjust ...
    Adjust EventsOutOfOrderPolicy = "Adjust"
    // Drop ...
    Drop EventsOutOfOrderPolicy = "Drop"
)

func PossibleEventsOutOfOrderPolicyValues Uses

func PossibleEventsOutOfOrderPolicyValues() []EventsOutOfOrderPolicy

PossibleEventsOutOfOrderPolicyValues returns an array of possible values for the EventsOutOfOrderPolicy const type.

type Function Uses

type Function struct {
    autorest.Response `json:"-"`
    // Properties - The properties that are associated with a function.
    Properties BasicFunctionProperties `json:"properties,omitempty"`
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
}

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

func (*Function) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for Function struct.

type FunctionBinding Uses

type FunctionBinding struct {
    // Type - Possible values include: 'TypeFunctionBinding', 'TypeMicrosoftStreamAnalyticsJavascriptUdf', 'TypeMicrosoftMachineLearningWebService'
    Type TypeBasicFunctionBinding `json:"type,omitempty"`
}

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

func (FunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding Uses

func (fb FunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding() (*AzureMachineLearningWebServiceFunctionBinding, bool)

AsAzureMachineLearningWebServiceFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsBasicFunctionBinding Uses

func (fb FunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool)

AsBasicFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsFunctionBinding Uses

func (fb FunctionBinding) AsFunctionBinding() (*FunctionBinding, bool)

AsFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsJavaScriptFunctionBinding Uses

func (fb FunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) MarshalJSON Uses

func (fb FunctionBinding) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for FunctionBinding.

type FunctionInput Uses

type FunctionInput struct {
    // DataType - The (Azure Stream Analytics supported) data type of the function input parameter. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
    DataType *string `json:"dataType,omitempty"`
    // IsConfigurationParameter - A flag indicating if the parameter is a configuration parameter. True if this input parameter is expected to be a constant. Default is false.
    IsConfigurationParameter *bool `json:"isConfigurationParameter,omitempty"`
}

FunctionInput describes one input parameter of a function.

type FunctionListResult Uses

type FunctionListResult struct {
    autorest.Response `json:"-"`
    // Value - READ-ONLY; A list of functions under a streaming job. Populated by a 'List' operation.
    Value *[]Function `json:"value,omitempty"`
    // NextLink - READ-ONLY; The link (url) to the next page of results.
    NextLink *string `json:"nextLink,omitempty"`
}

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

func (FunctionListResult) IsEmpty Uses

func (flr FunctionListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type FunctionListResultIterator Uses

type FunctionListResultIterator struct {
    // contains filtered or unexported fields
}

FunctionListResultIterator provides access to a complete listing of Function values.

func NewFunctionListResultIterator Uses

func NewFunctionListResultIterator(page FunctionListResultPage) FunctionListResultIterator

Creates a new instance of the FunctionListResultIterator type.

func (*FunctionListResultIterator) Next Uses

func (iter *FunctionListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*FunctionListResultIterator) NextWithContext Uses

func (iter *FunctionListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (FunctionListResultIterator) NotDone Uses

func (iter FunctionListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (FunctionListResultIterator) Response Uses

func (iter FunctionListResultIterator) Response() FunctionListResult

Response returns the raw server response from the last page request.

func (FunctionListResultIterator) Value Uses

func (iter FunctionListResultIterator) Value() Function

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type FunctionListResultPage Uses

type FunctionListResultPage struct {
    // contains filtered or unexported fields
}

FunctionListResultPage contains a page of Function values.

func NewFunctionListResultPage Uses

func NewFunctionListResultPage(getNextPage func(context.Context, FunctionListResult) (FunctionListResult, error)) FunctionListResultPage

Creates a new instance of the FunctionListResultPage type.

func (*FunctionListResultPage) Next Uses

func (page *FunctionListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*FunctionListResultPage) NextWithContext Uses

func (page *FunctionListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (FunctionListResultPage) NotDone Uses

func (page FunctionListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (FunctionListResultPage) Response Uses

func (page FunctionListResultPage) Response() FunctionListResult

Response returns the raw server response from the last page request.

func (FunctionListResultPage) Values Uses

func (page FunctionListResultPage) Values() []Function

Values returns the slice of values for the current page or nil if there are no values.

type FunctionOutput Uses

type FunctionOutput struct {
    // DataType - The (Azure Stream Analytics supported) data type of the function output. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
    DataType *string `json:"dataType,omitempty"`
}

FunctionOutput describes the output of a function.

type FunctionProperties Uses

type FunctionProperties struct {
    // Etag - READ-ONLY; The current entity tag for the function. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
    // Type - Possible values include: 'TypeFunctionProperties', 'TypeScalar'
    Type TypeBasicFunctionProperties `json:"type,omitempty"`
}

FunctionProperties the properties that are associated with a function.

func (FunctionProperties) AsBasicFunctionProperties Uses

func (fp FunctionProperties) AsBasicFunctionProperties() (BasicFunctionProperties, bool)

AsBasicFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsFunctionProperties Uses

func (fp FunctionProperties) AsFunctionProperties() (*FunctionProperties, bool)

AsFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsScalarFunctionProperties Uses

func (fp FunctionProperties) AsScalarFunctionProperties() (*ScalarFunctionProperties, bool)

AsScalarFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) MarshalJSON Uses

func (fp FunctionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for FunctionProperties.

type FunctionRetrieveDefaultDefinitionParameters Uses

type FunctionRetrieveDefaultDefinitionParameters struct {
    // BindingType - Possible values include: 'BindingTypeFunctionRetrieveDefaultDefinitionParameters', 'BindingTypeMicrosoftMachineLearningWebService', 'BindingTypeMicrosoftStreamAnalyticsJavascriptUdf'
    BindingType BindingType `json:"bindingType,omitempty"`
}

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

func (FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters Uses

func (frddp FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters Uses

func (frddp FunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool)

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters Uses

func (frddp FunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool)

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

func (frddp FunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) MarshalJSON Uses

func (frddp FunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for FunctionRetrieveDefaultDefinitionParameters.

type FunctionsClient Uses

type FunctionsClient struct {
    BaseClient
}

FunctionsClient is the stream Analytics Client

func NewFunctionsClient Uses

func NewFunctionsClient(subscriptionID string) FunctionsClient

NewFunctionsClient creates an instance of the FunctionsClient client.

func NewFunctionsClientWithBaseURI Uses

func NewFunctionsClientWithBaseURI(baseURI string, subscriptionID string) FunctionsClient

NewFunctionsClientWithBaseURI creates an instance of the FunctionsClient client.

func (FunctionsClient) CreateOrReplace Uses

func (client FunctionsClient) CreateOrReplace(ctx context.Context, 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. Parameters: function - the definition of the function that will be used to create a new function or replace the existing one under the streaming job. resourceGroupName - 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 - the name of the streaming job. functionName - the name of the function. ifMatch - the ETag of the function. Omit this value to always overwrite the current function. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes. ifNoneMatch - 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 Uses

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

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (FunctionsClient) CreateOrReplaceResponder Uses

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 Uses

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 Uses

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

Delete deletes a function from the streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job. functionName - the name of the function.

func (FunctionsClient) DeletePreparer Uses

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

DeletePreparer prepares the Delete request.

func (FunctionsClient) DeleteResponder Uses

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 Uses

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 Uses

func (client FunctionsClient) Get(ctx context.Context, resourceGroupName string, jobName string, functionName string) (result Function, err error)

Get gets details about the specified function. Parameters: resourceGroupName - 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 - the name of the streaming job. functionName - the name of the function.

func (FunctionsClient) GetPreparer Uses

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

GetPreparer prepares the Get request.

func (FunctionsClient) GetResponder Uses

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 Uses

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 Uses

func (client FunctionsClient) ListByStreamingJob(ctx context.Context, resourceGroupName string, jobName string, selectParameter string) (result FunctionListResultPage, err error)

ListByStreamingJob lists all of the functions under the specified streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job. selectParameter - 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 Uses

func (client FunctionsClient) ListByStreamingJobComplete(ctx context.Context, resourceGroupName string, jobName string, selectParameter string) (result FunctionListResultIterator, err error)

ListByStreamingJobComplete enumerates all values, automatically crossing page boundaries as required.

func (FunctionsClient) ListByStreamingJobPreparer Uses

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (FunctionsClient) ListByStreamingJobResponder Uses

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 Uses

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 Uses

func (client FunctionsClient) RetrieveDefaultDefinition(ctx context.Context, resourceGroupName string, jobName string, functionName string, functionRetrieveDefaultDefinitionParameters *BasicFunctionRetrieveDefaultDefinitionParameters) (result Function, err error)

RetrieveDefaultDefinition retrieves the default definition of a function based on the parameters specified. Parameters: resourceGroupName - 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 - the name of the streaming job. functionName - the name of the function. functionRetrieveDefaultDefinitionParameters - parameters used to specify the type of function to retrieve the default definition for.

func (FunctionsClient) RetrieveDefaultDefinitionPreparer Uses

func (client FunctionsClient) RetrieveDefaultDefinitionPreparer(ctx context.Context, resourceGroupName string, jobName string, functionName string, functionRetrieveDefaultDefinitionParameters *BasicFunctionRetrieveDefaultDefinitionParameters) (*http.Request, error)

RetrieveDefaultDefinitionPreparer prepares the RetrieveDefaultDefinition request.

func (FunctionsClient) RetrieveDefaultDefinitionResponder Uses

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 Uses

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 Uses

func (client FunctionsClient) Test(ctx context.Context, resourceGroupName string, jobName string, functionName string, function *Function) (result FunctionsTestFuture, err 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. Parameters: resourceGroupName - 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 - the name of the streaming job. functionName - the name of the function. function - 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 Uses

func (client FunctionsClient) TestPreparer(ctx context.Context, resourceGroupName string, jobName string, functionName string, function *Function) (*http.Request, error)

TestPreparer prepares the Test request.

func (FunctionsClient) TestResponder Uses

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 Uses

func (client FunctionsClient) TestSender(req *http.Request) (future FunctionsTestFuture, err error)

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

func (FunctionsClient) Update Uses

func (client FunctionsClient) Update(ctx context.Context, 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. Parameters: function - 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 - 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 - the name of the streaming job. functionName - the name of the function. ifMatch - the ETag of the function. Omit this value to always overwrite the current function. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.

func (FunctionsClient) UpdatePreparer Uses

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

UpdatePreparer prepares the Update request.

func (FunctionsClient) UpdateResponder Uses

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 Uses

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 FunctionsTestFuture Uses

type FunctionsTestFuture struct {
    azure.Future
}

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

func (*FunctionsTestFuture) Result Uses

func (future *FunctionsTestFuture) Result(client FunctionsClient) (rts ResourceTestStatus, err error)

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

type Input Uses

type Input struct {
    autorest.Response `json:"-"`
    // Properties - The properties that are associated with an input. Required on PUT (CreateOrReplace) requests.
    Properties BasicInputProperties `json:"properties,omitempty"`
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
}

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

func (*Input) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for Input struct.

type InputListResult Uses

type InputListResult struct {
    autorest.Response `json:"-"`
    // Value - READ-ONLY; A list of inputs under a streaming job. Populated by a 'List' operation.
    Value *[]Input `json:"value,omitempty"`
    // NextLink - READ-ONLY; The link (url) to the next page of results.
    NextLink *string `json:"nextLink,omitempty"`
}

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

func (InputListResult) IsEmpty Uses

func (ilr InputListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type InputListResultIterator Uses

type InputListResultIterator struct {
    // contains filtered or unexported fields
}

InputListResultIterator provides access to a complete listing of Input values.

func NewInputListResultIterator Uses

func NewInputListResultIterator(page InputListResultPage) InputListResultIterator

Creates a new instance of the InputListResultIterator type.

func (*InputListResultIterator) Next Uses

func (iter *InputListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*InputListResultIterator) NextWithContext Uses

func (iter *InputListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (InputListResultIterator) NotDone Uses

func (iter InputListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (InputListResultIterator) Response Uses

func (iter InputListResultIterator) Response() InputListResult

Response returns the raw server response from the last page request.

func (InputListResultIterator) Value Uses

func (iter InputListResultIterator) Value() Input

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type InputListResultPage Uses

type InputListResultPage struct {
    // contains filtered or unexported fields
}

InputListResultPage contains a page of Input values.

func NewInputListResultPage Uses

func NewInputListResultPage(getNextPage func(context.Context, InputListResult) (InputListResult, error)) InputListResultPage

Creates a new instance of the InputListResultPage type.

func (*InputListResultPage) Next Uses

func (page *InputListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*InputListResultPage) NextWithContext Uses

func (page *InputListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (InputListResultPage) NotDone Uses

func (page InputListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (InputListResultPage) Response Uses

func (page InputListResultPage) Response() InputListResult

Response returns the raw server response from the last page request.

func (InputListResultPage) Values Uses

func (page InputListResultPage) Values() []Input

Values returns the slice of values for the current page or nil if there are no values.

type InputProperties Uses

type InputProperties struct {
    // Serialization - Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.
    Serialization BasicSerialization `json:"serialization,omitempty"`
    // Diagnostics - READ-ONLY; Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention.
    Diagnostics *Diagnostics `json:"diagnostics,omitempty"`
    // Etag - READ-ONLY; The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
    // Type - Possible values include: 'TypeInputProperties', 'TypeReference', 'TypeStream'
    Type TypeBasicInputProperties `json:"type,omitempty"`
}

InputProperties the properties that are associated with an input.

func (InputProperties) AsBasicInputProperties Uses

func (IP InputProperties) AsBasicInputProperties() (BasicInputProperties, bool)

AsBasicInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsInputProperties Uses

func (IP InputProperties) AsInputProperties() (*InputProperties, bool)

AsInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsReferenceInputProperties Uses

func (IP InputProperties) AsReferenceInputProperties() (*ReferenceInputProperties, bool)

AsReferenceInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsStreamInputProperties Uses

func (IP InputProperties) AsStreamInputProperties() (*StreamInputProperties, bool)

AsStreamInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) MarshalJSON Uses

func (IP InputProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for InputProperties.

func (*InputProperties) UnmarshalJSON Uses

func (IP *InputProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for InputProperties struct.

type InputsClient Uses

type InputsClient struct {
    BaseClient
}

InputsClient is the stream Analytics Client

func NewInputsClient Uses

func NewInputsClient(subscriptionID string) InputsClient

NewInputsClient creates an instance of the InputsClient client.

func NewInputsClientWithBaseURI Uses

func NewInputsClientWithBaseURI(baseURI string, subscriptionID string) InputsClient

NewInputsClientWithBaseURI creates an instance of the InputsClient client.

func (InputsClient) CreateOrReplace Uses

func (client InputsClient) CreateOrReplace(ctx context.Context, 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. Parameters: input - the definition of the input that will be used to create a new input or replace the existing one under the streaming job. resourceGroupName - 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 - the name of the streaming job. inputName - the name of the input. ifMatch - the ETag of the input. Omit this value to always overwrite the current input. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes. ifNoneMatch - 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 Uses

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

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (InputsClient) CreateOrReplaceResponder Uses

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 Uses

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 Uses

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

Delete deletes an input from the streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job. inputName - the name of the input.

func (InputsClient) DeletePreparer Uses

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

DeletePreparer prepares the Delete request.

func (InputsClient) DeleteResponder Uses

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 Uses

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 Uses

func (client InputsClient) Get(ctx context.Context, resourceGroupName string, jobName string, inputName string) (result Input, err error)

Get gets details about the specified input. Parameters: resourceGroupName - 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 - the name of the streaming job. inputName - the name of the input.

func (InputsClient) GetPreparer Uses

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

GetPreparer prepares the Get request.

func (InputsClient) GetResponder Uses

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 Uses

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 Uses

func (client InputsClient) ListByStreamingJob(ctx context.Context, resourceGroupName string, jobName string, selectParameter string) (result InputListResultPage, err error)

ListByStreamingJob lists all of the inputs under the specified streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job. selectParameter - 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 Uses

func (client InputsClient) ListByStreamingJobComplete(ctx context.Context, resourceGroupName string, jobName string, selectParameter string) (result InputListResultIterator, err error)

ListByStreamingJobComplete enumerates all values, automatically crossing page boundaries as required.

func (InputsClient) ListByStreamingJobPreparer Uses

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (InputsClient) ListByStreamingJobResponder Uses

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 Uses

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 Uses

func (client InputsClient) Test(ctx context.Context, resourceGroupName string, jobName string, inputName string, input *Input) (result InputsTestFuture, err error)

Test tests whether an input’s datasource is reachable and usable by the Azure Stream Analytics service. Parameters: resourceGroupName - 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 - the name of the streaming job. inputName - the name of the input. input - 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 Uses

func (client InputsClient) TestPreparer(ctx context.Context, resourceGroupName string, jobName string, inputName string, input *Input) (*http.Request, error)

TestPreparer prepares the Test request.

func (InputsClient) TestResponder Uses

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 Uses

func (client InputsClient) TestSender(req *http.Request) (future InputsTestFuture, err error)

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

func (InputsClient) Update Uses

func (client InputsClient) Update(ctx context.Context, 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. Parameters: input - 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 - 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 - the name of the streaming job. inputName - the name of the input. ifMatch - the ETag of the input. Omit this value to always overwrite the current input. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.

func (InputsClient) UpdatePreparer Uses

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

UpdatePreparer prepares the Update request.

func (InputsClient) UpdateResponder Uses

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 Uses

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 InputsTestFuture Uses

type InputsTestFuture struct {
    azure.Future
}

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

func (*InputsTestFuture) Result Uses

func (future *InputsTestFuture) Result(client InputsClient) (rts ResourceTestStatus, err error)

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

type IoTHubStreamInputDataSource Uses

type IoTHubStreamInputDataSource struct {
    // IoTHubStreamInputDataSourceProperties - The properties that are associated with an IoT Hub input containing stream data. Required on PUT (CreateOrReplace) requests.
    *IoTHubStreamInputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeBasicStreamInputDataSourceTypeStreamInputDataSource', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob'
    Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

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

func (IoTHubStreamInputDataSource) AsBasicStreamInputDataSource Uses

func (ithsids IoTHubStreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool)

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsBlobStreamInputDataSource Uses

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsEventHubStreamInputDataSource Uses

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsIoTHubStreamInputDataSource Uses

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsStreamInputDataSource Uses

func (ithsids IoTHubStreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool)

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for IoTHubStreamInputDataSource.

func (*IoTHubStreamInputDataSource) UnmarshalJSON Uses

func (ithsids *IoTHubStreamInputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for IoTHubStreamInputDataSource struct.

type IoTHubStreamInputDataSourceProperties Uses

type IoTHubStreamInputDataSourceProperties struct {
    // IotHubNamespace - The name or the URI of the IoT Hub. Required on PUT (CreateOrReplace) requests.
    IotHubNamespace *string `json:"iotHubNamespace,omitempty"`
    // SharedAccessPolicyName - The shared access policy name for the IoT Hub. This policy must contain at least the Service connect permission. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
    // SharedAccessPolicyKey - The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyKey *string `json:"sharedAccessPolicyKey,omitempty"`
    // ConsumerGroupName - The name of an IoT Hub Consumer Group that should be used to read events from the IoT Hub. If not specified, the input uses the Iot Hub’s default consumer group.
    ConsumerGroupName *string `json:"consumerGroupName,omitempty"`
    // Endpoint - The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
    Endpoint *string `json:"endpoint,omitempty"`
}

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

type JSONOutputSerializationFormat Uses

type JSONOutputSerializationFormat string

JSONOutputSerializationFormat enumerates the values for json output serialization format.

const (
    // Array ...
    Array JSONOutputSerializationFormat = "Array"
    // LineSeparated ...
    LineSeparated JSONOutputSerializationFormat = "LineSeparated"
)

func PossibleJSONOutputSerializationFormatValues Uses

func PossibleJSONOutputSerializationFormatValues() []JSONOutputSerializationFormat

PossibleJSONOutputSerializationFormatValues returns an array of possible values for the JSONOutputSerializationFormat const type.

type JSONSerialization Uses

type JSONSerialization struct {
    // JSONSerializationProperties - The properties that are associated with the JSON serialization type. Required on PUT (CreateOrReplace) requests.
    *JSONSerializationProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeSerialization', 'TypeAvro', 'TypeJSON', 'TypeCsv'
    Type Type `json:"type,omitempty"`
}

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

func (JSONSerialization) AsAvroSerialization Uses

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

AsAvroSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsBasicSerialization Uses

func (js JSONSerialization) AsBasicSerialization() (BasicSerialization, bool)

AsBasicSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsCsvSerialization Uses

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

AsCsvSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsJSONSerialization Uses

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

AsJSONSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsSerialization Uses

func (js JSONSerialization) AsSerialization() (*Serialization, bool)

AsSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for JSONSerialization.

func (*JSONSerialization) UnmarshalJSON Uses

func (js *JSONSerialization) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for JSONSerialization struct.

type JSONSerializationProperties Uses

type JSONSerializationProperties struct {
    // Encoding - Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests. Possible values include: 'UTF8'
    Encoding Encoding `json:"encoding,omitempty"`
    // Format - This property only applies to JSON serialization of outputs only. It is not applicable to inputs. This property specifies the format of the JSON the output will be written in. The currently supported values are 'lineSeparated' indicating the output will be formatted by having each JSON object separated by a new line and 'array' indicating the output will be formatted as an array of JSON objects. Default value is 'lineSeparated' if left null. Possible values include: 'LineSeparated', 'Array'
    Format JSONOutputSerializationFormat `json:"format,omitempty"`
}

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

type JavaScriptFunctionBinding Uses

type JavaScriptFunctionBinding struct {
    // JavaScriptFunctionBindingProperties - The binding properties associated with a JavaScript function.
    *JavaScriptFunctionBindingProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeFunctionBinding', 'TypeMicrosoftStreamAnalyticsJavascriptUdf', 'TypeMicrosoftMachineLearningWebService'
    Type TypeBasicFunctionBinding `json:"type,omitempty"`
}

JavaScriptFunctionBinding the binding to a JavaScript function.

func (JavaScriptFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding Uses

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

AsAzureMachineLearningWebServiceFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsBasicFunctionBinding Uses

func (jsfb JavaScriptFunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool)

AsBasicFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsFunctionBinding Uses

func (jsfb JavaScriptFunctionBinding) AsFunctionBinding() (*FunctionBinding, bool)

AsFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsJavaScriptFunctionBinding Uses

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for JavaScriptFunctionBinding.

func (*JavaScriptFunctionBinding) UnmarshalJSON Uses

func (jsfb *JavaScriptFunctionBinding) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for JavaScriptFunctionBinding struct.

type JavaScriptFunctionBindingProperties Uses

type JavaScriptFunctionBindingProperties struct {
    // Script - The JavaScript code containing a single function definition. For example: 'function (x, y) { return x + y; }'
    Script *string `json:"script,omitempty"`
}

JavaScriptFunctionBindingProperties the binding properties associated with a JavaScript function.

type JavaScriptFunctionBindingRetrievalProperties Uses

type JavaScriptFunctionBindingRetrievalProperties struct {
    // Script - The JavaScript code containing a single function definition. For example: 'function (x, y) { return x + y; }'.
    Script *string `json:"script,omitempty"`
    // UdfType - The function type. Possible values include: 'Scalar'
    UdfType UdfType `json:"udfType,omitempty"`
}

JavaScriptFunctionBindingRetrievalProperties the binding retrieval properties associated with a JavaScript function.

type JavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

type JavaScriptFunctionRetrieveDefaultDefinitionParameters struct {
    // JavaScriptFunctionBindingRetrievalProperties - The binding retrieval properties associated with a JavaScript function.
    *JavaScriptFunctionBindingRetrievalProperties `json:"bindingRetrievalProperties,omitempty"`
    // BindingType - Possible values include: 'BindingTypeFunctionRetrieveDefaultDefinitionParameters', 'BindingTypeMicrosoftMachineLearningWebService', 'BindingTypeMicrosoftStreamAnalyticsJavascriptUdf'
    BindingType BindingType `json:"bindingType,omitempty"`
}

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

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters Uses

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

AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters Uses

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool)

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters Uses

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool)

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (*JavaScriptFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON Uses

func (jsfrddp *JavaScriptFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for JavaScriptFunctionRetrieveDefaultDefinitionParameters struct.

type OAuthBasedDataSourceProperties Uses

type OAuthBasedDataSourceProperties struct {
    // RefreshToken - A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.
    RefreshToken *string `json:"refreshToken,omitempty"`
    // TokenUserPrincipalName - The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.
    TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty"`
    // TokenUserDisplayName - The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.
    TokenUserDisplayName *string `json:"tokenUserDisplayName,omitempty"`
}

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

type Operation Uses

type Operation struct {
    // Name - READ-ONLY; The name of the operation being performed on this particular object.
    Name *string `json:"name,omitempty"`
    // Display - READ-ONLY; Contains the localized display information for this particular operation / action.
    Display *OperationDisplay `json:"display,omitempty"`
}

Operation a Stream Analytics REST API operation

type OperationDisplay Uses

type OperationDisplay struct {
    // Provider - READ-ONLY; The localized friendly form of the resource provider name.
    Provider *string `json:"provider,omitempty"`
    // Resource - READ-ONLY; The localized friendly form of the resource type related to this action/operation.
    Resource *string `json:"resource,omitempty"`
    // Operation - READ-ONLY; The localized friendly name for the operation.
    Operation *string `json:"operation,omitempty"`
    // Description - READ-ONLY; The localized friendly description for the operation.
    Description *string `json:"description,omitempty"`
}

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

type OperationListResult Uses

type OperationListResult struct {
    autorest.Response `json:"-"`
    // Value - READ-ONLY; List of Stream Analytics operations supported by the Microsoft.StreamAnalytics resource provider.
    Value *[]Operation `json:"value,omitempty"`
    // NextLink - READ-ONLY; URL to get the next set of operation list results if there are any.
    NextLink *string `json:"nextLink,omitempty"`
}

OperationListResult 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) IsEmpty Uses

func (olr OperationListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type OperationListResultIterator Uses

type OperationListResultIterator struct {
    // contains filtered or unexported fields
}

OperationListResultIterator provides access to a complete listing of Operation values.

func NewOperationListResultIterator Uses

func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator

Creates a new instance of the OperationListResultIterator type.

func (*OperationListResultIterator) Next Uses

func (iter *OperationListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultIterator) NextWithContext Uses

func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (OperationListResultIterator) NotDone Uses

func (iter OperationListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (OperationListResultIterator) Response Uses

func (iter OperationListResultIterator) Response() OperationListResult

Response returns the raw server response from the last page request.

func (OperationListResultIterator) Value Uses

func (iter OperationListResultIterator) Value() Operation

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type OperationListResultPage Uses

type OperationListResultPage struct {
    // contains filtered or unexported fields
}

OperationListResultPage contains a page of Operation values.

func NewOperationListResultPage Uses

func NewOperationListResultPage(getNextPage func(context.Context, OperationListResult) (OperationListResult, error)) OperationListResultPage

Creates a new instance of the OperationListResultPage type.

func (*OperationListResultPage) Next Uses

func (page *OperationListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultPage) NextWithContext Uses

func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (OperationListResultPage) NotDone Uses

func (page OperationListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (OperationListResultPage) Response Uses

func (page OperationListResultPage) Response() OperationListResult

Response returns the raw server response from the last page request.

func (OperationListResultPage) Values Uses

func (page OperationListResultPage) Values() []Operation

Values returns the slice of values for the current page or nil if there are no values.

type OperationsClient Uses

type OperationsClient struct {
    BaseClient
}

OperationsClient is the stream Analytics Client

func NewOperationsClient Uses

func NewOperationsClient(subscriptionID string) OperationsClient

NewOperationsClient creates an instance of the OperationsClient client.

func NewOperationsClientWithBaseURI Uses

func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient

NewOperationsClientWithBaseURI creates an instance of the OperationsClient client.

func (OperationsClient) List Uses

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

List lists all of the available Stream Analytics related operations.

func (OperationsClient) ListComplete Uses

func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error)

ListComplete enumerates all values, automatically crossing page boundaries as required.

func (OperationsClient) ListPreparer Uses

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

ListPreparer prepares the List request.

func (OperationsClient) ListResponder Uses

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 Uses

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 Uses

type Output struct {
    autorest.Response `json:"-"`
    // OutputProperties - The properties that are associated with an output. Required on PUT (CreateOrReplace) requests.
    *OutputProperties `json:"properties,omitempty"`
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
}

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

func (Output) MarshalJSON Uses

func (o Output) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Output.

func (*Output) UnmarshalJSON Uses

func (o *Output) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for Output struct.

type OutputDataSource Uses

type OutputDataSource struct {
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

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

func (OutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

func (ods OutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

func (ods OutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsAzureTableOutputDataSource Uses

func (ods OutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsBasicOutputDataSource Uses

func (ods OutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsBlobOutputDataSource Uses

func (ods OutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsDocumentDbOutputDataSource Uses

func (ods OutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsEventHubOutputDataSource Uses

func (ods OutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsOutputDataSource Uses

func (ods OutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsPowerBIOutputDataSource Uses

func (ods OutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsServiceBusQueueOutputDataSource Uses

func (ods OutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsServiceBusTopicOutputDataSource Uses

func (ods OutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) MarshalJSON Uses

func (ods OutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OutputDataSource.

type OutputErrorPolicy Uses

type OutputErrorPolicy string

OutputErrorPolicy enumerates the values for output error policy.

const (
    // OutputErrorPolicyDrop ...
    OutputErrorPolicyDrop OutputErrorPolicy = "Drop"
    // OutputErrorPolicyStop ...
    OutputErrorPolicyStop OutputErrorPolicy = "Stop"
)

func PossibleOutputErrorPolicyValues Uses

func PossibleOutputErrorPolicyValues() []OutputErrorPolicy

PossibleOutputErrorPolicyValues returns an array of possible values for the OutputErrorPolicy const type.

type OutputListResult Uses

type OutputListResult struct {
    autorest.Response `json:"-"`
    // Value - READ-ONLY; A list of outputs under a streaming job. Populated by a 'List' operation.
    Value *[]Output `json:"value,omitempty"`
    // NextLink - READ-ONLY; The link (url) to the next page of results.
    NextLink *string `json:"nextLink,omitempty"`
}

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

func (OutputListResult) IsEmpty Uses

func (olr OutputListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type OutputListResultIterator Uses

type OutputListResultIterator struct {
    // contains filtered or unexported fields
}

OutputListResultIterator provides access to a complete listing of Output values.

func NewOutputListResultIterator Uses

func NewOutputListResultIterator(page OutputListResultPage) OutputListResultIterator

Creates a new instance of the OutputListResultIterator type.

func (*OutputListResultIterator) Next Uses

func (iter *OutputListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OutputListResultIterator) NextWithContext Uses

func (iter *OutputListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (OutputListResultIterator) NotDone Uses

func (iter OutputListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (OutputListResultIterator) Response Uses

func (iter OutputListResultIterator) Response() OutputListResult

Response returns the raw server response from the last page request.

func (OutputListResultIterator) Value Uses

func (iter OutputListResultIterator) Value() Output

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type OutputListResultPage Uses

type OutputListResultPage struct {
    // contains filtered or unexported fields
}

OutputListResultPage contains a page of Output values.

func NewOutputListResultPage Uses

func NewOutputListResultPage(getNextPage func(context.Context, OutputListResult) (OutputListResult, error)) OutputListResultPage

Creates a new instance of the OutputListResultPage type.

func (*OutputListResultPage) Next Uses

func (page *OutputListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OutputListResultPage) NextWithContext Uses

func (page *OutputListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (OutputListResultPage) NotDone Uses

func (page OutputListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (OutputListResultPage) Response Uses

func (page OutputListResultPage) Response() OutputListResult

Response returns the raw server response from the last page request.

func (OutputListResultPage) Values Uses

func (page OutputListResultPage) Values() []Output

Values returns the slice of values for the current page or nil if there are no values.

type OutputProperties Uses

type OutputProperties struct {
    // Datasource - Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests.
    Datasource BasicOutputDataSource `json:"datasource,omitempty"`
    // Serialization - Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.
    Serialization BasicSerialization `json:"serialization,omitempty"`
    // Diagnostics - READ-ONLY; Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention.
    Diagnostics *Diagnostics `json:"diagnostics,omitempty"`
    // Etag - READ-ONLY; The current entity tag for the output. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
}

OutputProperties the properties that are associated with an output.

func (*OutputProperties) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for OutputProperties struct.

type OutputStartMode Uses

type OutputStartMode string

OutputStartMode enumerates the values for output start mode.

const (
    // CustomTime ...
    CustomTime OutputStartMode = "CustomTime"
    // JobStartTime ...
    JobStartTime OutputStartMode = "JobStartTime"
    // LastOutputEventTime ...
    LastOutputEventTime OutputStartMode = "LastOutputEventTime"
)

func PossibleOutputStartModeValues Uses

func PossibleOutputStartModeValues() []OutputStartMode

PossibleOutputStartModeValues returns an array of possible values for the OutputStartMode const type.

type OutputsClient Uses

type OutputsClient struct {
    BaseClient
}

OutputsClient is the stream Analytics Client

func NewOutputsClient Uses

func NewOutputsClient(subscriptionID string) OutputsClient

NewOutputsClient creates an instance of the OutputsClient client.

func NewOutputsClientWithBaseURI Uses

func NewOutputsClientWithBaseURI(baseURI string, subscriptionID string) OutputsClient

NewOutputsClientWithBaseURI creates an instance of the OutputsClient client.

func (OutputsClient) CreateOrReplace Uses

func (client OutputsClient) CreateOrReplace(ctx context.Context, 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. Parameters: output - the definition of the output that will be used to create a new output or replace the existing one under the streaming job. resourceGroupName - 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 - the name of the streaming job. outputName - the name of the output. ifMatch - the ETag of the output. Omit this value to always overwrite the current output. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes. ifNoneMatch - 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 Uses

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

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (OutputsClient) CreateOrReplaceResponder Uses

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 Uses

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 Uses

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

Delete deletes an output from the streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job. outputName - the name of the output.

func (OutputsClient) DeletePreparer Uses

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

DeletePreparer prepares the Delete request.

func (OutputsClient) DeleteResponder Uses

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 Uses

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 Uses

func (client OutputsClient) Get(ctx context.Context, resourceGroupName string, jobName string, outputName string) (result Output, err error)

Get gets details about the specified output. Parameters: resourceGroupName - 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 - the name of the streaming job. outputName - the name of the output.

func (OutputsClient) GetPreparer Uses

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

GetPreparer prepares the Get request.

func (OutputsClient) GetResponder Uses

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 Uses

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 Uses

func (client OutputsClient) ListByStreamingJob(ctx context.Context, resourceGroupName string, jobName string, selectParameter string) (result OutputListResultPage, err error)

ListByStreamingJob lists all of the outputs under the specified streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job. selectParameter - 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 Uses

func (client OutputsClient) ListByStreamingJobComplete(ctx context.Context, resourceGroupName string, jobName string, selectParameter string) (result OutputListResultIterator, err error)

ListByStreamingJobComplete enumerates all values, automatically crossing page boundaries as required.

func (OutputsClient) ListByStreamingJobPreparer Uses

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (OutputsClient) ListByStreamingJobResponder Uses

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 Uses

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 Uses

func (client OutputsClient) Test(ctx context.Context, resourceGroupName string, jobName string, outputName string, output *Output) (result OutputsTestFuture, err error)

Test tests whether an output’s datasource is reachable and usable by the Azure Stream Analytics service. Parameters: resourceGroupName - 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 - the name of the streaming job. outputName - the name of the output. output - 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 Uses

func (client OutputsClient) TestPreparer(ctx context.Context, resourceGroupName string, jobName string, outputName string, output *Output) (*http.Request, error)

TestPreparer prepares the Test request.

func (OutputsClient) TestResponder Uses

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 Uses

func (client OutputsClient) TestSender(req *http.Request) (future OutputsTestFuture, err error)

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

func (OutputsClient) Update Uses

func (client OutputsClient) Update(ctx context.Context, 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. Parameters: output - 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 - 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 - the name of the streaming job. outputName - the name of the output. ifMatch - the ETag of the output. Omit this value to always overwrite the current output. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.

func (OutputsClient) UpdatePreparer Uses

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

UpdatePreparer prepares the Update request.

func (OutputsClient) UpdateResponder Uses

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 Uses

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 OutputsTestFuture Uses

type OutputsTestFuture struct {
    azure.Future
}

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

func (*OutputsTestFuture) Result Uses

func (future *OutputsTestFuture) Result(client OutputsClient) (rts ResourceTestStatus, err error)

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

type PowerBIOutputDataSource Uses

type PowerBIOutputDataSource struct {
    // PowerBIOutputDataSourceProperties - The properties that are associated with a Power BI output. Required on PUT (CreateOrReplace) requests.
    *PowerBIOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

PowerBIOutputDataSource describes a Power BI output data source.

func (PowerBIOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsBasicOutputDataSource Uses

func (pbods PowerBIOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsOutputDataSource Uses

func (pbods PowerBIOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for PowerBIOutputDataSource.

func (*PowerBIOutputDataSource) UnmarshalJSON Uses

func (pbods *PowerBIOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for PowerBIOutputDataSource struct.

type PowerBIOutputDataSourceProperties Uses

type PowerBIOutputDataSourceProperties struct {
    // Dataset - The name of the Power BI dataset. Required on PUT (CreateOrReplace) requests.
    Dataset *string `json:"dataset,omitempty"`
    // Table - The name of the Power BI table under the specified dataset. Required on PUT (CreateOrReplace) requests.
    Table *string `json:"table,omitempty"`
    // GroupID - The ID of the Power BI group.
    GroupID *string `json:"groupId,omitempty"`
    // GroupName - The name of the Power BI group. Use this property to help remember which specific Power BI group id was used.
    GroupName *string `json:"groupName,omitempty"`
    // RefreshToken - A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.
    RefreshToken *string `json:"refreshToken,omitempty"`
    // TokenUserPrincipalName - The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.
    TokenUserPrincipalName *string `json:"tokenUserPrincipalName,omitempty"`
    // TokenUserDisplayName - The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.
    TokenUserDisplayName *string `json:"tokenUserDisplayName,omitempty"`
}

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

type ReferenceInputDataSource Uses

type ReferenceInputDataSource struct {
    // Type - Possible values include: 'TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource', 'TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob'
    Type TypeBasicReferenceInputDataSource `json:"type,omitempty"`
}

ReferenceInputDataSource describes an input data source that contains reference data.

func (ReferenceInputDataSource) AsBasicReferenceInputDataSource Uses

func (rids ReferenceInputDataSource) AsBasicReferenceInputDataSource() (BasicReferenceInputDataSource, bool)

AsBasicReferenceInputDataSource is the BasicReferenceInputDataSource implementation for ReferenceInputDataSource.

func (ReferenceInputDataSource) AsBlobReferenceInputDataSource Uses

func (rids ReferenceInputDataSource) AsBlobReferenceInputDataSource() (*BlobReferenceInputDataSource, bool)

AsBlobReferenceInputDataSource is the BasicReferenceInputDataSource implementation for ReferenceInputDataSource.

func (ReferenceInputDataSource) AsReferenceInputDataSource Uses

func (rids ReferenceInputDataSource) AsReferenceInputDataSource() (*ReferenceInputDataSource, bool)

AsReferenceInputDataSource is the BasicReferenceInputDataSource implementation for ReferenceInputDataSource.

func (ReferenceInputDataSource) MarshalJSON Uses

func (rids ReferenceInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ReferenceInputDataSource.

type ReferenceInputProperties Uses

type ReferenceInputProperties struct {
    // Datasource - Describes an input data source that contains reference data. Required on PUT (CreateOrReplace) requests.
    Datasource BasicReferenceInputDataSource `json:"datasource,omitempty"`
    // Serialization - Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.
    Serialization BasicSerialization `json:"serialization,omitempty"`
    // Diagnostics - READ-ONLY; Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention.
    Diagnostics *Diagnostics `json:"diagnostics,omitempty"`
    // Etag - READ-ONLY; The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
    // Type - Possible values include: 'TypeInputProperties', 'TypeReference', 'TypeStream'
    Type TypeBasicInputProperties `json:"type,omitempty"`
}

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

func (ReferenceInputProperties) AsBasicInputProperties Uses

func (rip ReferenceInputProperties) AsBasicInputProperties() (BasicInputProperties, bool)

AsBasicInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) AsInputProperties Uses

func (rip ReferenceInputProperties) AsInputProperties() (*InputProperties, bool)

AsInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) AsReferenceInputProperties Uses

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

AsReferenceInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) AsStreamInputProperties Uses

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

AsStreamInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for ReferenceInputProperties.

func (*ReferenceInputProperties) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for ReferenceInputProperties struct.

type Resource Uses

type Resource struct {
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - READ-ONLY; Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
    // Location - Resource location. Required on PUT (CreateOrReplace) requests.
    Location *string `json:"location,omitempty"`
    // Tags - Resource tags
    Tags map[string]*string `json:"tags"`
}

Resource the base resource model definition.

func (Resource) MarshalJSON Uses

func (r Resource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Resource.

type ResourceTestStatus Uses

type ResourceTestStatus struct {
    autorest.Response `json:"-"`
    // Status - READ-ONLY; The status of the test operation.
    Status *string `json:"status,omitempty"`
    // Error - READ-ONLY; Describes the error that occurred.
    Error *ErrorResponse `json:"error,omitempty"`
}

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

type ScalarFunctionConfiguration Uses

type ScalarFunctionConfiguration struct {
    // Inputs - A list of inputs describing the parameters of the function.
    Inputs *[]FunctionInput `json:"inputs,omitempty"`
    // Output - The output of the function.
    Output *FunctionOutput `json:"output,omitempty"`
    // Binding - The physical binding of the function. For example, in the Azure Machine Learning web service’s case, this describes the endpoint.
    Binding BasicFunctionBinding `json:"binding,omitempty"`
}

ScalarFunctionConfiguration describes the configuration of the scalar function.

func (*ScalarFunctionConfiguration) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for ScalarFunctionConfiguration struct.

type ScalarFunctionProperties Uses

type ScalarFunctionProperties struct {
    // ScalarFunctionConfiguration - Describes the configuration of the scalar function.
    *ScalarFunctionConfiguration `json:"properties,omitempty"`
    // Etag - READ-ONLY; The current entity tag for the function. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
    // Type - Possible values include: 'TypeFunctionProperties', 'TypeScalar'
    Type TypeBasicFunctionProperties `json:"type,omitempty"`
}

ScalarFunctionProperties the properties that are associated with a scalar function.

func (ScalarFunctionProperties) AsBasicFunctionProperties Uses

func (sfp ScalarFunctionProperties) AsBasicFunctionProperties() (BasicFunctionProperties, bool)

AsBasicFunctionProperties is the BasicFunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) AsFunctionProperties Uses

func (sfp ScalarFunctionProperties) AsFunctionProperties() (*FunctionProperties, bool)

AsFunctionProperties is the BasicFunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) AsScalarFunctionProperties Uses

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

AsScalarFunctionProperties is the BasicFunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for ScalarFunctionProperties.

func (*ScalarFunctionProperties) UnmarshalJSON Uses

func (sfp *ScalarFunctionProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ScalarFunctionProperties struct.

type Serialization Uses

type Serialization struct {
    // Type - Possible values include: 'TypeSerialization', 'TypeAvro', 'TypeJSON', 'TypeCsv'
    Type Type `json:"type,omitempty"`
}

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

func (Serialization) AsAvroSerialization Uses

func (s Serialization) AsAvroSerialization() (*AvroSerialization, bool)

AsAvroSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsBasicSerialization Uses

func (s Serialization) AsBasicSerialization() (BasicSerialization, bool)

AsBasicSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsCsvSerialization Uses

func (s Serialization) AsCsvSerialization() (*CsvSerialization, bool)

AsCsvSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsJSONSerialization Uses

func (s Serialization) AsJSONSerialization() (*JSONSerialization, bool)

AsJSONSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsSerialization Uses

func (s Serialization) AsSerialization() (*Serialization, bool)

AsSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) MarshalJSON Uses

func (s Serialization) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Serialization.

type ServiceBusDataSourceProperties Uses

type ServiceBusDataSourceProperties struct {
    // ServiceBusNamespace - The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    ServiceBusNamespace *string `json:"serviceBusNamespace,omitempty"`
    // SharedAccessPolicyName - The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
    // SharedAccessPolicyKey - The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyKey *string `json:"sharedAccessPolicyKey,omitempty"`
}

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

type ServiceBusQueueOutputDataSource Uses

type ServiceBusQueueOutputDataSource struct {
    // ServiceBusQueueOutputDataSourceProperties - The properties that are associated with a Service Bus Queue output. Required on PUT (CreateOrReplace) requests.
    *ServiceBusQueueOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

ServiceBusQueueOutputDataSource describes a Service Bus Queue output data source.

func (ServiceBusQueueOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsBasicOutputDataSource Uses

func (sbqods ServiceBusQueueOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsOutputDataSource Uses

func (sbqods ServiceBusQueueOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for ServiceBusQueueOutputDataSource.

func (*ServiceBusQueueOutputDataSource) UnmarshalJSON Uses

func (sbqods *ServiceBusQueueOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ServiceBusQueueOutputDataSource struct.

type ServiceBusQueueOutputDataSourceProperties Uses

type ServiceBusQueueOutputDataSourceProperties struct {
    // QueueName - The name of the Service Bus Queue. Required on PUT (CreateOrReplace) requests.
    QueueName *string `json:"queueName,omitempty"`
    // PropertyColumns - A string array of the names of output columns to be attached to Service Bus messages as custom properties.
    PropertyColumns *[]string `json:"propertyColumns,omitempty"`
    // ServiceBusNamespace - The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    ServiceBusNamespace *string `json:"serviceBusNamespace,omitempty"`
    // SharedAccessPolicyName - The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
    // SharedAccessPolicyKey - The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyKey *string `json:"sharedAccessPolicyKey,omitempty"`
}

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

type ServiceBusTopicOutputDataSource Uses

type ServiceBusTopicOutputDataSource struct {
    // ServiceBusTopicOutputDataSourceProperties - The properties that are associated with a Service Bus Topic output. Required on PUT (CreateOrReplace) requests.
    *ServiceBusTopicOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', 'TypeMicrosoftDataLakeAccounts', 'TypePowerBI', 'TypeMicrosoftServiceBusTopic', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftStorageTable', 'TypeMicrosoftStorageBlob'
    Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

ServiceBusTopicOutputDataSource describes a Service Bus Topic output data source.

func (ServiceBusTopicOutputDataSource) AsAzureDataLakeStoreOutputDataSource Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsBasicOutputDataSource Uses

func (sbtods ServiceBusTopicOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsOutputDataSource Uses

func (sbtods ServiceBusTopicOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for ServiceBusTopicOutputDataSource.

func (*ServiceBusTopicOutputDataSource) UnmarshalJSON Uses

func (sbtods *ServiceBusTopicOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ServiceBusTopicOutputDataSource struct.

type ServiceBusTopicOutputDataSourceProperties Uses

type ServiceBusTopicOutputDataSourceProperties struct {
    // TopicName - The name of the Service Bus Topic. Required on PUT (CreateOrReplace) requests.
    TopicName *string `json:"topicName,omitempty"`
    // PropertyColumns - A string array of the names of output columns to be attached to Service Bus messages as custom properties.
    PropertyColumns *[]string `json:"propertyColumns,omitempty"`
    // ServiceBusNamespace - The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    ServiceBusNamespace *string `json:"serviceBusNamespace,omitempty"`
    // SharedAccessPolicyName - The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
    // SharedAccessPolicyKey - The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
    SharedAccessPolicyKey *string `json:"sharedAccessPolicyKey,omitempty"`
}

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

type Sku Uses

type Sku struct {
    // Name - The name of the SKU. Required on PUT (CreateOrReplace) requests. Possible values include: 'Standard'
    Name SkuName `json:"name,omitempty"`
}

Sku the properties that are associated with a SKU.

type SkuName Uses

type SkuName string

SkuName enumerates the values for sku name.

const (
    // Standard ...
    Standard SkuName = "Standard"
)

func PossibleSkuNameValues Uses

func PossibleSkuNameValues() []SkuName

PossibleSkuNameValues returns an array of possible values for the SkuName const type.

type StartStreamingJobParameters Uses

type StartStreamingJobParameters struct {
    // OutputStartMode - Value may be JobStartTime, CustomTime, or LastOutputEventTime to indicate whether the starting point of the output event stream should start whenever the job is started, start at a custom user time stamp specified via the outputStartTime property, or start from the last event output time. Possible values include: 'JobStartTime', 'CustomTime', 'LastOutputEventTime'
    OutputStartMode OutputStartMode `json:"outputStartMode,omitempty"`
    // OutputStartTime - Value is either an ISO-8601 formatted time stamp that indicates the starting point of the output event stream, or null to indicate that the output event stream will start whenever the streaming job is started. This property must have a value if outputStartMode is set to CustomTime.
    OutputStartTime *date.Time `json:"outputStartTime,omitempty"`
}

StartStreamingJobParameters parameters supplied to the Start Streaming Job operation.

type StorageAccount Uses

type StorageAccount struct {
    // AccountName - The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.
    AccountName *string `json:"accountName,omitempty"`
    // AccountKey - The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.
    AccountKey *string `json:"accountKey,omitempty"`
}

StorageAccount the properties that are associated with an Azure Storage account

type StreamInputDataSource Uses

type StreamInputDataSource struct {
    // Type - Possible values include: 'TypeBasicStreamInputDataSourceTypeStreamInputDataSource', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob'
    Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

StreamInputDataSource describes an input data source that contains stream data.

func (StreamInputDataSource) AsBasicStreamInputDataSource Uses

func (sids StreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool)

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsBlobStreamInputDataSource Uses

func (sids StreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool)

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsEventHubStreamInputDataSource Uses

func (sids StreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool)

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsIoTHubStreamInputDataSource Uses

func (sids StreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool)

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsStreamInputDataSource Uses

func (sids StreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool)

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) MarshalJSON Uses

func (sids StreamInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for StreamInputDataSource.

type StreamInputProperties Uses

type StreamInputProperties struct {
    // Datasource - Describes an input data source that contains stream data. Required on PUT (CreateOrReplace) requests.
    Datasource BasicStreamInputDataSource `json:"datasource,omitempty"`
    // Serialization - Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.
    Serialization BasicSerialization `json:"serialization,omitempty"`
    // Diagnostics - READ-ONLY; Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention.
    Diagnostics *Diagnostics `json:"diagnostics,omitempty"`
    // Etag - READ-ONLY; The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
    // Type - Possible values include: 'TypeInputProperties', 'TypeReference', 'TypeStream'
    Type TypeBasicInputProperties `json:"type,omitempty"`
}

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

func (StreamInputProperties) AsBasicInputProperties Uses

func (sip StreamInputProperties) AsBasicInputProperties() (BasicInputProperties, bool)

AsBasicInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) AsInputProperties Uses

func (sip StreamInputProperties) AsInputProperties() (*InputProperties, bool)

AsInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) AsReferenceInputProperties Uses

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

AsReferenceInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) AsStreamInputProperties Uses

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

AsStreamInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for StreamInputProperties.

func (*StreamInputProperties) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for StreamInputProperties struct.

type StreamingJob Uses

type StreamingJob struct {
    autorest.Response `json:"-"`
    // StreamingJobProperties - The properties that are associated with a streaming job.  Required on PUT (CreateOrReplace) requests.
    *StreamingJobProperties `json:"properties,omitempty"`
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - READ-ONLY; Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
    // Location - Resource location. Required on PUT (CreateOrReplace) requests.
    Location *string `json:"location,omitempty"`
    // Tags - Resource tags
    Tags map[string]*string `json:"tags"`
}

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

func (StreamingJob) MarshalJSON Uses

func (sj StreamingJob) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for StreamingJob.

func (*StreamingJob) UnmarshalJSON Uses

func (sj *StreamingJob) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for StreamingJob struct.

type StreamingJobListResult Uses

type StreamingJobListResult struct {
    autorest.Response `json:"-"`
    // Value - READ-ONLY; A list of streaming jobs. Populated by a 'List' operation.
    Value *[]StreamingJob `json:"value,omitempty"`
    // NextLink - READ-ONLY; The link (url) to the next page of results.
    NextLink *string `json:"nextLink,omitempty"`
}

StreamingJobListResult object containing a list of streaming jobs.

func (StreamingJobListResult) IsEmpty Uses

func (sjlr StreamingJobListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type StreamingJobListResultIterator Uses

type StreamingJobListResultIterator struct {
    // contains filtered or unexported fields
}

StreamingJobListResultIterator provides access to a complete listing of StreamingJob values.

func NewStreamingJobListResultIterator Uses

func NewStreamingJobListResultIterator(page StreamingJobListResultPage) StreamingJobListResultIterator

Creates a new instance of the StreamingJobListResultIterator type.

func (*StreamingJobListResultIterator) Next Uses

func (iter *StreamingJobListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*StreamingJobListResultIterator) NextWithContext Uses

func (iter *StreamingJobListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (StreamingJobListResultIterator) NotDone Uses

func (iter StreamingJobListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (StreamingJobListResultIterator) Response Uses

func (iter StreamingJobListResultIterator) Response() StreamingJobListResult

Response returns the raw server response from the last page request.

func (StreamingJobListResultIterator) Value Uses

func (iter StreamingJobListResultIterator) Value() StreamingJob

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type StreamingJobListResultPage Uses

type StreamingJobListResultPage struct {
    // contains filtered or unexported fields
}

StreamingJobListResultPage contains a page of StreamingJob values.

func NewStreamingJobListResultPage Uses

func NewStreamingJobListResultPage(getNextPage func(context.Context, StreamingJobListResult) (StreamingJobListResult, error)) StreamingJobListResultPage

Creates a new instance of the StreamingJobListResultPage type.

func (*StreamingJobListResultPage) Next Uses

func (page *StreamingJobListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*StreamingJobListResultPage) NextWithContext Uses

func (page *StreamingJobListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (StreamingJobListResultPage) NotDone Uses

func (page StreamingJobListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (StreamingJobListResultPage) Response Uses

func (page StreamingJobListResultPage) Response() StreamingJobListResult

Response returns the raw server response from the last page request.

func (StreamingJobListResultPage) Values Uses

func (page StreamingJobListResultPage) Values() []StreamingJob

Values returns the slice of values for the current page or nil if there are no values.

type StreamingJobProperties Uses

type StreamingJobProperties struct {
    // Sku - Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.
    Sku *Sku `json:"sku,omitempty"`
    // JobID - READ-ONLY; A GUID uniquely identifying the streaming job. This GUID is generated upon creation of the streaming job.
    JobID *string `json:"jobId,omitempty"`
    // ProvisioningState - READ-ONLY; Describes the provisioning status of the streaming job.
    ProvisioningState *string `json:"provisioningState,omitempty"`
    // JobState - READ-ONLY; Describes the state of the streaming job.
    JobState *string `json:"jobState,omitempty"`
    // OutputStartMode - This property should only be utilized when it is desired that the job be started immediately upon creation. Value may be JobStartTime, CustomTime, or LastOutputEventTime to indicate whether the starting point of the output event stream should start whenever the job is started, start at a custom user time stamp specified via the outputStartTime property, or start from the last event output time. Possible values include: 'JobStartTime', 'CustomTime', 'LastOutputEventTime'
    OutputStartMode OutputStartMode `json:"outputStartMode,omitempty"`
    // OutputStartTime - Value is either an ISO-8601 formatted time stamp that indicates the starting point of the output event stream, or null to indicate that the output event stream will start whenever the streaming job is started. This property must have a value if outputStartMode is set to CustomTime.
    OutputStartTime *date.Time `json:"outputStartTime,omitempty"`
    // LastOutputEventTime - READ-ONLY; Value is either an ISO-8601 formatted timestamp indicating the last output event time of the streaming job or null indicating that output has not yet been produced. In case of multiple outputs or multiple streams, this shows the latest value in that set.
    LastOutputEventTime *date.Time `json:"lastOutputEventTime,omitempty"`
    // EventsOutOfOrderPolicy - Indicates the policy to apply to events that arrive out of order in the input event stream. Possible values include: 'Adjust', 'Drop'
    EventsOutOfOrderPolicy EventsOutOfOrderPolicy `json:"eventsOutOfOrderPolicy,omitempty"`
    // OutputErrorPolicy - Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size). Possible values include: 'OutputErrorPolicyStop', 'OutputErrorPolicyDrop'
    OutputErrorPolicy OutputErrorPolicy `json:"outputErrorPolicy,omitempty"`
    // EventsOutOfOrderMaxDelayInSeconds - The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
    EventsOutOfOrderMaxDelayInSeconds *int32 `json:"eventsOutOfOrderMaxDelayInSeconds,omitempty"`
    // EventsLateArrivalMaxDelayInSeconds - The maximum tolerable delay in seconds where events arriving late could be included.  Supported range is -1 to 1814399 (20.23:59:59 days) and -1 is used to specify wait indefinitely. If the property is absent, it is interpreted to have a value of -1.
    EventsLateArrivalMaxDelayInSeconds *int32 `json:"eventsLateArrivalMaxDelayInSeconds,omitempty"`
    // DataLocale - The data locale of the stream analytics job. Value should be the name of a supported .NET Culture from the set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Defaults to 'en-US' if none specified.
    DataLocale *string `json:"dataLocale,omitempty"`
    // CompatibilityLevel - Controls certain runtime behaviors of the streaming job. Possible values include: 'OneFullStopZero'
    CompatibilityLevel CompatibilityLevel `json:"compatibilityLevel,omitempty"`
    // CreatedDate - READ-ONLY; Value is an ISO-8601 formatted UTC timestamp indicating when the streaming job was created.
    CreatedDate *date.Time `json:"createdDate,omitempty"`
    // Inputs - A list of one or more inputs to the streaming job. The name property for each input is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual input.
    Inputs *[]Input `json:"inputs,omitempty"`
    // Transformation - Indicates the query and the number of streaming units to use for the streaming job. The name property of the transformation is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.
    Transformation *Transformation `json:"transformation,omitempty"`
    // Outputs - A list of one or more outputs for the streaming job. The name property for each output is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual output.
    Outputs *[]Output `json:"outputs,omitempty"`
    // Functions - A list of one or more functions for the streaming job. The name property for each function is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.
    Functions *[]Function `json:"functions,omitempty"`
    // Etag - READ-ONLY; The current entity tag for the streaming job. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
}

StreamingJobProperties the properties that are associated with a streaming job.

type StreamingJobsClient Uses

type StreamingJobsClient struct {
    BaseClient
}

StreamingJobsClient is the stream Analytics Client

func NewStreamingJobsClient Uses

func NewStreamingJobsClient(subscriptionID string) StreamingJobsClient

NewStreamingJobsClient creates an instance of the StreamingJobsClient client.

func NewStreamingJobsClientWithBaseURI Uses

func NewStreamingJobsClientWithBaseURI(baseURI string, subscriptionID string) StreamingJobsClient

NewStreamingJobsClientWithBaseURI creates an instance of the StreamingJobsClient client.

func (StreamingJobsClient) CreateOrReplace Uses

func (client StreamingJobsClient) CreateOrReplace(ctx context.Context, streamingJob StreamingJob, resourceGroupName string, jobName string, ifMatch string, ifNoneMatch string) (result StreamingJobsCreateOrReplaceFuture, err error)

CreateOrReplace creates a streaming job or replaces an already existing streaming job. Parameters: streamingJob - the definition of the streaming job that will be used to create a new streaming job or replace the existing one. resourceGroupName - 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 - the name of the streaming job. ifMatch - 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 overwriting concurrent changes. ifNoneMatch - 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 Uses

func (client StreamingJobsClient) CreateOrReplacePreparer(ctx context.Context, streamingJob StreamingJob, resourceGroupName string, jobName string, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (StreamingJobsClient) CreateOrReplaceResponder Uses

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 Uses

func (client StreamingJobsClient) CreateOrReplaceSender(req *http.Request) (future StreamingJobsCreateOrReplaceFuture, err error)

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

func (StreamingJobsClient) Delete Uses

func (client StreamingJobsClient) Delete(ctx context.Context, resourceGroupName string, jobName string) (result StreamingJobsDeleteFuture, err error)

Delete deletes a streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job.

func (StreamingJobsClient) DeletePreparer Uses

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

DeletePreparer prepares the Delete request.

func (StreamingJobsClient) DeleteResponder Uses

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 Uses

func (client StreamingJobsClient) DeleteSender(req *http.Request) (future StreamingJobsDeleteFuture, err error)

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

func (StreamingJobsClient) Get Uses

func (client StreamingJobsClient) Get(ctx context.Context, resourceGroupName string, jobName string, expand string) (result StreamingJob, err error)

Get gets details about the specified streaming job. Parameters: resourceGroupName - 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 - the name of the streaming job. expand - 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 Uses

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

GetPreparer prepares the Get request.

func (StreamingJobsClient) GetResponder Uses

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 Uses

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 Uses

func (client StreamingJobsClient) List(ctx context.Context, expand string) (result StreamingJobListResultPage, err error)

List lists all of the streaming jobs in the given subscription. Parameters: expand - 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 Uses

func (client StreamingJobsClient) ListByResourceGroup(ctx context.Context, resourceGroupName string, expand string) (result StreamingJobListResultPage, err error)

ListByResourceGroup lists all of the streaming jobs in the specified resource group. Parameters: resourceGroupName - 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 - 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 Uses

func (client StreamingJobsClient) ListByResourceGroupComplete(ctx context.Context, resourceGroupName string, expand string) (result StreamingJobListResultIterator, err error)

ListByResourceGroupComplete enumerates all values, automatically crossing page boundaries as required.

func (StreamingJobsClient) ListByResourceGroupPreparer Uses

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

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (StreamingJobsClient) ListByResourceGroupResponder Uses

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 Uses

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 Uses

func (client StreamingJobsClient) ListComplete(ctx context.Context, expand string) (result StreamingJobListResultIterator, err error)

ListComplete enumerates all values, automatically crossing page boundaries as required.

func (StreamingJobsClient) ListPreparer Uses

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

ListPreparer prepares the List request.

func (StreamingJobsClient) ListResponder Uses

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 Uses

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 Uses

func (client StreamingJobsClient) Start(ctx context.Context, resourceGroupName string, jobName string, startJobParameters *StartStreamingJobParameters) (result StreamingJobsStartFuture, err error)

Start starts a streaming job. Once a job is started it will start processing input events and produce output. Parameters: resourceGroupName - 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 - the name of the streaming job. startJobParameters - parameters applicable to a start streaming job operation.

func (StreamingJobsClient) StartPreparer Uses

func (client StreamingJobsClient) StartPreparer(ctx context.Context, resourceGroupName string, jobName string, startJobParameters *StartStreamingJobParameters) (*http.Request, error)

StartPreparer prepares the Start request.

func (StreamingJobsClient) StartResponder Uses

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 Uses

func (client StreamingJobsClient) StartSender(req *http.Request) (future StreamingJobsStartFuture, err error)

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

func (StreamingJobsClient) Stop Uses

func (client StreamingJobsClient) Stop(ctx context.Context, resourceGroupName string, jobName string) (result StreamingJobsStopFuture, err error)

Stop stops a running streaming job. This will cause a running streaming job to stop processing input events and producing output. Parameters: resourceGroupName - 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 - the name of the streaming job.

func (StreamingJobsClient) StopPreparer Uses

func (client StreamingJobsClient) StopPreparer(ctx context.Context, resourceGroupName string, jobName string) (*http.Request, error)

StopPreparer prepares the Stop request.

func (StreamingJobsClient) StopResponder Uses

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 Uses

func (client StreamingJobsClient) StopSender(req *http.Request) (future StreamingJobsStopFuture, err error)

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

func (StreamingJobsClient) Update Uses

func (client StreamingJobsClient) Update(ctx context.Context, 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. Parameters: streamingJob - 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 - 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 - the name of the streaming job. ifMatch - 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 overwriting concurrent changes.

func (StreamingJobsClient) UpdatePreparer Uses

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

UpdatePreparer prepares the Update request.

func (StreamingJobsClient) UpdateResponder Uses

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 Uses

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 StreamingJobsCreateOrReplaceFuture Uses

type StreamingJobsCreateOrReplaceFuture struct {
    azure.Future
}

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

func (*StreamingJobsCreateOrReplaceFuture) Result Uses

func (future *StreamingJobsCreateOrReplaceFuture) Result(client StreamingJobsClient) (sj StreamingJob, err error)

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

type StreamingJobsDeleteFuture Uses

type StreamingJobsDeleteFuture struct {
    azure.Future
}

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

func (*StreamingJobsDeleteFuture) Result Uses

func (future *StreamingJobsDeleteFuture) Result(client StreamingJobsClient) (ar autorest.Response, err error)

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

type StreamingJobsStartFuture Uses

type StreamingJobsStartFuture struct {
    azure.Future
}

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

func (*StreamingJobsStartFuture) Result Uses

func (future *StreamingJobsStartFuture) Result(client StreamingJobsClient) (ar autorest.Response, err error)

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

type StreamingJobsStopFuture Uses

type StreamingJobsStopFuture struct {
    azure.Future
}

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

func (*StreamingJobsStopFuture) Result Uses

func (future *StreamingJobsStopFuture) Result(client StreamingJobsClient) (ar autorest.Response, err error)

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

type SubResource Uses

type SubResource struct {
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
}

SubResource the base sub-resource model definition.

type SubscriptionQuota Uses

type SubscriptionQuota struct {
    // SubscriptionQuotaProperties - READ-ONLY; Describes the properties of the quota.
    *SubscriptionQuotaProperties `json:"properties,omitempty"`
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
}

SubscriptionQuota describes the current quota for the subscription.

func (SubscriptionQuota) MarshalJSON Uses

func (sq SubscriptionQuota) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SubscriptionQuota.

func (*SubscriptionQuota) UnmarshalJSON Uses

func (sq *SubscriptionQuota) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for SubscriptionQuota struct.

type SubscriptionQuotaProperties Uses

type SubscriptionQuotaProperties struct {
    // MaxCount - READ-ONLY; The max permitted usage of this resource.
    MaxCount *int32 `json:"maxCount,omitempty"`
    // CurrentCount - READ-ONLY; The current usage of this resource.
    CurrentCount *int32 `json:"currentCount,omitempty"`
}

SubscriptionQuotaProperties describes the properties of the quota.

type SubscriptionQuotasListResult Uses

type SubscriptionQuotasListResult struct {
    autorest.Response `json:"-"`
    // Value - READ-ONLY; List of quotas for the subscription in a particular region.
    Value *[]SubscriptionQuota `json:"value,omitempty"`
}

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

type SubscriptionsClient Uses

type SubscriptionsClient struct {
    BaseClient
}

SubscriptionsClient is the stream Analytics Client

func NewSubscriptionsClient Uses

func NewSubscriptionsClient(subscriptionID string) SubscriptionsClient

NewSubscriptionsClient creates an instance of the SubscriptionsClient client.

func NewSubscriptionsClientWithBaseURI Uses

func NewSubscriptionsClientWithBaseURI(baseURI string, subscriptionID string) SubscriptionsClient

NewSubscriptionsClientWithBaseURI creates an instance of the SubscriptionsClient client.

func (SubscriptionsClient) ListQuotas Uses

func (client SubscriptionsClient) ListQuotas(ctx context.Context, location string) (result SubscriptionQuotasListResult, err error)

ListQuotas retrieves the subscription's current quota information in a particular region. Parameters: location - 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 Uses

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

ListQuotasPreparer prepares the ListQuotas request.

func (SubscriptionsClient) ListQuotasResponder Uses

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 Uses

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 Uses

type Transformation struct {
    autorest.Response `json:"-"`
    // TransformationProperties - The properties that are associated with a transformation. Required on PUT (CreateOrReplace) requests.
    *TransformationProperties `json:"properties,omitempty"`
    // ID - READ-ONLY; Resource Id
    ID  *string `json:"id,omitempty"`
    // Name - Resource name
    Name *string `json:"name,omitempty"`
    // Type - READ-ONLY; Resource type
    Type *string `json:"type,omitempty"`
}

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

func (Transformation) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for Transformation.

func (*Transformation) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for Transformation struct.

type TransformationProperties Uses

type TransformationProperties struct {
    // StreamingUnits - Specifies the number of streaming units that the streaming job uses.
    StreamingUnits *int32 `json:"streamingUnits,omitempty"`
    // Query - Specifies the query that will be run in the streaming job. You can learn more about the Stream Analytics Query Language (SAQL) here: https://msdn.microsoft.com/library/azure/dn834998 . Required on PUT (CreateOrReplace) requests.
    Query *string `json:"query,omitempty"`
    // Etag - READ-ONLY; The current entity tag for the transformation. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag *string `json:"etag,omitempty"`
}

TransformationProperties the properties that are associated with a transformation.

type TransformationsClient Uses

type TransformationsClient struct {
    BaseClient
}

TransformationsClient is the stream Analytics Client

func NewTransformationsClient Uses

func NewTransformationsClient(subscriptionID string) TransformationsClient

NewTransformationsClient creates an instance of the TransformationsClient client.

func NewTransformationsClientWithBaseURI Uses

func NewTransformationsClientWithBaseURI(baseURI string, subscriptionID string) TransformationsClient

NewTransformationsClientWithBaseURI creates an instance of the TransformationsClient client.

func (TransformationsClient) CreateOrReplace Uses

func (client TransformationsClient) CreateOrReplace(ctx context.Context, 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. Parameters: transformation - the definition of the transformation that will be used to create a new transformation or replace the existing one under the streaming job. resourceGroupName - 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 - the name of the streaming job. transformationName - the name of the transformation. ifMatch - the ETag of the transformation. Omit this value to always overwrite the current transformation. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes. ifNoneMatch - 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 Uses

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

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (TransformationsClient) CreateOrReplaceResponder Uses

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 Uses

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 Uses

func (client TransformationsClient) Get(ctx context.Context, resourceGroupName string, jobName string, transformationName string) (result Transformation, err error)

Get gets details about the specified transformation. Parameters: resourceGroupName - 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 - the name of the streaming job. transformationName - the name of the transformation.

func (TransformationsClient) GetPreparer Uses

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

GetPreparer prepares the Get request.

func (TransformationsClient) GetResponder Uses

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 Uses

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 Uses

func (client TransformationsClient) Update(ctx context.Context, 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. Parameters: transformation - 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 - 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 - the name of the streaming job. transformationName - the name of the transformation. ifMatch - the ETag of the transformation. Omit this value to always overwrite the current transformation. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.

func (TransformationsClient) UpdatePreparer Uses

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

UpdatePreparer prepares the Update request.

func (TransformationsClient) UpdateResponder Uses

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 Uses

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 Uses

type Type string

Type enumerates the values for type.

const (
    // TypeAvro ...
    TypeAvro Type = "Avro"
    // TypeCsv ...
    TypeCsv Type = "Csv"
    // TypeJSON ...
    TypeJSON Type = "Json"
    // TypeSerialization ...
    TypeSerialization Type = "Serialization"
)

func PossibleTypeValues Uses

func PossibleTypeValues() []Type

PossibleTypeValues returns an array of possible values for the Type const type.

type TypeBasicFunctionBinding Uses

type TypeBasicFunctionBinding string

TypeBasicFunctionBinding enumerates the values for type basic function binding.

const (
    // TypeFunctionBinding ...
    TypeFunctionBinding TypeBasicFunctionBinding = "FunctionBinding"
    // TypeMicrosoftMachineLearningWebService ...
    TypeMicrosoftMachineLearningWebService TypeBasicFunctionBinding = "Microsoft.MachineLearning/WebService"
    // TypeMicrosoftStreamAnalyticsJavascriptUdf ...
    TypeMicrosoftStreamAnalyticsJavascriptUdf TypeBasicFunctionBinding = "Microsoft.StreamAnalytics/JavascriptUdf"
)

func PossibleTypeBasicFunctionBindingValues Uses

func PossibleTypeBasicFunctionBindingValues() []TypeBasicFunctionBinding

PossibleTypeBasicFunctionBindingValues returns an array of possible values for the TypeBasicFunctionBinding const type.

type TypeBasicFunctionProperties Uses

type TypeBasicFunctionProperties string

TypeBasicFunctionProperties enumerates the values for type basic function properties.

const (
    // TypeFunctionProperties ...
    TypeFunctionProperties TypeBasicFunctionProperties = "FunctionProperties"
    // TypeScalar ...
    TypeScalar TypeBasicFunctionProperties = "Scalar"
)

func PossibleTypeBasicFunctionPropertiesValues Uses

func PossibleTypeBasicFunctionPropertiesValues() []TypeBasicFunctionProperties

PossibleTypeBasicFunctionPropertiesValues returns an array of possible values for the TypeBasicFunctionProperties const type.

type TypeBasicInputProperties Uses

type TypeBasicInputProperties string

TypeBasicInputProperties enumerates the values for type basic input properties.

const (
    // TypeInputProperties ...
    TypeInputProperties TypeBasicInputProperties = "InputProperties"
    // TypeReference ...
    TypeReference TypeBasicInputProperties = "Reference"
    // TypeStream ...
    TypeStream TypeBasicInputProperties = "Stream"
)

func PossibleTypeBasicInputPropertiesValues Uses

func PossibleTypeBasicInputPropertiesValues() []TypeBasicInputProperties

PossibleTypeBasicInputPropertiesValues returns an array of possible values for the TypeBasicInputProperties const type.

type TypeBasicOutputDataSource Uses

type TypeBasicOutputDataSource string

TypeBasicOutputDataSource enumerates the values for type basic output data source.

const (
    // TypeMicrosoftDataLakeAccounts ...
    TypeMicrosoftDataLakeAccounts TypeBasicOutputDataSource = "Microsoft.DataLake/Accounts"
    // TypeMicrosoftServiceBusEventHub ...
    TypeMicrosoftServiceBusEventHub TypeBasicOutputDataSource = "Microsoft.ServiceBus/EventHub"
    // TypeMicrosoftServiceBusQueue ...
    TypeMicrosoftServiceBusQueue TypeBasicOutputDataSource = "Microsoft.ServiceBus/Queue"
    // TypeMicrosoftServiceBusTopic ...
    TypeMicrosoftServiceBusTopic TypeBasicOutputDataSource = "Microsoft.ServiceBus/Topic"
    // TypeMicrosoftSQLServerDatabase ...
    TypeMicrosoftSQLServerDatabase TypeBasicOutputDataSource = "Microsoft.Sql/Server/Database"
    // TypeMicrosoftStorageBlob ...
    TypeMicrosoftStorageBlob TypeBasicOutputDataSource = "Microsoft.Storage/Blob"
    // TypeMicrosoftStorageDocumentDB ...
    TypeMicrosoftStorageDocumentDB TypeBasicOutputDataSource = "Microsoft.Storage/DocumentDB"
    // TypeMicrosoftStorageTable ...
    TypeMicrosoftStorageTable TypeBasicOutputDataSource = "Microsoft.Storage/Table"
    // TypeOutputDataSource ...
    TypeOutputDataSource TypeBasicOutputDataSource = "OutputDataSource"
    // TypePowerBI ...
    TypePowerBI TypeBasicOutputDataSource = "PowerBI"
)

func PossibleTypeBasicOutputDataSourceValues Uses

func PossibleTypeBasicOutputDataSourceValues() []TypeBasicOutputDataSource

PossibleTypeBasicOutputDataSourceValues returns an array of possible values for the TypeBasicOutputDataSource const type.

type TypeBasicReferenceInputDataSource Uses

type TypeBasicReferenceInputDataSource string

TypeBasicReferenceInputDataSource enumerates the values for type basic reference input data source.

const (
    // TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob ...
    TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob TypeBasicReferenceInputDataSource = "Microsoft.Storage/Blob"
    // TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource ...
    TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource TypeBasicReferenceInputDataSource = "ReferenceInputDataSource"
)

func PossibleTypeBasicReferenceInputDataSourceValues Uses

func PossibleTypeBasicReferenceInputDataSourceValues() []TypeBasicReferenceInputDataSource

PossibleTypeBasicReferenceInputDataSourceValues returns an array of possible values for the TypeBasicReferenceInputDataSource const type.

type TypeBasicStreamInputDataSource Uses

type TypeBasicStreamInputDataSource string

TypeBasicStreamInputDataSource enumerates the values for type basic stream input data source.

const (
    // TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs ...
    TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs TypeBasicStreamInputDataSource = "Microsoft.Devices/IotHubs"
    // TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub ...
    TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub TypeBasicStreamInputDataSource = "Microsoft.ServiceBus/EventHub"
    // TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob ...
    TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob TypeBasicStreamInputDataSource = "Microsoft.Storage/Blob"
    // TypeBasicStreamInputDataSourceTypeStreamInputDataSource ...
    TypeBasicStreamInputDataSourceTypeStreamInputDataSource TypeBasicStreamInputDataSource = "StreamInputDataSource"
)

func PossibleTypeBasicStreamInputDataSourceValues Uses

func PossibleTypeBasicStreamInputDataSourceValues() []TypeBasicStreamInputDataSource

PossibleTypeBasicStreamInputDataSourceValues returns an array of possible values for the TypeBasicStreamInputDataSource const type.

type UdfType Uses

type UdfType string

UdfType enumerates the values for udf type.

const (
    // Scalar ...
    Scalar UdfType = "Scalar"
)

func PossibleUdfTypeValues Uses

func PossibleUdfTypeValues() []UdfType

PossibleUdfTypeValues returns an array of possible values for the UdfType const type.

Directories

PathSynopsis
streamanalyticsapi

Package streamanalytics imports 9 packages (graph) and is imported by 5 packages. Updated 2019-08-10. Refresh now. Tools for package owners.