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

package streamanalytics

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

Package streamanalytics implements the Azure ARM Streamanalytics service API version .

Stream Analytics Client

Index

Package Files

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

Constants

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

func UserAgent Uses

func UserAgent() string

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

func Version Uses

func Version() string

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

type AggregateFunctionProperties Uses

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 Uses

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

AsAggregateFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) AsBasicFunctionProperties Uses

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

AsBasicFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) AsFunctionProperties Uses

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

AsFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) AsScalarFunctionProperties Uses

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

AsScalarFunctionProperties is the BasicFunctionProperties implementation for AggregateFunctionProperties.

func (AggregateFunctionProperties) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AggregateFunctionProperties.

type AuthenticationMode Uses

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 Uses

func PossibleAuthenticationModeValues() []AuthenticationMode

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

type AvroSerialization Uses

type AvroSerialization struct {
    // Properties - The properties that are associated with the Avro serialization type. Required on PUT (CreateOrReplace) requests.
    Properties interface{} `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeSerialization', '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 Uses

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

AsAvroSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsBasicSerialization Uses

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

AsBasicSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsCsvSerialization Uses

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

AsCsvSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsCustomClrSerialization Uses

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

AsCustomClrSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsJSONSerialization Uses

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

AsJSONSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsParquetSerialization Uses

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

AsParquetSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) AsSerialization Uses

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

AsSerialization is the BasicSerialization implementation for AvroSerialization.

func (AvroSerialization) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AvroSerialization.

type AzureDataLakeStoreOutputDataSource Uses

type AzureDataLakeStoreOutputDataSource struct {
    // AzureDataLakeStoreOutputDataSourceProperties - The properties that are associated with an Azure Data Lake Store output. Required on PUT (CreateOrReplace) requests.
    *AzureDataLakeStoreOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', '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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureDataLakeStoreOutputDataSource.

func (AzureDataLakeStoreOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureDataLakeStoreOutputDataSource.

func (*AzureDataLakeStoreOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureDataLakeStoreOutputDataSource struct.

type AzureDataLakeStoreOutputDataSourceProperties Uses

type AzureDataLakeStoreOutputDataSourceProperties struct {
    // AccountName - The name of the Azure Data Lake Store account. Required on PUT (CreateOrReplace) requests.
    AccountName *string `json:"accountName,omitempty"`
    // TenantID - The tenant id of the user used to obtain the refresh token. Required on PUT (CreateOrReplace) requests.
    TenantID *string `json:"tenantId,omitempty"`
    // FilePathPrefix - The location of the file to which the output should be written to. Required on PUT (CreateOrReplace) requests.
    FilePathPrefix *string `json:"filePathPrefix,omitempty"`
    // DateFormat - The date format. Wherever {date} appears in filePathPrefix, the value of this property is used as the date format instead.
    DateFormat *string `json:"dateFormat,omitempty"`
    // TimeFormat - The time format. Wherever {time} appears in filePathPrefix, the value of this property is used as the time format instead.
    TimeFormat *string `json:"timeFormat,omitempty"`
    // 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 Uses

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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureFunctionOutputDataSource.

func (AzureFunctionOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureFunctionOutputDataSource.

func (*AzureFunctionOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureFunctionOutputDataSource struct.

type AzureFunctionOutputDataSourceProperties Uses

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 Uses

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 Uses

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

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsAzureMachineLearningStudioFunctionBinding Uses

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

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsBasicFunctionBinding Uses

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

AsBasicFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsCSharpFunctionBinding Uses

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

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsFunctionBinding Uses

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

AsFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) AsJavaScriptFunctionBinding Uses

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningServiceFunctionBinding.

func (AzureMachineLearningServiceFunctionBinding) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureMachineLearningServiceFunctionBinding.

func (*AzureMachineLearningServiceFunctionBinding) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningServiceFunctionBinding struct.

type AzureMachineLearningServiceFunctionBindingProperties Uses

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 Uses

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 Uses

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 Uses

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

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters Uses

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

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters Uses

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

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters Uses

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

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters Uses

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

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters.

func (*AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters struct.

type AzureMachineLearningServiceInputColumn Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsAzureMachineLearningStudioFunctionBinding Uses

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

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsBasicFunctionBinding Uses

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

AsBasicFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsCSharpFunctionBinding Uses

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

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsFunctionBinding Uses

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

AsFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) AsJavaScriptFunctionBinding Uses

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for AzureMachineLearningStudioFunctionBinding.

func (AzureMachineLearningStudioFunctionBinding) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureMachineLearningStudioFunctionBinding.

func (*AzureMachineLearningStudioFunctionBinding) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningStudioFunctionBinding struct.

type AzureMachineLearningStudioFunctionBindingProperties Uses

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 Uses

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 Uses

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 Uses

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

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters Uses

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

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters Uses

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

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters Uses

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

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters Uses

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

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters.

func (*AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters struct.

type AzureMachineLearningStudioInputColumn Uses

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 Uses

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 Uses

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 Uses

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

type AzureSQLDatabaseOutputDataSource struct {
    // AzureSQLDatabaseOutputDataSourceProperties - The properties that are associated with an Azure SQL database output. Required on PUT (CreateOrReplace) requests.
    *AzureSQLDatabaseOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', '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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureSQLDatabaseOutputDataSource.

func (AzureSQLDatabaseOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureSQLDatabaseOutputDataSource.

func (*AzureSQLDatabaseOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureSQLDatabaseOutputDataSource struct.

type AzureSQLDatabaseOutputDataSourceProperties Uses

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

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 Uses

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

AsAzureSQLReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) AsBasicReferenceInputDataSource Uses

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

AsBasicReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) AsBlobReferenceInputDataSource Uses

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

AsBlobReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) AsReferenceInputDataSource Uses

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

AsReferenceInputDataSource is the BasicReferenceInputDataSource implementation for AzureSQLReferenceInputDataSource.

func (AzureSQLReferenceInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureSQLReferenceInputDataSource.

type AzureSQLReferenceInputDataSourceProperties Uses

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 Uses

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 Uses

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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureSynapseOutputDataSource.

func (AzureSynapseOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureSynapseOutputDataSource.

func (*AzureSynapseOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureSynapseOutputDataSource struct.

type AzureSynapseOutputDataSourceProperties Uses

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 Uses

type AzureTableOutputDataSource struct {
    // AzureTableOutputDataSourceProperties - The properties that are associated with an Azure Table output. Required on PUT (CreateOrReplace) requests.
    *AzureTableOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', '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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for AzureTableOutputDataSource.

func (AzureTableOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for AzureTableOutputDataSource.

func (*AzureTableOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for AzureTableOutputDataSource struct.

type AzureTableOutputDataSourceProperties Uses

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

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

type BaseClient Uses

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

BaseClient is the base client for Streamanalytics.

func New Uses

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI Uses

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client 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 Uses

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 Uses

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

BasicFunctionProperties the properties that are associated with a function.

type BasicFunctionRetrieveDefaultDefinitionParameters Uses

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 Uses

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

BasicInputProperties the properties that are associated with an input.

type BasicOutputDataSource Uses

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 Uses

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

BasicReferenceInputDataSource describes an input data source that contains reference data.

type BasicSerialization Uses

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 Uses

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 Uses

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 Uses

func PossibleBindingTypeValues() []BindingType

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

type BlobDataSourceProperties Uses

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

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

type BlobOutputDataSource Uses

type BlobOutputDataSource struct {
    // BlobOutputDataSourceProperties - The properties that are associated with a blob output. Required on PUT (CreateOrReplace) requests.
    *BlobOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', '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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for BlobOutputDataSource.

func (BlobOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for BlobOutputDataSource.

func (*BlobOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for BlobOutputDataSource struct.

type BlobOutputDataSourceProperties Uses

type BlobOutputDataSourceProperties struct {
    // 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 Uses

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

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

func (BlobReferenceInputDataSource) AsAzureSQLReferenceInputDataSource Uses

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

AsAzureSQLReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsBasicReferenceInputDataSource Uses

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

AsBasicReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsBlobReferenceInputDataSource Uses

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

AsBlobReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) AsReferenceInputDataSource Uses

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

AsReferenceInputDataSource is the BasicReferenceInputDataSource implementation for BlobReferenceInputDataSource.

func (BlobReferenceInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for BlobReferenceInputDataSource.

func (*BlobReferenceInputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for BlobReferenceInputDataSource struct.

type BlobReferenceInputDataSourceProperties Uses

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

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

type BlobStreamInputDataSource Uses

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

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

func (BlobStreamInputDataSource) AsBasicStreamInputDataSource Uses

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsBlobStreamInputDataSource Uses

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsEventHubStreamInputDataSource Uses

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsEventHubV2StreamInputDataSource Uses

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

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsIoTHubStreamInputDataSource Uses

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) AsStreamInputDataSource Uses

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for BlobStreamInputDataSource.

func (BlobStreamInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for BlobStreamInputDataSource.

func (*BlobStreamInputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for BlobStreamInputDataSource struct.

type BlobStreamInputDataSourceProperties Uses

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

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

type CSharpFunctionBinding Uses

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 Uses

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

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsAzureMachineLearningStudioFunctionBinding Uses

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

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsBasicFunctionBinding Uses

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

AsBasicFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsCSharpFunctionBinding Uses

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

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsFunctionBinding Uses

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

AsFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) AsJavaScriptFunctionBinding Uses

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for CSharpFunctionBinding.

func (CSharpFunctionBinding) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for CSharpFunctionBinding.

func (*CSharpFunctionBinding) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for CSharpFunctionBinding struct.

type CSharpFunctionBindingProperties Uses

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 Uses

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 Uses

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 Uses

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

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters Uses

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

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters Uses

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

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters Uses

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

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters Uses

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

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (CSharpFunctionRetrieveDefaultDefinitionParameters) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for CSharpFunctionRetrieveDefaultDefinitionParameters.

func (*CSharpFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for CSharpFunctionRetrieveDefaultDefinitionParameters struct.

type Cluster Uses

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 Uses

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

MarshalJSON is the custom marshaler for Cluster.

type ClusterInfo Uses

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 Uses

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 Uses

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

MarshalJSON is the custom marshaler for ClusterJob.

type ClusterJobListResult Uses

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 Uses

func (cjlr ClusterJobListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type ClusterJobListResultIterator Uses

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

ClusterJobListResultIterator provides access to a complete listing of ClusterJob values.

func NewClusterJobListResultIterator Uses

func NewClusterJobListResultIterator(page ClusterJobListResultPage) ClusterJobListResultIterator

Creates a new instance of the ClusterJobListResultIterator type.

func (*ClusterJobListResultIterator) Next Uses

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 Uses

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 Uses

func (iter ClusterJobListResultIterator) NotDone() bool

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

func (ClusterJobListResultIterator) Response Uses

func (iter ClusterJobListResultIterator) Response() ClusterJobListResult

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

func (ClusterJobListResultIterator) Value Uses

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 Uses

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

ClusterJobListResultPage contains a page of ClusterJob values.

func NewClusterJobListResultPage Uses

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

Creates a new instance of the ClusterJobListResultPage type.

func (*ClusterJobListResultPage) Next Uses

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 Uses

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 Uses

func (page ClusterJobListResultPage) NotDone() bool

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

func (ClusterJobListResultPage) Response Uses

func (page ClusterJobListResultPage) Response() ClusterJobListResult

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

func (ClusterJobListResultPage) Values Uses

func (page ClusterJobListResultPage) Values() []ClusterJob

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

type ClusterListResult Uses

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 Uses

func (clr ClusterListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type ClusterListResultIterator Uses

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

ClusterListResultIterator provides access to a complete listing of Cluster values.

func NewClusterListResultIterator Uses

func NewClusterListResultIterator(page ClusterListResultPage) ClusterListResultIterator

Creates a new instance of the ClusterListResultIterator type.

func (*ClusterListResultIterator) Next Uses

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 Uses

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 Uses

func (iter ClusterListResultIterator) NotDone() bool

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

func (ClusterListResultIterator) Response Uses

func (iter ClusterListResultIterator) Response() ClusterListResult

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

func (ClusterListResultIterator) Value Uses

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 Uses

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

ClusterListResultPage contains a page of Cluster values.

func NewClusterListResultPage Uses

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

Creates a new instance of the ClusterListResultPage type.

func (*ClusterListResultPage) Next Uses

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 Uses

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 Uses

func (page ClusterListResultPage) NotDone() bool

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

func (ClusterListResultPage) Response Uses

func (page ClusterListResultPage) Response() ClusterListResult

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

func (ClusterListResultPage) Values Uses

func (page ClusterListResultPage) Values() []Cluster

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

type ClusterProperties Uses

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 Uses

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

MarshalJSON is the custom marshaler for ClusterProperties.

type ClusterProvisioningState Uses

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 Uses

func PossibleClusterProvisioningStateValues() []ClusterProvisioningState

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

type ClusterSku Uses

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 Uses

type ClusterSkuName string

ClusterSkuName enumerates the values for cluster sku name.

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

func PossibleClusterSkuNameValues Uses

func PossibleClusterSkuNameValues() []ClusterSkuName

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

type ClustersClient Uses

type ClustersClient struct {
    BaseClient
}

ClustersClient is the stream Analytics Client

func NewClustersClient Uses

func NewClustersClient(subscriptionID string) ClustersClient

NewClustersClient creates an instance of the ClustersClient client.

func NewClustersClientWithBaseURI Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

DeletePreparer prepares the Delete request.

func (ClustersClient) DeleteResponder Uses

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 Uses

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 Uses

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 Uses

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

GetPreparer prepares the Get request.

func (ClustersClient) GetResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListByResourceGroupPreparer prepares the ListByResourceGroup request.

func (ClustersClient) ListByResourceGroupResponder Uses

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 Uses

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 Uses

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

ListBySubscription lists all of the clusters in the given subscription.

func (ClustersClient) ListBySubscriptionComplete Uses

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

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

func (ClustersClient) ListBySubscriptionPreparer Uses

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

ListBySubscriptionPreparer prepares the ListBySubscription request.

func (ClustersClient) ListBySubscriptionResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

ListStreamingJobsPreparer prepares the ListStreamingJobs request.

func (ClustersClient) ListStreamingJobsResponder Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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.

type ClustersDeleteFuture Uses

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.

type ClustersUpdateFuture Uses

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.

type CompatibilityLevel Uses

type CompatibilityLevel string

CompatibilityLevel enumerates the values for compatibility level.

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

func PossibleCompatibilityLevelValues Uses

func PossibleCompatibilityLevelValues() []CompatibilityLevel

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

type Compression Uses

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

Compression describes how input data is compressed

type ContentStoragePolicy Uses

type ContentStoragePolicy string

ContentStoragePolicy enumerates the values for content storage policy.

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

func PossibleContentStoragePolicyValues Uses

func PossibleContentStoragePolicyValues() []ContentStoragePolicy

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

type CsvSerialization Uses

type CsvSerialization struct {
    // CsvSerializationProperties - The properties that are associated with the CSV serialization type. Required on PUT (CreateOrReplace) requests.
    *CsvSerializationProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeSerialization', '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 Uses

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

AsAvroSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsBasicSerialization Uses

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

AsBasicSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsCsvSerialization Uses

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

AsCsvSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsCustomClrSerialization Uses

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

AsCustomClrSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsJSONSerialization Uses

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

AsJSONSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsParquetSerialization Uses

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

AsParquetSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) AsSerialization Uses

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

AsSerialization is the BasicSerialization implementation for CsvSerialization.

func (CsvSerialization) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for CsvSerialization.

func (*CsvSerialization) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for CsvSerialization struct.

type CsvSerializationProperties Uses

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

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

type CustomClrSerialization Uses

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 Uses

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

AsAvroSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsBasicSerialization Uses

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

AsBasicSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsCsvSerialization Uses

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

AsCsvSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsCustomClrSerialization Uses

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

AsCustomClrSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsJSONSerialization Uses

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

AsJSONSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsParquetSerialization Uses

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

AsParquetSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) AsSerialization Uses

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

AsSerialization is the BasicSerialization implementation for CustomClrSerialization.

func (CustomClrSerialization) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for CustomClrSerialization.

func (*CustomClrSerialization) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for CustomClrSerialization struct.

type CustomClrSerializationProperties Uses

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 Uses

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

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

type Diagnostics Uses

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

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

type DocumentDbOutputDataSource Uses

type DocumentDbOutputDataSource struct {
    // DocumentDbOutputDataSourceProperties - The properties that are associated with a DocumentDB output. Required on PUT (CreateOrReplace) requests.
    *DocumentDbOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', '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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for DocumentDbOutputDataSource.

func (DocumentDbOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for DocumentDbOutputDataSource.

func (*DocumentDbOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for DocumentDbOutputDataSource struct.

type DocumentDbOutputDataSourceProperties Uses

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

DocumentDbOutputDataSourceProperties the properties that are associated with a DocumentDB output.

type Encoding Uses

type Encoding string

Encoding enumerates the values for encoding.

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

func PossibleEncodingValues Uses

func PossibleEncodingValues() []Encoding

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

type Error Uses

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

Error common error representation.

type ErrorDetails Uses

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 Uses

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 Uses

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

ErrorResponse describes the error that occurred.

type EventHubDataSourceProperties Uses

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

type EventHubOutputDataSource struct {
    // EventHubOutputDataSourceProperties - The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.
    *EventHubOutputDataSourceProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeOutputDataSource', '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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for EventHubOutputDataSource.

func (EventHubOutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for EventHubOutputDataSource.

func (*EventHubOutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for EventHubOutputDataSource struct.

type EventHubOutputDataSourceProperties Uses

type EventHubOutputDataSourceProperties struct {
    // PartitionKey - The key/column that is used to determine to which partition to send event data.
    PartitionKey    *string   `json:"partitionKey,omitempty"`
    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 Uses

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

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

func (EventHubStreamInputDataSource) AsBasicStreamInputDataSource Uses

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsBlobStreamInputDataSource Uses

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsEventHubStreamInputDataSource Uses

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsEventHubV2StreamInputDataSource Uses

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

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsIoTHubStreamInputDataSource Uses

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) AsStreamInputDataSource Uses

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubStreamInputDataSource.

func (EventHubStreamInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for EventHubStreamInputDataSource.

func (*EventHubStreamInputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for EventHubStreamInputDataSource struct.

type EventHubStreamInputDataSourceProperties Uses

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

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 Uses

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

AsAzureDataLakeStoreOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureFunctionOutputDataSource Uses

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

AsAzureFunctionOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureSQLDatabaseOutputDataSource Uses

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

AsAzureSQLDatabaseOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureSynapseOutputDataSource Uses

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

AsAzureSynapseOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsAzureTableOutputDataSource Uses

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

AsAzureTableOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsBasicOutputDataSource Uses

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

AsBasicOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsBlobOutputDataSource Uses

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

AsBlobOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsDocumentDbOutputDataSource Uses

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

AsDocumentDbOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsEventHubOutputDataSource Uses

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

AsEventHubOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsEventHubV2OutputDataSource Uses

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

AsEventHubV2OutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsOutputDataSource Uses

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

AsOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsPowerBIOutputDataSource Uses

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

AsPowerBIOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsServiceBusQueueOutputDataSource Uses

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

AsServiceBusQueueOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) AsServiceBusTopicOutputDataSource Uses

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

AsServiceBusTopicOutputDataSource is the BasicOutputDataSource implementation for EventHubV2OutputDataSource.

func (EventHubV2OutputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for EventHubV2OutputDataSource.

func (*EventHubV2OutputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for EventHubV2OutputDataSource struct.

type EventHubV2StreamInputDataSource Uses

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 Uses

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsBlobStreamInputDataSource Uses

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsEventHubStreamInputDataSource Uses

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsEventHubV2StreamInputDataSource Uses

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

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsIoTHubStreamInputDataSource Uses

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) AsStreamInputDataSource Uses

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for EventHubV2StreamInputDataSource.

func (EventHubV2StreamInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for EventHubV2StreamInputDataSource.

func (*EventHubV2StreamInputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for EventHubV2StreamInputDataSource struct.

type EventSerializationType Uses

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 Uses

func PossibleEventSerializationTypeValues() []EventSerializationType

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

type EventsOutOfOrderPolicy Uses

type EventsOutOfOrderPolicy string

EventsOutOfOrderPolicy enumerates the values for events out of order policy.

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

func PossibleEventsOutOfOrderPolicyValues Uses

func PossibleEventsOutOfOrderPolicyValues() []EventsOutOfOrderPolicy

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

type External Uses

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 Uses

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

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

func (Function) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for Function.

func (*Function) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for Function struct.

type FunctionBinding Uses

type FunctionBinding struct {
    // Type - Possible values include: 'TypeFunctionBinding', '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 Uses

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

AsAzureMachineLearningServiceFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsAzureMachineLearningStudioFunctionBinding Uses

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

AsAzureMachineLearningStudioFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsBasicFunctionBinding Uses

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

AsBasicFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsCSharpFunctionBinding Uses

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

AsCSharpFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsFunctionBinding Uses

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

AsFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) AsJavaScriptFunctionBinding Uses

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

AsJavaScriptFunctionBinding is the BasicFunctionBinding implementation for FunctionBinding.

func (FunctionBinding) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for FunctionBinding.

type FunctionConfiguration Uses

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

FunctionConfiguration ...

func (*FunctionConfiguration) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for FunctionConfiguration struct.

type FunctionInput Uses

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

FunctionInput describes one input parameter of a function.

type FunctionListResult Uses

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

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

func (FunctionListResult) IsEmpty Uses

func (flr FunctionListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type FunctionListResultIterator Uses

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

FunctionListResultIterator provides access to a complete listing of Function values.

func NewFunctionListResultIterator Uses

func NewFunctionListResultIterator(page FunctionListResultPage) FunctionListResultIterator

Creates a new instance of the FunctionListResultIterator type.

func (*FunctionListResultIterator) Next Uses

func (iter *FunctionListResultIterator) Next() error

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

func (*FunctionListResultIterator) NextWithContext Uses

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

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

func (FunctionListResultIterator) NotDone Uses

func (iter FunctionListResultIterator) NotDone() bool

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

func (FunctionListResultIterator) Response Uses

func (iter FunctionListResultIterator) Response() FunctionListResult

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

func (FunctionListResultIterator) Value Uses

func (iter FunctionListResultIterator) Value() Function

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

type FunctionListResultPage Uses

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

FunctionListResultPage contains a page of Function values.

func NewFunctionListResultPage Uses

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

Creates a new instance of the FunctionListResultPage type.

func (*FunctionListResultPage) Next Uses

func (page *FunctionListResultPage) Next() error

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

func (*FunctionListResultPage) NextWithContext Uses

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

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

func (FunctionListResultPage) NotDone Uses

func (page FunctionListResultPage) NotDone() bool

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

func (FunctionListResultPage) Response Uses

func (page FunctionListResultPage) Response() FunctionListResult

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

func (FunctionListResultPage) Values Uses

func (page FunctionListResultPage) Values() []Function

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

type FunctionOutput Uses

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

FunctionOutput describes the output of a function.

type FunctionProperties Uses

type FunctionProperties struct {
    // Etag - READ-ONLY; The current entity tag for the function. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.
    Etag                   *string `json:"etag,omitempty"`
    *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 Uses

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

AsAggregateFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsBasicFunctionProperties Uses

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

AsBasicFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsFunctionProperties Uses

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

AsFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) AsScalarFunctionProperties Uses

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

AsScalarFunctionProperties is the BasicFunctionProperties implementation for FunctionProperties.

func (FunctionProperties) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for FunctionProperties.

func (*FunctionProperties) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for FunctionProperties struct.

type FunctionRetrieveDefaultDefinitionParameters Uses

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 Uses

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

AsAzureMachineLearningServiceFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters Uses

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

AsAzureMachineLearningStudioFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters Uses

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

AsBasicFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsCSharpFunctionRetrieveDefaultDefinitionParameters Uses

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

AsCSharpFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters Uses

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

AsFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters Uses

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

AsJavaScriptFunctionRetrieveDefaultDefinitionParameters is the BasicFunctionRetrieveDefaultDefinitionParameters implementation for FunctionRetrieveDefaultDefinitionParameters.

func (FunctionRetrieveDefaultDefinitionParameters) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for FunctionRetrieveDefaultDefinitionParameters.

type FunctionsClient Uses

type FunctionsClient struct {
    BaseClient
}

FunctionsClient is the stream Analytics Client

func NewFunctionsClient Uses

func NewFunctionsClient(subscriptionID string) FunctionsClient

NewFunctionsClient creates an instance of the FunctionsClient client.

func NewFunctionsClientWithBaseURI Uses

func NewFunctionsClientWithBaseURI(baseURI string, subscriptionID string) FunctionsClient

NewFunctionsClientWithBaseURI creates an instance of the FunctionsClient client 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 Uses

func (client FunctionsClient) CreateOrReplace(ctx context.Context, function Function, resourceGroupName string, jobName string, functionName string, ifMatch string, ifNoneMatch string) (result Function, err error)

CreateOrReplace creates a function or replaces an already existing function under an existing streaming job. Parameters: function - the definition of the function that will be used to create a new function or replace the existing one under the streaming job. resourceGroupName - the name of the resource group. 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 Uses

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

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (FunctionsClient) CreateOrReplaceResponder Uses

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

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

func (FunctionsClient) CreateOrReplaceSender Uses

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

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

func (FunctionsClient) Delete Uses

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

Delete deletes a function from the streaming job. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. jobName - the name of the streaming job. functionName - the name of the function.

func (FunctionsClient) DeletePreparer Uses

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

DeletePreparer prepares the Delete request.

func (FunctionsClient) DeleteResponder Uses

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

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

func (FunctionsClient) DeleteSender Uses

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

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

func (FunctionsClient) Get Uses

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

Get gets details about the specified function. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. jobName - the name of the streaming job. functionName - the name of the function.

func (FunctionsClient) GetPreparer Uses

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

GetPreparer prepares the Get request.

func (FunctionsClient) GetResponder Uses

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

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

func (FunctionsClient) GetSender Uses

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

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

func (FunctionsClient) ListByStreamingJob Uses

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

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

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

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

func (FunctionsClient) ListByStreamingJobPreparer Uses

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (FunctionsClient) ListByStreamingJobResponder Uses

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

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

func (FunctionsClient) ListByStreamingJobSender Uses

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

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

func (FunctionsClient) RetrieveDefaultDefinition Uses

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

RetrieveDefaultDefinition retrieves the default definition of a function based on the parameters specified. Parameters: resourceGroupName - the name of the resource group. 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 Uses

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

RetrieveDefaultDefinitionPreparer prepares the RetrieveDefaultDefinition request.

func (FunctionsClient) RetrieveDefaultDefinitionResponder Uses

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

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

func (FunctionsClient) RetrieveDefaultDefinitionSender Uses

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

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

func (FunctionsClient) Test Uses

func (client FunctionsClient) Test(ctx context.Context, resourceGroupName string, jobName string, functionName string, function *Function) (result FunctionsTestFuture, err error)

Test tests if the information provided for a function is valid. This can range from testing the connection to the underlying web service behind the function or making sure the function code provided is syntactically correct. Parameters: resourceGroupName - the name of the resource group. 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 Uses

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

TestPreparer prepares the Test request.

func (FunctionsClient) TestResponder Uses

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

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

func (FunctionsClient) TestSender Uses

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

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

func (FunctionsClient) Update Uses

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

Update updates an existing function under an existing streaming job. This can be used to partially update (ie. update one or two properties) a function without affecting the rest the job or function definition. Parameters: function - a function object. The properties specified here will overwrite the corresponding properties in the existing function (ie. Those properties will be updated). Any properties that are set to null here will mean that the corresponding property in the existing function will remain the same and not change as a result of this PATCH operation. resourceGroupName - the name of the resource group. 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 Uses

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

UpdatePreparer prepares the Update request.

func (FunctionsClient) UpdateResponder Uses

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

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

func (FunctionsClient) UpdateSender Uses

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

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

type FunctionsTestFuture Uses

type FunctionsTestFuture struct {
    azure.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.

type Identity Uses

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 Uses

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

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

func (Input) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for Input.

func (*Input) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for Input struct.

type InputListResult Uses

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

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

func (InputListResult) IsEmpty Uses

func (ilr InputListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type InputListResultIterator Uses

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

InputListResultIterator provides access to a complete listing of Input values.

func NewInputListResultIterator Uses

func NewInputListResultIterator(page InputListResultPage) InputListResultIterator

Creates a new instance of the InputListResultIterator type.

func (*InputListResultIterator) Next Uses

func (iter *InputListResultIterator) Next() error

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

func (*InputListResultIterator) NextWithContext Uses

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

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

func (InputListResultIterator) NotDone Uses

func (iter InputListResultIterator) NotDone() bool

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

func (InputListResultIterator) Response Uses

func (iter InputListResultIterator) Response() InputListResult

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

func (InputListResultIterator) Value Uses

func (iter InputListResultIterator) Value() Input

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

type InputListResultPage Uses

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

InputListResultPage contains a page of Input values.

func NewInputListResultPage Uses

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

Creates a new instance of the InputListResultPage type.

func (*InputListResultPage) Next Uses

func (page *InputListResultPage) Next() error

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

func (*InputListResultPage) NextWithContext Uses

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

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

func (InputListResultPage) NotDone Uses

func (page InputListResultPage) NotDone() bool

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

func (InputListResultPage) Response Uses

func (page InputListResultPage) Response() InputListResult

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

func (InputListResultPage) Values Uses

func (page InputListResultPage) Values() []Input

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

type InputProperties Uses

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

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

AsBasicInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsInputProperties Uses

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

AsInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsReferenceInputProperties Uses

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

AsReferenceInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) AsStreamInputProperties Uses

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

AsStreamInputProperties is the BasicInputProperties implementation for InputProperties.

func (InputProperties) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for InputProperties.

func (*InputProperties) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for InputProperties struct.

type InputsClient Uses

type InputsClient struct {
    BaseClient
}

InputsClient is the stream Analytics Client

func NewInputsClient Uses

func NewInputsClient(subscriptionID string) InputsClient

NewInputsClient creates an instance of the InputsClient client.

func NewInputsClientWithBaseURI Uses

func NewInputsClientWithBaseURI(baseURI string, subscriptionID string) InputsClient

NewInputsClientWithBaseURI creates an instance of the InputsClient client 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 Uses

func (client InputsClient) CreateOrReplace(ctx context.Context, input Input, resourceGroupName string, jobName string, inputName string, ifMatch string, ifNoneMatch string) (result Input, err error)

CreateOrReplace creates an input or replaces an already existing input under an existing streaming job. Parameters: input - the definition of the input that will be used to create a new input or replace the existing one under the streaming job. resourceGroupName - the name of the resource group. 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 Uses

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

CreateOrReplacePreparer prepares the CreateOrReplace request.

func (InputsClient) CreateOrReplaceResponder Uses

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

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

func (InputsClient) CreateOrReplaceSender Uses

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

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

func (InputsClient) Delete Uses

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

Delete deletes an input from the streaming job. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. jobName - the name of the streaming job. inputName - the name of the input.

func (InputsClient) DeletePreparer Uses

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

DeletePreparer prepares the Delete request.

func (InputsClient) DeleteResponder Uses

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

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

func (InputsClient) DeleteSender Uses

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

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

func (InputsClient) Get Uses

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

Get gets details about the specified input. Parameters: resourceGroupName - the name of the resource group. The name is case insensitive. jobName - the name of the streaming job. inputName - the name of the input.

func (InputsClient) GetPreparer Uses

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

GetPreparer prepares the Get request.

func (InputsClient) GetResponder Uses

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

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

func (InputsClient) GetSender Uses

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

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

func (InputsClient) ListByStreamingJob Uses

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

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

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

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

func (InputsClient) ListByStreamingJobPreparer Uses

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

ListByStreamingJobPreparer prepares the ListByStreamingJob request.

func (InputsClient) ListByStreamingJobResponder Uses

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

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

func (InputsClient) ListByStreamingJobSender Uses

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

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

func (InputsClient) Test Uses

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

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

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

TestPreparer prepares the Test request.

func (InputsClient) TestResponder Uses

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

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

func (InputsClient) TestSender Uses

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

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

func (InputsClient) Update Uses

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

Update updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition. Parameters: input - an Input object. The properties specified here will overwrite the corresponding properties in the existing input (ie. Those properties will be updated). Any properties that are set to null here will mean that the corresponding property in the existing input will remain the same and not change as a result of this PATCH operation. resourceGroupName - the name of the resource group. 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 Uses

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

UpdatePreparer prepares the Update request.

func (InputsClient) UpdateResponder Uses

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

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

func (InputsClient) UpdateSender Uses

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

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

type InputsTestFuture Uses

type InputsTestFuture struct {
    azure.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.

type IoTHubStreamInputDataSource Uses

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

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

func (IoTHubStreamInputDataSource) AsBasicStreamInputDataSource Uses

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

AsBasicStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsBlobStreamInputDataSource Uses

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

AsBlobStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsEventHubStreamInputDataSource Uses

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

AsEventHubStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsEventHubV2StreamInputDataSource Uses

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

AsEventHubV2StreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsIoTHubStreamInputDataSource Uses

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

AsIoTHubStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) AsStreamInputDataSource Uses

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

AsStreamInputDataSource is the BasicStreamInputDataSource implementation for IoTHubStreamInputDataSource.

func (IoTHubStreamInputDataSource) MarshalJSON Uses

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

MarshalJSON is the custom marshaler for IoTHubStreamInputDataSource.

func (*IoTHubStreamInputDataSource) UnmarshalJSON Uses

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

UnmarshalJSON is the custom unmarshaler for IoTHubStreamInputDataSource struct.

type IoTHubStreamInputDataSourceProperties Uses

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

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

type JSONOutputSerializationFormat Uses

type JSONOutputSerializationFormat string

JSONOutputSerializationFormat enumerates the values for json output serialization format.

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

func PossibleJSONOutputSerializationFormatValues Uses

func PossibleJSONOutputSerializationFormatValues() []JSONOutputSerializationFormat

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

type JSONSerialization Uses

type JSONSerialization struct {
    // JSONSerializationProperties - The properties that are associated with the JSON serialization type. Required on PUT (CreateOrReplace) requests.
    *JSONSerializationProperties `json:"properties,omitempty"`
    // Type - Possible values include: 'TypeSerialization', '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 Uses

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

AsAvroSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsBasicSerialization Uses

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

AsBasicSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsCsvSerialization Uses

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

AsCsvSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsCustomClrSerialization Uses

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

AsCustomClrSerialization is the BasicSerialization implementation for JSONSerialization.

func (JSONSerialization) AsJSONSerialization Uses

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

AsJSONSerialization is the BasicSerialization implementation for JSONSerialization.