Versions in this module Expand all Collapse all v43 v43.3.0 Jun 19, 2020 v43.2.0 Jun 15, 2020 v43.1.0 Jun 9, 2020 v43.0.0 Jun 2, 2020 Changes in this version + const DefaultBaseURI + func UserAgent() string + func Version() string + type AvroSerialization struct + Properties interface{} + Type Type + func (as AvroSerialization) AsAvroSerialization() (*AvroSerialization, bool) + func (as AvroSerialization) AsBasicSerialization() (BasicSerialization, bool) + func (as AvroSerialization) AsCsvSerialization() (*CsvSerialization, bool) + func (as AvroSerialization) AsJSONSerialization() (*JSONSerialization, bool) + func (as AvroSerialization) AsSerialization() (*Serialization, bool) + func (as AvroSerialization) MarshalJSON() ([]byte, error) + type AzureDataLakeStoreOutputDataSource struct + Type TypeBasicOutputDataSource + func (adlsods *AzureDataLakeStoreOutputDataSource) UnmarshalJSON(body []byte) error + func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (adlsods AzureDataLakeStoreOutputDataSource) MarshalJSON() ([]byte, error) + type AzureDataLakeStoreOutputDataSourceProperties struct + AccountName *string + DateFormat *string + FilePathPrefix *string + RefreshToken *string + TenantID *string + TimeFormat *string + TokenUserDisplayName *string + TokenUserPrincipalName *string + type AzureMachineLearningWebServiceFunctionBinding struct + Type TypeBasicFunctionBinding + func (amlwsfb *AzureMachineLearningWebServiceFunctionBinding) UnmarshalJSON(body []byte) error + func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding() (*AzureMachineLearningWebServiceFunctionBinding, bool) + func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool) + func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsFunctionBinding() (*FunctionBinding, bool) + func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool) + func (amlwsfb AzureMachineLearningWebServiceFunctionBinding) MarshalJSON() ([]byte, error) + type AzureMachineLearningWebServiceFunctionBindingProperties struct + APIKey *string + BatchSize *int32 + Endpoint *string + Inputs *AzureMachineLearningWebServiceInputs + Outputs *[]AzureMachineLearningWebServiceOutputColumn + type AzureMachineLearningWebServiceFunctionBindingRetrievalProperties struct + ExecuteEndpoint *string + UdfType UdfType + type AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters struct + BindingType BindingType + func (amlwsfrddp *AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(body []byte) error + func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, ...) + func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool) + func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool) + func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool) + func (amlwsfrddp AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error) + type AzureMachineLearningWebServiceInputColumn struct + DataType *string + MapTo *int32 + Name *string + type AzureMachineLearningWebServiceInputs struct + ColumnNames *[]AzureMachineLearningWebServiceInputColumn + Name *string + type AzureMachineLearningWebServiceOutputColumn struct + DataType *string + Name *string + type AzureSQLDatabaseDataSourceProperties struct + Database *string + Password *string + Server *string + Table *string + User *string + type AzureSQLDatabaseOutputDataSource struct + Type TypeBasicOutputDataSource + func (asdods *AzureSQLDatabaseOutputDataSource) UnmarshalJSON(body []byte) error + func (asdods AzureSQLDatabaseOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (asdods AzureSQLDatabaseOutputDataSource) MarshalJSON() ([]byte, error) + type AzureSQLDatabaseOutputDataSourceProperties struct + Database *string + Password *string + Server *string + Table *string + User *string + type AzureTableOutputDataSource struct + Type TypeBasicOutputDataSource + func (atods *AzureTableOutputDataSource) UnmarshalJSON(body []byte) error + func (atods AzureTableOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (atods AzureTableOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (atods AzureTableOutputDataSource) MarshalJSON() ([]byte, error) + type AzureTableOutputDataSourceProperties struct + AccountKey *string + AccountName *string + BatchSize *int32 + ColumnsToRemove *[]string + PartitionKey *string + RowKey *string + Table *string + type BaseClient struct + BaseURI string + SubscriptionID string + func New(subscriptionID string) BaseClient + func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient + type BasicFunctionBinding interface + AsAzureMachineLearningWebServiceFunctionBinding func() (*AzureMachineLearningWebServiceFunctionBinding, bool) + AsFunctionBinding func() (*FunctionBinding, bool) + AsJavaScriptFunctionBinding func() (*JavaScriptFunctionBinding, bool) + type BasicFunctionProperties interface + AsFunctionProperties func() (*FunctionProperties, bool) + AsScalarFunctionProperties func() (*ScalarFunctionProperties, bool) + type BasicFunctionRetrieveDefaultDefinitionParameters interface + AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters func() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, ...) + AsFunctionRetrieveDefaultDefinitionParameters func() (*FunctionRetrieveDefaultDefinitionParameters, bool) + AsJavaScriptFunctionRetrieveDefaultDefinitionParameters func() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool) + type BasicInputProperties interface + AsInputProperties func() (*InputProperties, bool) + AsReferenceInputProperties func() (*ReferenceInputProperties, bool) + AsStreamInputProperties func() (*StreamInputProperties, bool) + type BasicOutputDataSource interface + AsAzureDataLakeStoreOutputDataSource func() (*AzureDataLakeStoreOutputDataSource, bool) + AsAzureSQLDatabaseOutputDataSource func() (*AzureSQLDatabaseOutputDataSource, bool) + AsAzureTableOutputDataSource func() (*AzureTableOutputDataSource, bool) + AsBlobOutputDataSource func() (*BlobOutputDataSource, bool) + AsDocumentDbOutputDataSource func() (*DocumentDbOutputDataSource, bool) + AsEventHubOutputDataSource func() (*EventHubOutputDataSource, bool) + AsOutputDataSource func() (*OutputDataSource, bool) + AsPowerBIOutputDataSource func() (*PowerBIOutputDataSource, bool) + AsServiceBusQueueOutputDataSource func() (*ServiceBusQueueOutputDataSource, bool) + AsServiceBusTopicOutputDataSource func() (*ServiceBusTopicOutputDataSource, bool) + type BasicReferenceInputDataSource interface + AsBlobReferenceInputDataSource func() (*BlobReferenceInputDataSource, bool) + AsReferenceInputDataSource func() (*ReferenceInputDataSource, bool) + type BasicSerialization interface + AsAvroSerialization func() (*AvroSerialization, bool) + AsCsvSerialization func() (*CsvSerialization, bool) + AsJSONSerialization func() (*JSONSerialization, bool) + AsSerialization func() (*Serialization, bool) + type BasicStreamInputDataSource interface + AsBlobStreamInputDataSource func() (*BlobStreamInputDataSource, bool) + AsEventHubStreamInputDataSource func() (*EventHubStreamInputDataSource, bool) + AsIoTHubStreamInputDataSource func() (*IoTHubStreamInputDataSource, bool) + AsStreamInputDataSource func() (*StreamInputDataSource, bool) + type BindingType string + const BindingTypeFunctionRetrieveDefaultDefinitionParameters + const BindingTypeMicrosoftMachineLearningWebService + const BindingTypeMicrosoftStreamAnalyticsJavascriptUdf + func PossibleBindingTypeValues() []BindingType + type BlobDataSourceProperties struct + Container *string + DateFormat *string + PathPattern *string + StorageAccounts *[]StorageAccount + TimeFormat *string + type BlobOutputDataSource struct + Type TypeBasicOutputDataSource + func (bods *BlobOutputDataSource) UnmarshalJSON(body []byte) error + func (bods BlobOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (bods BlobOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (bods BlobOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (bods BlobOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (bods BlobOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (bods BlobOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (bods BlobOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (bods BlobOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (bods BlobOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (bods BlobOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (bods BlobOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (bods BlobOutputDataSource) MarshalJSON() ([]byte, error) + type BlobOutputDataSourceProperties struct + Container *string + DateFormat *string + PathPattern *string + StorageAccounts *[]StorageAccount + TimeFormat *string + type BlobReferenceInputDataSource struct + Type TypeBasicReferenceInputDataSource + func (brids *BlobReferenceInputDataSource) UnmarshalJSON(body []byte) error + func (brids BlobReferenceInputDataSource) AsBasicReferenceInputDataSource() (BasicReferenceInputDataSource, bool) + func (brids BlobReferenceInputDataSource) AsBlobReferenceInputDataSource() (*BlobReferenceInputDataSource, bool) + func (brids BlobReferenceInputDataSource) AsReferenceInputDataSource() (*ReferenceInputDataSource, bool) + func (brids BlobReferenceInputDataSource) MarshalJSON() ([]byte, error) + type BlobReferenceInputDataSourceProperties struct + Container *string + DateFormat *string + PathPattern *string + StorageAccounts *[]StorageAccount + TimeFormat *string + type BlobStreamInputDataSource struct + Type TypeBasicStreamInputDataSource + func (bsids *BlobStreamInputDataSource) UnmarshalJSON(body []byte) error + func (bsids BlobStreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool) + func (bsids BlobStreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool) + func (bsids BlobStreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool) + func (bsids BlobStreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool) + func (bsids BlobStreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool) + func (bsids BlobStreamInputDataSource) MarshalJSON() ([]byte, error) + type BlobStreamInputDataSourceProperties struct + Container *string + DateFormat *string + PathPattern *string + SourcePartitionCount *int32 + StorageAccounts *[]StorageAccount + TimeFormat *string + type CompatibilityLevel string + const OneFullStopZero + func PossibleCompatibilityLevelValues() []CompatibilityLevel + type CsvSerialization struct + Type Type + func (cs *CsvSerialization) UnmarshalJSON(body []byte) error + func (cs CsvSerialization) AsAvroSerialization() (*AvroSerialization, bool) + func (cs CsvSerialization) AsBasicSerialization() (BasicSerialization, bool) + func (cs CsvSerialization) AsCsvSerialization() (*CsvSerialization, bool) + func (cs CsvSerialization) AsJSONSerialization() (*JSONSerialization, bool) + func (cs CsvSerialization) AsSerialization() (*Serialization, bool) + func (cs CsvSerialization) MarshalJSON() ([]byte, error) + type CsvSerializationProperties struct + Encoding Encoding + FieldDelimiter *string + type DiagnosticCondition struct + Code *string + Message *string + Since *string + type Diagnostics struct + Conditions *[]DiagnosticCondition + type DocumentDbOutputDataSource struct + Type TypeBasicOutputDataSource + func (ddods *DocumentDbOutputDataSource) UnmarshalJSON(body []byte) error + func (ddods DocumentDbOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (ddods DocumentDbOutputDataSource) MarshalJSON() ([]byte, error) + type DocumentDbOutputDataSourceProperties struct + AccountID *string + AccountKey *string + CollectionNamePattern *string + Database *string + DocumentID *string + PartitionKey *string + type Encoding string + const UTF8 + func PossibleEncodingValues() []Encoding + type ErrorResponse struct + Code *string + Message *string + type EventHubDataSourceProperties struct + EventHubName *string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type EventHubOutputDataSource struct + Type TypeBasicOutputDataSource + func (ehods *EventHubOutputDataSource) UnmarshalJSON(body []byte) error + func (ehods EventHubOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (ehods EventHubOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (ehods EventHubOutputDataSource) MarshalJSON() ([]byte, error) + type EventHubOutputDataSourceProperties struct + EventHubName *string + PartitionKey *string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type EventHubStreamInputDataSource struct + Type TypeBasicStreamInputDataSource + func (ehsids *EventHubStreamInputDataSource) UnmarshalJSON(body []byte) error + func (ehsids EventHubStreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool) + func (ehsids EventHubStreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool) + func (ehsids EventHubStreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool) + func (ehsids EventHubStreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool) + func (ehsids EventHubStreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool) + func (ehsids EventHubStreamInputDataSource) MarshalJSON() ([]byte, error) + type EventHubStreamInputDataSourceProperties struct + ConsumerGroupName *string + EventHubName *string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type EventsOutOfOrderPolicy string + const Adjust + const Drop + func PossibleEventsOutOfOrderPolicyValues() []EventsOutOfOrderPolicy + type Function struct + ID *string + Name *string + Properties BasicFunctionProperties + Type *string + func (f *Function) UnmarshalJSON(body []byte) error + type FunctionBinding struct + Type TypeBasicFunctionBinding + func (fb FunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding() (*AzureMachineLearningWebServiceFunctionBinding, bool) + func (fb FunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool) + func (fb FunctionBinding) AsFunctionBinding() (*FunctionBinding, bool) + func (fb FunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool) + func (fb FunctionBinding) MarshalJSON() ([]byte, error) + type FunctionInput struct + DataType *string + IsConfigurationParameter *bool + type FunctionListResult struct + NextLink *string + Value *[]Function + func (flr FunctionListResult) IsEmpty() bool + type FunctionListResultIterator struct + func NewFunctionListResultIterator(page FunctionListResultPage) FunctionListResultIterator + func (iter *FunctionListResultIterator) Next() error + func (iter *FunctionListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter FunctionListResultIterator) NotDone() bool + func (iter FunctionListResultIterator) Response() FunctionListResult + func (iter FunctionListResultIterator) Value() Function + type FunctionListResultPage struct + func NewFunctionListResultPage(...) FunctionListResultPage + func (page *FunctionListResultPage) Next() error + func (page *FunctionListResultPage) NextWithContext(ctx context.Context) (err error) + func (page FunctionListResultPage) NotDone() bool + func (page FunctionListResultPage) Response() FunctionListResult + func (page FunctionListResultPage) Values() []Function + type FunctionOutput struct + DataType *string + type FunctionProperties struct + Etag *string + Type TypeBasicFunctionProperties + func (fp FunctionProperties) AsBasicFunctionProperties() (BasicFunctionProperties, bool) + func (fp FunctionProperties) AsFunctionProperties() (*FunctionProperties, bool) + func (fp FunctionProperties) AsScalarFunctionProperties() (*ScalarFunctionProperties, bool) + func (fp FunctionProperties) MarshalJSON() ([]byte, error) + type FunctionRetrieveDefaultDefinitionParameters struct + BindingType BindingType + func (frddp FunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, ...) + func (frddp FunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool) + func (frddp FunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool) + func (frddp FunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool) + func (frddp FunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error) + type FunctionsClient struct + func NewFunctionsClient(subscriptionID string) FunctionsClient + func NewFunctionsClientWithBaseURI(baseURI string, subscriptionID string) FunctionsClient + func (client FunctionsClient) CreateOrReplace(ctx context.Context, function Function, resourceGroupName string, ...) (result Function, err error) + func (client FunctionsClient) CreateOrReplacePreparer(ctx context.Context, function Function, resourceGroupName string, ...) (*http.Request, error) + func (client FunctionsClient) CreateOrReplaceResponder(resp *http.Response) (result Function, err error) + func (client FunctionsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error) + func (client FunctionsClient) Delete(ctx context.Context, resourceGroupName string, jobName string, ...) (result autorest.Response, err error) + func (client FunctionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client FunctionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) + func (client FunctionsClient) DeleteSender(req *http.Request) (*http.Response, error) + func (client FunctionsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (result Function, err error) + func (client FunctionsClient) GetPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client FunctionsClient) GetResponder(resp *http.Response) (result Function, err error) + func (client FunctionsClient) GetSender(req *http.Request) (*http.Response, error) + func (client FunctionsClient) ListByStreamingJob(ctx context.Context, resourceGroupName string, jobName string, ...) (result FunctionListResultPage, err error) + func (client FunctionsClient) ListByStreamingJobComplete(ctx context.Context, resourceGroupName string, jobName string, ...) (result FunctionListResultIterator, err error) + func (client FunctionsClient) ListByStreamingJobPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client FunctionsClient) ListByStreamingJobResponder(resp *http.Response) (result FunctionListResult, err error) + func (client FunctionsClient) ListByStreamingJobSender(req *http.Request) (*http.Response, error) + func (client FunctionsClient) RetrieveDefaultDefinition(ctx context.Context, resourceGroupName string, jobName string, ...) (result Function, err error) + func (client FunctionsClient) RetrieveDefaultDefinitionPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client FunctionsClient) RetrieveDefaultDefinitionResponder(resp *http.Response) (result Function, err error) + func (client FunctionsClient) RetrieveDefaultDefinitionSender(req *http.Request) (*http.Response, error) + func (client FunctionsClient) Test(ctx context.Context, resourceGroupName string, jobName string, ...) (result FunctionsTestFuture, err error) + func (client FunctionsClient) TestPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client FunctionsClient) TestResponder(resp *http.Response) (result ResourceTestStatus, err error) + func (client FunctionsClient) TestSender(req *http.Request) (future FunctionsTestFuture, err error) + func (client FunctionsClient) Update(ctx context.Context, function Function, resourceGroupName string, ...) (result Function, err error) + func (client FunctionsClient) UpdatePreparer(ctx context.Context, function Function, resourceGroupName string, ...) (*http.Request, error) + func (client FunctionsClient) UpdateResponder(resp *http.Response) (result Function, err error) + func (client FunctionsClient) UpdateSender(req *http.Request) (*http.Response, error) + type FunctionsTestFuture struct + func (future *FunctionsTestFuture) Result(client FunctionsClient) (rts ResourceTestStatus, err error) + type Input struct + ID *string + Name *string + Properties BasicInputProperties + Type *string + func (i *Input) UnmarshalJSON(body []byte) error + type InputListResult struct + NextLink *string + Value *[]Input + func (ilr InputListResult) IsEmpty() bool + type InputListResultIterator struct + func NewInputListResultIterator(page InputListResultPage) InputListResultIterator + func (iter *InputListResultIterator) Next() error + func (iter *InputListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter InputListResultIterator) NotDone() bool + func (iter InputListResultIterator) Response() InputListResult + func (iter InputListResultIterator) Value() Input + type InputListResultPage struct + func NewInputListResultPage(getNextPage func(context.Context, InputListResult) (InputListResult, error)) InputListResultPage + func (page *InputListResultPage) Next() error + func (page *InputListResultPage) NextWithContext(ctx context.Context) (err error) + func (page InputListResultPage) NotDone() bool + func (page InputListResultPage) Response() InputListResult + func (page InputListResultPage) Values() []Input + type InputProperties struct + Diagnostics *Diagnostics + Etag *string + Serialization BasicSerialization + Type TypeBasicInputProperties + func (IP *InputProperties) UnmarshalJSON(body []byte) error + func (IP InputProperties) AsBasicInputProperties() (BasicInputProperties, bool) + func (IP InputProperties) AsInputProperties() (*InputProperties, bool) + func (IP InputProperties) AsReferenceInputProperties() (*ReferenceInputProperties, bool) + func (IP InputProperties) AsStreamInputProperties() (*StreamInputProperties, bool) + func (IP InputProperties) MarshalJSON() ([]byte, error) + type InputsClient struct + func NewInputsClient(subscriptionID string) InputsClient + func NewInputsClientWithBaseURI(baseURI string, subscriptionID string) InputsClient + func (client InputsClient) CreateOrReplace(ctx context.Context, input Input, resourceGroupName string, jobName string, ...) (result Input, err error) + func (client InputsClient) CreateOrReplacePreparer(ctx context.Context, input Input, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client InputsClient) CreateOrReplaceResponder(resp *http.Response) (result Input, err error) + func (client InputsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error) + func (client InputsClient) Delete(ctx context.Context, resourceGroupName string, jobName string, ...) (result autorest.Response, err error) + func (client InputsClient) DeletePreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client InputsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) + func (client InputsClient) DeleteSender(req *http.Request) (*http.Response, error) + func (client InputsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (result Input, err error) + func (client InputsClient) GetPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client InputsClient) GetResponder(resp *http.Response) (result Input, err error) + func (client InputsClient) GetSender(req *http.Request) (*http.Response, error) + func (client InputsClient) ListByStreamingJob(ctx context.Context, resourceGroupName string, jobName string, ...) (result InputListResultPage, err error) + func (client InputsClient) ListByStreamingJobComplete(ctx context.Context, resourceGroupName string, jobName string, ...) (result InputListResultIterator, err error) + func (client InputsClient) ListByStreamingJobPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client InputsClient) ListByStreamingJobResponder(resp *http.Response) (result InputListResult, err error) + func (client InputsClient) ListByStreamingJobSender(req *http.Request) (*http.Response, error) + func (client InputsClient) Test(ctx context.Context, resourceGroupName string, jobName string, ...) (result InputsTestFuture, err error) + func (client InputsClient) TestPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client InputsClient) TestResponder(resp *http.Response) (result ResourceTestStatus, err error) + func (client InputsClient) TestSender(req *http.Request) (future InputsTestFuture, err error) + func (client InputsClient) Update(ctx context.Context, input Input, resourceGroupName string, jobName string, ...) (result Input, err error) + func (client InputsClient) UpdatePreparer(ctx context.Context, input Input, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client InputsClient) UpdateResponder(resp *http.Response) (result Input, err error) + func (client InputsClient) UpdateSender(req *http.Request) (*http.Response, error) + type InputsTestFuture struct + func (future *InputsTestFuture) Result(client InputsClient) (rts ResourceTestStatus, err error) + type IoTHubStreamInputDataSource struct + Type TypeBasicStreamInputDataSource + func (ithsids *IoTHubStreamInputDataSource) UnmarshalJSON(body []byte) error + func (ithsids IoTHubStreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool) + func (ithsids IoTHubStreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool) + func (ithsids IoTHubStreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool) + func (ithsids IoTHubStreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool) + func (ithsids IoTHubStreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool) + func (ithsids IoTHubStreamInputDataSource) MarshalJSON() ([]byte, error) + type IoTHubStreamInputDataSourceProperties struct + ConsumerGroupName *string + Endpoint *string + IotHubNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type JSONOutputSerializationFormat string + const Array + const LineSeparated + func PossibleJSONOutputSerializationFormatValues() []JSONOutputSerializationFormat + type JSONSerialization struct + Type Type + func (js *JSONSerialization) UnmarshalJSON(body []byte) error + func (js JSONSerialization) AsAvroSerialization() (*AvroSerialization, bool) + func (js JSONSerialization) AsBasicSerialization() (BasicSerialization, bool) + func (js JSONSerialization) AsCsvSerialization() (*CsvSerialization, bool) + func (js JSONSerialization) AsJSONSerialization() (*JSONSerialization, bool) + func (js JSONSerialization) AsSerialization() (*Serialization, bool) + func (js JSONSerialization) MarshalJSON() ([]byte, error) + type JSONSerializationProperties struct + Encoding Encoding + Format JSONOutputSerializationFormat + type JavaScriptFunctionBinding struct + Type TypeBasicFunctionBinding + func (jsfb *JavaScriptFunctionBinding) UnmarshalJSON(body []byte) error + func (jsfb JavaScriptFunctionBinding) AsAzureMachineLearningWebServiceFunctionBinding() (*AzureMachineLearningWebServiceFunctionBinding, bool) + func (jsfb JavaScriptFunctionBinding) AsBasicFunctionBinding() (BasicFunctionBinding, bool) + func (jsfb JavaScriptFunctionBinding) AsFunctionBinding() (*FunctionBinding, bool) + func (jsfb JavaScriptFunctionBinding) AsJavaScriptFunctionBinding() (*JavaScriptFunctionBinding, bool) + func (jsfb JavaScriptFunctionBinding) MarshalJSON() ([]byte, error) + type JavaScriptFunctionBindingProperties struct + Script *string + type JavaScriptFunctionBindingRetrievalProperties struct + Script *string + UdfType UdfType + type JavaScriptFunctionRetrieveDefaultDefinitionParameters struct + BindingType BindingType + func (jsfrddp *JavaScriptFunctionRetrieveDefaultDefinitionParameters) UnmarshalJSON(body []byte) error + func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsAzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters() (*AzureMachineLearningWebServiceFunctionRetrieveDefaultDefinitionParameters, ...) + func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsBasicFunctionRetrieveDefaultDefinitionParameters() (BasicFunctionRetrieveDefaultDefinitionParameters, bool) + func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsFunctionRetrieveDefaultDefinitionParameters() (*FunctionRetrieveDefaultDefinitionParameters, bool) + func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) AsJavaScriptFunctionRetrieveDefaultDefinitionParameters() (*JavaScriptFunctionRetrieveDefaultDefinitionParameters, bool) + func (jsfrddp JavaScriptFunctionRetrieveDefaultDefinitionParameters) MarshalJSON() ([]byte, error) + type OAuthBasedDataSourceProperties struct + RefreshToken *string + TokenUserDisplayName *string + TokenUserPrincipalName *string + type Operation struct + Display *OperationDisplay + Name *string + type OperationDisplay struct + Description *string + Operation *string + Provider *string + Resource *string + type OperationListResult struct + NextLink *string + Value *[]Operation + func (olr OperationListResult) IsEmpty() bool + type OperationListResultIterator struct + func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator + func (iter *OperationListResultIterator) Next() error + func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter OperationListResultIterator) NotDone() bool + func (iter OperationListResultIterator) Response() OperationListResult + func (iter OperationListResultIterator) Value() Operation + type OperationListResultPage struct + func NewOperationListResultPage(...) OperationListResultPage + func (page *OperationListResultPage) Next() error + func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error) + func (page OperationListResultPage) NotDone() bool + func (page OperationListResultPage) Response() OperationListResult + func (page OperationListResultPage) Values() []Operation + type OperationsClient struct + func NewOperationsClient(subscriptionID string) OperationsClient + func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient + func (client OperationsClient) List(ctx context.Context) (result OperationListResultPage, err error) + func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error) + func (client OperationsClient) ListPreparer(ctx context.Context) (*http.Request, error) + func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error) + func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error) + type Output struct + ID *string + Name *string + Type *string + func (o *Output) UnmarshalJSON(body []byte) error + func (o Output) MarshalJSON() ([]byte, error) + type OutputDataSource struct + Type TypeBasicOutputDataSource + func (ods OutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (ods OutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (ods OutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (ods OutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (ods OutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (ods OutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (ods OutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (ods OutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (ods OutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (ods OutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (ods OutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (ods OutputDataSource) MarshalJSON() ([]byte, error) + type OutputErrorPolicy string + const OutputErrorPolicyDrop + const OutputErrorPolicyStop + func PossibleOutputErrorPolicyValues() []OutputErrorPolicy + type OutputListResult struct + NextLink *string + Value *[]Output + func (olr OutputListResult) IsEmpty() bool + type OutputListResultIterator struct + func NewOutputListResultIterator(page OutputListResultPage) OutputListResultIterator + func (iter *OutputListResultIterator) Next() error + func (iter *OutputListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter OutputListResultIterator) NotDone() bool + func (iter OutputListResultIterator) Response() OutputListResult + func (iter OutputListResultIterator) Value() Output + type OutputListResultPage struct + func NewOutputListResultPage(getNextPage func(context.Context, OutputListResult) (OutputListResult, error)) OutputListResultPage + func (page *OutputListResultPage) Next() error + func (page *OutputListResultPage) NextWithContext(ctx context.Context) (err error) + func (page OutputListResultPage) NotDone() bool + func (page OutputListResultPage) Response() OutputListResult + func (page OutputListResultPage) Values() []Output + type OutputProperties struct + Datasource BasicOutputDataSource + Diagnostics *Diagnostics + Etag *string + Serialization BasicSerialization + func (op *OutputProperties) UnmarshalJSON(body []byte) error + type OutputStartMode string + const CustomTime + const JobStartTime + const LastOutputEventTime + func PossibleOutputStartModeValues() []OutputStartMode + type OutputsClient struct + func NewOutputsClient(subscriptionID string) OutputsClient + func NewOutputsClientWithBaseURI(baseURI string, subscriptionID string) OutputsClient + func (client OutputsClient) CreateOrReplace(ctx context.Context, output Output, resourceGroupName string, jobName string, ...) (result Output, err error) + func (client OutputsClient) CreateOrReplacePreparer(ctx context.Context, output Output, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client OutputsClient) CreateOrReplaceResponder(resp *http.Response) (result Output, err error) + func (client OutputsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error) + func (client OutputsClient) Delete(ctx context.Context, resourceGroupName string, jobName string, ...) (result autorest.Response, err error) + func (client OutputsClient) DeletePreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client OutputsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) + func (client OutputsClient) DeleteSender(req *http.Request) (*http.Response, error) + func (client OutputsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (result Output, err error) + func (client OutputsClient) GetPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client OutputsClient) GetResponder(resp *http.Response) (result Output, err error) + func (client OutputsClient) GetSender(req *http.Request) (*http.Response, error) + func (client OutputsClient) ListByStreamingJob(ctx context.Context, resourceGroupName string, jobName string, ...) (result OutputListResultPage, err error) + func (client OutputsClient) ListByStreamingJobComplete(ctx context.Context, resourceGroupName string, jobName string, ...) (result OutputListResultIterator, err error) + func (client OutputsClient) ListByStreamingJobPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client OutputsClient) ListByStreamingJobResponder(resp *http.Response) (result OutputListResult, err error) + func (client OutputsClient) ListByStreamingJobSender(req *http.Request) (*http.Response, error) + func (client OutputsClient) Test(ctx context.Context, resourceGroupName string, jobName string, ...) (result OutputsTestFuture, err error) + func (client OutputsClient) TestPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client OutputsClient) TestResponder(resp *http.Response) (result ResourceTestStatus, err error) + func (client OutputsClient) TestSender(req *http.Request) (future OutputsTestFuture, err error) + func (client OutputsClient) Update(ctx context.Context, output Output, resourceGroupName string, jobName string, ...) (result Output, err error) + func (client OutputsClient) UpdatePreparer(ctx context.Context, output Output, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client OutputsClient) UpdateResponder(resp *http.Response) (result Output, err error) + func (client OutputsClient) UpdateSender(req *http.Request) (*http.Response, error) + type OutputsTestFuture struct + func (future *OutputsTestFuture) Result(client OutputsClient) (rts ResourceTestStatus, err error) + type PowerBIOutputDataSource struct + Type TypeBasicOutputDataSource + func (pbods *PowerBIOutputDataSource) UnmarshalJSON(body []byte) error + func (pbods PowerBIOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (pbods PowerBIOutputDataSource) MarshalJSON() ([]byte, error) + type PowerBIOutputDataSourceProperties struct + Dataset *string + GroupID *string + GroupName *string + RefreshToken *string + Table *string + TokenUserDisplayName *string + TokenUserPrincipalName *string + type ReferenceInputDataSource struct + Type TypeBasicReferenceInputDataSource + func (rids ReferenceInputDataSource) AsBasicReferenceInputDataSource() (BasicReferenceInputDataSource, bool) + func (rids ReferenceInputDataSource) AsBlobReferenceInputDataSource() (*BlobReferenceInputDataSource, bool) + func (rids ReferenceInputDataSource) AsReferenceInputDataSource() (*ReferenceInputDataSource, bool) + func (rids ReferenceInputDataSource) MarshalJSON() ([]byte, error) + type ReferenceInputProperties struct + Datasource BasicReferenceInputDataSource + Diagnostics *Diagnostics + Etag *string + Serialization BasicSerialization + Type TypeBasicInputProperties + func (rip *ReferenceInputProperties) UnmarshalJSON(body []byte) error + func (rip ReferenceInputProperties) AsBasicInputProperties() (BasicInputProperties, bool) + func (rip ReferenceInputProperties) AsInputProperties() (*InputProperties, bool) + func (rip ReferenceInputProperties) AsReferenceInputProperties() (*ReferenceInputProperties, bool) + func (rip ReferenceInputProperties) AsStreamInputProperties() (*StreamInputProperties, bool) + func (rip ReferenceInputProperties) MarshalJSON() ([]byte, error) + type Resource struct + ID *string + Location *string + Name *string + Tags map[string]*string + Type *string + func (r Resource) MarshalJSON() ([]byte, error) + type ResourceTestStatus struct + Error *ErrorResponse + Status *string + type ScalarFunctionConfiguration struct + Binding BasicFunctionBinding + Inputs *[]FunctionInput + Output *FunctionOutput + func (sfc *ScalarFunctionConfiguration) UnmarshalJSON(body []byte) error + type ScalarFunctionProperties struct + Etag *string + Type TypeBasicFunctionProperties + func (sfp *ScalarFunctionProperties) UnmarshalJSON(body []byte) error + func (sfp ScalarFunctionProperties) AsBasicFunctionProperties() (BasicFunctionProperties, bool) + func (sfp ScalarFunctionProperties) AsFunctionProperties() (*FunctionProperties, bool) + func (sfp ScalarFunctionProperties) AsScalarFunctionProperties() (*ScalarFunctionProperties, bool) + func (sfp ScalarFunctionProperties) MarshalJSON() ([]byte, error) + type Serialization struct + Type Type + func (s Serialization) AsAvroSerialization() (*AvroSerialization, bool) + func (s Serialization) AsBasicSerialization() (BasicSerialization, bool) + func (s Serialization) AsCsvSerialization() (*CsvSerialization, bool) + func (s Serialization) AsJSONSerialization() (*JSONSerialization, bool) + func (s Serialization) AsSerialization() (*Serialization, bool) + func (s Serialization) MarshalJSON() ([]byte, error) + type ServiceBusDataSourceProperties struct + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type ServiceBusQueueOutputDataSource struct + Type TypeBasicOutputDataSource + func (sbqods *ServiceBusQueueOutputDataSource) UnmarshalJSON(body []byte) error + func (sbqods ServiceBusQueueOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (sbqods ServiceBusQueueOutputDataSource) MarshalJSON() ([]byte, error) + type ServiceBusQueueOutputDataSourceProperties struct + PropertyColumns *[]string + QueueName *string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type ServiceBusTopicOutputDataSource struct + Type TypeBasicOutputDataSource + func (sbtods *ServiceBusTopicOutputDataSource) UnmarshalJSON(body []byte) error + func (sbtods ServiceBusTopicOutputDataSource) AsAzureDataLakeStoreOutputDataSource() (*AzureDataLakeStoreOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsAzureSQLDatabaseOutputDataSource() (*AzureSQLDatabaseOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsAzureTableOutputDataSource() (*AzureTableOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsBasicOutputDataSource() (BasicOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsBlobOutputDataSource() (*BlobOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsDocumentDbOutputDataSource() (*DocumentDbOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsEventHubOutputDataSource() (*EventHubOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsOutputDataSource() (*OutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsPowerBIOutputDataSource() (*PowerBIOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsServiceBusQueueOutputDataSource() (*ServiceBusQueueOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) AsServiceBusTopicOutputDataSource() (*ServiceBusTopicOutputDataSource, bool) + func (sbtods ServiceBusTopicOutputDataSource) MarshalJSON() ([]byte, error) + type ServiceBusTopicOutputDataSourceProperties struct + PropertyColumns *[]string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + TopicName *string + type Sku struct + Name SkuName + type SkuName string + const Standard + func PossibleSkuNameValues() []SkuName + type StartStreamingJobParameters struct + OutputStartMode OutputStartMode + OutputStartTime *date.Time + type StorageAccount struct + AccountKey *string + AccountName *string + type StreamInputDataSource struct + Type TypeBasicStreamInputDataSource + func (sids StreamInputDataSource) AsBasicStreamInputDataSource() (BasicStreamInputDataSource, bool) + func (sids StreamInputDataSource) AsBlobStreamInputDataSource() (*BlobStreamInputDataSource, bool) + func (sids StreamInputDataSource) AsEventHubStreamInputDataSource() (*EventHubStreamInputDataSource, bool) + func (sids StreamInputDataSource) AsIoTHubStreamInputDataSource() (*IoTHubStreamInputDataSource, bool) + func (sids StreamInputDataSource) AsStreamInputDataSource() (*StreamInputDataSource, bool) + func (sids StreamInputDataSource) MarshalJSON() ([]byte, error) + type StreamInputProperties struct + Datasource BasicStreamInputDataSource + Diagnostics *Diagnostics + Etag *string + Serialization BasicSerialization + Type TypeBasicInputProperties + func (sip *StreamInputProperties) UnmarshalJSON(body []byte) error + func (sip StreamInputProperties) AsBasicInputProperties() (BasicInputProperties, bool) + func (sip StreamInputProperties) AsInputProperties() (*InputProperties, bool) + func (sip StreamInputProperties) AsReferenceInputProperties() (*ReferenceInputProperties, bool) + func (sip StreamInputProperties) AsStreamInputProperties() (*StreamInputProperties, bool) + func (sip StreamInputProperties) MarshalJSON() ([]byte, error) + type StreamingJob struct + ID *string + Location *string + Name *string + Tags map[string]*string + Type *string + func (sj *StreamingJob) UnmarshalJSON(body []byte) error + func (sj StreamingJob) MarshalJSON() ([]byte, error) + type StreamingJobListResult struct + NextLink *string + Value *[]StreamingJob + func (sjlr StreamingJobListResult) IsEmpty() bool + type StreamingJobListResultIterator struct + func NewStreamingJobListResultIterator(page StreamingJobListResultPage) StreamingJobListResultIterator + func (iter *StreamingJobListResultIterator) Next() error + func (iter *StreamingJobListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter StreamingJobListResultIterator) NotDone() bool + func (iter StreamingJobListResultIterator) Response() StreamingJobListResult + func (iter StreamingJobListResultIterator) Value() StreamingJob + type StreamingJobListResultPage struct + func NewStreamingJobListResultPage(...) StreamingJobListResultPage + func (page *StreamingJobListResultPage) Next() error + func (page *StreamingJobListResultPage) NextWithContext(ctx context.Context) (err error) + func (page StreamingJobListResultPage) NotDone() bool + func (page StreamingJobListResultPage) Response() StreamingJobListResult + func (page StreamingJobListResultPage) Values() []StreamingJob + type StreamingJobProperties struct + CompatibilityLevel CompatibilityLevel + CreatedDate *date.Time + DataLocale *string + Etag *string + EventsLateArrivalMaxDelayInSeconds *int32 + EventsOutOfOrderMaxDelayInSeconds *int32 + EventsOutOfOrderPolicy EventsOutOfOrderPolicy + Functions *[]Function + Inputs *[]Input + JobID *string + JobState *string + LastOutputEventTime *date.Time + OutputErrorPolicy OutputErrorPolicy + OutputStartMode OutputStartMode + OutputStartTime *date.Time + Outputs *[]Output + ProvisioningState *string + Sku *Sku + Transformation *Transformation + type StreamingJobsClient struct + func NewStreamingJobsClient(subscriptionID string) StreamingJobsClient + func NewStreamingJobsClientWithBaseURI(baseURI string, subscriptionID string) StreamingJobsClient + func (client StreamingJobsClient) CreateOrReplace(ctx context.Context, streamingJob StreamingJob, resourceGroupName string, ...) (result StreamingJobsCreateOrReplaceFuture, err error) + func (client StreamingJobsClient) CreateOrReplacePreparer(ctx context.Context, streamingJob StreamingJob, resourceGroupName string, ...) (*http.Request, error) + func (client StreamingJobsClient) CreateOrReplaceResponder(resp *http.Response) (result StreamingJob, err error) + func (client StreamingJobsClient) CreateOrReplaceSender(req *http.Request) (future StreamingJobsCreateOrReplaceFuture, err error) + func (client StreamingJobsClient) Delete(ctx context.Context, resourceGroupName string, jobName string) (result StreamingJobsDeleteFuture, err error) + func (client StreamingJobsClient) DeletePreparer(ctx context.Context, resourceGroupName string, jobName string) (*http.Request, error) + func (client StreamingJobsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error) + func (client StreamingJobsClient) DeleteSender(req *http.Request) (future StreamingJobsDeleteFuture, err error) + func (client StreamingJobsClient) Get(ctx context.Context, resourceGroupName string, jobName string, expand string) (result StreamingJob, err error) + func (client StreamingJobsClient) GetPreparer(ctx context.Context, resourceGroupName string, jobName string, expand string) (*http.Request, error) + func (client StreamingJobsClient) GetResponder(resp *http.Response) (result StreamingJob, err error) + func (client StreamingJobsClient) GetSender(req *http.Request) (*http.Response, error) + func (client StreamingJobsClient) List(ctx context.Context, expand string) (result StreamingJobListResultPage, err error) + func (client StreamingJobsClient) ListByResourceGroup(ctx context.Context, resourceGroupName string, expand string) (result StreamingJobListResultPage, err error) + func (client StreamingJobsClient) ListByResourceGroupComplete(ctx context.Context, resourceGroupName string, expand string) (result StreamingJobListResultIterator, err error) + func (client StreamingJobsClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string, expand string) (*http.Request, error) + func (client StreamingJobsClient) ListByResourceGroupResponder(resp *http.Response) (result StreamingJobListResult, err error) + func (client StreamingJobsClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error) + func (client StreamingJobsClient) ListComplete(ctx context.Context, expand string) (result StreamingJobListResultIterator, err error) + func (client StreamingJobsClient) ListPreparer(ctx context.Context, expand string) (*http.Request, error) + func (client StreamingJobsClient) ListResponder(resp *http.Response) (result StreamingJobListResult, err error) + func (client StreamingJobsClient) ListSender(req *http.Request) (*http.Response, error) + func (client StreamingJobsClient) Start(ctx context.Context, resourceGroupName string, jobName string, ...) (result StreamingJobsStartFuture, err error) + func (client StreamingJobsClient) StartPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client StreamingJobsClient) StartResponder(resp *http.Response) (result autorest.Response, err error) + func (client StreamingJobsClient) StartSender(req *http.Request) (future StreamingJobsStartFuture, err error) + func (client StreamingJobsClient) Stop(ctx context.Context, resourceGroupName string, jobName string) (result StreamingJobsStopFuture, err error) + func (client StreamingJobsClient) StopPreparer(ctx context.Context, resourceGroupName string, jobName string) (*http.Request, error) + func (client StreamingJobsClient) StopResponder(resp *http.Response) (result autorest.Response, err error) + func (client StreamingJobsClient) StopSender(req *http.Request) (future StreamingJobsStopFuture, err error) + func (client StreamingJobsClient) Update(ctx context.Context, streamingJob StreamingJob, resourceGroupName string, ...) (result StreamingJob, err error) + func (client StreamingJobsClient) UpdatePreparer(ctx context.Context, streamingJob StreamingJob, resourceGroupName string, ...) (*http.Request, error) + func (client StreamingJobsClient) UpdateResponder(resp *http.Response) (result StreamingJob, err error) + func (client StreamingJobsClient) UpdateSender(req *http.Request) (*http.Response, error) + type StreamingJobsCreateOrReplaceFuture struct + func (future *StreamingJobsCreateOrReplaceFuture) Result(client StreamingJobsClient) (sj StreamingJob, err error) + type StreamingJobsDeleteFuture struct + func (future *StreamingJobsDeleteFuture) Result(client StreamingJobsClient) (ar autorest.Response, err error) + type StreamingJobsStartFuture struct + func (future *StreamingJobsStartFuture) Result(client StreamingJobsClient) (ar autorest.Response, err error) + type StreamingJobsStopFuture struct + func (future *StreamingJobsStopFuture) Result(client StreamingJobsClient) (ar autorest.Response, err error) + type SubResource struct + ID *string + Name *string + Type *string + type SubscriptionQuota struct + ID *string + Name *string + Type *string + func (sq *SubscriptionQuota) UnmarshalJSON(body []byte) error + func (sq SubscriptionQuota) MarshalJSON() ([]byte, error) + type SubscriptionQuotaProperties struct + CurrentCount *int32 + MaxCount *int32 + type SubscriptionQuotasListResult struct + Value *[]SubscriptionQuota + type SubscriptionsClient struct + func NewSubscriptionsClient(subscriptionID string) SubscriptionsClient + func NewSubscriptionsClientWithBaseURI(baseURI string, subscriptionID string) SubscriptionsClient + func (client SubscriptionsClient) ListQuotas(ctx context.Context, location string) (result SubscriptionQuotasListResult, err error) + func (client SubscriptionsClient) ListQuotasPreparer(ctx context.Context, location string) (*http.Request, error) + func (client SubscriptionsClient) ListQuotasResponder(resp *http.Response) (result SubscriptionQuotasListResult, err error) + func (client SubscriptionsClient) ListQuotasSender(req *http.Request) (*http.Response, error) + type Transformation struct + ID *string + Name *string + Type *string + func (t *Transformation) UnmarshalJSON(body []byte) error + func (t Transformation) MarshalJSON() ([]byte, error) + type TransformationProperties struct + Etag *string + Query *string + StreamingUnits *int32 + type TransformationsClient struct + func NewTransformationsClient(subscriptionID string) TransformationsClient + func NewTransformationsClientWithBaseURI(baseURI string, subscriptionID string) TransformationsClient + func (client TransformationsClient) CreateOrReplace(ctx context.Context, transformation Transformation, resourceGroupName string, ...) (result Transformation, err error) + func (client TransformationsClient) CreateOrReplacePreparer(ctx context.Context, transformation Transformation, resourceGroupName string, ...) (*http.Request, error) + func (client TransformationsClient) CreateOrReplaceResponder(resp *http.Response) (result Transformation, err error) + func (client TransformationsClient) CreateOrReplaceSender(req *http.Request) (*http.Response, error) + func (client TransformationsClient) Get(ctx context.Context, resourceGroupName string, jobName string, ...) (result Transformation, err error) + func (client TransformationsClient) GetPreparer(ctx context.Context, resourceGroupName string, jobName string, ...) (*http.Request, error) + func (client TransformationsClient) GetResponder(resp *http.Response) (result Transformation, err error) + func (client TransformationsClient) GetSender(req *http.Request) (*http.Response, error) + func (client TransformationsClient) Update(ctx context.Context, transformation Transformation, resourceGroupName string, ...) (result Transformation, err error) + func (client TransformationsClient) UpdatePreparer(ctx context.Context, transformation Transformation, resourceGroupName string, ...) (*http.Request, error) + func (client TransformationsClient) UpdateResponder(resp *http.Response) (result Transformation, err error) + func (client TransformationsClient) UpdateSender(req *http.Request) (*http.Response, error) + type Type string + const TypeAvro + const TypeCsv + const TypeJSON + const TypeSerialization + func PossibleTypeValues() []Type + type TypeBasicFunctionBinding string + const TypeFunctionBinding + const TypeMicrosoftMachineLearningWebService + const TypeMicrosoftStreamAnalyticsJavascriptUdf + func PossibleTypeBasicFunctionBindingValues() []TypeBasicFunctionBinding + type TypeBasicFunctionProperties string + const TypeFunctionProperties + const TypeScalar + func PossibleTypeBasicFunctionPropertiesValues() []TypeBasicFunctionProperties + type TypeBasicInputProperties string + const TypeInputProperties + const TypeReference + const TypeStream + func PossibleTypeBasicInputPropertiesValues() []TypeBasicInputProperties + type TypeBasicOutputDataSource string + const TypeMicrosoftDataLakeAccounts + const TypeMicrosoftSQLServerDatabase + const TypeMicrosoftServiceBusEventHub + const TypeMicrosoftServiceBusQueue + const TypeMicrosoftServiceBusTopic + const TypeMicrosoftStorageBlob + const TypeMicrosoftStorageDocumentDB + const TypeMicrosoftStorageTable + const TypeOutputDataSource + const TypePowerBI + func PossibleTypeBasicOutputDataSourceValues() []TypeBasicOutputDataSource + type TypeBasicReferenceInputDataSource string + const TypeBasicReferenceInputDataSourceTypeMicrosoftStorageBlob + const TypeBasicReferenceInputDataSourceTypeReferenceInputDataSource + func PossibleTypeBasicReferenceInputDataSourceValues() []TypeBasicReferenceInputDataSource + type TypeBasicStreamInputDataSource string + const TypeBasicStreamInputDataSourceTypeMicrosoftDevicesIotHubs + const TypeBasicStreamInputDataSourceTypeMicrosoftServiceBusEventHub + const TypeBasicStreamInputDataSourceTypeMicrosoftStorageBlob + const TypeBasicStreamInputDataSourceTypeStreamInputDataSource + func PossibleTypeBasicStreamInputDataSourceValues() []TypeBasicStreamInputDataSource + type UdfType string + const Scalar + func PossibleUdfTypeValues() []UdfType Other modules containing this package gopkg.in/azure/azure-sdk-for-go.v15 gopkg.in/azure/azure-sdk-for-go.v16 gopkg.in/azure/azure-sdk-for-go.v17 gopkg.in/azure/azure-sdk-for-go.v18 gopkg.in/azure/azure-sdk-for-go.v19 gopkg.in/azure/azure-sdk-for-go.v20 gopkg.in/azure/azure-sdk-for-go.v21 gopkg.in/azure/azure-sdk-for-go.v22 gopkg.in/azure/azure-sdk-for-go.v23 gopkg.in/azure/azure-sdk-for-go.v24 gopkg.in/azure/azure-sdk-for-go.v25 gopkg.in/azure/azure-sdk-for-go.v26 gopkg.in/azure/azure-sdk-for-go.v27 gopkg.in/azure/azure-sdk-for-go.v28 gopkg.in/azure/azure-sdk-for-go.v29 gopkg.in/azure/azure-sdk-for-go.v30 gopkg.in/azure/azure-sdk-for-go.v31 gopkg.in/azure/azure-sdk-for-go.v32 gopkg.in/azure/azure-sdk-for-go.v33 gopkg.in/azure/azure-sdk-for-go.v34 gopkg.in/azure/azure-sdk-for-go.v35 gopkg.in/azure/azure-sdk-for-go.v36 gopkg.in/azure/azure-sdk-for-go.v37 gopkg.in/azure/azure-sdk-for-go.v38 gopkg.in/azure/azure-sdk-for-go.v39 gopkg.in/azure/azure-sdk-for-go.v40 gopkg.in/azure/azure-sdk-for-go.v41 gopkg.in/azure/azure-sdk-for-go.v42 gopkg.in/azure/azure-sdk-for-go.v44 gopkg.in/azure/azure-sdk-for-go.v45 gopkg.in/azure/azure-sdk-for-go.v46 gopkg.in/azure/azure-sdk-for-go.v47 gopkg.in/azure/azure-sdk-for-go.v48 gopkg.in/azure/azure-sdk-for-go.v49