Versions in this module Expand all Collapse all v0 v0.20241126.2320 Nov 26, 2024 v0.20241126.1723 Nov 26, 2024 Changes in this version + func PossibleValuesForAuthenticationMode() []string + func PossibleValuesForCompressionType() []string + func PossibleValuesForEncoding() []string + func PossibleValuesForEventSerializationType() []string + func PossibleValuesForJsonOutputSerializationFormat() []string + func PossibleValuesForRefreshType() []string + func ValidateInputID(input interface{}, key string) (warnings []string, errors []error) + func ValidateStreamingJobID(input interface{}, key string) (warnings []string, errors []error) + type AuthenticationMode string + const AuthenticationModeConnectionString + const AuthenticationModeMsi + const AuthenticationModeUserToken + func (s *AuthenticationMode) UnmarshalJSON(bytes []byte) error + type AvroSerialization struct + Properties *interface{} + Type EventSerializationType + func (s AvroSerialization) MarshalJSON() ([]byte, error) + func (s AvroSerialization) Serialization() BaseSerializationImpl + type AzureSqlReferenceInputDataSource struct + Properties *AzureSqlReferenceInputDataSourceProperties + Type string + func (s AzureSqlReferenceInputDataSource) MarshalJSON() ([]byte, error) + func (s AzureSqlReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type AzureSqlReferenceInputDataSourceProperties struct + Database *string + DeltaSnapshotQuery *string + FullSnapshotQuery *string + Password *string + RefreshRate *string + RefreshType *RefreshType + Server *string + Table *string + User *string + type BaseInputPropertiesImpl struct + Compression *Compression + Diagnostics *Diagnostics + Etag *string + PartitionKey *string + Serialization Serialization + Type string + func (s *BaseInputPropertiesImpl) UnmarshalJSON(bytes []byte) error + func (s BaseInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl + type BaseReferenceInputDataSourceImpl struct + Type string + func (s BaseReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type BaseSerializationImpl struct + Type EventSerializationType + func (s BaseSerializationImpl) Serialization() BaseSerializationImpl + type BaseStreamInputDataSourceImpl struct + Type string + func (s BaseStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl + type BlobDataSourceProperties struct + AuthenticationMode *AuthenticationMode + Container *string + DateFormat *string + PathPattern *string + StorageAccounts *[]StorageAccount + TimeFormat *string + type BlobReferenceInputDataSource struct + Properties *BlobDataSourceProperties + Type string + func (s BlobReferenceInputDataSource) MarshalJSON() ([]byte, error) + func (s BlobReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type BlobStreamInputDataSource struct + Properties *BlobStreamInputDataSourceProperties + Type string + func (s BlobStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s BlobStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type BlobStreamInputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + Container *string + DateFormat *string + PathPattern *string + SourcePartitionCount *int64 + StorageAccounts *[]StorageAccount + TimeFormat *string + type Compression struct + Type CompressionType + type CompressionType string + const CompressionTypeDeflate + const CompressionTypeGZip + const CompressionTypeNone + func (s *CompressionType) UnmarshalJSON(bytes []byte) error + type CreateOrReplaceOperationOptions struct + IfMatch *string + IfNoneMatch *string + func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions + func (o CreateOrReplaceOperationOptions) ToHeaders() *client.Headers + func (o CreateOrReplaceOperationOptions) ToOData() *odata.Query + func (o CreateOrReplaceOperationOptions) ToQuery() *client.QueryParams + type CreateOrReplaceOperationResponse struct + HttpResponse *http.Response + Model *Input + OData *odata.OData + type CsvSerialization struct + Properties *CsvSerializationProperties + Type EventSerializationType + func (s CsvSerialization) MarshalJSON() ([]byte, error) + func (s CsvSerialization) Serialization() BaseSerializationImpl + type CsvSerializationProperties struct + Encoding *Encoding + FieldDelimiter *string + type DeleteOperationResponse struct + HttpResponse *http.Response + OData *odata.OData + type DiagnosticCondition struct + Code *string + Message *string + Since *string + type Diagnostics struct + Conditions *[]DiagnosticCondition + type Encoding string + const EncodingUTFEight + func (s *Encoding) UnmarshalJSON(bytes []byte) error + type ErrorResponse struct + Code *string + Message *string + type EventHubStreamInputDataSource struct + Properties *EventHubStreamInputDataSourceProperties + Type string + func (s EventHubStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s EventHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type EventHubStreamInputDataSourceProperties struct + AuthenticationMode *AuthenticationMode + ConsumerGroupName *string + EventHubName *string + ServiceBusNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type EventHubV2StreamInputDataSource struct + Properties *EventHubStreamInputDataSourceProperties + Type string + func (s EventHubV2StreamInputDataSource) MarshalJSON() ([]byte, error) + func (s EventHubV2StreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type EventSerializationType string + const EventSerializationTypeAvro + const EventSerializationTypeCsv + const EventSerializationTypeJson + const EventSerializationTypeParquet + func (s *EventSerializationType) UnmarshalJSON(bytes []byte) error + type FileReferenceInputDataSource struct + Properties *FileReferenceInputDataSourceProperties + Type string + func (s FileReferenceInputDataSource) MarshalJSON() ([]byte, error) + func (s FileReferenceInputDataSource) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type FileReferenceInputDataSourceProperties struct + Path *string + type GatewayMessageBusSourceProperties struct + Topic *string + type GatewayMessageBusStreamInputDataSource struct + Properties *GatewayMessageBusSourceProperties + Type string + func (s GatewayMessageBusStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s GatewayMessageBusStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type GetOperationResponse struct + HttpResponse *http.Response + Model *Input + OData *odata.OData + type Input struct + Id *string + Name *string + Properties InputProperties + Type *string + func (s *Input) UnmarshalJSON(bytes []byte) error + type InputId struct + InputName string + ResourceGroupName string + StreamingJobName string + SubscriptionId string + func NewInputID(subscriptionId string, resourceGroupName string, streamingJobName string, ...) InputId + func ParseInputID(input string) (*InputId, error) + func ParseInputIDInsensitively(input string) (*InputId, error) + func (id *InputId) FromParseResult(input resourceids.ParseResult) error + func (id InputId) ID() string + func (id InputId) Segments() []resourceids.Segment + func (id InputId) String() string + type InputOperationPredicate struct + Id *string + Name *string + Type *string + func (p InputOperationPredicate) Matches(input Input) bool + type InputProperties interface + InputProperties func() BaseInputPropertiesImpl + func UnmarshalInputPropertiesImplementation(input []byte) (InputProperties, error) + type InputsClient struct + Client *resourcemanager.Client + func NewInputsClientWithBaseURI(sdkApi sdkEnv.Api) (*InputsClient, error) + func (c InputsClient) CreateOrReplace(ctx context.Context, id InputId, input Input, ...) (result CreateOrReplaceOperationResponse, err error) + func (c InputsClient) Delete(ctx context.Context, id InputId) (result DeleteOperationResponse, err error) + func (c InputsClient) Get(ctx context.Context, id InputId) (result GetOperationResponse, err error) + func (c InputsClient) ListByStreamingJob(ctx context.Context, id StreamingJobId, ...) (result ListByStreamingJobOperationResponse, err error) + func (c InputsClient) ListByStreamingJobComplete(ctx context.Context, id StreamingJobId, ...) (ListByStreamingJobCompleteResult, error) + func (c InputsClient) ListByStreamingJobCompleteMatchingPredicate(ctx context.Context, id StreamingJobId, ...) (result ListByStreamingJobCompleteResult, err error) + func (c InputsClient) Update(ctx context.Context, id InputId, input Input, options UpdateOperationOptions) (result UpdateOperationResponse, err error) + type IoTHubStreamInputDataSource struct + Properties *IoTHubStreamInputDataSourceProperties + Type string + func (s IoTHubStreamInputDataSource) MarshalJSON() ([]byte, error) + func (s IoTHubStreamInputDataSource) StreamInputDataSource() BaseStreamInputDataSourceImpl + type IoTHubStreamInputDataSourceProperties struct + ConsumerGroupName *string + Endpoint *string + IotHubNamespace *string + SharedAccessPolicyKey *string + SharedAccessPolicyName *string + type JsonOutputSerializationFormat string + const JsonOutputSerializationFormatArray + const JsonOutputSerializationFormatLineSeparated + func (s *JsonOutputSerializationFormat) UnmarshalJSON(bytes []byte) error + type JsonSerialization struct + Properties *JsonSerializationProperties + Type EventSerializationType + func (s JsonSerialization) MarshalJSON() ([]byte, error) + func (s JsonSerialization) Serialization() BaseSerializationImpl + type JsonSerializationProperties struct + Encoding *Encoding + Format *JsonOutputSerializationFormat + type ListByStreamingJobCompleteResult struct + Items []Input + LatestHttpResponse *http.Response + type ListByStreamingJobCustomPager struct + NextLink *odata.Link + func (p *ListByStreamingJobCustomPager) NextPageLink() *odata.Link + type ListByStreamingJobOperationOptions struct + Select *string + func DefaultListByStreamingJobOperationOptions() ListByStreamingJobOperationOptions + func (o ListByStreamingJobOperationOptions) ToHeaders() *client.Headers + func (o ListByStreamingJobOperationOptions) ToOData() *odata.Query + func (o ListByStreamingJobOperationOptions) ToQuery() *client.QueryParams + type ListByStreamingJobOperationResponse struct + HttpResponse *http.Response + Model *[]Input + OData *odata.OData + type ParquetSerialization struct + Properties *interface{} + Type EventSerializationType + func (s ParquetSerialization) MarshalJSON() ([]byte, error) + func (s ParquetSerialization) Serialization() BaseSerializationImpl + type RawInputPropertiesImpl struct + Type string + Values map[string]interface{} + func (s RawInputPropertiesImpl) InputProperties() BaseInputPropertiesImpl + type RawReferenceInputDataSourceImpl struct + Type string + Values map[string]interface{} + func (s RawReferenceInputDataSourceImpl) ReferenceInputDataSource() BaseReferenceInputDataSourceImpl + type RawSerializationImpl struct + Type string + Values map[string]interface{} + func (s RawSerializationImpl) Serialization() BaseSerializationImpl + type RawStreamInputDataSourceImpl struct + Type string + Values map[string]interface{} + func (s RawStreamInputDataSourceImpl) StreamInputDataSource() BaseStreamInputDataSourceImpl + type ReferenceInputDataSource interface + ReferenceInputDataSource func() BaseReferenceInputDataSourceImpl + func UnmarshalReferenceInputDataSourceImplementation(input []byte) (ReferenceInputDataSource, error) + type ReferenceInputProperties struct + Compression *Compression + Datasource ReferenceInputDataSource + Diagnostics *Diagnostics + Etag *string + PartitionKey *string + Serialization Serialization + Type string + func (s *ReferenceInputProperties) UnmarshalJSON(bytes []byte) error + func (s ReferenceInputProperties) InputProperties() BaseInputPropertiesImpl + func (s ReferenceInputProperties) MarshalJSON() ([]byte, error) + type RefreshType string + const RefreshTypeRefreshPeriodicallyWithDelta + const RefreshTypeRefreshPeriodicallyWithFull + const RefreshTypeStatic + func (s *RefreshType) UnmarshalJSON(bytes []byte) error + type ResourceTestStatus struct + Error *ErrorResponse + Status *string + type Serialization interface + Serialization func() BaseSerializationImpl + func UnmarshalSerializationImplementation(input []byte) (Serialization, error) + type StorageAccount struct + AccountKey *string + AccountName *string + type StreamInputDataSource interface + StreamInputDataSource func() BaseStreamInputDataSourceImpl + func UnmarshalStreamInputDataSourceImplementation(input []byte) (StreamInputDataSource, error) + type StreamInputProperties struct + Compression *Compression + Datasource StreamInputDataSource + Diagnostics *Diagnostics + Etag *string + PartitionKey *string + Serialization Serialization + Type string + func (s *StreamInputProperties) UnmarshalJSON(bytes []byte) error + func (s StreamInputProperties) InputProperties() BaseInputPropertiesImpl + func (s StreamInputProperties) MarshalJSON() ([]byte, error) + type StreamingJobId struct + ResourceGroupName string + StreamingJobName string + SubscriptionId string + func NewStreamingJobID(subscriptionId string, resourceGroupName string, streamingJobName string) StreamingJobId + func ParseStreamingJobID(input string) (*StreamingJobId, error) + func ParseStreamingJobIDInsensitively(input string) (*StreamingJobId, error) + func (id *StreamingJobId) FromParseResult(input resourceids.ParseResult) error + func (id StreamingJobId) ID() string + func (id StreamingJobId) Segments() []resourceids.Segment + func (id StreamingJobId) String() string + type UpdateOperationOptions struct + IfMatch *string + func DefaultUpdateOperationOptions() UpdateOperationOptions + func (o UpdateOperationOptions) ToHeaders() *client.Headers + func (o UpdateOperationOptions) ToOData() *odata.Query + func (o UpdateOperationOptions) ToQuery() *client.QueryParams + type UpdateOperationResponse struct + HttpResponse *http.Response + Model *Input + OData *odata.OData
Go to main page