Documentation ¶
Index ¶
- func PossibleValuesForBlobStorageEventType() []string
- func PossibleValuesForCompression() []string
- func PossibleValuesForDataConnectionKind() []string
- func PossibleValuesForDataConnectionType() []string
- func PossibleValuesForDatabaseRouting() []string
- func PossibleValuesForEventGridDataFormat() []string
- func PossibleValuesForEventHubDataFormat() []string
- func PossibleValuesForIotHubDataFormat() []string
- func PossibleValuesForProvisioningState() []string
- func PossibleValuesForReason() []string
- func ValidateDataConnectionID(input interface{}, key string) (warnings []string, errors []error)
- type BlobStorageEventType
- type CheckNameAvailabilityOperationResponse
- type CheckNameResult
- type Compression
- type CosmosDbDataConnection
- type CosmosDbDataConnectionProperties
- type CreateOrUpdateOperationResponse
- type DataConnection
- type DataConnectionCheckNameRequest
- type DataConnectionId
- type DataConnectionKind
- type DataConnectionListResult
- type DataConnectionType
- type DataConnectionValidation
- type DataConnectionValidationListResult
- type DataConnectionValidationOperationResponse
- type DataConnectionValidationResult
- type DataConnectionsClient
- func (c DataConnectionsClient) CheckNameAvailability(ctx context.Context, id commonids.KustoDatabaseId, ...) (result CheckNameAvailabilityOperationResponse, err error)
- func (c DataConnectionsClient) CreateOrUpdate(ctx context.Context, id DataConnectionId, input DataConnection) (result CreateOrUpdateOperationResponse, err error)
- func (c DataConnectionsClient) CreateOrUpdateThenPoll(ctx context.Context, id DataConnectionId, input DataConnection) error
- func (c DataConnectionsClient) DataConnectionValidation(ctx context.Context, id commonids.KustoDatabaseId, ...) (result DataConnectionValidationOperationResponse, err error)
- func (c DataConnectionsClient) DataConnectionValidationThenPoll(ctx context.Context, id commonids.KustoDatabaseId, ...) error
- func (c DataConnectionsClient) Delete(ctx context.Context, id DataConnectionId) (result DeleteOperationResponse, err error)
- func (c DataConnectionsClient) DeleteThenPoll(ctx context.Context, id DataConnectionId) error
- func (c DataConnectionsClient) Get(ctx context.Context, id DataConnectionId) (result GetOperationResponse, err error)
- func (c DataConnectionsClient) ListByDatabase(ctx context.Context, id commonids.KustoDatabaseId) (result ListByDatabaseOperationResponse, err error)
- func (c DataConnectionsClient) Update(ctx context.Context, id DataConnectionId, input DataConnection) (result UpdateOperationResponse, err error)
- func (c DataConnectionsClient) UpdateThenPoll(ctx context.Context, id DataConnectionId, input DataConnection) error
- type DatabaseRouting
- type DeleteOperationResponse
- type EventGridConnectionProperties
- type EventGridDataConnection
- type EventGridDataFormat
- type EventHubConnectionProperties
- type EventHubDataConnection
- type EventHubDataFormat
- type GetOperationResponse
- type IotHubConnectionProperties
- type IotHubDataConnection
- type IotHubDataFormat
- type ListByDatabaseOperationResponse
- type ProvisioningState
- type RawDataConnectionImpl
- type Reason
- type UpdateOperationResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PossibleValuesForBlobStorageEventType ¶
func PossibleValuesForBlobStorageEventType() []string
func PossibleValuesForCompression ¶
func PossibleValuesForCompression() []string
func PossibleValuesForDataConnectionKind ¶
func PossibleValuesForDataConnectionKind() []string
func PossibleValuesForDataConnectionType ¶
func PossibleValuesForDataConnectionType() []string
func PossibleValuesForDatabaseRouting ¶
func PossibleValuesForDatabaseRouting() []string
func PossibleValuesForEventGridDataFormat ¶
func PossibleValuesForEventGridDataFormat() []string
func PossibleValuesForEventHubDataFormat ¶
func PossibleValuesForEventHubDataFormat() []string
func PossibleValuesForIotHubDataFormat ¶
func PossibleValuesForIotHubDataFormat() []string
func PossibleValuesForProvisioningState ¶
func PossibleValuesForProvisioningState() []string
func PossibleValuesForReason ¶
func PossibleValuesForReason() []string
func ValidateDataConnectionID ¶
ValidateDataConnectionID checks that 'input' can be parsed as a Data Connection ID
Types ¶
type BlobStorageEventType ¶
type BlobStorageEventType string
const ( BlobStorageEventTypeMicrosoftPointStoragePointBlobCreated BlobStorageEventType = "Microsoft.Storage.BlobCreated" BlobStorageEventTypeMicrosoftPointStoragePointBlobRenamed BlobStorageEventType = "Microsoft.Storage.BlobRenamed" )
func (*BlobStorageEventType) UnmarshalJSON ¶
func (s *BlobStorageEventType) UnmarshalJSON(bytes []byte) error
type CheckNameAvailabilityOperationResponse ¶
type CheckNameAvailabilityOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *CheckNameResult }
type CheckNameResult ¶
type Compression ¶
type Compression string
const ( CompressionGZip Compression = "GZip" CompressionNone Compression = "None" )
func (*Compression) UnmarshalJSON ¶
func (s *Compression) UnmarshalJSON(bytes []byte) error
type CosmosDbDataConnection ¶
type CosmosDbDataConnection struct { Properties *CosmosDbDataConnectionProperties `json:"properties,omitempty"` // Fields inherited from DataConnection Id *string `json:"id,omitempty"` Location *string `json:"location,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` }
func (CosmosDbDataConnection) MarshalJSON ¶
func (s CosmosDbDataConnection) MarshalJSON() ([]byte, error)
type CosmosDbDataConnectionProperties ¶
type CosmosDbDataConnectionProperties struct { CosmosDbAccountResourceId string `json:"cosmosDbAccountResourceId"` CosmosDbContainer string `json:"cosmosDbContainer"` CosmosDbDatabase string `json:"cosmosDbDatabase"` ManagedIdentityObjectId *string `json:"managedIdentityObjectId,omitempty"` ManagedIdentityResourceId string `json:"managedIdentityResourceId"` MappingRuleName *string `json:"mappingRuleName,omitempty"` ProvisioningState *ProvisioningState `json:"provisioningState,omitempty"` RetrievalStartDate *string `json:"retrievalStartDate,omitempty"` TableName string `json:"tableName"` }
func (*CosmosDbDataConnectionProperties) GetRetrievalStartDateAsTime ¶
func (o *CosmosDbDataConnectionProperties) GetRetrievalStartDateAsTime() (*time.Time, error)
func (*CosmosDbDataConnectionProperties) SetRetrievalStartDateAsTime ¶
func (o *CosmosDbDataConnectionProperties) SetRetrievalStartDateAsTime(input time.Time)
type DataConnection ¶
type DataConnection interface { }
type DataConnectionCheckNameRequest ¶
type DataConnectionCheckNameRequest struct { Name string `json:"name"` Type DataConnectionType `json:"type"` }
type DataConnectionId ¶
type DataConnectionId struct { SubscriptionId string ResourceGroupName string ClusterName string DatabaseName string DataConnectionName string }
DataConnectionId is a struct representing the Resource ID for a Data Connection
func NewDataConnectionID ¶
func NewDataConnectionID(subscriptionId string, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) DataConnectionId
NewDataConnectionID returns a new DataConnectionId struct
func ParseDataConnectionID ¶
func ParseDataConnectionID(input string) (*DataConnectionId, error)
ParseDataConnectionID parses 'input' into a DataConnectionId
func ParseDataConnectionIDInsensitively ¶
func ParseDataConnectionIDInsensitively(input string) (*DataConnectionId, error)
ParseDataConnectionIDInsensitively parses 'input' case-insensitively into a DataConnectionId note: this method should only be used for API response data and not user input
func (*DataConnectionId) FromParseResult ¶
func (id *DataConnectionId) FromParseResult(input resourceids.ParseResult) error
func (DataConnectionId) ID ¶
func (id DataConnectionId) ID() string
ID returns the formatted Data Connection ID
func (DataConnectionId) Segments ¶
func (id DataConnectionId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Data Connection ID
func (DataConnectionId) String ¶
func (id DataConnectionId) String() string
String returns a human-readable description of this Data Connection ID
type DataConnectionKind ¶
type DataConnectionKind string
const ( DataConnectionKindCosmosDb DataConnectionKind = "CosmosDb" DataConnectionKindEventGrid DataConnectionKind = "EventGrid" DataConnectionKindEventHub DataConnectionKind = "EventHub" DataConnectionKindIotHub DataConnectionKind = "IotHub" )
func (*DataConnectionKind) UnmarshalJSON ¶
func (s *DataConnectionKind) UnmarshalJSON(bytes []byte) error
type DataConnectionListResult ¶
type DataConnectionListResult struct {
Value *[]DataConnection `json:"value,omitempty"`
}
func (*DataConnectionListResult) UnmarshalJSON ¶
func (s *DataConnectionListResult) UnmarshalJSON(bytes []byte) error
type DataConnectionType ¶
type DataConnectionType string
const (
DataConnectionTypeMicrosoftPointKustoClustersDatabasesDataConnections DataConnectionType = "Microsoft.Kusto/clusters/databases/dataConnections"
)
func (*DataConnectionType) UnmarshalJSON ¶
func (s *DataConnectionType) UnmarshalJSON(bytes []byte) error
type DataConnectionValidation ¶
type DataConnectionValidation struct { DataConnectionName *string `json:"dataConnectionName,omitempty"` Properties DataConnection `json:"properties"` }
func (*DataConnectionValidation) UnmarshalJSON ¶
func (s *DataConnectionValidation) UnmarshalJSON(bytes []byte) error
type DataConnectionValidationListResult ¶
type DataConnectionValidationListResult struct {
Value *[]DataConnectionValidationResult `json:"value,omitempty"`
}
type DataConnectionValidationResult ¶
type DataConnectionValidationResult struct {
ErrorMessage *string `json:"errorMessage,omitempty"`
}
type DataConnectionsClient ¶
type DataConnectionsClient struct {
Client *resourcemanager.Client
}
func NewDataConnectionsClientWithBaseURI ¶
func NewDataConnectionsClientWithBaseURI(sdkApi sdkEnv.Api) (*DataConnectionsClient, error)
func (DataConnectionsClient) CheckNameAvailability ¶
func (c DataConnectionsClient) CheckNameAvailability(ctx context.Context, id commonids.KustoDatabaseId, input DataConnectionCheckNameRequest) (result CheckNameAvailabilityOperationResponse, err error)
CheckNameAvailability ...
func (DataConnectionsClient) CreateOrUpdate ¶
func (c DataConnectionsClient) CreateOrUpdate(ctx context.Context, id DataConnectionId, input DataConnection) (result CreateOrUpdateOperationResponse, err error)
CreateOrUpdate ...
func (DataConnectionsClient) CreateOrUpdateThenPoll ¶
func (c DataConnectionsClient) CreateOrUpdateThenPoll(ctx context.Context, id DataConnectionId, input DataConnection) error
CreateOrUpdateThenPoll performs CreateOrUpdate then polls until it's completed
func (DataConnectionsClient) DataConnectionValidation ¶
func (c DataConnectionsClient) DataConnectionValidation(ctx context.Context, id commonids.KustoDatabaseId, input DataConnectionValidation) (result DataConnectionValidationOperationResponse, err error)
DataConnectionValidation ...
func (DataConnectionsClient) DataConnectionValidationThenPoll ¶
func (c DataConnectionsClient) DataConnectionValidationThenPoll(ctx context.Context, id commonids.KustoDatabaseId, input DataConnectionValidation) error
DataConnectionValidationThenPoll performs DataConnectionValidation then polls until it's completed
func (DataConnectionsClient) Delete ¶
func (c DataConnectionsClient) Delete(ctx context.Context, id DataConnectionId) (result DeleteOperationResponse, err error)
Delete ...
func (DataConnectionsClient) DeleteThenPoll ¶
func (c DataConnectionsClient) DeleteThenPoll(ctx context.Context, id DataConnectionId) error
DeleteThenPoll performs Delete then polls until it's completed
func (DataConnectionsClient) Get ¶
func (c DataConnectionsClient) Get(ctx context.Context, id DataConnectionId) (result GetOperationResponse, err error)
Get ...
func (DataConnectionsClient) ListByDatabase ¶
func (c DataConnectionsClient) ListByDatabase(ctx context.Context, id commonids.KustoDatabaseId) (result ListByDatabaseOperationResponse, err error)
ListByDatabase ...
func (DataConnectionsClient) Update ¶
func (c DataConnectionsClient) Update(ctx context.Context, id DataConnectionId, input DataConnection) (result UpdateOperationResponse, err error)
Update ...
func (DataConnectionsClient) UpdateThenPoll ¶
func (c DataConnectionsClient) UpdateThenPoll(ctx context.Context, id DataConnectionId, input DataConnection) error
UpdateThenPoll performs Update then polls until it's completed
type DatabaseRouting ¶
type DatabaseRouting string
const ( DatabaseRoutingMulti DatabaseRouting = "Multi" DatabaseRoutingSingle DatabaseRouting = "Single" )
func (*DatabaseRouting) UnmarshalJSON ¶
func (s *DatabaseRouting) UnmarshalJSON(bytes []byte) error
type DeleteOperationResponse ¶
type EventGridConnectionProperties ¶
type EventGridConnectionProperties struct { BlobStorageEventType *BlobStorageEventType `json:"blobStorageEventType,omitempty"` ConsumerGroup string `json:"consumerGroup"` DataFormat *EventGridDataFormat `json:"dataFormat,omitempty"` DatabaseRouting *DatabaseRouting `json:"databaseRouting,omitempty"` EventGridResourceId *string `json:"eventGridResourceId,omitempty"` EventHubResourceId string `json:"eventHubResourceId"` IgnoreFirstRecord *bool `json:"ignoreFirstRecord,omitempty"` ManagedIdentityObjectId *string `json:"managedIdentityObjectId,omitempty"` ManagedIdentityResourceId *string `json:"managedIdentityResourceId,omitempty"` MappingRuleName *string `json:"mappingRuleName,omitempty"` ProvisioningState *ProvisioningState `json:"provisioningState,omitempty"` StorageAccountResourceId string `json:"storageAccountResourceId"` TableName *string `json:"tableName,omitempty"` }
type EventGridDataConnection ¶
type EventGridDataConnection struct { Properties *EventGridConnectionProperties `json:"properties,omitempty"` // Fields inherited from DataConnection Id *string `json:"id,omitempty"` Location *string `json:"location,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` }
func (EventGridDataConnection) MarshalJSON ¶
func (s EventGridDataConnection) MarshalJSON() ([]byte, error)
type EventGridDataFormat ¶
type EventGridDataFormat string
const ( EventGridDataFormatAPACHEAVRO EventGridDataFormat = "APACHEAVRO" EventGridDataFormatAVRO EventGridDataFormat = "AVRO" EventGridDataFormatCSV EventGridDataFormat = "CSV" EventGridDataFormatJSON EventGridDataFormat = "JSON" EventGridDataFormatMULTIJSON EventGridDataFormat = "MULTIJSON" EventGridDataFormatORC EventGridDataFormat = "ORC" EventGridDataFormatPARQUET EventGridDataFormat = "PARQUET" EventGridDataFormatPSV EventGridDataFormat = "PSV" EventGridDataFormatRAW EventGridDataFormat = "RAW" EventGridDataFormatSCSV EventGridDataFormat = "SCSV" EventGridDataFormatSINGLEJSON EventGridDataFormat = "SINGLEJSON" EventGridDataFormatSOHSV EventGridDataFormat = "SOHSV" EventGridDataFormatTSV EventGridDataFormat = "TSV" EventGridDataFormatTSVE EventGridDataFormat = "TSVE" EventGridDataFormatTXT EventGridDataFormat = "TXT" EventGridDataFormatWThreeCLOGFILE EventGridDataFormat = "W3CLOGFILE" )
func (*EventGridDataFormat) UnmarshalJSON ¶
func (s *EventGridDataFormat) UnmarshalJSON(bytes []byte) error
type EventHubConnectionProperties ¶
type EventHubConnectionProperties struct { Compression *Compression `json:"compression,omitempty"` ConsumerGroup string `json:"consumerGroup"` DataFormat *EventHubDataFormat `json:"dataFormat,omitempty"` DatabaseRouting *DatabaseRouting `json:"databaseRouting,omitempty"` EventHubResourceId string `json:"eventHubResourceId"` EventSystemProperties *[]string `json:"eventSystemProperties,omitempty"` ManagedIdentityObjectId *string `json:"managedIdentityObjectId,omitempty"` ManagedIdentityResourceId *string `json:"managedIdentityResourceId,omitempty"` MappingRuleName *string `json:"mappingRuleName,omitempty"` ProvisioningState *ProvisioningState `json:"provisioningState,omitempty"` RetrievalStartDate *string `json:"retrievalStartDate,omitempty"` TableName *string `json:"tableName,omitempty"` }
func (*EventHubConnectionProperties) GetRetrievalStartDateAsTime ¶
func (o *EventHubConnectionProperties) GetRetrievalStartDateAsTime() (*time.Time, error)
func (*EventHubConnectionProperties) SetRetrievalStartDateAsTime ¶
func (o *EventHubConnectionProperties) SetRetrievalStartDateAsTime(input time.Time)
type EventHubDataConnection ¶
type EventHubDataConnection struct { Properties *EventHubConnectionProperties `json:"properties,omitempty"` // Fields inherited from DataConnection Id *string `json:"id,omitempty"` Location *string `json:"location,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` }
func (EventHubDataConnection) MarshalJSON ¶
func (s EventHubDataConnection) MarshalJSON() ([]byte, error)
type EventHubDataFormat ¶
type EventHubDataFormat string
const ( EventHubDataFormatAPACHEAVRO EventHubDataFormat = "APACHEAVRO" EventHubDataFormatAVRO EventHubDataFormat = "AVRO" EventHubDataFormatCSV EventHubDataFormat = "CSV" EventHubDataFormatJSON EventHubDataFormat = "JSON" EventHubDataFormatMULTIJSON EventHubDataFormat = "MULTIJSON" EventHubDataFormatORC EventHubDataFormat = "ORC" EventHubDataFormatPARQUET EventHubDataFormat = "PARQUET" EventHubDataFormatPSV EventHubDataFormat = "PSV" EventHubDataFormatRAW EventHubDataFormat = "RAW" EventHubDataFormatSCSV EventHubDataFormat = "SCSV" EventHubDataFormatSINGLEJSON EventHubDataFormat = "SINGLEJSON" EventHubDataFormatSOHSV EventHubDataFormat = "SOHSV" EventHubDataFormatTSV EventHubDataFormat = "TSV" EventHubDataFormatTSVE EventHubDataFormat = "TSVE" EventHubDataFormatTXT EventHubDataFormat = "TXT" EventHubDataFormatWThreeCLOGFILE EventHubDataFormat = "W3CLOGFILE" )
func (*EventHubDataFormat) UnmarshalJSON ¶
func (s *EventHubDataFormat) UnmarshalJSON(bytes []byte) error
type GetOperationResponse ¶
type GetOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *DataConnection }
type IotHubConnectionProperties ¶
type IotHubConnectionProperties struct { ConsumerGroup string `json:"consumerGroup"` DataFormat *IotHubDataFormat `json:"dataFormat,omitempty"` DatabaseRouting *DatabaseRouting `json:"databaseRouting,omitempty"` EventSystemProperties *[]string `json:"eventSystemProperties,omitempty"` IotHubResourceId string `json:"iotHubResourceId"` MappingRuleName *string `json:"mappingRuleName,omitempty"` ProvisioningState *ProvisioningState `json:"provisioningState,omitempty"` RetrievalStartDate *string `json:"retrievalStartDate,omitempty"` TableName *string `json:"tableName,omitempty"` }
func (*IotHubConnectionProperties) GetRetrievalStartDateAsTime ¶
func (o *IotHubConnectionProperties) GetRetrievalStartDateAsTime() (*time.Time, error)
func (*IotHubConnectionProperties) SetRetrievalStartDateAsTime ¶
func (o *IotHubConnectionProperties) SetRetrievalStartDateAsTime(input time.Time)
type IotHubDataConnection ¶
type IotHubDataConnection struct { Properties *IotHubConnectionProperties `json:"properties,omitempty"` // Fields inherited from DataConnection Id *string `json:"id,omitempty"` Location *string `json:"location,omitempty"` Name *string `json:"name,omitempty"` Type *string `json:"type,omitempty"` }
func (IotHubDataConnection) MarshalJSON ¶
func (s IotHubDataConnection) MarshalJSON() ([]byte, error)
type IotHubDataFormat ¶
type IotHubDataFormat string
const ( IotHubDataFormatAPACHEAVRO IotHubDataFormat = "APACHEAVRO" IotHubDataFormatAVRO IotHubDataFormat = "AVRO" IotHubDataFormatCSV IotHubDataFormat = "CSV" IotHubDataFormatJSON IotHubDataFormat = "JSON" IotHubDataFormatMULTIJSON IotHubDataFormat = "MULTIJSON" IotHubDataFormatORC IotHubDataFormat = "ORC" IotHubDataFormatPARQUET IotHubDataFormat = "PARQUET" IotHubDataFormatPSV IotHubDataFormat = "PSV" IotHubDataFormatRAW IotHubDataFormat = "RAW" IotHubDataFormatSCSV IotHubDataFormat = "SCSV" IotHubDataFormatSINGLEJSON IotHubDataFormat = "SINGLEJSON" IotHubDataFormatSOHSV IotHubDataFormat = "SOHSV" IotHubDataFormatTSV IotHubDataFormat = "TSV" IotHubDataFormatTSVE IotHubDataFormat = "TSVE" IotHubDataFormatTXT IotHubDataFormat = "TXT" IotHubDataFormatWThreeCLOGFILE IotHubDataFormat = "W3CLOGFILE" )
func (*IotHubDataFormat) UnmarshalJSON ¶
func (s *IotHubDataFormat) UnmarshalJSON(bytes []byte) error
type ListByDatabaseOperationResponse ¶
type ListByDatabaseOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *DataConnectionListResult }
type ProvisioningState ¶
type ProvisioningState string
const ( ProvisioningStateCanceled ProvisioningState = "Canceled" ProvisioningStateCreating ProvisioningState = "Creating" ProvisioningStateDeleting ProvisioningState = "Deleting" ProvisioningStateFailed ProvisioningState = "Failed" ProvisioningStateMoving ProvisioningState = "Moving" ProvisioningStateRunning ProvisioningState = "Running" ProvisioningStateSucceeded ProvisioningState = "Succeeded" )
func (*ProvisioningState) UnmarshalJSON ¶
func (s *ProvisioningState) UnmarshalJSON(bytes []byte) error
type RawDataConnectionImpl ¶
RawDataConnectionImpl 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 UpdateOperationResponse ¶
Source Files ¶
- client.go
- constants.go
- id_dataconnection.go
- method_checknameavailability.go
- method_createorupdate.go
- method_dataconnectionvalidation.go
- method_delete.go
- method_get.go
- method_listbydatabase.go
- method_update.go
- model_checknameresult.go
- model_cosmosdbdataconnection.go
- model_cosmosdbdataconnectionproperties.go
- model_dataconnection.go
- model_dataconnectionchecknamerequest.go
- model_dataconnectionlistresult.go
- model_dataconnectionvalidation.go
- model_dataconnectionvalidationlistresult.go
- model_dataconnectionvalidationresult.go
- model_eventgridconnectionproperties.go
- model_eventgriddataconnection.go
- model_eventhubconnectionproperties.go
- model_eventhubdataconnection.go
- model_iothubconnectionproperties.go
- model_iothubdataconnection.go
- version.go