streamanalytics

package
v67.2.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Deprecated: Please note, this package has been deprecated. A replacement package is available github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics(https://pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics). We strongly encourage you to upgrade to continue receiving updates. See [Migration Guide](https://aka.ms/azsdk/golang/t2/migration) for guidance on upgrading. Refer to our [deprecation policy](https://azure.github.io/azure-sdk/policies_support.html) for more details.

Package streamanalytics implements the Azure ARM Streamanalytics service API version .

Stream Analytics Client

Index

Constants

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

Variables

This section is empty.

Functions

func UserAgent 

func UserAgent() string

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

func Version 

func Version() string

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

Types

type AggregateFunctionProperties 

type AggregateFunctionProperties 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"`
	*FunctionConfiguration `json:"properties,omitempty"`
	// Type - Possible values include: 'TypeFunctionProperties', 'TypeScalar', 'TypeAggregate'
	Type TypeBasicFunctionProperties `json:"type,omitempty"`
}

AggregateFunctionProperties the properties that are associated with an aggregate function.

func (AggregateFunctionProperties) AsAggregateFunctionProperties 

func (afp AggregateFunctionProperties) AsAggregateFunctionProperties() (*AggregateFunctionProperties, bool)

AsAggregateFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) AsBasicFunctionProperties 

func (afp AggregateFunctionProperties) AsBasicFunctionProperties() (BasicFunctionProperties, bool)

AsBasicFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) AsFunctionProperties 

func (afp AggregateFunctionProperties) AsFunctionProperties() (*FunctionProperties, bool)

AsFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) AsScalarFunctionProperties 

func (afp AggregateFunctionProperties) AsScalarFunctionProperties() (*ScalarFunctionProperties, bool)

AsScalarFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) MarshalJSON 

func (afp AggregateFunctionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AggregateFunctionProperties.

func (*AggregateFunctionProperties) UnmarshalJSON 

func (afp *AggregateFunctionProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AggregateFunctionProperties struct.

type AuthenticationMode 

type AuthenticationMode string

AuthenticationMode enumerates the values for authentication mode. 

const (
	// ConnectionString ...
	ConnectionString AuthenticationMode = "ConnectionString"
	// Msi ...
	Msi AuthenticationMode = "Msi"
	// UserToken ...
	UserToken AuthenticationMode = "UserToken"
)

func PossibleAuthenticationModeValues 

func PossibleAuthenticationModeValues() []AuthenticationMode

PossibleAuthenticationModeValues returns an array of possible values for the AuthenticationMode const type.

type AvroSerialization 

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', 'TypeParquet', 'TypeCustomClr', 'TypeCsv', 'TypeJSON', 'TypeAvro'
	Type TypeBasicSerialization `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 

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

AsAvroSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsBasicSerialization 

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

AsBasicSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsCsvSerialization 

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

AsCsvSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsCustomClrSerialization 

func (as AvroSerialization) AsCustomClrSerialization() (*CustomClrSerialization, bool)

AsCustomClrSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsJSONSerialization 

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

AsJSONSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsParquetSerialization 

func (as AvroSerialization) AsParquetSerialization() (*ParquetSerialization, bool)

AsParquetSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsSerialization 

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

AsSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) MarshalJSON 

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

MarshalJSON is the custom marshaler for AvroSerialization.

type AzureDataLakeStoreOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

AzureDataLakeStoreOutputDataSource describes an Azure Data Lake Store output data source.

func (AzureDataLakeStoreOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureFunctionOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureSynapseOutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsEventHubV2OutputDataSource 

func (adlsods AzureDataLakeStoreOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for AzureDataLakeStoreOutputDataSource.

func (*AzureDataLakeStoreOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for AzureDataLakeStoreOutputDataSource struct.

type AzureDataLakeStoreOutputDataSourceProperties 

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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,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 AzureFunctionOutputDataSource 

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

AzureFunctionOutputDataSource defines the metadata of AzureFunctionOutputDataSource

func (AzureFunctionOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureFunctionOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureSynapseOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureTableOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsBasicOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsBlobOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsDocumentDbOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsEventHubOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsEventHubV2OutputDataSource 

func (afods AzureFunctionOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsPowerBIOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsServiceBusQueueOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsServiceBusTopicOutputDataSource 

func (afods AzureFunctionOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) MarshalJSON 

func (afods AzureFunctionOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureFunctionOutputDataSource.

func (*AzureFunctionOutputDataSource) UnmarshalJSON 

func (afods *AzureFunctionOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureFunctionOutputDataSource struct.

type AzureFunctionOutputDataSourceProperties 

type AzureFunctionOutputDataSourceProperties struct {
	// FunctionAppName - The name of your Azure Functions app.
	FunctionAppName *string `json:"functionAppName,omitempty"`
	// FunctionName - The name of the function in your Azure Functions app.
	FunctionName *string `json:"functionName,omitempty"`
	// APIKey - If you want to use an Azure Function from another subscription, you can do so by providing the key to access your function.
	APIKey *string `json:"apiKey,omitempty"`
	// MaxBatchSize - A property that lets you set the maximum size for each output batch that's sent to your Azure function. The input unit is in bytes. By default, this value is 262,144 bytes (256 KB).
	MaxBatchSize *float64 `json:"maxBatchSize,omitempty"`
	// MaxBatchCount - A property that lets you specify the maximum number of events in each batch that's sent to Azure Functions. The default value is 100.
	MaxBatchCount *float64 `json:"maxBatchCount,omitempty"`
}

AzureFunctionOutputDataSourceProperties the properties that are associated with a DocumentDB output.

type AzureMachineLearningServiceFunctionBinding 

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

AzureMachineLearningServiceFunctionBinding the binding to an Azure Machine Learning web service.

func (AzureMachineLearningServiceFunctionBinding) AsAzureMachineLearningServiceFunctionBinding 

func (amlsfb AzureMachineLearningServiceFunctionBinding) AsAzureMachineLearningServiceFunctionBinding() (*AzureMachineLearningServiceFunctionBinding, bool)

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsAzureMachineLearningStudioFunctionBinding 

func (amlsfb AzureMachineLearningServiceFunctionBinding) AsAzureMachineLearningStudioFunctionBinding() (*AzureMachineLearningStudioFunctionBinding, bool)

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsBasicFunctionBinding 

func (amlsfb AzureMachineLearningServiceFunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool)

AsBasicFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsCSharpFunctionBinding 

func (amlsfb AzureMachineLearningServiceFunctionBinding) AsCSharpFunctionBinding() (*CSharpFunctionBinding, bool)

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsFunctionBinding 

func (amlsfb AzureMachineLearningServiceFunctionBinding) AsFunctionBinding() (*FunctionBinding, bool)

AsFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsJavaScriptFunctionBinding 

func (amlsfb AzureMachineLearningServiceFunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) MarshalJSON 

func (amlsfb AzureMachineLearningServiceFunctionBinding) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureMachineLearningServiceFunctionBinding.

func (*AzureMachineLearningServiceFunctionBinding) UnmarshalJSON 

func (amlsfb *AzureMachineLearningServiceFunctionBinding) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningServiceFunctionBinding struct.

type AzureMachineLearningServiceFunctionBindingProperties 

type AzureMachineLearningServiceFunctionBindingProperties struct {
	// Endpoint - The Request-Response execute endpoint of the Azure Machine Learning web service.
	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 *[]AzureMachineLearningServiceInputColumn `json:"inputs,omitempty"`
	// Outputs - A list of outputs from the Azure Machine Learning web service endpoint execution.
	Outputs *[]AzureMachineLearningServiceOutputColumn `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"`
	// NumberOfParallelRequests - The number of parallel requests that will be sent per partition of your job to the machine learning service. Default is 1.
	NumberOfParallelRequests *int32 `json:"numberOfParallelRequests,omitempty"`
}

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

type AzureMachineLearningServiceFunctionBindingRetrievalProperties 

type AzureMachineLearningServiceFunctionBindingRetrievalProperties struct {
	// ExecuteEndpoint - The Request-Response execute endpoint of the Azure Machine Learning web service.
	ExecuteEndpoint *string `json:"executeEndpoint,omitempty"`
	// UdfType - The function type. Possible values include: 'Scalar'
	UdfType UdfType `json:"udfType,omitempty"`
}

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

type AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters 

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

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

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool)

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters() (*CSharpFunctionRetrieveDefaultDefinitionParameters, bool)

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool)

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON 

func (amlsfrddp AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON 

func (amlsfrddp *AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters struct.

type AzureMachineLearningServiceInputColumn 

type AzureMachineLearningServiceInputColumn 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.
	DataType *string `json:"dataType,omitempty"`
	// MapTo - The zero based index of the function parameter this input maps to.
	MapTo *int32 `json:"mapTo,omitempty"`
}

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

type AzureMachineLearningServiceInputs 

type AzureMachineLearningServiceInputs 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 *[]AzureMachineLearningServiceInputColumn `json:"columnNames,omitempty"`
}

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

type AzureMachineLearningServiceOutputColumn 

type AzureMachineLearningServiceOutputColumn 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.
	DataType *string `json:"dataType,omitempty"`
	// MapTo - The zero based index of the function parameter this input maps to.
	MapTo *int32 `json:"mapTo,omitempty"`
}

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

type AzureMachineLearningStudioFunctionBinding 

type AzureMachineLearningStudioFunctionBinding struct {
	// AzureMachineLearningStudioFunctionBindingProperties - The binding properties associated with an Azure Machine learning Studio.
	*AzureMachineLearningStudioFunctionBindingProperties `json:"properties,omitempty"`
	// Type - Possible values include: 'TypeFunctionBinding', 'TypeMicrosoftMachineLearningWebService', 'TypeMicrosoftStreamAnalyticsJavascriptUdf', 'TypeMicrosoftStreamAnalyticsCLRUdf', 'TypeMicrosoftMachineLearningServices'
	Type Type `json:"type,omitempty"`
}

AzureMachineLearningStudioFunctionBinding the binding to an Azure Machine Learning Studio.

func (AzureMachineLearningStudioFunctionBinding) AsAzureMachineLearningServiceFunctionBinding 

func (amlsfb AzureMachineLearningStudioFunctionBinding) AsAzureMachineLearningServiceFunctionBinding() (*AzureMachineLearningServiceFunctionBinding, bool)

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsAzureMachineLearningStudioFunctionBinding 

func (amlsfb AzureMachineLearningStudioFunctionBinding) AsAzureMachineLearningStudioFunctionBinding() (*AzureMachineLearningStudioFunctionBinding, bool)

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsBasicFunctionBinding 

func (amlsfb AzureMachineLearningStudioFunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool)

AsBasicFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsCSharpFunctionBinding 

func (amlsfb AzureMachineLearningStudioFunctionBinding) AsCSharpFunctionBinding() (*CSharpFunctionBinding, bool)

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsFunctionBinding 

func (amlsfb AzureMachineLearningStudioFunctionBinding) AsFunctionBinding() (*FunctionBinding, bool)

AsFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsJavaScriptFunctionBinding 

func (amlsfb AzureMachineLearningStudioFunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) MarshalJSON 

func (amlsfb AzureMachineLearningStudioFunctionBinding) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureMachineLearningStudioFunctionBinding.

func (*AzureMachineLearningStudioFunctionBinding) UnmarshalJSON 

func (amlsfb *AzureMachineLearningStudioFunctionBinding) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningStudioFunctionBinding struct.

type AzureMachineLearningStudioFunctionBindingProperties 

type AzureMachineLearningStudioFunctionBindingProperties struct {
	// Endpoint - The Request-Response execute endpoint of the Azure Machine Learning Studio. 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 Studio endpoint.
	Inputs *AzureMachineLearningStudioInputs `json:"inputs,omitempty"`
	// Outputs - A list of outputs from the Azure Machine Learning Studio endpoint execution.
	Outputs *[]AzureMachineLearningStudioOutputColumn `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"`
}

AzureMachineLearningStudioFunctionBindingProperties the binding properties associated with an Azure Machine learning Studio.

type AzureMachineLearningStudioFunctionBindingRetrievalProperties 

type AzureMachineLearningStudioFunctionBindingRetrievalProperties struct {
	// ExecuteEndpoint - The Request-Response execute endpoint of the Azure Machine Learning Studio. 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"`
}

AzureMachineLearningStudioFunctionBindingRetrievalProperties the binding retrieval properties associated with an Azure Machine learning Studio.

type AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters 

type AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters struct {
	// AzureMachineLearningStudioFunctionBindingRetrievalProperties - The binding retrieval properties associated with an Azure Machine learning Studio.
	*AzureMachineLearningStudioFunctionBindingRetrievalProperties `json:"bindingRetrievalProperties,omitempty"`
	// BindingType - Possible values include: 'BindingTypeFunctionRetrieveDefaultDefinitionParameters', 'BindingTypeMicrosoftMachineLearningWebService', 'BindingTypeMicrosoftMachineLearningServices', 'BindingTypeMicrosoftStreamAnalyticsJavascriptUdf', 'BindingTypeMicrosoftStreamAnalyticsCLRUdf'
	BindingType BindingType `json:"bindingType,omitempty"`
}

AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters the parameters needed to retrieve the default function definition for an Azure Machine Learning Studio function.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool)

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters() (*CSharpFunctionRetrieveDefaultDefinitionParameters, bool)

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool)

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters 

func (amlsfrddp AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) MarshalJSON 

func (amlsfrddp AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON 

func (amlsfrddp *AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters struct.

type AzureMachineLearningStudioInputColumn 

type AzureMachineLearningStudioInputColumn 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"`
}

AzureMachineLearningStudioInputColumn describes an input column for the Azure Machine Learning Studio endpoint.

type AzureMachineLearningStudioInputs 

type AzureMachineLearningStudioInputs 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 Studio endpoint.
	ColumnNames *[]AzureMachineLearningStudioInputColumn `json:"columnNames,omitempty"`
}

AzureMachineLearningStudioInputs the inputs for the Azure Machine Learning Studio endpoint.

type AzureMachineLearningStudioOutputColumn 

type AzureMachineLearningStudioOutputColumn 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"`
}

AzureMachineLearningStudioOutputColumn describes an output column for the Azure Machine Learning Studio endpoint.

type AzureSQLDatabaseDataSourceProperties 

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"`
	// MaxBatchCount - Max Batch count for write to Sql database, the default value is 10,000. Optional on PUT requests.
	MaxBatchCount *float64 `json:"maxBatchCount,omitempty"`
	// MaxWriterCount - Max Write r count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.
	MaxWriterCount *float64 `json:"maxWriterCount,omitempty"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

type AzureSQLDatabaseOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

AzureSQLDatabaseOutputDataSource describes an Azure SQL database output data source.

func (AzureSQLDatabaseOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureFunctionOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureSynapseOutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsEventHubV2OutputDataSource 

func (asdods AzureSQLDatabaseOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for AzureSQLDatabaseOutputDataSource.

func (*AzureSQLDatabaseOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for AzureSQLDatabaseOutputDataSource struct.

type AzureSQLDatabaseOutputDataSourceProperties 

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"`
	// MaxBatchCount - Max Batch count for write to Sql database, the default value is 10,000. Optional on PUT requests.
	MaxBatchCount *float64 `json:"maxBatchCount,omitempty"`
	// MaxWriterCount - Max Write r count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.
	MaxWriterCount *float64 `json:"maxWriterCount,omitempty"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

type AzureSQLReferenceInputDataSource 

type AzureSQLReferenceInputDataSource struct {
	Properties *AzureSQLReferenceInputDataSourceProperties `json:"properties,omitempty"`
	// Type - Possible values include: 'TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource', 'TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob', 'TypeBasicReferenceInputDataSourceTypeMicrosoftSQLServerDatabase'
	Type TypeBasicReferenceInputDataSource `json:"type,omitempty"`
}

AzureSQLReferenceInputDataSource describes an Azure SQL database reference input data source.

func (AzureSQLReferenceInputDataSource) AsAzureSQLReferenceInputDataSource 

func (asrids AzureSQLReferenceInputDataSource) AsAzureSQLReferenceInputDataSource() (*AzureSQLReferenceInputDataSource, bool)

AsAzureSQLReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) AsBasicReferenceInputDataSource 

func (asrids AzureSQLReferenceInputDataSource) AsBasicReferenceInputDataSource() (BasicReferenceInputDataSource, bool)

AsBasicReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) AsBlobReferenceInputDataSource 

func (asrids AzureSQLReferenceInputDataSource) AsBlobReferenceInputDataSource() (*BlobReferenceInputDataSource, bool)

AsBlobReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) AsReferenceInputDataSource 

func (asrids AzureSQLReferenceInputDataSource) AsReferenceInputDataSource() (*ReferenceInputDataSource, bool)

AsReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) MarshalJSON 

func (asrids AzureSQLReferenceInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureSQLReferenceInputDataSource.

type AzureSQLReferenceInputDataSourceProperties 

type AzureSQLReferenceInputDataSourceProperties struct {
	// Server - This element is associated with the datasource element. This is the name of the server that contains the database that will be written to.
	Server *string `json:"server,omitempty"`
	// Database - This element is associated with the datasource element. This is the name of the database that output will be written to.
	Database *string `json:"database,omitempty"`
	// User - This element is associated with the datasource element. This is the user name that will be used to connect to the SQL Database instance.
	User *string `json:"user,omitempty"`
	// Password - This element is associated with the datasource element. This is the password that will be used to connect to the SQL Database instance.
	Password *string `json:"password,omitempty"`
	// Table - This element is associated with the datasource element. The name of the table in the Azure SQL database..
	Table *string `json:"table,omitempty"`
	// RefreshType - This element is associated with the datasource element. This element is of enum type. It indicates what kind of data refresh option do we want to use:Static/RefreshPeriodicallyWithFull/RefreshPeriodicallyWithDelta
	RefreshType *string `json:"refreshType,omitempty"`
	// RefreshRate - This element is associated with the datasource element. This indicates how frequently the data will be fetched from the database. It is of DateTime format.
	RefreshRate *string `json:"refreshRate,omitempty"`
	// FullSnapshotQuery - This element is associated with the datasource element. This query is used to fetch data from the sql database.
	FullSnapshotQuery *string `json:"fullSnapshotQuery,omitempty"`
	// DeltaSnapshotQuery - This element is associated with the datasource element. This query is used to fetch incremental changes from the SQL database. To use this option, we recommend using temporal tables in Azure SQL Database.
	DeltaSnapshotQuery *string `json:"deltaSnapshotQuery,omitempty"`
}

AzureSQLReferenceInputDataSourceProperties ...

type AzureSynapseDataSourceProperties 

type AzureSynapseDataSourceProperties 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"`
	// Table - The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.
	Table *string `json:"table,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"`
}

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

type AzureSynapseOutputDataSource 

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

AzureSynapseOutputDataSource describes an Azure Synapse output data source.

func (AzureSynapseOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureFunctionOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureSynapseOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureTableOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsBasicOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsBlobOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsDocumentDbOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsEventHubOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsEventHubV2OutputDataSource 

func (asods AzureSynapseOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsPowerBIOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsServiceBusQueueOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsServiceBusTopicOutputDataSource 

func (asods AzureSynapseOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) MarshalJSON 

func (asods AzureSynapseOutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureSynapseOutputDataSource.

func (*AzureSynapseOutputDataSource) UnmarshalJSON 

func (asods *AzureSynapseOutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AzureSynapseOutputDataSource struct.

type AzureSynapseOutputDataSourceProperties 

type AzureSynapseOutputDataSourceProperties 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"`
	// Table - The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.
	Table *string `json:"table,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"`
}

AzureSynapseOutputDataSourceProperties the properties that are associated with an Azure Synapse output.

type AzureTableOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

AzureTableOutputDataSource describes an Azure Table output data source.

func (AzureTableOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureFunctionOutputDataSource 

func (atods AzureTableOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureSynapseOutputDataSource 

func (atods AzureTableOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsEventHubV2OutputDataSource 

func (atods AzureTableOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for AzureTableOutputDataSource.

func (*AzureTableOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for AzureTableOutputDataSource struct.

type AzureTableOutputDataSourceProperties 

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 

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

BaseClient is the base client for Streamanalytics.

func New 

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI 

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

type BasicFunctionBinding 

type BasicFunctionBinding interface {
	AsAzureMachineLearningStudioFunctionBinding() (*AzureMachineLearningStudioFunctionBinding, bool)
	AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)
	AsCSharpFunctionBinding() (*CSharpFunctionBinding, bool)
	AsAzureMachineLearningServiceFunctionBinding() (*AzureMachineLearningServiceFunctionBinding, 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 

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

BasicFunctionProperties the properties that are associated with a function.

type BasicFunctionRetrieveDefaultDefinitionParameters 

type BasicFunctionRetrieveDefaultDefinitionParameters interface {
	AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters, bool)
	AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters, bool)
	AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)
	AsCSharpFunctionRetrieveDefaultDefinitionParameters() (*CSharpFunctionRetrieveDefaultDefinitionParameters, bool)
	AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool)
}

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

type BasicInputProperties 

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

BasicInputProperties the properties that are associated with an input.

type BasicOutputDataSource 

type BasicOutputDataSource interface {
	AsBlobOutputDataSource() (*BlobOutputDataSource, bool)
	AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)
	AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)
	AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)
	AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)
	AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)
	AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)
	AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)
	AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)
	AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)
	AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)
	AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)
	AsOutputDataSource() (*OutputDataSource, bool)
}

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

type BasicReferenceInputDataSource 

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

BasicReferenceInputDataSource describes an input data source that contains reference data.

type BasicSerialization 

type BasicSerialization interface {
	AsParquetSerialization() (*ParquetSerialization, bool)
	AsCustomClrSerialization() (*CustomClrSerialization, bool)
	AsCsvSerialization() (*CsvSerialization, bool)
	AsJSONSerialization() (*JSONSerialization, bool)
	AsAvroSerialization() (*AvroSerialization, 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 

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

BasicStreamInputDataSource describes an input data source that contains stream data.

type BindingType 

type BindingType string

BindingType enumerates the values for binding type. 

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

func PossibleBindingTypeValues 

func PossibleBindingTypeValues() []BindingType

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

type BlobDataSourceProperties 

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 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

BlobOutputDataSource describes a blob output data source.

func (BlobOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureFunctionOutputDataSource 

func (bods BlobOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureSynapseOutputDataSource 

func (bods BlobOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsEventHubV2OutputDataSource 

func (bods BlobOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for BlobOutputDataSource.

func (*BlobOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for BlobOutputDataSource struct.

type BlobOutputDataSourceProperties 

type BlobOutputDataSourceProperties struct {
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,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"`
}

BlobOutputDataSourceProperties the properties that are associated with a blob output.

type BlobReferenceInputDataSource 

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', 'TypeBasicReferenceInputDataSourceTypeMicrosoftSQLServerDatabase'
	Type TypeBasicReferenceInputDataSource `json:"type,omitempty"`
}

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

func (BlobReferenceInputDataSource) AsAzureSQLReferenceInputDataSource 

func (brids BlobReferenceInputDataSource) AsAzureSQLReferenceInputDataSource() (*AzureSQLReferenceInputDataSource, bool)

AsAzureSQLReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsBasicReferenceInputDataSource 

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

AsBasicReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsBlobReferenceInputDataSource 

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

AsBlobReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsReferenceInputDataSource 

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

AsReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for BlobReferenceInputDataSource.

func (*BlobReferenceInputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for BlobReferenceInputDataSource struct.

type BlobReferenceInputDataSourceProperties 

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 

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', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftEventHubEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs'
	Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

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

func (BlobStreamInputDataSource) AsBasicStreamInputDataSource 

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsBlobStreamInputDataSource 

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsEventHubStreamInputDataSource 

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsEventHubV2StreamInputDataSource 

func (bsids BlobStreamInputDataSource) AsEventHubV2StreamInputDataSource() (*EventHubV2StreamInputDataSource, bool)

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsIoTHubStreamInputDataSource 

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsStreamInputDataSource 

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for BlobStreamInputDataSource.

func (*BlobStreamInputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for BlobStreamInputDataSource struct.

type BlobStreamInputDataSourceProperties 

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 CSharpFunctionBinding 

type CSharpFunctionBinding struct {
	// CSharpFunctionBindingProperties - The binding properties associated with a CSharp function.
	*CSharpFunctionBindingProperties `json:"properties,omitempty"`
	// Type - Possible values include: 'TypeFunctionBinding', 'TypeMicrosoftMachineLearningWebService', 'TypeMicrosoftStreamAnalyticsJavascriptUdf', 'TypeMicrosoftStreamAnalyticsCLRUdf', 'TypeMicrosoftMachineLearningServices'
	Type Type `json:"type,omitempty"`
}

CSharpFunctionBinding the binding to a CSharp function.

func (CSharpFunctionBinding) AsAzureMachineLearningServiceFunctionBinding 

func (csfb CSharpFunctionBinding) AsAzureMachineLearningServiceFunctionBinding() (*AzureMachineLearningServiceFunctionBinding, bool)

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsAzureMachineLearningStudioFunctionBinding 

func (csfb CSharpFunctionBinding) AsAzureMachineLearningStudioFunctionBinding() (*AzureMachineLearningStudioFunctionBinding, bool)

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsBasicFunctionBinding 

func (csfb CSharpFunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool)

AsBasicFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsCSharpFunctionBinding 

func (csfb CSharpFunctionBinding) AsCSharpFunctionBinding() (*CSharpFunctionBinding, bool)

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsFunctionBinding 

func (csfb CSharpFunctionBinding) AsFunctionBinding() (*FunctionBinding, bool)

AsFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsJavaScriptFunctionBinding 

func (csfb CSharpFunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool)

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) MarshalJSON 

func (csfb CSharpFunctionBinding) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for CSharpFunctionBinding.

func (*CSharpFunctionBinding) UnmarshalJSON 

func (csfb *CSharpFunctionBinding) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for CSharpFunctionBinding struct.

type CSharpFunctionBindingProperties 

type CSharpFunctionBindingProperties struct {
	// Script - The Csharp code containing a single function definition.
	Script *string `json:"script,omitempty"`
	// DllPath - The Csharp code containing a single function definition.
	DllPath *string `json:"dllPath,omitempty"`
	// Class - The Csharp code containing a single function definition.
	Class *string `json:"class,omitempty"`
	// Method - The Csharp code containing a single function definition.
	Method *string `json:"method,omitempty"`
}

CSharpFunctionBindingProperties the binding properties associated with a CSharp function.

type CSharpFunctionBindingRetrievalProperties 

type CSharpFunctionBindingRetrievalProperties struct {
	// Script - The CSharp code containing a single function definition.
	Script *string `json:"script,omitempty"`
	// UdfType - The function type. Possible values include: 'Scalar'
	UdfType UdfType `json:"udfType,omitempty"`
}

CSharpFunctionBindingRetrievalProperties the binding retrieval properties associated with a CSharp function.

type CSharpFunctionRetrieveDefaultDefinitionParameters 

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

CSharpFunctionRetrieveDefaultDefinitionParameters the parameters needed to retrieve the default function definition for a CSharp function.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters 

func (csfrddp CSharpFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters 

func (csfrddp CSharpFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters 

func (csfrddp CSharpFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool)

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters 

func (csfrddp CSharpFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters() (*CSharpFunctionRetrieveDefaultDefinitionParameters, bool)

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters 

func (csfrddp CSharpFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool)

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters 

func (csfrddp CSharpFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool)

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) MarshalJSON 

func (csfrddp CSharpFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (*CSharpFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON 

func (csfrddp *CSharpFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for CSharpFunctionRetrieveDefaultDefinitionParameters struct.

type Cluster 

type Cluster struct {
	autorest.Response `json:"-"`
	Sku               *ClusterSku `json:"sku,omitempty"`
	// Etag - READ-ONLY; The current entity tag for the cluster. 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"`
	// Properties - The properties associated with a Stream Analytics cluster.
	Properties *ClusterProperties `json:"properties,omitempty"`
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - The geo-location where the resource lives
	Location *string `json:"location,omitempty"`
	// ID - READ-ONLY; Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
	Type *string `json:"type,omitempty"`
}

Cluster a Stream Analytics Cluster object

func (Cluster) MarshalJSON 

func (c Cluster) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Cluster.

type ClusterInfo 

type ClusterInfo struct {
	// ID - The resource id of cluster.
	ID *string `json:"id,omitempty"`
}

ClusterInfo the properties associated with a Stream Analytics cluster.

type ClusterJob 

type ClusterJob struct {
	// ID - READ-ONLY; Resource ID of the streaming job.
	ID *string `json:"id,omitempty"`
	// StreamingUnits - READ-ONLY; The number of streaming units that are used by the streaming job.
	StreamingUnits *int32 `json:"streamingUnits,omitempty"`
	// JobState - Possible values include: 'JobStateCreated', 'JobStateStarting', 'JobStateRunning', 'JobStateStopping', 'JobStateStopped', 'JobStateDeleting', 'JobStateFailed', 'JobStateDegraded', 'JobStateRestarting', 'JobStateScaling'
	JobState JobState `json:"jobState,omitempty"`
}

ClusterJob a streaming job.

func (ClusterJob) MarshalJSON 

func (cj ClusterJob) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterJob.

type ClusterJobListResult 

type ClusterJobListResult struct {
	autorest.Response `json:"-"`
	// Value - READ-ONLY; A list of streaming jobs.
	Value *[]ClusterJob `json:"value,omitempty"`
	// NextLink - READ-ONLY; The URL to fetch the next set of streaming jobs.
	NextLink *string `json:"nextLink,omitempty"`
}

ClusterJobListResult a list of streaming jobs. Populated by a List operation.

func (ClusterJobListResult) IsEmpty 

func (cjlr ClusterJobListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (ClusterJobListResult) MarshalJSON 

func (cjlr ClusterJobListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterJobListResult.

type ClusterJobListResultIterator 

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

ClusterJobListResultIterator provides access to a complete listing of ClusterJob values.

func NewClusterJobListResultIterator 

func NewClusterJobListResultIterator(page ClusterJobListResultPage) ClusterJobListResultIterator

Creates a new instance of the ClusterJobListResultIterator type.

func (*ClusterJobListResultIterator) Next 

func (iter *ClusterJobListResultIterator) 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 (*ClusterJobListResultIterator) NextWithContext 

func (iter *ClusterJobListResultIterator) 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 (ClusterJobListResultIterator) NotDone 

func (iter ClusterJobListResultIterator) NotDone() bool

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

func (ClusterJobListResultIterator) Response 

func (iter ClusterJobListResultIterator) Response() ClusterJobListResult

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

func (ClusterJobListResultIterator) Value 

func (iter ClusterJobListResultIterator) Value() ClusterJob

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

type ClusterJobListResultPage 

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

ClusterJobListResultPage contains a page of ClusterJob values.

func NewClusterJobListResultPage 

func NewClusterJobListResultPage(cur ClusterJobListResult, getNextPage func(context.Context, ClusterJobListResult) (ClusterJobListResult, error)) ClusterJobListResultPage

Creates a new instance of the ClusterJobListResultPage type.

func (*ClusterJobListResultPage) Next 

func (page *ClusterJobListResultPage) 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 (*ClusterJobListResultPage) NextWithContext 

func (page *ClusterJobListResultPage) 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 (ClusterJobListResultPage) NotDone 

func (page ClusterJobListResultPage) NotDone() bool

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

func (ClusterJobListResultPage) Response 

func (page ClusterJobListResultPage) Response() ClusterJobListResult

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

func (ClusterJobListResultPage) Values 

func (page ClusterJobListResultPage) Values() []ClusterJob

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

type ClusterListResult 

type ClusterListResult struct {
	autorest.Response `json:"-"`
	// Value - READ-ONLY; A list of clusters.
	Value *[]Cluster `json:"value,omitempty"`
	// NextLink - READ-ONLY; The URL to fetch the next set of clusters.
	NextLink *string `json:"nextLink,omitempty"`
}

ClusterListResult a list of clusters populated by a 'list' operation.

func (ClusterListResult) IsEmpty 

func (clr ClusterListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (ClusterListResult) MarshalJSON 

func (clr ClusterListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterListResult.

type ClusterListResultIterator 

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

ClusterListResultIterator provides access to a complete listing of Cluster values.

func NewClusterListResultIterator 

func NewClusterListResultIterator(page ClusterListResultPage) ClusterListResultIterator

Creates a new instance of the ClusterListResultIterator type.

func (*ClusterListResultIterator) Next 

func (iter *ClusterListResultIterator) 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 (*ClusterListResultIterator) NextWithContext 

func (iter *ClusterListResultIterator) 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 (ClusterListResultIterator) NotDone 

func (iter ClusterListResultIterator) NotDone() bool

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

func (ClusterListResultIterator) Response 

func (iter ClusterListResultIterator) Response() ClusterListResult

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

func (ClusterListResultIterator) Value 

func (iter ClusterListResultIterator) Value() Cluster

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

type ClusterListResultPage 

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

ClusterListResultPage contains a page of Cluster values.

func NewClusterListResultPage 

func NewClusterListResultPage(cur ClusterListResult, getNextPage func(context.Context, ClusterListResult) (ClusterListResult, error)) ClusterListResultPage

Creates a new instance of the ClusterListResultPage type.

func (*ClusterListResultPage) Next 

func (page *ClusterListResultPage) 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 (*ClusterListResultPage) NextWithContext 

func (page *ClusterListResultPage) 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 (ClusterListResultPage) NotDone 

func (page ClusterListResultPage) NotDone() bool

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

func (ClusterListResultPage) Response 

func (page ClusterListResultPage) Response() ClusterListResult

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

func (ClusterListResultPage) Values 

func (page ClusterListResultPage) Values() []Cluster

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

type ClusterProperties 

type ClusterProperties struct {
	// CreatedDate - READ-ONLY; The date this cluster was created.
	CreatedDate *date.Time `json:"createdDate,omitempty"`
	// ClusterID - READ-ONLY; Unique identifier for the cluster.
	ClusterID *string `json:"clusterId,omitempty"`
	// ProvisioningState - Possible values include: 'Succeeded', 'Failed', 'Canceled', 'InProgress'
	ProvisioningState ClusterProvisioningState `json:"provisioningState,omitempty"`
	// CapacityAllocated - READ-ONLY; Represents the number of streaming units currently being used on the cluster.
	CapacityAllocated *int32 `json:"capacityAllocated,omitempty"`
	// CapacityAssigned - READ-ONLY; Represents the sum of the SUs of all streaming jobs associated with the cluster. If all of the jobs were running, this would be the capacity allocated.
	CapacityAssigned *int32 `json:"capacityAssigned,omitempty"`
}

ClusterProperties the properties associated with a Stream Analytics cluster.

func (ClusterProperties) MarshalJSON 

func (cp ClusterProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterProperties.

type ClusterProvisioningState 

type ClusterProvisioningState string

ClusterProvisioningState enumerates the values for cluster provisioning state. 

const (
	// Canceled The cluster provisioning was canceled.
	Canceled ClusterProvisioningState = "Canceled"
	// Failed The cluster provisioning failed.
	Failed ClusterProvisioningState = "Failed"
	// InProgress The cluster provisioning was inprogress.
	InProgress ClusterProvisioningState = "InProgress"
	// Succeeded The cluster provisioning succeeded.
	Succeeded ClusterProvisioningState = "Succeeded"
)

func PossibleClusterProvisioningStateValues 

func PossibleClusterProvisioningStateValues() []ClusterProvisioningState

PossibleClusterProvisioningStateValues returns an array of possible values for the ClusterProvisioningState const type.

type ClusterSku 

type ClusterSku struct {
	// Name - Specifies the SKU name of the cluster. Required on PUT (CreateOrUpdate) requests. Possible values include: 'Default'
	Name ClusterSkuName `json:"name,omitempty"`
	// Capacity - Denotes the number of streaming units the cluster can support. Valid values for this property are multiples of 36 with a minimum value of 36 and maximum value of 216. Required on PUT (CreateOrUpdate) requests.
	Capacity *int32 `json:"capacity,omitempty"`
}

ClusterSku the SKU of the cluster. This determines the size/capacity of the cluster. Required on PUT (CreateOrUpdate) requests.

type ClusterSkuName 

type ClusterSkuName string

ClusterSkuName enumerates the values for cluster sku name. 

const (
	// Default The default SKU.
	Default ClusterSkuName = "Default"
)

func PossibleClusterSkuNameValues 

func PossibleClusterSkuNameValues() []ClusterSkuName

PossibleClusterSkuNameValues returns an array of possible values for the ClusterSkuName const type.

type ClustersClient 

type ClustersClient struct {
	BaseClient
}

ClustersClient is the stream Analytics Client

func NewClustersClient 

func NewClustersClient(subscriptionID string) ClustersClient

NewClustersClient creates an instance of the ClustersClient client.

func NewClustersClientWithBaseURI 

func NewClustersClientWithBaseURI(baseURI string, subscriptionID string) ClustersClient

NewClustersClientWithBaseURI creates an instance of the ClustersClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ClustersClient) CreateOrUpdate 

func (client ClustersClient) CreateOrUpdate(ctx context.Context, cluster Cluster, resourceGroupName string, clusterName string, ifMatch string, ifNoneMatch string) (result ClustersCreateOrUpdateFuture, err error)

CreateOrUpdate creates a Stream Analytics Cluster or replaces an already existing cluster. Parameters: cluster - the definition of the cluster that will be used to create a new cluster or replace the existing one. resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster. ifMatch - the ETag of the resource. 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 resource to be created, but to prevent updating an existing record set. Other values will result in a 412 Pre-condition Failed response.

func (ClustersClient) CreateOrUpdatePreparer 

func (client ClustersClient) CreateOrUpdatePreparer(ctx context.Context, cluster Cluster, resourceGroupName string, clusterName string, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (ClustersClient) CreateOrUpdateResponder 

func (client ClustersClient) CreateOrUpdateResponder(resp *http.Response) (result Cluster, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (ClustersClient) CreateOrUpdateSender 

func (client ClustersClient) CreateOrUpdateSender(req *http.Request) (future ClustersCreateOrUpdateFuture, err error)

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

func (ClustersClient) Delete 

func (client ClustersClient) Delete(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDeleteFuture, err error)

Delete deletes the specified cluster. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster.

func (ClustersClient) DeletePreparer 

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

DeletePreparer prepares the Delete request.

func (ClustersClient) DeleteResponder 

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

func (client ClustersClient) DeleteSender(req *http.Request) (future ClustersDeleteFuture, err error)

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

func (ClustersClient) Get 

func (client ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string) (result Cluster, err error)

Get gets information about the specified cluster. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster.

func (ClustersClient) GetPreparer 

func (client ClustersClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ClustersClient) GetResponder 

func (client ClustersClient) GetResponder(resp *http.Response) (result Cluster, err error)

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

func (ClustersClient) GetSender 

func (client ClustersClient) 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 (ClustersClient) ListByResourceGroup 

func (client ClustersClient) ListByResourceGroup(ctx context.Context, resourceGroupName string) (result ClusterListResultPage, err error)

ListByResourceGroup lists all of the clusters in the given resource group. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive.

func (ClustersClient) ListByResourceGroupComplete 

func (client ClustersClient) ListByResourceGroupComplete(ctx context.Context, resourceGroupName string) (result ClusterListResultIterator, err error)

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

func (ClustersClient) ListByResourceGroupPreparer 

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

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (ClustersClient) ListByResourceGroupResponder 

func (client ClustersClient) ListByResourceGroupResponder(resp *http.Response) (result ClusterListResult, err error)

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

func (ClustersClient) ListByResourceGroupSender 

func (client ClustersClient) 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 (ClustersClient) ListBySubscription 

func (client ClustersClient) ListBySubscription(ctx context.Context) (result ClusterListResultPage, err error)

ListBySubscription lists all of the clusters in the given subscription.

func (ClustersClient) ListBySubscriptionComplete 

func (client ClustersClient) ListBySubscriptionComplete(ctx context.Context) (result ClusterListResultIterator, err error)

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

func (ClustersClient) ListBySubscriptionPreparer 

func (client ClustersClient) ListBySubscriptionPreparer(ctx context.Context) (*http.Request, error)

ListBySubscriptionPreparer prepares the ListBySubscription request.

func (ClustersClient) ListBySubscriptionResponder 

func (client ClustersClient) ListBySubscriptionResponder(resp *http.Response) (result ClusterListResult, err error)

ListBySubscriptionResponder handles the response to the ListBySubscription request. The method always closes the http.Response Body.

func (ClustersClient) ListBySubscriptionSender 

func (client ClustersClient) ListBySubscriptionSender(req *http.Request) (*http.Response, error)

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

func (ClustersClient) ListStreamingJobs 

func (client ClustersClient) ListStreamingJobs(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterJobListResultPage, err error)

ListStreamingJobs lists all of the streaming jobs in the given cluster. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster.

func (ClustersClient) ListStreamingJobsComplete 

func (client ClustersClient) ListStreamingJobsComplete(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterJobListResultIterator, err error)

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

func (ClustersClient) ListStreamingJobsPreparer 

func (client ClustersClient) ListStreamingJobsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListStreamingJobsPreparer prepares the ListStreamingJobs request.

func (ClustersClient) ListStreamingJobsResponder 

func (client ClustersClient) ListStreamingJobsResponder(resp *http.Response) (result ClusterJobListResult, err error)

ListStreamingJobsResponder handles the response to the ListStreamingJobs request. The method always closes the http.Response Body.

func (ClustersClient) ListStreamingJobsSender 

func (client ClustersClient) ListStreamingJobsSender(req *http.Request) (*http.Response, error)

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

func (ClustersClient) Update 

func (client ClustersClient) Update(ctx context.Context, cluster Cluster, resourceGroupName string, clusterName string, ifMatch string) (result ClustersUpdateFuture, err error)

Update updates an existing cluster. This can be used to partially update (ie. update one or two properties) a cluster without affecting the rest of the cluster definition. Parameters: cluster - the properties specified here will overwrite the corresponding properties in the existing cluster (ie. Those properties will be updated). resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster. ifMatch - the ETag of the resource. Omit this value to always overwrite the current record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.

func (ClustersClient) UpdatePreparer 

func (client ClustersClient) UpdatePreparer(ctx context.Context, cluster Cluster, resourceGroupName string, clusterName string, ifMatch string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (ClustersClient) UpdateResponder 

func (client ClustersClient) UpdateResponder(resp *http.Response) (result Cluster, err error)

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

func (ClustersClient) UpdateSender 

func (client ClustersClient) UpdateSender(req *http.Request) (future ClustersUpdateFuture, err error)

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

type ClustersCreateOrUpdateFuture 

type ClustersCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (Cluster, error)
}

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

func (*ClustersCreateOrUpdateFuture) UnmarshalJSON 

func (future *ClustersCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersDeleteFuture 

type ClustersDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

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

func (*ClustersDeleteFuture) UnmarshalJSON 

func (future *ClustersDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersUpdateFuture 

type ClustersUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (Cluster, error)
}

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

func (*ClustersUpdateFuture) UnmarshalJSON 

func (future *ClustersUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type CompatibilityLevel 

type CompatibilityLevel string

CompatibilityLevel enumerates the values for compatibility level. 

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

func PossibleCompatibilityLevelValues 

func PossibleCompatibilityLevelValues() []CompatibilityLevel

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

type Compression 

type Compression struct {
	Type *string `json:"type,omitempty"`
}

Compression describes how input data is compressed

type ContentStoragePolicy 

type ContentStoragePolicy string

ContentStoragePolicy enumerates the values for content storage policy. 

const (
	// ContentStoragePolicyJobStorageAccount ...
	ContentStoragePolicyJobStorageAccount ContentStoragePolicy = "JobStorageAccount"
	// ContentStoragePolicySystemAccount ...
	ContentStoragePolicySystemAccount ContentStoragePolicy = "SystemAccount"
)

func PossibleContentStoragePolicyValues 

func PossibleContentStoragePolicyValues() []ContentStoragePolicy

PossibleContentStoragePolicyValues returns an array of possible values for the ContentStoragePolicy const type.

type CsvSerialization 

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', 'TypeParquet', 'TypeCustomClr', 'TypeCsv', 'TypeJSON', 'TypeAvro'
	Type TypeBasicSerialization `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 

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

AsAvroSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsBasicSerialization 

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

AsBasicSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsCsvSerialization 

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

AsCsvSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsCustomClrSerialization 

func (cs CsvSerialization) AsCustomClrSerialization() (*CustomClrSerialization, bool)

AsCustomClrSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsJSONSerialization 

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

AsJSONSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsParquetSerialization 

func (cs CsvSerialization) AsParquetSerialization() (*ParquetSerialization, bool)

AsParquetSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsSerialization 

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

AsSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) MarshalJSON 

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

MarshalJSON is the custom marshaler for CsvSerialization.

func (*CsvSerialization) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for CsvSerialization struct.

type CsvSerializationProperties 

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 CustomClrSerialization 

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

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

func (CustomClrSerialization) AsAvroSerialization 

func (ccs CustomClrSerialization) AsAvroSerialization() (*AvroSerialization, bool)

AsAvroSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsBasicSerialization 

func (ccs CustomClrSerialization) AsBasicSerialization() (BasicSerialization, bool)

AsBasicSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsCsvSerialization 

func (ccs CustomClrSerialization) AsCsvSerialization() (*CsvSerialization, bool)

AsCsvSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsCustomClrSerialization 

func (ccs CustomClrSerialization) AsCustomClrSerialization() (*CustomClrSerialization, bool)

AsCustomClrSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsJSONSerialization 

func (ccs CustomClrSerialization) AsJSONSerialization() (*JSONSerialization, bool)

AsJSONSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsParquetSerialization 

func (ccs CustomClrSerialization) AsParquetSerialization() (*ParquetSerialization, bool)

AsParquetSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsSerialization 

func (ccs CustomClrSerialization) AsSerialization() (*Serialization, bool)

AsSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) MarshalJSON 

func (ccs CustomClrSerialization) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for CustomClrSerialization.

func (*CustomClrSerialization) UnmarshalJSON 

func (ccs *CustomClrSerialization) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for CustomClrSerialization struct.

type CustomClrSerializationProperties 

type CustomClrSerializationProperties struct {
	// SerializationDllPath - The serialization library path.
	SerializationDllPath *string `json:"serializationDllPath,omitempty"`
	// SerializationClassName - The serialization class name.
	SerializationClassName *string `json:"serializationClassName,omitempty"`
}

CustomClrSerializationProperties the properties that are associated with the CustomClr serialization type.

type DiagnosticCondition 

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.

func (DiagnosticCondition) MarshalJSON 

func (dc DiagnosticCondition) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DiagnosticCondition.

type Diagnostics 

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.

func (Diagnostics) MarshalJSON 

func (d Diagnostics) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Diagnostics.

type DocumentDbOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

DocumentDbOutputDataSource describes a DocumentDB output data source.

func (DocumentDbOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureFunctionOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureSynapseOutputDataSource 

func (ddods DocumentDbOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsEventHubV2OutputDataSource 

func (ddods DocumentDbOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for DocumentDbOutputDataSource.

func (*DocumentDbOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for DocumentDbOutputDataSource struct.

type DocumentDbOutputDataSourceProperties 

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 

type Encoding string

Encoding enumerates the values for encoding. 

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

func PossibleEncodingValues 

func PossibleEncodingValues() []Encoding

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

type Error 

type Error struct {
	// Error - Error definition properties.
	Error *ErrorError `json:"error,omitempty"`
}

Error common error representation.

type ErrorDetails 

type ErrorDetails struct {
	// Code - Error code.
	Code *string `json:"code,omitempty"`
	// Target - Error target.
	Target *string `json:"target,omitempty"`
	// Message - Error message.
	Message *string `json:"message,omitempty"`
}

ErrorDetails common error details representation.

type ErrorError 

type ErrorError struct {
	// Code - Error code.
	Code *string `json:"code,omitempty"`
	// Message - Error message.
	Message *string `json:"message,omitempty"`
	// Target - Error target.
	Target *string `json:"target,omitempty"`
	// Details - Error details.
	Details *[]ErrorDetails `json:"details,omitempty"`
}

ErrorError error definition properties.

type ErrorResponse 

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.

func (ErrorResponse) MarshalJSON 

func (er ErrorResponse) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ErrorResponse.

type EventHubDataSourceProperties 

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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

type EventHubOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

EventHubOutputDataSource describes an Event Hub output data source.

func (EventHubOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureFunctionOutputDataSource 

func (ehods EventHubOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureSynapseOutputDataSource 

func (ehods EventHubOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsEventHubV2OutputDataSource 

func (ehods EventHubOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for EventHubOutputDataSource.

func (*EventHubOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for EventHubOutputDataSource struct.

type EventHubOutputDataSourceProperties 

type EventHubOutputDataSourceProperties struct {
	// PartitionKey - The key/column that is used to determine to which partition to send event data.
	PartitionKey    *string   `json:"partitionKey,omitempty"`
	PropertyColumns *[]string `json:"propertyColumns,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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

type EventHubStreamInputDataSource 

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', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftEventHubEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs'
	Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

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

func (EventHubStreamInputDataSource) AsBasicStreamInputDataSource 

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsBlobStreamInputDataSource 

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsEventHubStreamInputDataSource 

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsEventHubV2StreamInputDataSource 

func (ehsids EventHubStreamInputDataSource) AsEventHubV2StreamInputDataSource() (*EventHubV2StreamInputDataSource, bool)

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsIoTHubStreamInputDataSource 

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsStreamInputDataSource 

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for EventHubStreamInputDataSource.

func (*EventHubStreamInputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for EventHubStreamInputDataSource struct.

type EventHubStreamInputDataSourceProperties 

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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

type EventHubV2OutputDataSource 

type EventHubV2OutputDataSource 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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

EventHubV2OutputDataSource describes an Event Hub output data source.

func (EventHubV2OutputDataSource) AsAzureDataLakeStoreOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool)

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureFunctionOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureSQLDatabaseOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool)

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureSynapseOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureTableOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool)

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsBasicOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool)

AsBasicOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsBlobOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool)

AsBlobOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsDocumentDbOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool)

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsEventHubOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool)

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsEventHubV2OutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsOutputDataSource() (*OutputDataSource, bool)

AsOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsPowerBIOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool)

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsServiceBusQueueOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool)

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsServiceBusTopicOutputDataSource 

func (ehvods EventHubV2OutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool)

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) MarshalJSON 

func (ehvods EventHubV2OutputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventHubV2OutputDataSource.

func (*EventHubV2OutputDataSource) UnmarshalJSON 

func (ehvods *EventHubV2OutputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventHubV2OutputDataSource struct.

type EventHubV2StreamInputDataSource 

type EventHubV2StreamInputDataSource 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', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftEventHubEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs'
	Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

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

func (EventHubV2StreamInputDataSource) AsBasicStreamInputDataSource 

func (ehvsids EventHubV2StreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool)

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsBlobStreamInputDataSource 

func (ehvsids EventHubV2StreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool)

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsEventHubStreamInputDataSource 

func (ehvsids EventHubV2StreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool)

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsEventHubV2StreamInputDataSource 

func (ehvsids EventHubV2StreamInputDataSource) AsEventHubV2StreamInputDataSource() (*EventHubV2StreamInputDataSource, bool)

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsIoTHubStreamInputDataSource 

func (ehvsids EventHubV2StreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool)

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsStreamInputDataSource 

func (ehvsids EventHubV2StreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool)

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) MarshalJSON 

func (ehvsids EventHubV2StreamInputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventHubV2StreamInputDataSource.

func (*EventHubV2StreamInputDataSource) UnmarshalJSON 

func (ehvsids *EventHubV2StreamInputDataSource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventHubV2StreamInputDataSource struct.

type EventSerializationType 

type EventSerializationType string

EventSerializationType enumerates the values for event serialization type. 

const (
	// Avro ...
	Avro EventSerializationType = "Avro"
	// Csv ...
	Csv EventSerializationType = "Csv"
	// CustomClr ...
	CustomClr EventSerializationType = "CustomClr"
	// JSON ...
	JSON EventSerializationType = "Json"
	// Parquet ...
	Parquet EventSerializationType = "Parquet"
)

func PossibleEventSerializationTypeValues 

func PossibleEventSerializationTypeValues() []EventSerializationType

PossibleEventSerializationTypeValues returns an array of possible values for the EventSerializationType const type.

type EventsOutOfOrderPolicy 

type EventsOutOfOrderPolicy string

EventsOutOfOrderPolicy enumerates the values for events out of order policy. 

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

func PossibleEventsOutOfOrderPolicyValues 

func PossibleEventsOutOfOrderPolicyValues() []EventsOutOfOrderPolicy

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

type External 

type External struct {
	StorageAccount *StorageAccount `json:"storageAccount,omitempty"`
	Container      *string         `json:"container,omitempty"`
	Path           *string         `json:"path,omitempty"`
}

External the storage account where the custom code artifacts are located.

type Function 

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

func (f Function) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Function.

func (*Function) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for Function struct.

type FunctionBinding 

type FunctionBinding struct {
	// Type - Possible values include: 'TypeFunctionBinding', 'TypeMicrosoftMachineLearningWebService', 'TypeMicrosoftStreamAnalyticsJavascriptUdf', 'TypeMicrosoftStreamAnalyticsCLRUdf', 'TypeMicrosoftMachineLearningServices'
	Type Type `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) AsAzureMachineLearningServiceFunctionBinding 

func (fb FunctionBinding) AsAzureMachineLearningServiceFunctionBinding() (*AzureMachineLearningServiceFunctionBinding, bool)

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsAzureMachineLearningStudioFunctionBinding 

func (fb FunctionBinding) AsAzureMachineLearningStudioFunctionBinding() (*AzureMachineLearningStudioFunctionBinding, bool)

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsBasicFunctionBinding 

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

AsBasicFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsCSharpFunctionBinding 

func (fb FunctionBinding) AsCSharpFunctionBinding() (*CSharpFunctionBinding, bool)

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsFunctionBinding 

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

AsFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsJavaScriptFunctionBinding 

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) MarshalJSON 

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

MarshalJSON is the custom marshaler for FunctionBinding.

type FunctionConfiguration 

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

FunctionConfiguration ...

func (*FunctionConfiguration) UnmarshalJSON 

func (fc *FunctionConfiguration) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for FunctionConfiguration struct.

type FunctionInput 

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 

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 

func (flr FunctionListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (FunctionListResult) MarshalJSON 

func (flr FunctionListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for FunctionListResult.

type FunctionListResultIterator 

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

FunctionListResultIterator provides access to a complete listing of Function values.

func NewFunctionListResultIterator 

func NewFunctionListResultIterator(page FunctionListResultPage) FunctionListResultIterator

Creates a new instance of the FunctionListResultIterator type.

func (*FunctionListResultIterator) Next 

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 

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 

func (iter FunctionListResultIterator) NotDone() bool

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

func (FunctionListResultIterator) Response 

func (iter FunctionListResultIterator) Response() FunctionListResult

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

func (FunctionListResultIterator) Value 

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 

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

FunctionListResultPage contains a page of Function values.

func NewFunctionListResultPage 

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

Creates a new instance of the FunctionListResultPage type.

func (*FunctionListResultPage) Next 

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 

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 

func (page FunctionListResultPage) NotDone() bool

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

func (FunctionListResultPage) Response 

func (page FunctionListResultPage) Response() FunctionListResult

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

func (FunctionListResultPage) Values 

func (page FunctionListResultPage) Values() []Function

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

type FunctionOutput 

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 

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"`
	*FunctionConfiguration `json:"properties,omitempty"`
	// Type - Possible values include: 'TypeFunctionProperties', 'TypeScalar', 'TypeAggregate'
	Type TypeBasicFunctionProperties `json:"type,omitempty"`
}

FunctionProperties the properties that are associated with a function.

func (FunctionProperties) AsAggregateFunctionProperties 

func (fp FunctionProperties) AsAggregateFunctionProperties() (*AggregateFunctionProperties, bool)

AsAggregateFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsBasicFunctionProperties 

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

AsBasicFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsFunctionProperties 

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

AsFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsScalarFunctionProperties 

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

AsScalarFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) MarshalJSON 

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

MarshalJSON is the custom marshaler for FunctionProperties.

func (*FunctionProperties) UnmarshalJSON 

func (fp *FunctionProperties) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for FunctionProperties struct.

type FunctionRetrieveDefaultDefinitionParameters 

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

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

func (FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters 

func (frddp FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters 

func (frddp FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters 

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

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters 

func (frddp FunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters() (*CSharpFunctionRetrieveDefaultDefinitionParameters, bool)

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters 

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

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters 

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) MarshalJSON 

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

MarshalJSON is the custom marshaler for FunctionRetrieveDefaultDefinitionParameters.

type FunctionsClient 

type FunctionsClient struct {
	BaseClient
}

FunctionsClient is the stream Analytics Client

func NewFunctionsClient 

func NewFunctionsClient(subscriptionID string) FunctionsClient

NewFunctionsClient creates an instance of the FunctionsClient client.

func NewFunctionsClientWithBaseURI 

func NewFunctionsClientWithBaseURI(baseURI string, subscriptionID string) FunctionsClient

NewFunctionsClientWithBaseURI creates an instance of the FunctionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (FunctionsClient) CreateOrReplace 

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. The name is case insensitive. 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 

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 

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

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

func (FunctionsClient) CreateOrReplaceSender 

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

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

func (FunctionsClient) Delete 

func (client FunctionsClient) Delete(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. The name is case insensitive. jobName - the name of the streaming job. functionName - the name of the function.

func (FunctionsClient) DeletePreparer 

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

DeletePreparer prepares the Delete request.

func (FunctionsClient) DeleteResponder 

func (client FunctionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (FunctionsClient) DeleteSender 

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

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

func (FunctionsClient) Get 

func (client FunctionsClient) Get(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. The name is case insensitive. jobName - the name of the streaming job. functionName - the name of the function.

func (FunctionsClient) GetPreparer 

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

GetPreparer prepares the Get request.

func (FunctionsClient) GetResponder 

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

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

func (FunctionsClient) GetSender 

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

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

func (FunctionsClient) ListByStreamingJob 

func (client FunctionsClient) ListByStreamingJob(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. The name is case insensitive. 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 

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 

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (FunctionsClient) ListByStreamingJobResponder 

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

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

func (FunctionsClient) ListByStreamingJobSender 

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

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

func (FunctionsClient) RetrieveDefaultDefinition 

func (client FunctionsClient) RetrieveDefaultDefinition(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. The name is case insensitive. 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 

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 

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

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

func (FunctionsClient) RetrieveDefaultDefinitionSender 

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

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

func (FunctionsClient) Test 

func (client FunctionsClient) Test(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. The name is case insensitive. 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 

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 

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

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

func (FunctionsClient) TestSender 

func (client FunctionsClient) TestSender(req *http.Request) (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 

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. The name is case insensitive. 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 

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 

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

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

func (FunctionsClient) UpdateSender 

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

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

type FunctionsTestFuture 

type FunctionsTestFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(FunctionsClient) (ResourceTestStatus, error)
}

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

func (*FunctionsTestFuture) UnmarshalJSON 

func (future *FunctionsTestFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type Identity 

type Identity struct {
	TenantID    *string `json:"tenantId,omitempty"`
	PrincipalID *string `json:"principalId,omitempty"`
	Type        *string `json:"type,omitempty"`
}

Identity describes how identity is verified

type Input 

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

func (i Input) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Input.

func (*Input) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for Input struct.

type InputListResult 

type InputListResult struct {
	autorest.Response `json:"-"`
	// Value - 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 

func (ilr InputListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (InputListResult) MarshalJSON 

func (ilr InputListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for InputListResult.

type InputListResultIterator 

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

InputListResultIterator provides access to a complete listing of Input values.

func NewInputListResultIterator 

func NewInputListResultIterator(page InputListResultPage) InputListResultIterator

Creates a new instance of the InputListResultIterator type.

func (*InputListResultIterator) Next 

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 

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 

func (iter InputListResultIterator) NotDone() bool

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

func (InputListResultIterator) Response 

func (iter InputListResultIterator) Response() InputListResult

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

func (InputListResultIterator) Value 

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 

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

InputListResultPage contains a page of Input values.

func NewInputListResultPage 

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

Creates a new instance of the InputListResultPage type.

func (*InputListResultPage) Next 

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 

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 

func (page InputListResultPage) NotDone() bool

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

func (InputListResultPage) Response 

func (page InputListResultPage) Response() InputListResult

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

func (InputListResultPage) Values 

func (page InputListResultPage) Values() []Input

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

type InputProperties 

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"`
	Compression *Compression `json:"compression,omitempty"`
	// PartitionKey - partitionKey Describes a key in the input data which is used for partitioning the input data
	PartitionKey *string `json:"partitionKey,omitempty"`
	// Type - Possible values include: 'TypeInputProperties', 'TypeStream', 'TypeReference'
	Type TypeBasicInputProperties `json:"type,omitempty"`
}

InputProperties the properties that are associated with an input.

func (InputProperties) AsBasicInputProperties 

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

AsBasicInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsInputProperties 

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

AsInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsReferenceInputProperties 

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

AsReferenceInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsStreamInputProperties 

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

AsStreamInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) MarshalJSON 

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

MarshalJSON is the custom marshaler for InputProperties.

func (*InputProperties) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for InputProperties struct.

type InputsClient 

type InputsClient struct {
	BaseClient
}

InputsClient is the stream Analytics Client

func NewInputsClient 

func NewInputsClient(subscriptionID string) InputsClient

NewInputsClient creates an instance of the InputsClient client.

func NewInputsClientWithBaseURI 

func NewInputsClientWithBaseURI(baseURI string, subscriptionID string) InputsClient

NewInputsClientWithBaseURI creates an instance of the InputsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (InputsClient) CreateOrReplace 

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. The name is case insensitive. 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 

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 

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

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

func (InputsClient) CreateOrReplaceSender 

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

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

func (InputsClient) Delete 

func (client InputsClient) Delete(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. The name is case insensitive. jobName - the name of the streaming job. inputName - the name of the input.

func (InputsClient) DeletePreparer 

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

DeletePreparer prepares the Delete request.

func (InputsClient) DeleteResponder 

func (client InputsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (InputsClient) DeleteSender 

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

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

func (InputsClient) Get 

func (client InputsClient) Get(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. The name is case insensitive. jobName - the name of the streaming job. inputName - the name of the input.

func (InputsClient) GetPreparer 

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

GetPreparer prepares the Get request.

func (InputsClient) GetResponder 

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

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

func (InputsClient) GetSender 

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

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

func (InputsClient) ListByStreamingJob 

func (client InputsClient) ListByStreamingJob(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. The name is case insensitive. 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 

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 

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (InputsClient) ListByStreamingJobResponder 

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

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

func (InputsClient) ListByStreamingJobSender 

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

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

func (InputsClient) Test 

func (client InputsClient) Test(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. The name is case insensitive. 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 

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 

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

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

func (InputsClient) TestSender 

func (client InputsClient) TestSender(req *http.Request) (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 

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. The name is case insensitive. 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 

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 

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

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

func (InputsClient) UpdateSender 

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

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

type InputsTestFuture 

type InputsTestFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(InputsClient) (ResourceTestStatus, error)
}

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

func (*InputsTestFuture) UnmarshalJSON 

func (future *InputsTestFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type IoTHubStreamInputDataSource 

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', 'TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob', 'TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftEventHubEventHub', 'TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs'
	Type TypeBasicStreamInputDataSource `json:"type,omitempty"`
}

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

func (IoTHubStreamInputDataSource) AsBasicStreamInputDataSource 

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsBlobStreamInputDataSource 

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsEventHubStreamInputDataSource 

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsEventHubV2StreamInputDataSource 

func (ithsids IoTHubStreamInputDataSource) AsEventHubV2StreamInputDataSource() (*EventHubV2StreamInputDataSource, bool)

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsIoTHubStreamInputDataSource 

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsStreamInputDataSource 

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for IoTHubStreamInputDataSource.

func (*IoTHubStreamInputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for IoTHubStreamInputDataSource struct.

type IoTHubStreamInputDataSourceProperties 

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 

type JSONOutputSerializationFormat string

JSONOutputSerializationFormat enumerates the values for json output serialization format. 

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

func PossibleJSONOutputSerializationFormatValues 

func PossibleJSONOutputSerializationFormatValues() []JSONOutputSerializationFormat

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

type JSONSerialization 

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', 'TypeParquet', 'TypeCustomClr', 'TypeCsv', 'TypeJSON', 'TypeAvro'
	Type TypeBasicSerialization `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 

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

AsAvroSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsBasicSerialization 

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

AsBasicSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsCsvSerialization 

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

AsCsvSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsCustomClrSerialization 

func (js JSONSerialization) AsCustomClrSerialization() (*CustomClrSerialization, bool)

AsCustomClrSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsJSONSerialization 

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

AsJSONSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsParquetSerialization 

func (js JSONSerialization) AsParquetSerialization() (*ParquetSerialization, bool)

AsParquetSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsSerialization 

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

AsSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) MarshalJSON 

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

MarshalJSON is the custom marshaler for JSONSerialization.

func (*JSONSerialization) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for JSONSerialization struct.

type JSONSerializationProperties 

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 

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

JavaScriptFunctionBinding the binding to a JavaScript function.

func (JavaScriptFunctionBinding) AsAzureMachineLearningServiceFunctionBinding 

func (jsfb JavaScriptFunctionBinding) AsAzureMachineLearningServiceFunctionBinding() (*AzureMachineLearningServiceFunctionBinding, bool)

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsAzureMachineLearningStudioFunctionBinding 

func (jsfb JavaScriptFunctionBinding) AsAzureMachineLearningStudioFunctionBinding() (*AzureMachineLearningStudioFunctionBinding, bool)

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsBasicFunctionBinding 

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

AsBasicFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsCSharpFunctionBinding 

func (jsfb JavaScriptFunctionBinding) AsCSharpFunctionBinding() (*CSharpFunctionBinding, bool)

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsFunctionBinding 

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

AsFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) AsJavaScriptFunctionBinding 

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for JavaScriptFunctionBinding.

func (JavaScriptFunctionBinding) MarshalJSON 

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

MarshalJSON is the custom marshaler for JavaScriptFunctionBinding.

func (*JavaScriptFunctionBinding) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for JavaScriptFunctionBinding struct.

type JavaScriptFunctionBindingProperties 

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 

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 

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

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

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters 

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters 

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters, bool)

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters 

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

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters 

func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters() (*CSharpFunctionRetrieveDefaultDefinitionParameters, bool)

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters 

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

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters 

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (JavaScriptFunctionRetrieveDefaultDefinitionParameters) MarshalJSON 

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

MarshalJSON is the custom marshaler for JavaScriptFunctionRetrieveDefaultDefinitionParameters.

func (*JavaScriptFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for JavaScriptFunctionRetrieveDefaultDefinitionParameters struct.

type JobState 

type JobState string

JobState enumerates the values for job state. 

const (
	// JobStateCreated The job is currently in the Created state.
	JobStateCreated JobState = "Created"
	// JobStateDegraded The job is currently in the Degraded state.
	JobStateDegraded JobState = "Degraded"
	// JobStateDeleting The job is currently in the Deleting state.
	JobStateDeleting JobState = "Deleting"
	// JobStateFailed The job is currently in the Failed state.
	JobStateFailed JobState = "Failed"
	// JobStateRestarting The job is currently in the Restarting state.
	JobStateRestarting JobState = "Restarting"
	// JobStateRunning The job is currently in the Running state.
	JobStateRunning JobState = "Running"
	// JobStateScaling The job is currently in the Scaling state.
	JobStateScaling JobState = "Scaling"
	// JobStateStarting The job is currently in the Starting state.
	JobStateStarting JobState = "Starting"
	// JobStateStopped The job is currently in the Stopped state.
	JobStateStopped JobState = "Stopped"
	// JobStateStopping The job is currently in the Stopping state.
	JobStateStopping JobState = "Stopping"
)

func PossibleJobStateValues 

func PossibleJobStateValues() []JobState

PossibleJobStateValues returns an array of possible values for the JobState const type.

type JobStorageAccount 

type JobStorageAccount struct {
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
	// 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"`
}

JobStorageAccount the properties that are associated with an Azure Storage account with MSI

type JobType 

type JobType string

JobType enumerates the values for job type. 

const (
	// Cloud ...
	Cloud JobType = "Cloud"
	// Edge ...
	Edge JobType = "Edge"
)

func PossibleJobTypeValues 

func PossibleJobTypeValues() []JobType

PossibleJobTypeValues returns an array of possible values for the JobType const type.

type OAuthBasedDataSourceProperties 

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 

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

func (Operation) MarshalJSON 

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

MarshalJSON is the custom marshaler for Operation.

type OperationDisplay 

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.

func (OperationDisplay) MarshalJSON 

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

MarshalJSON is the custom marshaler for OperationDisplay.

type OperationListResult 

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 

func (olr OperationListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (OperationListResult) MarshalJSON 

func (olr OperationListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OperationListResult.

type OperationListResultIterator 

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

OperationListResultIterator provides access to a complete listing of Operation values.

func NewOperationListResultIterator 

func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator

Creates a new instance of the OperationListResultIterator type.

func (*OperationListResultIterator) Next 

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 

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 

func (iter OperationListResultIterator) NotDone() bool

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

func (OperationListResultIterator) Response 

func (iter OperationListResultIterator) Response() OperationListResult

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

func (OperationListResultIterator) Value 

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 

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

OperationListResultPage contains a page of Operation values.

func NewOperationListResultPage 

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

Creates a new instance of the OperationListResultPage type.

func (*OperationListResultPage) Next 

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 

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 

func (page OperationListResultPage) NotDone() bool

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

func (OperationListResultPage) Response 

func (page OperationListResultPage) Response() OperationListResult

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

func (OperationListResultPage) Values 

func (page OperationListResultPage) Values() []Operation

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

type OperationsClient 

type OperationsClient struct {
	BaseClient
}

OperationsClient is the stream Analytics Client

func NewOperationsClient 

func NewOperationsClient(subscriptionID string) OperationsClient

NewOperationsClient creates an instance of the OperationsClient client.

func NewOperationsClientWithBaseURI 

func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient

NewOperationsClientWithBaseURI creates an instance of the OperationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (OperationsClient) List 

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

List lists all of the available Stream Analytics related operations.

func (OperationsClient) ListComplete 

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

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

func (OperationsClient) ListPreparer 

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

ListPreparer prepares the List request.

func (OperationsClient) ListResponder 

func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)

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

func (OperationsClient) ListSender 

func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)

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

type Output 

type Output struct {
	autorest.Response `json:"-"`
	// 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 

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

MarshalJSON is the custom marshaler for Output.

func (*Output) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for Output struct.

type OutputDataSource 

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

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

func (OutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsAzureFunctionOutputDataSource 

func (ods OutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsAzureSynapseOutputDataSource 

func (ods OutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsEventHubV2OutputDataSource 

func (ods OutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for OutputDataSource.

func (OutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for OutputDataSource.

type OutputErrorPolicy 

type OutputErrorPolicy string

OutputErrorPolicy enumerates the values for output error policy. 

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

func PossibleOutputErrorPolicyValues 

func PossibleOutputErrorPolicyValues() []OutputErrorPolicy

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

type OutputListResult 

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 

func (olr OutputListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (OutputListResult) MarshalJSON 

func (olr OutputListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OutputListResult.

type OutputListResultIterator 

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

OutputListResultIterator provides access to a complete listing of Output values.

func NewOutputListResultIterator 

func NewOutputListResultIterator(page OutputListResultPage) OutputListResultIterator

Creates a new instance of the OutputListResultIterator type.

func (*OutputListResultIterator) Next 

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 

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 

func (iter OutputListResultIterator) NotDone() bool

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

func (OutputListResultIterator) Response 

func (iter OutputListResultIterator) Response() OutputListResult

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

func (OutputListResultIterator) Value 

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 

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

OutputListResultPage contains a page of Output values.

func NewOutputListResultPage 

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

Creates a new instance of the OutputListResultPage type.

func (*OutputListResultPage) Next 

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 

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 

func (page OutputListResultPage) NotDone() bool

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

func (OutputListResultPage) Response 

func (page OutputListResultPage) Response() OutputListResult

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

func (OutputListResultPage) Values 

func (page OutputListResultPage) Values() []Output

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

type OutputProperties 

type OutputProperties struct {
	// Datasource - Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests.
	Datasource BasicOutputDataSource `json:"datasource,omitempty"`
	TimeWindow *string               `json:"timeWindow,omitempty"`
	SizeWindow *float64              `json:"sizeWindow,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) MarshalJSON 

func (op OutputProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OutputProperties.

func (*OutputProperties) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for OutputProperties struct.

type OutputStartMode 

type OutputStartMode string

OutputStartMode enumerates the values for output start mode. 

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

func PossibleOutputStartModeValues 

func PossibleOutputStartModeValues() []OutputStartMode

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

type OutputsClient 

type OutputsClient struct {
	BaseClient
}

OutputsClient is the stream Analytics Client

func NewOutputsClient 

func NewOutputsClient(subscriptionID string) OutputsClient

NewOutputsClient creates an instance of the OutputsClient client.

func NewOutputsClientWithBaseURI 

func NewOutputsClientWithBaseURI(baseURI string, subscriptionID string) OutputsClient

NewOutputsClientWithBaseURI creates an instance of the OutputsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (OutputsClient) CreateOrReplace 

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. The name is case insensitive. 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 

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 

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

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

func (OutputsClient) CreateOrReplaceSender 

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

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

func (OutputsClient) Delete 

func (client OutputsClient) Delete(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. The name is case insensitive. jobName - the name of the streaming job. outputName - the name of the output.

func (OutputsClient) DeletePreparer 

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

DeletePreparer prepares the Delete request.

func (OutputsClient) DeleteResponder 

func (client OutputsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (OutputsClient) DeleteSender 

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

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

func (OutputsClient) Get 

func (client OutputsClient) Get(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. The name is case insensitive. jobName - the name of the streaming job. outputName - the name of the output.

func (OutputsClient) GetPreparer 

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

GetPreparer prepares the Get request.

func (OutputsClient) GetResponder 

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

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

func (OutputsClient) GetSender 

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

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

func (OutputsClient) ListByStreamingJob 

func (client OutputsClient) ListByStreamingJob(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. The name is case insensitive. 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 

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 

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (OutputsClient) ListByStreamingJobResponder 

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

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

func (OutputsClient) ListByStreamingJobSender 

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

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

func (OutputsClient) Test 

func (client OutputsClient) Test(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. The name is case insensitive. 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 

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 

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

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

func (OutputsClient) TestSender 

func (client OutputsClient) TestSender(req *http.Request) (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 

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. The name is case insensitive. 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 

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 

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

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

func (OutputsClient) UpdateSender 

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

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

type OutputsTestFuture 

type OutputsTestFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(OutputsClient) (ResourceTestStatus, error)
}

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

func (*OutputsTestFuture) UnmarshalJSON 

func (future *OutputsTestFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ParquetSerialization 

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

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

func (ParquetSerialization) AsAvroSerialization 

func (ps ParquetSerialization) AsAvroSerialization() (*AvroSerialization, bool)

AsAvroSerialization is the BasicSerialization implementation for ParquetSerialization.

func (ParquetSerialization) AsBasicSerialization 

func (ps ParquetSerialization) AsBasicSerialization() (BasicSerialization, bool)

AsBasicSerialization is the BasicSerialization implementation for ParquetSerialization.

func (ParquetSerialization) AsCsvSerialization 

func (ps ParquetSerialization) AsCsvSerialization() (*CsvSerialization, bool)

AsCsvSerialization is the BasicSerialization implementation for ParquetSerialization.

func (ParquetSerialization) AsCustomClrSerialization 

func (ps ParquetSerialization) AsCustomClrSerialization() (*CustomClrSerialization, bool)

AsCustomClrSerialization is the BasicSerialization implementation for ParquetSerialization.

func (ParquetSerialization) AsJSONSerialization 

func (ps ParquetSerialization) AsJSONSerialization() (*JSONSerialization, bool)

AsJSONSerialization is the BasicSerialization implementation for ParquetSerialization.

func (ParquetSerialization) AsParquetSerialization 

func (ps ParquetSerialization) AsParquetSerialization() (*ParquetSerialization, bool)

AsParquetSerialization is the BasicSerialization implementation for ParquetSerialization.

func (ParquetSerialization) AsSerialization 

func (ps ParquetSerialization) AsSerialization() (*Serialization, bool)

AsSerialization is the BasicSerialization implementation for ParquetSerialization.

func (ParquetSerialization) MarshalJSON 

func (ps ParquetSerialization) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ParquetSerialization.

type PowerBIOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

PowerBIOutputDataSource describes a Power BI output data source.

func (PowerBIOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureFunctionOutputDataSource 

func (pbods PowerBIOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureSynapseOutputDataSource 

func (pbods PowerBIOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsEventHubV2OutputDataSource 

func (pbods PowerBIOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for PowerBIOutputDataSource.

func (PowerBIOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for PowerBIOutputDataSource.

func (*PowerBIOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for PowerBIOutputDataSource struct.

type PowerBIOutputDataSourceProperties 

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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,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 PrivateEndpoint 

type PrivateEndpoint struct {
	autorest.Response `json:"-"`
	// Properties - The properties associated with a private endpoint.
	Properties *PrivateEndpointProperties `json:"properties,omitempty"`
	// Etag - READ-ONLY; Unique opaque string (generally a GUID) that represents the metadata state of the resource (private endpoint) and changes whenever the resource is updated. Required on PUT (CreateOrUpdate) requests.
	Etag *string `json:"etag,omitempty"`
	// ID - READ-ONLY; Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
	Type *string `json:"type,omitempty"`
}

PrivateEndpoint complete information about the private endpoint.

func (PrivateEndpoint) MarshalJSON 

func (peVar PrivateEndpoint) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpoint.

type PrivateEndpointListResult 

type PrivateEndpointListResult struct {
	autorest.Response `json:"-"`
	// Value - READ-ONLY; A list of private endpoints.
	Value *[]PrivateEndpoint `json:"value,omitempty"`
	// NextLink - READ-ONLY; The URL to fetch the next set of private endpoints.
	NextLink *string `json:"nextLink,omitempty"`
}

PrivateEndpointListResult a list of private endpoints.

func (PrivateEndpointListResult) IsEmpty 

func (pelr PrivateEndpointListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (PrivateEndpointListResult) MarshalJSON 

func (pelr PrivateEndpointListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointListResult.

type PrivateEndpointListResultIterator 

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

PrivateEndpointListResultIterator provides access to a complete listing of PrivateEndpoint values.

func NewPrivateEndpointListResultIterator 

func NewPrivateEndpointListResultIterator(page PrivateEndpointListResultPage) PrivateEndpointListResultIterator

Creates a new instance of the PrivateEndpointListResultIterator type.

func (*PrivateEndpointListResultIterator) Next 

func (iter *PrivateEndpointListResultIterator) 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 (*PrivateEndpointListResultIterator) NextWithContext 

func (iter *PrivateEndpointListResultIterator) 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 (PrivateEndpointListResultIterator) NotDone 

func (iter PrivateEndpointListResultIterator) NotDone() bool

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

func (PrivateEndpointListResultIterator) Response 

func (iter PrivateEndpointListResultIterator) Response() PrivateEndpointListResult

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

func (PrivateEndpointListResultIterator) Value 

func (iter PrivateEndpointListResultIterator) Value() PrivateEndpoint

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

type PrivateEndpointListResultPage 

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

PrivateEndpointListResultPage contains a page of PrivateEndpoint values.

func NewPrivateEndpointListResultPage 

func NewPrivateEndpointListResultPage(cur PrivateEndpointListResult, getNextPage func(context.Context, PrivateEndpointListResult) (PrivateEndpointListResult, error)) PrivateEndpointListResultPage

Creates a new instance of the PrivateEndpointListResultPage type.

func (*PrivateEndpointListResultPage) Next 

func (page *PrivateEndpointListResultPage) 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 (*PrivateEndpointListResultPage) NextWithContext 

func (page *PrivateEndpointListResultPage) 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 (PrivateEndpointListResultPage) NotDone 

func (page PrivateEndpointListResultPage) NotDone() bool

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

func (PrivateEndpointListResultPage) Response 

func (page PrivateEndpointListResultPage) Response() PrivateEndpointListResult

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

func (PrivateEndpointListResultPage) Values 

func (page PrivateEndpointListResultPage) Values() []PrivateEndpoint

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

type PrivateEndpointProperties 

type PrivateEndpointProperties struct {
	// CreatedDate - READ-ONLY; The date when this private endpoint was created.
	CreatedDate *string `json:"createdDate,omitempty"`
	// ManualPrivateLinkServiceConnections - A list of connections to the remote resource. Immutable after it is set.
	ManualPrivateLinkServiceConnections *[]PrivateLinkServiceConnection `json:"manualPrivateLinkServiceConnections,omitempty"`
}

PrivateEndpointProperties the properties associated with a private endpoint.

func (PrivateEndpointProperties) MarshalJSON 

func (pep PrivateEndpointProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointProperties.

type PrivateEndpointsClient 

type PrivateEndpointsClient struct {
	BaseClient
}

PrivateEndpointsClient is the stream Analytics Client

func NewPrivateEndpointsClient 

func NewPrivateEndpointsClient(subscriptionID string) PrivateEndpointsClient

NewPrivateEndpointsClient creates an instance of the PrivateEndpointsClient client.

func NewPrivateEndpointsClientWithBaseURI 

func NewPrivateEndpointsClientWithBaseURI(baseURI string, subscriptionID string) PrivateEndpointsClient

NewPrivateEndpointsClientWithBaseURI creates an instance of the PrivateEndpointsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (PrivateEndpointsClient) CreateOrUpdate 

func (client PrivateEndpointsClient) CreateOrUpdate(ctx context.Context, privateEndpoint PrivateEndpoint, resourceGroupName string, clusterName string, privateEndpointName string, ifMatch string, ifNoneMatch string) (result PrivateEndpoint, err error)

CreateOrUpdate creates a Stream Analytics Private Endpoint or replaces an already existing Private Endpoint. Parameters: privateEndpoint - the definition of the private endpoint that will be used to create a new cluster or replace the existing one. resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster. privateEndpointName - the name of the private endpoint. ifMatch - the ETag of the resource. 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 resource to be created, but to prevent updating an existing record set. Other values will result in a 412 Pre-condition Failed response.

func (PrivateEndpointsClient) CreateOrUpdatePreparer 

func (client PrivateEndpointsClient) CreateOrUpdatePreparer(ctx context.Context, privateEndpoint PrivateEndpoint, resourceGroupName string, clusterName string, privateEndpointName string, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (PrivateEndpointsClient) CreateOrUpdateResponder 

func (client PrivateEndpointsClient) CreateOrUpdateResponder(resp *http.Response) (result PrivateEndpoint, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (PrivateEndpointsClient) CreateOrUpdateSender 

func (client PrivateEndpointsClient) CreateOrUpdateSender(req *http.Request) (*http.Response, error)

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

func (PrivateEndpointsClient) Delete 

func (client PrivateEndpointsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointName string) (result PrivateEndpointsDeleteFuture, err error)

Delete delete the specified private endpoint. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster. privateEndpointName - the name of the private endpoint.

func (PrivateEndpointsClient) DeletePreparer 

func (client PrivateEndpointsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (PrivateEndpointsClient) DeleteResponder 

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

func (client PrivateEndpointsClient) DeleteSender(req *http.Request) (future PrivateEndpointsDeleteFuture, err error)

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

func (PrivateEndpointsClient) Get 

func (client PrivateEndpointsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointName string) (result PrivateEndpoint, err error)

Get gets information about the specified Private Endpoint. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster. privateEndpointName - the name of the private endpoint.

func (PrivateEndpointsClient) GetPreparer 

func (client PrivateEndpointsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (PrivateEndpointsClient) GetResponder 

func (client PrivateEndpointsClient) GetResponder(resp *http.Response) (result PrivateEndpoint, err error)

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

func (PrivateEndpointsClient) GetSender 

func (client PrivateEndpointsClient) 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 (PrivateEndpointsClient) ListByCluster 

func (client PrivateEndpointsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result PrivateEndpointListResultPage, err error)

ListByCluster lists the private endpoints in the cluster. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. clusterName - the name of the cluster.

func (PrivateEndpointsClient) ListByClusterComplete 

func (client PrivateEndpointsClient) ListByClusterComplete(ctx context.Context, resourceGroupName string, clusterName string) (result PrivateEndpointListResultIterator, err error)

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

func (PrivateEndpointsClient) ListByClusterPreparer 

func (client PrivateEndpointsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListByClusterPreparer prepares the ListByCluster request.

func (PrivateEndpointsClient) ListByClusterResponder 

func (client PrivateEndpointsClient) ListByClusterResponder(resp *http.Response) (result PrivateEndpointListResult, err error)

ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.

func (PrivateEndpointsClient) ListByClusterSender 

func (client PrivateEndpointsClient) ListByClusterSender(req *http.Request) (*http.Response, error)

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

type PrivateEndpointsDeleteFuture 

type PrivateEndpointsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(PrivateEndpointsClient) (autorest.Response, error)
}

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

func (*PrivateEndpointsDeleteFuture) UnmarshalJSON 

func (future *PrivateEndpointsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type PrivateLinkConnectionState 

type PrivateLinkConnectionState struct {
	// Status - READ-ONLY; Indicates whether the connection has been Approved/Rejected/Removed by the owner of the remote resource/service.
	Status *string `json:"status,omitempty"`
	// Description - READ-ONLY; The reason for approval/rejection of the connection.
	Description *string `json:"description,omitempty"`
	// ActionsRequired - READ-ONLY; A message indicating if changes on the service provider require any updates on the consumer.
	ActionsRequired *string `json:"actionsRequired,omitempty"`
}

PrivateLinkConnectionState a collection of read-only information about the state of the connection to the private remote resource.

func (PrivateLinkConnectionState) MarshalJSON 

func (plcs PrivateLinkConnectionState) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkConnectionState.

type PrivateLinkServiceConnection 

type PrivateLinkServiceConnection struct {
	// PrivateLinkServiceConnectionProperties - Bag of properties defining a privatelinkServiceConnection.
	*PrivateLinkServiceConnectionProperties `json:"properties,omitempty"`
}

PrivateLinkServiceConnection a grouping of information about the connection to the remote resource.

func (PrivateLinkServiceConnection) MarshalJSON 

func (plsc PrivateLinkServiceConnection) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkServiceConnection.

func (*PrivateLinkServiceConnection) UnmarshalJSON 

func (plsc *PrivateLinkServiceConnection) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for PrivateLinkServiceConnection struct.

type PrivateLinkServiceConnectionProperties 

type PrivateLinkServiceConnectionProperties struct {
	// PrivateLinkServiceID - The resource id of the private link service. Required on PUT (CreateOrUpdate) requests.
	PrivateLinkServiceID *string `json:"privateLinkServiceId,omitempty"`
	// GroupIds - The ID(s) of the group(s) obtained from the remote resource that this private endpoint should connect to. Required on PUT (CreateOrUpdate) requests.
	GroupIds *[]string `json:"groupIds,omitempty"`
	// RequestMessage - A message passed to the owner of the remote resource with this connection request. Restricted to 140 chars.
	RequestMessage *string `json:"requestMessage,omitempty"`
	// PrivateLinkServiceConnectionState - A collection of read-only information about the state of the connection to the private remote resource.
	PrivateLinkServiceConnectionState *PrivateLinkConnectionState `json:"privateLinkServiceConnectionState,omitempty"`
}

PrivateLinkServiceConnectionProperties bag of properties defining a privatelinkServiceConnection.

type ProxyResource 

type ProxyResource struct {
	// ID - READ-ONLY; Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
	Type *string `json:"type,omitempty"`
}

ProxyResource the resource model definition for a ARM proxy resource. It will have everything other than required location and tags

func (ProxyResource) MarshalJSON 

func (pr ProxyResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ProxyResource.

type ReferenceInputDataSource 

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

ReferenceInputDataSource describes an input data source that contains reference data.

func (ReferenceInputDataSource) AsAzureSQLReferenceInputDataSource 

func (rids ReferenceInputDataSource) AsAzureSQLReferenceInputDataSource() (*AzureSQLReferenceInputDataSource, bool)

AsAzureSQLReferenceInputDataSource is the BasicReferenceInputDataSource implementation for ReferenceInputDataSource.

func (ReferenceInputDataSource) AsBasicReferenceInputDataSource 

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

AsBasicReferenceInputDataSource is the BasicReferenceInputDataSource implementation for ReferenceInputDataSource.

func (ReferenceInputDataSource) AsBlobReferenceInputDataSource 

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

AsBlobReferenceInputDataSource is the BasicReferenceInputDataSource implementation for ReferenceInputDataSource.

func (ReferenceInputDataSource) AsReferenceInputDataSource 

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

AsReferenceInputDataSource is the BasicReferenceInputDataSource implementation for ReferenceInputDataSource.

func (ReferenceInputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for ReferenceInputDataSource.

type ReferenceInputProperties 

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"`
	Compression *Compression `json:"compression,omitempty"`
	// PartitionKey - partitionKey Describes a key in the input data which is used for partitioning the input data
	PartitionKey *string `json:"partitionKey,omitempty"`
	// Type - Possible values include: 'TypeInputProperties', 'TypeStream', 'TypeReference'
	Type TypeBasicInputProperties `json:"type,omitempty"`
}

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

func (ReferenceInputProperties) AsBasicInputProperties 

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

AsBasicInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) AsInputProperties 

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

AsInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) AsReferenceInputProperties 

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

AsReferenceInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) AsStreamInputProperties 

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

AsStreamInputProperties is the BasicInputProperties implementation for ReferenceInputProperties.

func (ReferenceInputProperties) MarshalJSON 

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

MarshalJSON is the custom marshaler for ReferenceInputProperties.

func (*ReferenceInputProperties) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for ReferenceInputProperties struct.

type Resource 

type Resource struct {
	// ID - READ-ONLY; Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
	Type *string `json:"type,omitempty"`
}

Resource ...

func (Resource) MarshalJSON 

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

MarshalJSON is the custom marshaler for Resource.

type ResourceTestStatus 

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.

func (ResourceTestStatus) MarshalJSON 

func (rts ResourceTestStatus) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ResourceTestStatus.

type ScalarFunctionProperties 

type ScalarFunctionProperties 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"`
	*FunctionConfiguration `json:"properties,omitempty"`
	// Type - Possible values include: 'TypeFunctionProperties', 'TypeScalar', 'TypeAggregate'
	Type TypeBasicFunctionProperties `json:"type,omitempty"`
}

ScalarFunctionProperties the properties that are associated with a scalar function.

func (ScalarFunctionProperties) AsAggregateFunctionProperties 

func (sfp ScalarFunctionProperties) AsAggregateFunctionProperties() (*AggregateFunctionProperties, bool)

AsAggregateFunctionProperties is the BasicFunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) AsBasicFunctionProperties 

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

AsBasicFunctionProperties is the BasicFunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) AsFunctionProperties 

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

AsFunctionProperties is the BasicFunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) AsScalarFunctionProperties 

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

AsScalarFunctionProperties is the BasicFunctionProperties implementation for ScalarFunctionProperties.

func (ScalarFunctionProperties) MarshalJSON 

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

MarshalJSON is the custom marshaler for ScalarFunctionProperties.

func (*ScalarFunctionProperties) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for ScalarFunctionProperties struct.

type Serialization 

type Serialization struct {
	// Type - Possible values include: 'TypeSerialization', 'TypeParquet', 'TypeCustomClr', 'TypeCsv', 'TypeJSON', 'TypeAvro'
	Type TypeBasicSerialization `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 

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

AsAvroSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsBasicSerialization 

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

AsBasicSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsCsvSerialization 

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

AsCsvSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsCustomClrSerialization 

func (s Serialization) AsCustomClrSerialization() (*CustomClrSerialization, bool)

AsCustomClrSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsJSONSerialization 

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

AsJSONSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsParquetSerialization 

func (s Serialization) AsParquetSerialization() (*ParquetSerialization, bool)

AsParquetSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) AsSerialization 

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

AsSerialization is the BasicSerialization implementation for Serialization.

func (Serialization) MarshalJSON 

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

MarshalJSON is the custom marshaler for Serialization.

type ServiceBusDataSourceProperties 

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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

type ServiceBusQueueOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

ServiceBusQueueOutputDataSource describes a Service Bus Queue output data source.

func (ServiceBusQueueOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureFunctionOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureSynapseOutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsEventHubV2OutputDataSource 

func (sbqods ServiceBusQueueOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusQueueOutputDataSource.

func (ServiceBusQueueOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for ServiceBusQueueOutputDataSource.

func (*ServiceBusQueueOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for ServiceBusQueueOutputDataSource struct.

type ServiceBusQueueOutputDataSourceProperties 

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"`
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns"`
	// 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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

func (ServiceBusQueueOutputDataSourceProperties) MarshalJSON 

func (sbqodsp ServiceBusQueueOutputDataSourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ServiceBusQueueOutputDataSourceProperties.

type ServiceBusTopicOutputDataSource 

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', 'TypeMicrosoftStorageBlob', 'TypeMicrosoftStorageTable', 'TypeMicrosoftServiceBusEventHub', 'TypeMicrosoftEventHubEventHub', 'TypeMicrosoftSQLServerDatabase', 'TypeMicrosoftSQLServerDataWarehouse', 'TypeMicrosoftStorageDocumentDB', 'TypeMicrosoftAzureFunction', 'TypeMicrosoftServiceBusQueue', 'TypeMicrosoftServiceBusTopic', 'TypePowerBI', 'TypeMicrosoftDataLakeAccounts'
	Type TypeBasicOutputDataSource `json:"type,omitempty"`
}

ServiceBusTopicOutputDataSource describes a Service Bus Topic output data source.

func (ServiceBusTopicOutputDataSource) AsAzureDataLakeStoreOutputDataSource 

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureFunctionOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsAzureFunctionOutputDataSource() (*AzureFunctionOutputDataSource, bool)

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureSQLDatabaseOutputDataSource 

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureSynapseOutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsAzureSynapseOutputDataSource() (*AzureSynapseOutputDataSource, bool)

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsAzureTableOutputDataSource 

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsBasicOutputDataSource 

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsBlobOutputDataSource 

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsDocumentDbOutputDataSource 

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsEventHubOutputDataSource 

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsEventHubV2OutputDataSource 

func (sbtods ServiceBusTopicOutputDataSource) AsEventHubV2OutputDataSource() (*EventHubV2OutputDataSource, bool)

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsOutputDataSource 

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

AsOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsPowerBIOutputDataSource 

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsServiceBusQueueOutputDataSource 

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) AsServiceBusTopicOutputDataSource 

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for ServiceBusTopicOutputDataSource.

func (ServiceBusTopicOutputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for ServiceBusTopicOutputDataSource.

func (*ServiceBusTopicOutputDataSource) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for ServiceBusTopicOutputDataSource struct.

type ServiceBusTopicOutputDataSourceProperties 

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"`
	SystemPropertyColumns map[string]*string `json:"systemPropertyColumns"`
	// 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"`
	// AuthenticationMode - Authentication Mode. Possible values include: 'Msi', 'UserToken', 'ConnectionString'
	AuthenticationMode AuthenticationMode `json:"authenticationMode,omitempty"`
}

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

func (ServiceBusTopicOutputDataSourceProperties) MarshalJSON 

func (sbtodsp ServiceBusTopicOutputDataSourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ServiceBusTopicOutputDataSourceProperties.

type StartStreamingJobParameters 

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 

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 

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

StreamInputDataSource describes an input data source that contains stream data.

func (StreamInputDataSource) AsBasicStreamInputDataSource 

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsBlobStreamInputDataSource 

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsEventHubStreamInputDataSource 

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsEventHubV2StreamInputDataSource 

func (sids StreamInputDataSource) AsEventHubV2StreamInputDataSource() (*EventHubV2StreamInputDataSource, bool)

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsIoTHubStreamInputDataSource 

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) AsStreamInputDataSource 

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for StreamInputDataSource.

func (StreamInputDataSource) MarshalJSON 

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

MarshalJSON is the custom marshaler for StreamInputDataSource.

type StreamInputProperties 

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"`
	Compression *Compression `json:"compression,omitempty"`
	// PartitionKey - partitionKey Describes a key in the input data which is used for partitioning the input data
	PartitionKey *string `json:"partitionKey,omitempty"`
	// Type - Possible values include: 'TypeInputProperties', 'TypeStream', 'TypeReference'
	Type TypeBasicInputProperties `json:"type,omitempty"`
}

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

func (StreamInputProperties) AsBasicInputProperties 

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

AsBasicInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) AsInputProperties 

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

AsInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) AsReferenceInputProperties 

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

AsReferenceInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) AsStreamInputProperties 

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

AsStreamInputProperties is the BasicInputProperties implementation for StreamInputProperties.

func (StreamInputProperties) MarshalJSON 

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

MarshalJSON is the custom marshaler for StreamInputProperties.

func (*StreamInputProperties) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for StreamInputProperties struct.

type StreamingJob 

type StreamingJob struct {
	autorest.Response `json:"-"`
	// StreamingJobProperties - The properties that are associated with a streaming job.  Required on PUT (CreateOrReplace) requests.
	*StreamingJobProperties `json:"properties,omitempty"`
	// Identity - Describes the system-assigned managed identity assigned to this job that can be used to authenticate with inputs and outputs.
	Identity *Identity `json:"identity,omitempty"`
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - The geo-location where the resource lives
	Location *string `json:"location,omitempty"`
	// ID - READ-ONLY; Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
	Type *string `json:"type,omitempty"`
}

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

func (StreamingJob) MarshalJSON 

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

MarshalJSON is the custom marshaler for StreamingJob.

func (*StreamingJob) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for StreamingJob struct.

type StreamingJobListResult 

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 

func (sjlr StreamingJobListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (StreamingJobListResult) MarshalJSON 

func (sjlr StreamingJobListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for StreamingJobListResult.

type StreamingJobListResultIterator 

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

StreamingJobListResultIterator provides access to a complete listing of StreamingJob values.

func NewStreamingJobListResultIterator 

func NewStreamingJobListResultIterator(page StreamingJobListResultPage) StreamingJobListResultIterator

Creates a new instance of the StreamingJobListResultIterator type.

func (*StreamingJobListResultIterator) Next 

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 

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 

func (iter StreamingJobListResultIterator) NotDone() bool

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

func (StreamingJobListResultIterator) Response 

func (iter StreamingJobListResultIterator) Response() StreamingJobListResult

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

func (StreamingJobListResultIterator) Value 

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 

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

StreamingJobListResultPage contains a page of StreamingJob values.

func NewStreamingJobListResultPage 

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

Creates a new instance of the StreamingJobListResultPage type.

func (*StreamingJobListResultPage) Next 

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 

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 

func (page StreamingJobListResultPage) NotDone() bool

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

func (StreamingJobListResultPage) Response 

func (page StreamingJobListResultPage) Response() StreamingJobListResult

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

func (StreamingJobListResultPage) Values 

func (page StreamingJobListResultPage) Values() []StreamingJob

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

type StreamingJobProperties 

type StreamingJobProperties struct {
	// Sku - Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.
	Sku *StreamingJobSku `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"`
	// JobType - Describes the type of the job. Valid modes are `Cloud` and 'Edge'. Possible values include: 'Cloud', 'Edge'
	JobType JobType `json:"jobType,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"`
	JobStorageAccount *JobStorageAccount `json:"jobStorageAccount,omitempty"`
	// ContentStoragePolicy - Valid values are JobStorageAccount and SystemAccount. If set to JobStorageAccount, this requires the user to also specify jobStorageAccount property. Possible values include: 'ContentStoragePolicySystemAccount', 'ContentStoragePolicyJobStorageAccount'
	ContentStoragePolicy ContentStoragePolicy `json:"contentStoragePolicy,omitempty"`
	// Externals - The storage account where the custom code artifacts are located.
	Externals *External `json:"externals,omitempty"`
	// Cluster - The cluster which streaming jobs will run on.
	Cluster *ClusterInfo `json:"cluster,omitempty"`
}

StreamingJobProperties the properties that are associated with a streaming job.

func (StreamingJobProperties) MarshalJSON 

func (sjp StreamingJobProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for StreamingJobProperties.

type StreamingJobSku 

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

StreamingJobSku the properties that are associated with a SKU.

type StreamingJobSkuName 

type StreamingJobSkuName string

StreamingJobSkuName enumerates the values for streaming job sku name. 

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

func PossibleStreamingJobSkuNameValues 

func PossibleStreamingJobSkuNameValues() []StreamingJobSkuName

PossibleStreamingJobSkuNameValues returns an array of possible values for the StreamingJobSkuName const type.

type StreamingJobsClient 

type StreamingJobsClient struct {
	BaseClient
}

StreamingJobsClient is the stream Analytics Client

func NewStreamingJobsClient 

func NewStreamingJobsClient(subscriptionID string) StreamingJobsClient

NewStreamingJobsClient creates an instance of the StreamingJobsClient client.

func NewStreamingJobsClientWithBaseURI 

func NewStreamingJobsClientWithBaseURI(baseURI string, subscriptionID string) StreamingJobsClient

NewStreamingJobsClientWithBaseURI creates an instance of the StreamingJobsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (StreamingJobsClient) CreateOrReplace 

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. The name is case insensitive. 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 

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 

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

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

func (StreamingJobsClient) CreateOrReplaceSender 

func (client StreamingJobsClient) CreateOrReplaceSender(req *http.Request) (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 

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. The name is case insensitive. jobName - the name of the streaming job.

func (StreamingJobsClient) DeletePreparer 

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

DeletePreparer prepares the Delete request.

func (StreamingJobsClient) DeleteResponder 

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

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (StreamingJobsClient) DeleteSender 

func (client StreamingJobsClient) DeleteSender(req *http.Request) (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 

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. The name is case insensitive. 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 

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

GetPreparer prepares the Get request.

func (StreamingJobsClient) GetResponder 

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

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

func (StreamingJobsClient) GetSender 

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

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

func (StreamingJobsClient) List 

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

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. The name is case insensitive. 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 

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 

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

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (StreamingJobsClient) ListByResourceGroupResponder 

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

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

func (StreamingJobsClient) ListByResourceGroupSender 

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

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

func (StreamingJobsClient) ListComplete 

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

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

func (StreamingJobsClient) ListPreparer 

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

ListPreparer prepares the List request.

func (StreamingJobsClient) ListResponder 

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

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

func (StreamingJobsClient) ListSender 

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

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

func (StreamingJobsClient) Start 

func (client StreamingJobsClient) Start(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. The name is case insensitive. jobName - the name of the streaming job. startJobParameters - parameters applicable to a start streaming job operation.

func (StreamingJobsClient) StartPreparer 

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

StartPreparer prepares the Start request.

func (StreamingJobsClient) StartResponder 

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

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

func (StreamingJobsClient) StartSender 

func (client StreamingJobsClient) StartSender(req *http.Request) (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 

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. The name is case insensitive. jobName - the name of the streaming job.

func (StreamingJobsClient) StopPreparer 

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

StopPreparer prepares the Stop request.

func (StreamingJobsClient) StopResponder 

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

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

func (StreamingJobsClient) StopSender 

func (client StreamingJobsClient) StopSender(req *http.Request) (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 

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. The name is case insensitive. 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 

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 

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

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

func (StreamingJobsClient) UpdateSender 

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

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

type StreamingJobsCreateOrReplaceFuture 

type StreamingJobsCreateOrReplaceFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(StreamingJobsClient) (StreamingJob, error)
}

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

func (*StreamingJobsCreateOrReplaceFuture) UnmarshalJSON 

func (future *StreamingJobsCreateOrReplaceFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type StreamingJobsDeleteFuture 

type StreamingJobsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(StreamingJobsClient) (autorest.Response, error)
}

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

func (*StreamingJobsDeleteFuture) UnmarshalJSON 

func (future *StreamingJobsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type StreamingJobsStartFuture 

type StreamingJobsStartFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(StreamingJobsClient) (autorest.Response, error)
}

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

func (*StreamingJobsStartFuture) UnmarshalJSON 

func (future *StreamingJobsStartFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type StreamingJobsStopFuture 

type StreamingJobsStopFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(StreamingJobsClient) (autorest.Response, error)
}

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

func (*StreamingJobsStopFuture) UnmarshalJSON 

func (future *StreamingJobsStopFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type SubResource 

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.

func (SubResource) MarshalJSON 

func (sr SubResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SubResource.

type SubscriptionQuota 

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 

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

MarshalJSON is the custom marshaler for SubscriptionQuota.

func (*SubscriptionQuota) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for SubscriptionQuota struct.

type SubscriptionQuotaProperties 

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.

func (SubscriptionQuotaProperties) MarshalJSON 

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

MarshalJSON is the custom marshaler for SubscriptionQuotaProperties.

type SubscriptionQuotasListResult 

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.

func (SubscriptionQuotasListResult) MarshalJSON 

func (sqlr SubscriptionQuotasListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SubscriptionQuotasListResult.

type SubscriptionsClient 

type SubscriptionsClient struct {
	BaseClient
}

SubscriptionsClient is the stream Analytics Client

func NewSubscriptionsClient 

func NewSubscriptionsClient(subscriptionID string) SubscriptionsClient

NewSubscriptionsClient creates an instance of the SubscriptionsClient client.

func NewSubscriptionsClientWithBaseURI 

func NewSubscriptionsClientWithBaseURI(baseURI string, subscriptionID string) SubscriptionsClient

NewSubscriptionsClientWithBaseURI creates an instance of the SubscriptionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (SubscriptionsClient) ListQuotas 

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 

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

ListQuotasPreparer prepares the ListQuotas request.

func (SubscriptionsClient) ListQuotasResponder 

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

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

func (SubscriptionsClient) ListQuotasSender 

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

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

type TrackedResource 

type TrackedResource struct {
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - The geo-location where the resource lives
	Location *string `json:"location,omitempty"`
	// ID - READ-ONLY; Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
	Type *string `json:"type,omitempty"`
}

TrackedResource the resource model definition for a ARM tracked top level resource

func (TrackedResource) MarshalJSON 

func (tr TrackedResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TrackedResource.

type Transformation 

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 

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

MarshalJSON is the custom marshaler for Transformation.

func (*Transformation) UnmarshalJSON 

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

UnmarshalJSON is the custom unmarshaler for Transformation struct.

type TransformationProperties 

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.

func (TransformationProperties) MarshalJSON 

func (tp TransformationProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TransformationProperties.

type TransformationsClient 

type TransformationsClient struct {
	BaseClient
}

TransformationsClient is the stream Analytics Client

func NewTransformationsClient 

func NewTransformationsClient(subscriptionID string) TransformationsClient

NewTransformationsClient creates an instance of the TransformationsClient client.

func NewTransformationsClientWithBaseURI 

func NewTransformationsClientWithBaseURI(baseURI string, subscriptionID string) TransformationsClient

NewTransformationsClientWithBaseURI creates an instance of the TransformationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (TransformationsClient) CreateOrReplace 

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. The name is case insensitive. 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 

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 

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

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

func (TransformationsClient) CreateOrReplaceSender 

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

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

func (TransformationsClient) Get 

func (client TransformationsClient) Get(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. The name is case insensitive. jobName - the name of the streaming job. transformationName - the name of the transformation.

func (TransformationsClient) GetPreparer 

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

GetPreparer prepares the Get request.

func (TransformationsClient) GetResponder 

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

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

func (TransformationsClient) GetSender 

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

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

func (TransformationsClient) Update 

func (client TransformationsClient) Update(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. The name is case insensitive. 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 

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 

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

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

func (TransformationsClient) UpdateSender 

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

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

type Type 

type Type string

Type enumerates the values for type. 

const (
	// TypeFunctionBinding ...
	TypeFunctionBinding Type = "FunctionBinding"
	// TypeMicrosoftMachineLearningServices ...
	TypeMicrosoftMachineLearningServices Type = "Microsoft.MachineLearningServices"
	// TypeMicrosoftMachineLearningWebService ...
	TypeMicrosoftMachineLearningWebService Type = "Microsoft.MachineLearning/WebService"
	// TypeMicrosoftStreamAnalyticsCLRUdf ...
	TypeMicrosoftStreamAnalyticsCLRUdf Type = "Microsoft.StreamAnalytics/CLRUdf"
	// TypeMicrosoftStreamAnalyticsJavascriptUdf ...
	TypeMicrosoftStreamAnalyticsJavascriptUdf Type = "Microsoft.StreamAnalytics/JavascriptUdf"
)

func PossibleTypeValues 

func PossibleTypeValues() []Type

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

type TypeBasicFunctionProperties 

type TypeBasicFunctionProperties string

TypeBasicFunctionProperties enumerates the values for type basic function properties. 

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

func PossibleTypeBasicFunctionPropertiesValues 

func PossibleTypeBasicFunctionPropertiesValues() []TypeBasicFunctionProperties

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

type TypeBasicInputProperties 

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 

func PossibleTypeBasicInputPropertiesValues() []TypeBasicInputProperties

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

type TypeBasicOutputDataSource 

type TypeBasicOutputDataSource string

TypeBasicOutputDataSource enumerates the values for type basic output data source. 

const (
	// TypeMicrosoftAzureFunction ...
	TypeMicrosoftAzureFunction TypeBasicOutputDataSource = "Microsoft.AzureFunction"
	// TypeMicrosoftDataLakeAccounts ...
	TypeMicrosoftDataLakeAccounts TypeBasicOutputDataSource = "Microsoft.DataLake/Accounts"
	// TypeMicrosoftEventHubEventHub ...
	TypeMicrosoftEventHubEventHub TypeBasicOutputDataSource = "Microsoft.EventHub/EventHub"
	// 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"
	// TypeMicrosoftSQLServerDataWarehouse ...
	TypeMicrosoftSQLServerDataWarehouse TypeBasicOutputDataSource = "Microsoft.Sql/Server/DataWarehouse"
	// 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 

func PossibleTypeBasicOutputDataSourceValues() []TypeBasicOutputDataSource

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

type TypeBasicReferenceInputDataSource 

type TypeBasicReferenceInputDataSource string

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

const (
	// TypeBasicReferenceInputDataSourceTypeMicrosoftSQLServerDatabase ...
	TypeBasicReferenceInputDataSourceTypeMicrosoftSQLServerDatabase TypeBasicReferenceInputDataSource = "Microsoft.Sql/Server/Database"
	// TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob ...
	TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob TypeBasicReferenceInputDataSource = "Microsoft.Storage/Blob"
	// TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource ...
	TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource TypeBasicReferenceInputDataSource = "ReferenceInputDataSource"
)

func PossibleTypeBasicReferenceInputDataSourceValues 

func PossibleTypeBasicReferenceInputDataSourceValues() []TypeBasicReferenceInputDataSource

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

type TypeBasicSerialization 

type TypeBasicSerialization string

TypeBasicSerialization enumerates the values for type basic serialization. 

const (
	// TypeAvro ...
	TypeAvro TypeBasicSerialization = "Avro"
	// TypeCsv ...
	TypeCsv TypeBasicSerialization = "Csv"
	// TypeCustomClr ...
	TypeCustomClr TypeBasicSerialization = "CustomClr"
	// TypeJSON ...
	TypeJSON TypeBasicSerialization = "Json"
	// TypeParquet ...
	TypeParquet TypeBasicSerialization = "Parquet"
	// TypeSerialization ...
	TypeSerialization TypeBasicSerialization = "Serialization"
)

func PossibleTypeBasicSerializationValues 

func PossibleTypeBasicSerializationValues() []TypeBasicSerialization

PossibleTypeBasicSerializationValues returns an array of possible values for the TypeBasicSerialization const type.

type TypeBasicStreamInputDataSource 

type TypeBasicStreamInputDataSource string

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

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

func PossibleTypeBasicStreamInputDataSourceValues 

func PossibleTypeBasicStreamInputDataSourceValues() []TypeBasicStreamInputDataSource

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

type UdfType 

type UdfType string

UdfType enumerates the values for udf type. 

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

func PossibleUdfTypeValues 

func PossibleUdfTypeValues() []UdfType

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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