Documentation ¶
Index ¶
- 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
- type AvroSerialization
- type AzureSqlReferenceInputDataSource
- type AzureSqlReferenceInputDataSourceProperties
- type BlobDataSourceProperties
- type BlobReferenceInputDataSource
- type BlobStreamInputDataSource
- type BlobStreamInputDataSourceProperties
- type Compression
- type CompressionType
- type CreateOrReplaceOperationOptions
- type CreateOrReplaceOperationResponse
- type CsvSerialization
- type CsvSerializationProperties
- type DeleteOperationResponse
- type DiagnosticCondition
- type Diagnostics
- type Encoding
- type ErrorResponse
- type EventHubStreamInputDataSource
- type EventHubStreamInputDataSourceProperties
- type EventHubV2StreamInputDataSource
- type EventSerializationType
- type FileReferenceInputDataSource
- type FileReferenceInputDataSourceProperties
- type GatewayMessageBusSourceProperties
- type GatewayMessageBusStreamInputDataSource
- type GetOperationResponse
- type Input
- type InputId
- type InputOperationPredicate
- type InputProperties
- type InputsClient
- 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
- type IoTHubStreamInputDataSourceProperties
- type JsonOutputSerializationFormat
- type JsonSerialization
- type JsonSerializationProperties
- type ListByStreamingJobCompleteResult
- type ListByStreamingJobCustomPager
- type ListByStreamingJobOperationOptions
- type ListByStreamingJobOperationResponse
- type ParquetSerialization
- type RawInputPropertiesImpl
- type RawReferenceInputDataSourceImpl
- type RawSerializationImpl
- type RawStreamInputDataSourceImpl
- type ReferenceInputDataSource
- type ReferenceInputProperties
- type RefreshType
- type ResourceTestStatus
- type Serialization
- type StorageAccount
- type StreamInputDataSource
- type StreamInputProperties
- type StreamingJobId
- type UpdateOperationOptions
- type UpdateOperationResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PossibleValuesForAuthenticationMode ¶
func PossibleValuesForAuthenticationMode() []string
func PossibleValuesForCompressionType ¶
func PossibleValuesForCompressionType() []string
func PossibleValuesForEncoding ¶
func PossibleValuesForEncoding() []string
func PossibleValuesForEventSerializationType ¶
func PossibleValuesForEventSerializationType() []string
func PossibleValuesForJsonOutputSerializationFormat ¶
func PossibleValuesForJsonOutputSerializationFormat() []string
func PossibleValuesForRefreshType ¶
func PossibleValuesForRefreshType() []string
func ValidateInputID ¶
ValidateInputID checks that 'input' can be parsed as a Input ID
func ValidateStreamingJobID ¶
ValidateStreamingJobID checks that 'input' can be parsed as a Streaming Job ID
Types ¶
type AuthenticationMode ¶
type AuthenticationMode string
const ( AuthenticationModeConnectionString AuthenticationMode = "ConnectionString" AuthenticationModeMsi AuthenticationMode = "Msi" AuthenticationModeUserToken AuthenticationMode = "UserToken" )
func (*AuthenticationMode) UnmarshalJSON ¶ added in v0.20240208.1095436
func (s *AuthenticationMode) UnmarshalJSON(bytes []byte) error
type AvroSerialization ¶
type AvroSerialization struct {
Properties *interface{} `json:"properties,omitempty"`
}
func (AvroSerialization) MarshalJSON ¶
func (s AvroSerialization) MarshalJSON() ([]byte, error)
type AzureSqlReferenceInputDataSource ¶
type AzureSqlReferenceInputDataSource struct {
Properties *AzureSqlReferenceInputDataSourceProperties `json:"properties,omitempty"`
}
func (AzureSqlReferenceInputDataSource) MarshalJSON ¶
func (s AzureSqlReferenceInputDataSource) MarshalJSON() ([]byte, error)
type AzureSqlReferenceInputDataSourceProperties ¶
type AzureSqlReferenceInputDataSourceProperties struct { Database *string `json:"database,omitempty"` DeltaSnapshotQuery *string `json:"deltaSnapshotQuery,omitempty"` FullSnapshotQuery *string `json:"fullSnapshotQuery,omitempty"` Password *string `json:"password,omitempty"` RefreshRate *string `json:"refreshRate,omitempty"` RefreshType *RefreshType `json:"refreshType,omitempty"` Server *string `json:"server,omitempty"` Table *string `json:"table,omitempty"` User *string `json:"user,omitempty"` }
type BlobDataSourceProperties ¶
type BlobDataSourceProperties struct { AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"` Container *string `json:"container,omitempty"` DateFormat *string `json:"dateFormat,omitempty"` PathPattern *string `json:"pathPattern,omitempty"` StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"` TimeFormat *string `json:"timeFormat,omitempty"` }
type BlobReferenceInputDataSource ¶
type BlobReferenceInputDataSource struct {
Properties *BlobDataSourceProperties `json:"properties,omitempty"`
}
func (BlobReferenceInputDataSource) MarshalJSON ¶
func (s BlobReferenceInputDataSource) MarshalJSON() ([]byte, error)
type BlobStreamInputDataSource ¶
type BlobStreamInputDataSource struct {
Properties *BlobStreamInputDataSourceProperties `json:"properties,omitempty"`
}
func (BlobStreamInputDataSource) MarshalJSON ¶
func (s BlobStreamInputDataSource) MarshalJSON() ([]byte, error)
type BlobStreamInputDataSourceProperties ¶
type BlobStreamInputDataSourceProperties struct { AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"` Container *string `json:"container,omitempty"` DateFormat *string `json:"dateFormat,omitempty"` PathPattern *string `json:"pathPattern,omitempty"` SourcePartitionCount *int64 `json:"sourcePartitionCount,omitempty"` StorageAccounts *[]StorageAccount `json:"storageAccounts,omitempty"` TimeFormat *string `json:"timeFormat,omitempty"` }
type Compression ¶
type Compression struct {
Type CompressionType `json:"type"`
}
type CompressionType ¶
type CompressionType string
const ( CompressionTypeDeflate CompressionType = "Deflate" CompressionTypeGZip CompressionType = "GZip" CompressionTypeNone CompressionType = "None" )
func (*CompressionType) UnmarshalJSON ¶ added in v0.20240208.1095436
func (s *CompressionType) UnmarshalJSON(bytes []byte) error
type CreateOrReplaceOperationOptions ¶
func DefaultCreateOrReplaceOperationOptions ¶
func DefaultCreateOrReplaceOperationOptions() CreateOrReplaceOperationOptions
func (CreateOrReplaceOperationOptions) ToHeaders ¶ added in v0.20240208.1095436
func (o CreateOrReplaceOperationOptions) ToHeaders() *client.Headers
func (CreateOrReplaceOperationOptions) ToOData ¶ added in v0.20240208.1095436
func (o CreateOrReplaceOperationOptions) ToOData() *odata.Query
func (CreateOrReplaceOperationOptions) ToQuery ¶ added in v0.20240208.1095436
func (o CreateOrReplaceOperationOptions) ToQuery() *client.QueryParams
type CsvSerialization ¶
type CsvSerialization struct {
Properties *CsvSerializationProperties `json:"properties,omitempty"`
}
func (CsvSerialization) MarshalJSON ¶
func (s CsvSerialization) MarshalJSON() ([]byte, error)
type DeleteOperationResponse ¶
type DiagnosticCondition ¶
type Diagnostics ¶
type Diagnostics struct {
Conditions *[]DiagnosticCondition `json:"conditions,omitempty"`
}
type Encoding ¶
type Encoding string
const (
EncodingUTFEight Encoding = "UTF8"
)
func (*Encoding) UnmarshalJSON ¶ added in v0.20240208.1095436
type ErrorResponse ¶
type EventHubStreamInputDataSource ¶
type EventHubStreamInputDataSource struct {
Properties *EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`
}
func (EventHubStreamInputDataSource) MarshalJSON ¶
func (s EventHubStreamInputDataSource) MarshalJSON() ([]byte, error)
type EventHubStreamInputDataSourceProperties ¶
type EventHubStreamInputDataSourceProperties struct { AuthenticationMode *AuthenticationMode `json:"authenticationMode,omitempty"` ConsumerGroupName *string `json:"consumerGroupName,omitempty"` EventHubName *string `json:"eventHubName,omitempty"` ServiceBusNamespace *string `json:"serviceBusNamespace,omitempty"` }
type EventHubV2StreamInputDataSource ¶
type EventHubV2StreamInputDataSource struct {
Properties *EventHubStreamInputDataSourceProperties `json:"properties,omitempty"`
}
func (EventHubV2StreamInputDataSource) MarshalJSON ¶
func (s EventHubV2StreamInputDataSource) MarshalJSON() ([]byte, error)
type EventSerializationType ¶
type EventSerializationType string
const ( EventSerializationTypeAvro EventSerializationType = "Avro" EventSerializationTypeCsv EventSerializationType = "Csv" EventSerializationTypeJson EventSerializationType = "Json" EventSerializationTypeParquet EventSerializationType = "Parquet" )
func (*EventSerializationType) UnmarshalJSON ¶ added in v0.20240208.1095436
func (s *EventSerializationType) UnmarshalJSON(bytes []byte) error
type FileReferenceInputDataSource ¶
type FileReferenceInputDataSource struct {
Properties *FileReferenceInputDataSourceProperties `json:"properties,omitempty"`
}
func (FileReferenceInputDataSource) MarshalJSON ¶
func (s FileReferenceInputDataSource) MarshalJSON() ([]byte, error)
type FileReferenceInputDataSourceProperties ¶
type FileReferenceInputDataSourceProperties struct {
Path *string `json:"path,omitempty"`
}
type GatewayMessageBusSourceProperties ¶
type GatewayMessageBusSourceProperties struct {
Topic *string `json:"topic,omitempty"`
}
type GatewayMessageBusStreamInputDataSource ¶
type GatewayMessageBusStreamInputDataSource struct {
Properties *GatewayMessageBusSourceProperties `json:"properties,omitempty"`
}
func (GatewayMessageBusStreamInputDataSource) MarshalJSON ¶
func (s GatewayMessageBusStreamInputDataSource) MarshalJSON() ([]byte, error)
type GetOperationResponse ¶
type Input ¶
type Input struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Properties InputProperties `json:"properties"` Type *string `json:"type,omitempty"` }
func (*Input) UnmarshalJSON ¶
type InputId ¶
type InputId struct { SubscriptionId string ResourceGroupName string StreamingJobName string InputName string }
InputId is a struct representing the Resource ID for a Input
func NewInputID ¶
func NewInputID(subscriptionId string, resourceGroupName string, streamingJobName string, inputName string) InputId
NewInputID returns a new InputId struct
func ParseInputID ¶
ParseInputID parses 'input' into a InputId
func ParseInputIDInsensitively ¶
ParseInputIDInsensitively parses 'input' case-insensitively into a InputId note: this method should only be used for API response data and not user input
func (*InputId) FromParseResult ¶
func (id *InputId) FromParseResult(input resourceids.ParseResult) error
func (InputId) Segments ¶
func (id InputId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Input ID
type InputOperationPredicate ¶
func (InputOperationPredicate) Matches ¶
func (p InputOperationPredicate) Matches(input Input) bool
type InputProperties ¶
type InputProperties interface { }
type InputsClient ¶
type InputsClient struct {
Client *resourcemanager.Client
}
func NewInputsClientWithBaseURI ¶
func NewInputsClientWithBaseURI(sdkApi sdkEnv.Api) (*InputsClient, error)
func (InputsClient) CreateOrReplace ¶
func (c InputsClient) CreateOrReplace(ctx context.Context, id InputId, input Input, options CreateOrReplaceOperationOptions) (result CreateOrReplaceOperationResponse, err error)
CreateOrReplace ...
func (InputsClient) Delete ¶
func (c InputsClient) Delete(ctx context.Context, id InputId) (result DeleteOperationResponse, err error)
Delete ...
func (InputsClient) Get ¶
func (c InputsClient) Get(ctx context.Context, id InputId) (result GetOperationResponse, err error)
Get ...
func (InputsClient) ListByStreamingJob ¶
func (c InputsClient) ListByStreamingJob(ctx context.Context, id StreamingJobId, options ListByStreamingJobOperationOptions) (result ListByStreamingJobOperationResponse, err error)
ListByStreamingJob ...
func (InputsClient) ListByStreamingJobComplete ¶
func (c InputsClient) ListByStreamingJobComplete(ctx context.Context, id StreamingJobId, options ListByStreamingJobOperationOptions) (ListByStreamingJobCompleteResult, error)
ListByStreamingJobComplete retrieves all the results into a single object
func (InputsClient) ListByStreamingJobCompleteMatchingPredicate ¶
func (c InputsClient) ListByStreamingJobCompleteMatchingPredicate(ctx context.Context, id StreamingJobId, options ListByStreamingJobOperationOptions, predicate InputOperationPredicate) (result ListByStreamingJobCompleteResult, err error)
ListByStreamingJobCompleteMatchingPredicate retrieves all the results and then applies the predicate
func (InputsClient) Update ¶
func (c InputsClient) Update(ctx context.Context, id InputId, input Input, options UpdateOperationOptions) (result UpdateOperationResponse, err error)
Update ...
type IoTHubStreamInputDataSource ¶
type IoTHubStreamInputDataSource struct {
Properties *IoTHubStreamInputDataSourceProperties `json:"properties,omitempty"`
}
func (IoTHubStreamInputDataSource) MarshalJSON ¶
func (s IoTHubStreamInputDataSource) MarshalJSON() ([]byte, error)
type JsonOutputSerializationFormat ¶
type JsonOutputSerializationFormat string
const ( JsonOutputSerializationFormatArray JsonOutputSerializationFormat = "Array" JsonOutputSerializationFormatLineSeparated JsonOutputSerializationFormat = "LineSeparated" )
func (*JsonOutputSerializationFormat) UnmarshalJSON ¶ added in v0.20240208.1095436
func (s *JsonOutputSerializationFormat) UnmarshalJSON(bytes []byte) error
type JsonSerialization ¶
type JsonSerialization struct {
Properties *JsonSerializationProperties `json:"properties,omitempty"`
}
func (JsonSerialization) MarshalJSON ¶
func (s JsonSerialization) MarshalJSON() ([]byte, error)
type JsonSerializationProperties ¶
type JsonSerializationProperties struct { Encoding *Encoding `json:"encoding,omitempty"` Format *JsonOutputSerializationFormat `json:"format,omitempty"` }
type ListByStreamingJobCustomPager ¶ added in v0.20240628.1153531
func (*ListByStreamingJobCustomPager) NextPageLink ¶ added in v0.20240628.1153531
func (p *ListByStreamingJobCustomPager) NextPageLink() *odata.Link
type ListByStreamingJobOperationOptions ¶
type ListByStreamingJobOperationOptions struct {
Select *string
}
func DefaultListByStreamingJobOperationOptions ¶
func DefaultListByStreamingJobOperationOptions() ListByStreamingJobOperationOptions
func (ListByStreamingJobOperationOptions) ToHeaders ¶ added in v0.20240208.1095436
func (o ListByStreamingJobOperationOptions) ToHeaders() *client.Headers
func (ListByStreamingJobOperationOptions) ToOData ¶ added in v0.20240208.1095436
func (o ListByStreamingJobOperationOptions) ToOData() *odata.Query
func (ListByStreamingJobOperationOptions) ToQuery ¶ added in v0.20240208.1095436
func (o ListByStreamingJobOperationOptions) ToQuery() *client.QueryParams
type ParquetSerialization ¶
type ParquetSerialization struct {
Properties *interface{} `json:"properties,omitempty"`
}
func (ParquetSerialization) MarshalJSON ¶
func (s ParquetSerialization) MarshalJSON() ([]byte, error)
type RawInputPropertiesImpl ¶
RawInputPropertiesImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).
type RawReferenceInputDataSourceImpl ¶
RawReferenceInputDataSourceImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).
type RawSerializationImpl ¶
RawSerializationImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).
type RawStreamInputDataSourceImpl ¶
RawStreamInputDataSourceImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).
type ReferenceInputDataSource ¶
type ReferenceInputDataSource interface { }
type ReferenceInputProperties ¶
type ReferenceInputProperties struct { Datasource ReferenceInputDataSource `json:"datasource"` // Fields inherited from InputProperties Compression *Compression `json:"compression,omitempty"` Diagnostics *Diagnostics `json:"diagnostics,omitempty"` Etag *string `json:"etag,omitempty"` PartitionKey *string `json:"partitionKey,omitempty"` Serialization Serialization `json:"serialization"` }
func (ReferenceInputProperties) MarshalJSON ¶
func (s ReferenceInputProperties) MarshalJSON() ([]byte, error)
func (*ReferenceInputProperties) UnmarshalJSON ¶
func (s *ReferenceInputProperties) UnmarshalJSON(bytes []byte) error
type RefreshType ¶
type RefreshType string
const ( RefreshTypeRefreshPeriodicallyWithDelta RefreshType = "RefreshPeriodicallyWithDelta" RefreshTypeRefreshPeriodicallyWithFull RefreshType = "RefreshPeriodicallyWithFull" RefreshTypeStatic RefreshType = "Static" )
func (*RefreshType) UnmarshalJSON ¶ added in v0.20240208.1095436
func (s *RefreshType) UnmarshalJSON(bytes []byte) error
type ResourceTestStatus ¶
type ResourceTestStatus struct { Error *ErrorResponse `json:"error,omitempty"` Status *string `json:"status,omitempty"` }
type Serialization ¶
type Serialization interface { }
type StorageAccount ¶
type StreamInputDataSource ¶
type StreamInputDataSource interface { }
type StreamInputProperties ¶
type StreamInputProperties struct { Datasource StreamInputDataSource `json:"datasource"` // Fields inherited from InputProperties Compression *Compression `json:"compression,omitempty"` Diagnostics *Diagnostics `json:"diagnostics,omitempty"` Etag *string `json:"etag,omitempty"` PartitionKey *string `json:"partitionKey,omitempty"` Serialization Serialization `json:"serialization"` }
func (StreamInputProperties) MarshalJSON ¶
func (s StreamInputProperties) MarshalJSON() ([]byte, error)
func (*StreamInputProperties) UnmarshalJSON ¶
func (s *StreamInputProperties) UnmarshalJSON(bytes []byte) error
type StreamingJobId ¶
type StreamingJobId struct { SubscriptionId string ResourceGroupName string StreamingJobName string }
StreamingJobId is a struct representing the Resource ID for a Streaming Job
func NewStreamingJobID ¶
func NewStreamingJobID(subscriptionId string, resourceGroupName string, streamingJobName string) StreamingJobId
NewStreamingJobID returns a new StreamingJobId struct
func ParseStreamingJobID ¶
func ParseStreamingJobID(input string) (*StreamingJobId, error)
ParseStreamingJobID parses 'input' into a StreamingJobId
func ParseStreamingJobIDInsensitively ¶
func ParseStreamingJobIDInsensitively(input string) (*StreamingJobId, error)
ParseStreamingJobIDInsensitively parses 'input' case-insensitively into a StreamingJobId note: this method should only be used for API response data and not user input
func (*StreamingJobId) FromParseResult ¶
func (id *StreamingJobId) FromParseResult(input resourceids.ParseResult) error
func (StreamingJobId) ID ¶
func (id StreamingJobId) ID() string
ID returns the formatted Streaming Job ID
func (StreamingJobId) Segments ¶
func (id StreamingJobId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Streaming Job ID
func (StreamingJobId) String ¶
func (id StreamingJobId) String() string
String returns a human-readable description of this Streaming Job ID
type UpdateOperationOptions ¶
type UpdateOperationOptions struct {
IfMatch *string
}
func DefaultUpdateOperationOptions ¶
func DefaultUpdateOperationOptions() UpdateOperationOptions
func (UpdateOperationOptions) ToHeaders ¶ added in v0.20240208.1095436
func (o UpdateOperationOptions) ToHeaders() *client.Headers
func (UpdateOperationOptions) ToOData ¶ added in v0.20240208.1095436
func (o UpdateOperationOptions) ToOData() *odata.Query
func (UpdateOperationOptions) ToQuery ¶ added in v0.20240208.1095436
func (o UpdateOperationOptions) ToQuery() *client.QueryParams
Source Files ¶
- client.go
- constants.go
- id_input.go
- id_streamingjob.go
- method_createorreplace.go
- method_delete.go
- method_get.go
- method_listbystreamingjob.go
- method_update.go
- model_avroserialization.go
- model_azuresqlreferenceinputdatasource.go
- model_azuresqlreferenceinputdatasourceproperties.go
- model_blobdatasourceproperties.go
- model_blobreferenceinputdatasource.go
- model_blobstreaminputdatasource.go
- model_blobstreaminputdatasourceproperties.go
- model_compression.go
- model_csvserialization.go
- model_csvserializationproperties.go
- model_diagnosticcondition.go
- model_diagnostics.go
- model_errorresponse.go
- model_eventhubstreaminputdatasource.go
- model_eventhubstreaminputdatasourceproperties.go
- model_eventhubv2streaminputdatasource.go
- model_filereferenceinputdatasource.go
- model_filereferenceinputdatasourceproperties.go
- model_gatewaymessagebussourceproperties.go
- model_gatewaymessagebusstreaminputdatasource.go
- model_input.go
- model_inputproperties.go
- model_iothubstreaminputdatasource.go
- model_iothubstreaminputdatasourceproperties.go
- model_jsonserialization.go
- model_jsonserializationproperties.go
- model_parquetserialization.go
- model_referenceinputdatasource.go
- model_referenceinputproperties.go
- model_resourceteststatus.go
- model_serialization.go
- model_storageaccount.go
- model_streaminputdatasource.go
- model_streaminputproperties.go
- predicates.go
- version.go