Documentation ¶
Overview ¶
Deprecated: Please note, this package has been deprecated. A replacement package is available github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/kusto/armkusto(https://pkg.go.dev/github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/kusto/armkusto). We strongly encourage you to upgrade to continue receiving updates. See [Migration Guide](https://aka.ms/azsdk/golang/t2/migration) for guidance on upgrading. Refer to our [deprecation policy](https://azure.github.io/azure-sdk/policies_support.html) for more details.
Package kusto implements the Azure ARM Kusto service API version 2021-01-01.
The Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
Index ¶
- Constants
- func UserAgent() string
- func Version() string
- type AttachedDatabaseConfiguration
- type AttachedDatabaseConfigurationListResult
- type AttachedDatabaseConfigurationProperties
- type AttachedDatabaseConfigurationsClient
- func (client AttachedDatabaseConfigurationsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (result AttachedDatabaseConfigurationsCreateOrUpdateFuture, err error)
- func (client AttachedDatabaseConfigurationsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client AttachedDatabaseConfigurationsClient) CreateOrUpdateResponder(resp *http.Response) (result AttachedDatabaseConfiguration, err error)
- func (client AttachedDatabaseConfigurationsClient) CreateOrUpdateSender(req *http.Request) (future AttachedDatabaseConfigurationsCreateOrUpdateFuture, err error)
- func (client AttachedDatabaseConfigurationsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result AttachedDatabaseConfigurationsDeleteFuture, err error)
- func (client AttachedDatabaseConfigurationsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client AttachedDatabaseConfigurationsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client AttachedDatabaseConfigurationsClient) DeleteSender(req *http.Request) (future AttachedDatabaseConfigurationsDeleteFuture, err error)
- func (client AttachedDatabaseConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result AttachedDatabaseConfiguration, err error)
- func (client AttachedDatabaseConfigurationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client AttachedDatabaseConfigurationsClient) GetResponder(resp *http.Response) (result AttachedDatabaseConfiguration, err error)
- func (client AttachedDatabaseConfigurationsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client AttachedDatabaseConfigurationsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result AttachedDatabaseConfigurationListResult, err error)
- func (client AttachedDatabaseConfigurationsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client AttachedDatabaseConfigurationsClient) ListByClusterResponder(resp *http.Response) (result AttachedDatabaseConfigurationListResult, err error)
- func (client AttachedDatabaseConfigurationsClient) ListByClusterSender(req *http.Request) (*http.Response, error)
- type AttachedDatabaseConfigurationsCreateOrUpdateFuture
- type AttachedDatabaseConfigurationsDeleteFuture
- type AzureCapacity
- type AzureEntityResource
- type AzureResourceSku
- type AzureScaleType
- type AzureSku
- type AzureSkuName
- type AzureSkuTier
- type BaseClient
- type BasicDataConnection
- type BasicDatabase
- type BlobStorageEventType
- type CheckNameRequest
- type CheckNameResult
- type CloudError
- type CloudErrorBody
- type Cluster
- type ClusterCheckNameRequest
- type ClusterListResult
- type ClusterPrincipalAssignment
- type ClusterPrincipalAssignmentCheckNameRequest
- type ClusterPrincipalAssignmentListResult
- type ClusterPrincipalAssignmentsClient
- func (client ClusterPrincipalAssignmentsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, ...) (result CheckNameResult, err error)
- func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
- func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
- func (client ClusterPrincipalAssignmentsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClusterPrincipalAssignmentsCreateOrUpdateFuture, err error)
- func (client ClusterPrincipalAssignmentsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClusterPrincipalAssignmentsClient) CreateOrUpdateResponder(resp *http.Response) (result ClusterPrincipalAssignment, err error)
- func (client ClusterPrincipalAssignmentsClient) CreateOrUpdateSender(req *http.Request) (future ClusterPrincipalAssignmentsCreateOrUpdateFuture, err error)
- func (client ClusterPrincipalAssignmentsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClusterPrincipalAssignmentsDeleteFuture, err error)
- func (client ClusterPrincipalAssignmentsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClusterPrincipalAssignmentsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClusterPrincipalAssignmentsClient) DeleteSender(req *http.Request) (future ClusterPrincipalAssignmentsDeleteFuture, err error)
- func (client ClusterPrincipalAssignmentsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClusterPrincipalAssignment, err error)
- func (client ClusterPrincipalAssignmentsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClusterPrincipalAssignmentsClient) GetResponder(resp *http.Response) (result ClusterPrincipalAssignment, err error)
- func (client ClusterPrincipalAssignmentsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ClusterPrincipalAssignmentsClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterPrincipalAssignmentListResult, err error)
- func (client ClusterPrincipalAssignmentsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClusterPrincipalAssignmentsClient) ListResponder(resp *http.Response) (result ClusterPrincipalAssignmentListResult, err error)
- func (client ClusterPrincipalAssignmentsClient) ListSender(req *http.Request) (*http.Response, error)
- type ClusterPrincipalAssignmentsCreateOrUpdateFuture
- type ClusterPrincipalAssignmentsDeleteFuture
- type ClusterPrincipalProperties
- type ClusterPrincipalRole
- type ClusterProperties
- type ClusterUpdate
- type ClustersAddLanguageExtensionsFuture
- type ClustersClient
- func (client ClustersClient) AddLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersAddLanguageExtensionsFuture, err error)
- func (client ClustersClient) AddLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) AddLanguageExtensionsResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) AddLanguageExtensionsSender(req *http.Request) (future ClustersAddLanguageExtensionsFuture, err error)
- func (client ClustersClient) CheckNameAvailability(ctx context.Context, location string, clusterName ClusterCheckNameRequest) (result CheckNameResult, err error)
- func (client ClustersClient) CheckNameAvailabilityPreparer(ctx context.Context, location string, clusterName ClusterCheckNameRequest) (*http.Request, error)
- func (client ClustersClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
- func (client ClustersClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersCreateOrUpdateFuture, err error)
- func (client ClustersClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) CreateOrUpdateResponder(resp *http.Response) (result Cluster, err error)
- func (client ClustersClient) CreateOrUpdateSender(req *http.Request) (future ClustersCreateOrUpdateFuture, err error)
- func (client ClustersClient) Delete(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDeleteFuture, err error)
- func (client ClustersClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) DeleteSender(req *http.Request) (future ClustersDeleteFuture, err error)
- func (client ClustersClient) DetachFollowerDatabases(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersDetachFollowerDatabasesFuture, err error)
- func (client ClustersClient) DetachFollowerDatabasesPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) DetachFollowerDatabasesResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) DetachFollowerDatabasesSender(req *http.Request) (future ClustersDetachFollowerDatabasesFuture, err error)
- func (client ClustersClient) DiagnoseVirtualNetwork(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDiagnoseVirtualNetworkFuture, err error)
- func (client ClustersClient) DiagnoseVirtualNetworkPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) DiagnoseVirtualNetworkResponder(resp *http.Response) (result DiagnoseVirtualNetworkResult, err error)
- func (client ClustersClient) DiagnoseVirtualNetworkSender(req *http.Request) (future ClustersDiagnoseVirtualNetworkFuture, err error)
- func (client ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string) (result Cluster, err error)
- func (client ClustersClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) GetResponder(resp *http.Response) (result Cluster, err error)
- func (client ClustersClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) List(ctx context.Context) (result ClusterListResult, err error)
- func (client ClustersClient) ListByResourceGroup(ctx context.Context, resourceGroupName string) (result ClusterListResult, err error)
- func (client ClustersClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error)
- func (client ClustersClient) ListByResourceGroupResponder(resp *http.Response) (result ClusterListResult, err error)
- func (client ClustersClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) ListFollowerDatabases(ctx context.Context, resourceGroupName string, clusterName string) (result FollowerDatabaseListResult, err error)
- func (client ClustersClient) ListFollowerDatabasesPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) ListFollowerDatabasesResponder(resp *http.Response) (result FollowerDatabaseListResult, err error)
- func (client ClustersClient) ListFollowerDatabasesSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) ListLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string) (result LanguageExtensionsList, err error)
- func (client ClustersClient) ListLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) ListLanguageExtensionsResponder(resp *http.Response) (result LanguageExtensionsList, err error)
- func (client ClustersClient) ListLanguageExtensionsSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) ListPreparer(ctx context.Context) (*http.Request, error)
- func (client ClustersClient) ListResponder(resp *http.Response) (result ClusterListResult, err error)
- func (client ClustersClient) ListSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) ListSkus(ctx context.Context) (result SkuDescriptionList, err error)
- func (client ClustersClient) ListSkusByResource(ctx context.Context, resourceGroupName string, clusterName string) (result ListResourceSkusResult, err error)
- func (client ClustersClient) ListSkusByResourcePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) ListSkusByResourceResponder(resp *http.Response) (result ListResourceSkusResult, err error)
- func (client ClustersClient) ListSkusByResourceSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) ListSkusPreparer(ctx context.Context) (*http.Request, error)
- func (client ClustersClient) ListSkusResponder(resp *http.Response) (result SkuDescriptionList, err error)
- func (client ClustersClient) ListSkusSender(req *http.Request) (*http.Response, error)
- func (client ClustersClient) RemoveLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersRemoveLanguageExtensionsFuture, err error)
- func (client ClustersClient) RemoveLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) RemoveLanguageExtensionsResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) RemoveLanguageExtensionsSender(req *http.Request) (future ClustersRemoveLanguageExtensionsFuture, err error)
- func (client ClustersClient) Start(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersStartFuture, err error)
- func (client ClustersClient) StartPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) StartResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) StartSender(req *http.Request) (future ClustersStartFuture, err error)
- func (client ClustersClient) Stop(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersStopFuture, err error)
- func (client ClustersClient) StopPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client ClustersClient) StopResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ClustersClient) StopSender(req *http.Request) (future ClustersStopFuture, err error)
- func (client ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ClustersUpdateFuture, err error)
- func (client ClustersClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ClustersClient) UpdateResponder(resp *http.Response) (result Cluster, err error)
- func (client ClustersClient) UpdateSender(req *http.Request) (future ClustersUpdateFuture, err error)
- type ClustersCreateOrUpdateFuture
- type ClustersDeleteFuture
- type ClustersDetachFollowerDatabasesFuture
- type ClustersDiagnoseVirtualNetworkFuture
- type ClustersRemoveLanguageExtensionsFuture
- type ClustersStartFuture
- type ClustersStopFuture
- type ClustersUpdateFuture
- type Compression
- type CreatedByType
- type DataConnection
- func (dc DataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
- func (dc DataConnection) AsDataConnection() (*DataConnection, bool)
- func (dc DataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
- func (dc DataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
- func (dc DataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
- func (dc DataConnection) MarshalJSON() ([]byte, error)
- type DataConnectionCheckNameRequest
- type DataConnectionListResult
- type DataConnectionModel
- type DataConnectionValidation
- type DataConnectionValidationListResult
- type DataConnectionValidationResult
- type DataConnectionsClient
- func (client DataConnectionsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, ...) (result CheckNameResult, err error)
- func (client DataConnectionsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DataConnectionsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
- func (client DataConnectionsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
- func (client DataConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DataConnectionsCreateOrUpdateFuture, err error)
- func (client DataConnectionsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DataConnectionsClient) CreateOrUpdateResponder(resp *http.Response) (result DataConnectionModel, err error)
- func (client DataConnectionsClient) CreateOrUpdateSender(req *http.Request) (future DataConnectionsCreateOrUpdateFuture, err error)
- func (client DataConnectionsClient) DataConnectionValidationMethod(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DataConnectionsDataConnectionValidationMethodFuture, err error)
- func (client DataConnectionsClient) DataConnectionValidationMethodPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DataConnectionsClient) DataConnectionValidationMethodResponder(resp *http.Response) (result DataConnectionValidationListResult, err error)
- func (client DataConnectionsClient) DataConnectionValidationMethodSender(req *http.Request) (future DataConnectionsDataConnectionValidationMethodFuture, err error)
- func (client DataConnectionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DataConnectionsDeleteFuture, err error)
- func (client DataConnectionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DataConnectionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client DataConnectionsClient) DeleteSender(req *http.Request) (future DataConnectionsDeleteFuture, err error)
- func (client DataConnectionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DataConnectionModel, err error)
- func (client DataConnectionsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DataConnectionsClient) GetResponder(resp *http.Response) (result DataConnectionModel, err error)
- func (client DataConnectionsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client DataConnectionsClient) ListByDatabase(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DataConnectionListResult, err error)
- func (client DataConnectionsClient) ListByDatabasePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DataConnectionsClient) ListByDatabaseResponder(resp *http.Response) (result DataConnectionListResult, err error)
- func (client DataConnectionsClient) ListByDatabaseSender(req *http.Request) (*http.Response, error)
- func (client DataConnectionsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DataConnectionsUpdateFuture, err error)
- func (client DataConnectionsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DataConnectionsClient) UpdateResponder(resp *http.Response) (result DataConnectionModel, err error)
- func (client DataConnectionsClient) UpdateSender(req *http.Request) (future DataConnectionsUpdateFuture, err error)
- type DataConnectionsCreateOrUpdateFuture
- type DataConnectionsDataConnectionValidationMethodFuture
- type DataConnectionsDeleteFuture
- type DataConnectionsUpdateFuture
- type Database
- func (d Database) AsBasicDatabase() (BasicDatabase, bool)
- func (d Database) AsDatabase() (*Database, bool)
- func (d Database) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)
- func (d Database) AsReadWriteDatabase() (*ReadWriteDatabase, bool)
- func (d Database) MarshalJSON() ([]byte, error)
- type DatabaseListResult
- type DatabaseModel
- type DatabasePrincipal
- type DatabasePrincipalAssignment
- type DatabasePrincipalAssignmentCheckNameRequest
- type DatabasePrincipalAssignmentListResult
- type DatabasePrincipalAssignmentsClient
- func (client DatabasePrincipalAssignmentsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, ...) (result CheckNameResult, err error)
- func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
- func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
- func (client DatabasePrincipalAssignmentsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasePrincipalAssignmentsCreateOrUpdateFuture, err error)
- func (client DatabasePrincipalAssignmentsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasePrincipalAssignmentsClient) CreateOrUpdateResponder(resp *http.Response) (result DatabasePrincipalAssignment, err error)
- func (client DatabasePrincipalAssignmentsClient) CreateOrUpdateSender(req *http.Request) (future DatabasePrincipalAssignmentsCreateOrUpdateFuture, err error)
- func (client DatabasePrincipalAssignmentsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasePrincipalAssignmentsDeleteFuture, err error)
- func (client DatabasePrincipalAssignmentsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasePrincipalAssignmentsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client DatabasePrincipalAssignmentsClient) DeleteSender(req *http.Request) (future DatabasePrincipalAssignmentsDeleteFuture, err error)
- func (client DatabasePrincipalAssignmentsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasePrincipalAssignment, err error)
- func (client DatabasePrincipalAssignmentsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasePrincipalAssignmentsClient) GetResponder(resp *http.Response) (result DatabasePrincipalAssignment, err error)
- func (client DatabasePrincipalAssignmentsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client DatabasePrincipalAssignmentsClient) List(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasePrincipalAssignmentListResult, err error)
- func (client DatabasePrincipalAssignmentsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasePrincipalAssignmentsClient) ListResponder(resp *http.Response) (result DatabasePrincipalAssignmentListResult, err error)
- func (client DatabasePrincipalAssignmentsClient) ListSender(req *http.Request) (*http.Response, error)
- type DatabasePrincipalAssignmentsCreateOrUpdateFuture
- type DatabasePrincipalAssignmentsDeleteFuture
- type DatabasePrincipalListRequest
- type DatabasePrincipalListResult
- type DatabasePrincipalProperties
- type DatabasePrincipalRole
- type DatabasePrincipalType
- type DatabaseStatistics
- type DatabasesClient
- func (client DatabasesClient) AddPrincipals(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasePrincipalListResult, err error)
- func (client DatabasesClient) AddPrincipalsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) AddPrincipalsResponder(resp *http.Response) (result DatabasePrincipalListResult, err error)
- func (client DatabasesClient) AddPrincipalsSender(req *http.Request) (*http.Response, error)
- func (client DatabasesClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, ...) (result CheckNameResult, err error)
- func (client DatabasesClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
- func (client DatabasesClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
- func (client DatabasesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasesCreateOrUpdateFuture, err error)
- func (client DatabasesClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) CreateOrUpdateResponder(resp *http.Response) (result DatabaseModel, err error)
- func (client DatabasesClient) CreateOrUpdateSender(req *http.Request) (future DatabasesCreateOrUpdateFuture, err error)
- func (client DatabasesClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasesDeleteFuture, err error)
- func (client DatabasesClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client DatabasesClient) DeleteSender(req *http.Request) (future DatabasesDeleteFuture, err error)
- func (client DatabasesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabaseModel, err error)
- func (client DatabasesClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) GetResponder(resp *http.Response) (result DatabaseModel, err error)
- func (client DatabasesClient) GetSender(req *http.Request) (*http.Response, error)
- func (client DatabasesClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result DatabaseListResult, err error)
- func (client DatabasesClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
- func (client DatabasesClient) ListByClusterResponder(resp *http.Response) (result DatabaseListResult, err error)
- func (client DatabasesClient) ListByClusterSender(req *http.Request) (*http.Response, error)
- func (client DatabasesClient) ListPrincipals(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasePrincipalListResult, err error)
- func (client DatabasesClient) ListPrincipalsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) ListPrincipalsResponder(resp *http.Response) (result DatabasePrincipalListResult, err error)
- func (client DatabasesClient) ListPrincipalsSender(req *http.Request) (*http.Response, error)
- func (client DatabasesClient) RemovePrincipals(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasePrincipalListResult, err error)
- func (client DatabasesClient) RemovePrincipalsPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) RemovePrincipalsResponder(resp *http.Response) (result DatabasePrincipalListResult, err error)
- func (client DatabasesClient) RemovePrincipalsSender(req *http.Request) (*http.Response, error)
- func (client DatabasesClient) Update(ctx context.Context, resourceGroupName string, clusterName string, ...) (result DatabasesUpdateFuture, err error)
- func (client DatabasesClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) UpdateResponder(resp *http.Response) (result DatabaseModel, err error)
- func (client DatabasesClient) UpdateSender(req *http.Request) (future DatabasesUpdateFuture, err error)
- type DatabasesCreateOrUpdateFuture
- type DatabasesDeleteFuture
- type DatabasesUpdateFuture
- type DefaultPrincipalsModificationKind
- type DiagnoseVirtualNetworkResult
- type EngineType
- type EventGridConnectionProperties
- type EventGridDataConnection
- func (egdc EventGridDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
- func (egdc EventGridDataConnection) AsDataConnection() (*DataConnection, bool)
- func (egdc EventGridDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
- func (egdc EventGridDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
- func (egdc EventGridDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
- func (egdc EventGridDataConnection) MarshalJSON() ([]byte, error)
- func (egdc *EventGridDataConnection) UnmarshalJSON(body []byte) error
- type EventGridDataFormat
- type EventHubConnectionProperties
- type EventHubDataConnection
- func (ehdc EventHubDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
- func (ehdc EventHubDataConnection) AsDataConnection() (*DataConnection, bool)
- func (ehdc EventHubDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
- func (ehdc EventHubDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
- func (ehdc EventHubDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
- func (ehdc EventHubDataConnection) MarshalJSON() ([]byte, error)
- func (ehdc *EventHubDataConnection) UnmarshalJSON(body []byte) error
- type EventHubDataFormat
- type FollowerDatabaseDefinition
- type FollowerDatabaseListResult
- type Identity
- type IdentityType
- type IdentityUserAssignedIdentitiesValue
- type IotHubConnectionProperties
- type IotHubDataConnection
- func (ihdc IotHubDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
- func (ihdc IotHubDataConnection) AsDataConnection() (*DataConnection, bool)
- func (ihdc IotHubDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
- func (ihdc IotHubDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
- func (ihdc IotHubDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
- func (ihdc IotHubDataConnection) MarshalJSON() ([]byte, error)
- func (ihdc *IotHubDataConnection) UnmarshalJSON(body []byte) error
- type IotHubDataFormat
- type KeyVaultProperties
- type Kind
- type KindBasicDataConnection
- type LanguageExtension
- type LanguageExtensionName
- type LanguageExtensionsList
- type ListResourceSkusResult
- type Operation
- type OperationDisplay
- type OperationListResult
- type 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
- 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 OperationResult
- type OperationResultErrorProperties
- type OperationResultProperties
- type 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 OperationsResultsClient
- func (client OperationsResultsClient) Get(ctx context.Context, location string, operationID string) (result OperationResult, err error)
- func (client OperationsResultsClient) GetPreparer(ctx context.Context, location string, operationID string) (*http.Request, error)
- func (client OperationsResultsClient) GetResponder(resp *http.Response) (result OperationResult, err error)
- func (client OperationsResultsClient) GetSender(req *http.Request) (*http.Response, error)
- type OptimizedAutoscale
- type PrincipalType
- type PrincipalsModificationKind
- type ProvisioningState
- type ProxyResource
- type ReadOnlyFollowingDatabase
- func (rofd ReadOnlyFollowingDatabase) AsBasicDatabase() (BasicDatabase, bool)
- func (rofd ReadOnlyFollowingDatabase) AsDatabase() (*Database, bool)
- func (rofd ReadOnlyFollowingDatabase) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)
- func (rofd ReadOnlyFollowingDatabase) AsReadWriteDatabase() (*ReadWriteDatabase, bool)
- func (rofd ReadOnlyFollowingDatabase) MarshalJSON() ([]byte, error)
- func (rofd *ReadOnlyFollowingDatabase) UnmarshalJSON(body []byte) error
- type ReadOnlyFollowingDatabaseProperties
- type ReadWriteDatabase
- func (rwd ReadWriteDatabase) AsBasicDatabase() (BasicDatabase, bool)
- func (rwd ReadWriteDatabase) AsDatabase() (*Database, bool)
- func (rwd ReadWriteDatabase) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)
- func (rwd ReadWriteDatabase) AsReadWriteDatabase() (*ReadWriteDatabase, bool)
- func (rwd ReadWriteDatabase) MarshalJSON() ([]byte, error)
- func (rwd *ReadWriteDatabase) UnmarshalJSON(body []byte) error
- type ReadWriteDatabaseProperties
- type Reason
- type Resource
- type Script
- type ScriptCheckNameRequest
- type ScriptListResult
- type ScriptProperties
- type ScriptsClient
- func (client ScriptsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, ...) (result CheckNameResult, err error)
- func (client ScriptsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
- func (client ScriptsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
- func (client ScriptsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ScriptsCreateOrUpdateFuture, err error)
- func (client ScriptsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptsClient) CreateOrUpdateResponder(resp *http.Response) (result Script, err error)
- func (client ScriptsClient) CreateOrUpdateSender(req *http.Request) (future ScriptsCreateOrUpdateFuture, err error)
- func (client ScriptsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ScriptsDeleteFuture, err error)
- func (client ScriptsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
- func (client ScriptsClient) DeleteSender(req *http.Request) (future ScriptsDeleteFuture, err error)
- func (client ScriptsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, ...) (result Script, err error)
- func (client ScriptsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptsClient) GetResponder(resp *http.Response) (result Script, err error)
- func (client ScriptsClient) GetSender(req *http.Request) (*http.Response, error)
- func (client ScriptsClient) ListByDatabase(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ScriptListResult, err error)
- func (client ScriptsClient) ListByDatabasePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptsClient) ListByDatabaseResponder(resp *http.Response) (result ScriptListResult, err error)
- func (client ScriptsClient) ListByDatabaseSender(req *http.Request) (*http.Response, error)
- func (client ScriptsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, ...) (result ScriptsUpdateFuture, err error)
- func (client ScriptsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client ScriptsClient) UpdateResponder(resp *http.Response) (result Script, err error)
- func (client ScriptsClient) UpdateSender(req *http.Request) (future ScriptsUpdateFuture, err error)
- type ScriptsCreateOrUpdateFuture
- type ScriptsDeleteFuture
- type ScriptsUpdateFuture
- type SkuDescription
- type SkuDescriptionList
- type SkuLocationInfoItem
- type State
- type Status
- type SystemData
- type TableLevelSharingProperties
- type TrackedResource
- type TrustedExternalTenant
- type Type
- type VirtualNetworkConfiguration
Constants ¶
const (
// DefaultBaseURI is the default URI used for the service Kusto
DefaultBaseURI = "https://management.azure.com"
)
Variables ¶
This section is empty.
Functions ¶
func UserAgent ¶
func UserAgent() string
UserAgent returns the UserAgent string to use when sending http.Requests.
func Version ¶
func Version() string
Version returns the semantic version (see http://semver.org) of the client.
Types ¶
type AttachedDatabaseConfiguration ¶
type AttachedDatabaseConfiguration struct { autorest.Response `json:"-"` // Location - Resource location. Location *string `json:"location,omitempty"` // AttachedDatabaseConfigurationProperties - The properties of the attached database configuration. *AttachedDatabaseConfigurationProperties `json:"properties,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
AttachedDatabaseConfiguration class representing an attached database configuration.
func (AttachedDatabaseConfiguration) MarshalJSON ¶
func (adc AttachedDatabaseConfiguration) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for AttachedDatabaseConfiguration.
func (*AttachedDatabaseConfiguration) UnmarshalJSON ¶
func (adc *AttachedDatabaseConfiguration) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for AttachedDatabaseConfiguration struct.
type AttachedDatabaseConfigurationListResult ¶
type AttachedDatabaseConfigurationListResult struct { autorest.Response `json:"-"` // Value - The list of attached database configurations. Value *[]AttachedDatabaseConfiguration `json:"value,omitempty"` }
AttachedDatabaseConfigurationListResult the list attached database configurations operation response.
type AttachedDatabaseConfigurationProperties ¶
type AttachedDatabaseConfigurationProperties struct { // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` // DatabaseName - The name of the database which you would like to attach, use * if you want to follow all current and future databases. DatabaseName *string `json:"databaseName,omitempty"` // ClusterResourceID - The resource id of the cluster where the databases you would like to attach reside. ClusterResourceID *string `json:"clusterResourceId,omitempty"` // AttachedDatabaseNames - READ-ONLY; The list of databases from the clusterResourceId which are currently attached to the cluster. AttachedDatabaseNames *[]string `json:"attachedDatabaseNames,omitempty"` // DefaultPrincipalsModificationKind - The default principals modification kind. Possible values include: 'DefaultPrincipalsModificationKindUnion', 'DefaultPrincipalsModificationKindReplace', 'DefaultPrincipalsModificationKindNone' DefaultPrincipalsModificationKind DefaultPrincipalsModificationKind `json:"defaultPrincipalsModificationKind,omitempty"` // TableLevelSharingProperties - Table level sharing specifications TableLevelSharingProperties *TableLevelSharingProperties `json:"tableLevelSharingProperties,omitempty"` }
AttachedDatabaseConfigurationProperties class representing the an attached database configuration properties of kind specific.
func (AttachedDatabaseConfigurationProperties) MarshalJSON ¶
func (adcp AttachedDatabaseConfigurationProperties) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for AttachedDatabaseConfigurationProperties.
type AttachedDatabaseConfigurationsClient ¶
type AttachedDatabaseConfigurationsClient struct {
BaseClient
}
AttachedDatabaseConfigurationsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewAttachedDatabaseConfigurationsClient ¶
func NewAttachedDatabaseConfigurationsClient(subscriptionID string) AttachedDatabaseConfigurationsClient
NewAttachedDatabaseConfigurationsClient creates an instance of the AttachedDatabaseConfigurationsClient client.
func NewAttachedDatabaseConfigurationsClientWithBaseURI ¶
func NewAttachedDatabaseConfigurationsClientWithBaseURI(baseURI string, subscriptionID string) AttachedDatabaseConfigurationsClient
NewAttachedDatabaseConfigurationsClientWithBaseURI creates an instance of the AttachedDatabaseConfigurationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (AttachedDatabaseConfigurationsClient) CreateOrUpdate ¶
func (client AttachedDatabaseConfigurationsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string, parameters AttachedDatabaseConfiguration) (result AttachedDatabaseConfigurationsCreateOrUpdateFuture, err error)
CreateOrUpdate creates or updates an attached database configuration. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. attachedDatabaseConfigurationName - the name of the attached database configuration. parameters - the database parameters supplied to the CreateOrUpdate operation.
func (AttachedDatabaseConfigurationsClient) CreateOrUpdatePreparer ¶
func (client AttachedDatabaseConfigurationsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string, parameters AttachedDatabaseConfiguration) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (AttachedDatabaseConfigurationsClient) CreateOrUpdateResponder ¶
func (client AttachedDatabaseConfigurationsClient) CreateOrUpdateResponder(resp *http.Response) (result AttachedDatabaseConfiguration, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (AttachedDatabaseConfigurationsClient) CreateOrUpdateSender ¶
func (client AttachedDatabaseConfigurationsClient) CreateOrUpdateSender(req *http.Request) (future AttachedDatabaseConfigurationsCreateOrUpdateFuture, err error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (AttachedDatabaseConfigurationsClient) Delete ¶
func (client AttachedDatabaseConfigurationsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (result AttachedDatabaseConfigurationsDeleteFuture, err error)
Delete deletes the attached database configuration with the given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. attachedDatabaseConfigurationName - the name of the attached database configuration.
func (AttachedDatabaseConfigurationsClient) DeletePreparer ¶
func (client AttachedDatabaseConfigurationsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (AttachedDatabaseConfigurationsClient) DeleteResponder ¶
func (client AttachedDatabaseConfigurationsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (AttachedDatabaseConfigurationsClient) DeleteSender ¶
func (client AttachedDatabaseConfigurationsClient) DeleteSender(req *http.Request) (future AttachedDatabaseConfigurationsDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (AttachedDatabaseConfigurationsClient) Get ¶
func (client AttachedDatabaseConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (result AttachedDatabaseConfiguration, err error)
Get returns an attached database configuration. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. attachedDatabaseConfigurationName - the name of the attached database configuration.
func (AttachedDatabaseConfigurationsClient) GetPreparer ¶
func (client AttachedDatabaseConfigurationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (AttachedDatabaseConfigurationsClient) GetResponder ¶
func (client AttachedDatabaseConfigurationsClient) GetResponder(resp *http.Response) (result AttachedDatabaseConfiguration, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (AttachedDatabaseConfigurationsClient) GetSender ¶
func (client AttachedDatabaseConfigurationsClient) GetSender(req *http.Request) (*http.Response, error)
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (AttachedDatabaseConfigurationsClient) ListByCluster ¶
func (client AttachedDatabaseConfigurationsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result AttachedDatabaseConfigurationListResult, err error)
ListByCluster returns the list of attached database configurations of the given Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (AttachedDatabaseConfigurationsClient) ListByClusterPreparer ¶
func (client AttachedDatabaseConfigurationsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListByClusterPreparer prepares the ListByCluster request.
func (AttachedDatabaseConfigurationsClient) ListByClusterResponder ¶
func (client AttachedDatabaseConfigurationsClient) ListByClusterResponder(resp *http.Response) (result AttachedDatabaseConfigurationListResult, err error)
ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.
func (AttachedDatabaseConfigurationsClient) ListByClusterSender ¶
func (client AttachedDatabaseConfigurationsClient) ListByClusterSender(req *http.Request) (*http.Response, error)
ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.
type AttachedDatabaseConfigurationsCreateOrUpdateFuture ¶
type AttachedDatabaseConfigurationsCreateOrUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(AttachedDatabaseConfigurationsClient) (AttachedDatabaseConfiguration, error) }
AttachedDatabaseConfigurationsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*AttachedDatabaseConfigurationsCreateOrUpdateFuture) UnmarshalJSON ¶
func (future *AttachedDatabaseConfigurationsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type AttachedDatabaseConfigurationsDeleteFuture ¶
type AttachedDatabaseConfigurationsDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(AttachedDatabaseConfigurationsClient) (autorest.Response, error) }
AttachedDatabaseConfigurationsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*AttachedDatabaseConfigurationsDeleteFuture) UnmarshalJSON ¶
func (future *AttachedDatabaseConfigurationsDeleteFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type AzureCapacity ¶
type AzureCapacity struct { // ScaleType - Scale type. Possible values include: 'AzureScaleTypeAutomatic', 'AzureScaleTypeManual', 'AzureScaleTypeNone' ScaleType AzureScaleType `json:"scaleType,omitempty"` // Minimum - Minimum allowed capacity. Minimum *int32 `json:"minimum,omitempty"` // Maximum - Maximum allowed capacity. Maximum *int32 `json:"maximum,omitempty"` // Default - The default capacity that would be used. Default *int32 `json:"default,omitempty"` }
AzureCapacity azure capacity definition.
type AzureEntityResource ¶
type AzureEntityResource struct { // Etag - READ-ONLY; Resource Etag. Etag *string `json:"etag,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
AzureEntityResource the resource model definition for an Azure Resource Manager resource with an etag.
func (AzureEntityResource) MarshalJSON ¶
func (aer AzureEntityResource) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for AzureEntityResource.
type AzureResourceSku ¶
type AzureResourceSku struct { // ResourceType - Resource Namespace and Type. ResourceType *string `json:"resourceType,omitempty"` // Sku - The SKU details. Sku *AzureSku `json:"sku,omitempty"` // Capacity - The number of instances of the cluster. Capacity *AzureCapacity `json:"capacity,omitempty"` }
AzureResourceSku azure resource SKU definition.
type AzureScaleType ¶
type AzureScaleType string
AzureScaleType enumerates the values for azure scale type.
const ( // AzureScaleTypeAutomatic ... AzureScaleTypeAutomatic AzureScaleType = "automatic" // AzureScaleTypeManual ... AzureScaleTypeManual AzureScaleType = "manual" // AzureScaleTypeNone ... AzureScaleTypeNone AzureScaleType = "none" )
func PossibleAzureScaleTypeValues ¶
func PossibleAzureScaleTypeValues() []AzureScaleType
PossibleAzureScaleTypeValues returns an array of possible values for the AzureScaleType const type.
type AzureSku ¶
type AzureSku struct { // Name - SKU name. Possible values include: 'AzureSkuNameStandardDS13V21TBPS', 'AzureSkuNameStandardDS13V22TBPS', 'AzureSkuNameStandardDS14V23TBPS', 'AzureSkuNameStandardDS14V24TBPS', 'AzureSkuNameStandardD13V2', 'AzureSkuNameStandardD14V2', 'AzureSkuNameStandardL8s', 'AzureSkuNameStandardL16s', 'AzureSkuNameStandardL8sV2', 'AzureSkuNameStandardL16sV2', 'AzureSkuNameStandardD11V2', 'AzureSkuNameStandardD12V2', 'AzureSkuNameStandardL4s', 'AzureSkuNameDevNoSLAStandardD11V2', 'AzureSkuNameStandardE64iV3', 'AzureSkuNameStandardE80idsV4', 'AzureSkuNameStandardE2aV4', 'AzureSkuNameStandardE4aV4', 'AzureSkuNameStandardE8aV4', 'AzureSkuNameStandardE16aV4', 'AzureSkuNameStandardE8asV41TBPS', 'AzureSkuNameStandardE8asV42TBPS', 'AzureSkuNameStandardE16asV43TBPS', 'AzureSkuNameStandardE16asV44TBPS', 'AzureSkuNameDevNoSLAStandardE2aV4' Name AzureSkuName `json:"name,omitempty"` // Capacity - The number of instances of the cluster. Capacity *int32 `json:"capacity,omitempty"` // Tier - SKU tier. Possible values include: 'AzureSkuTierBasic', 'AzureSkuTierStandard' Tier AzureSkuTier `json:"tier,omitempty"` }
AzureSku azure SKU definition.
type AzureSkuName ¶
type AzureSkuName string
AzureSkuName enumerates the values for azure sku name.
const ( // AzureSkuNameDevNoSLAStandardD11V2 ... AzureSkuNameDevNoSLAStandardD11V2 AzureSkuName = "Dev(No SLA)_Standard_D11_v2" // AzureSkuNameDevNoSLAStandardE2aV4 ... AzureSkuNameDevNoSLAStandardE2aV4 AzureSkuName = "Dev(No SLA)_Standard_E2a_v4" // AzureSkuNameStandardD11V2 ... AzureSkuNameStandardD11V2 AzureSkuName = "Standard_D11_v2" // AzureSkuNameStandardD12V2 ... AzureSkuNameStandardD12V2 AzureSkuName = "Standard_D12_v2" // AzureSkuNameStandardD13V2 ... AzureSkuNameStandardD13V2 AzureSkuName = "Standard_D13_v2" // AzureSkuNameStandardD14V2 ... AzureSkuNameStandardD14V2 AzureSkuName = "Standard_D14_v2" // AzureSkuNameStandardDS13V21TBPS ... AzureSkuNameStandardDS13V21TBPS AzureSkuName = "Standard_DS13_v2+1TB_PS" // AzureSkuNameStandardDS13V22TBPS ... AzureSkuNameStandardDS13V22TBPS AzureSkuName = "Standard_DS13_v2+2TB_PS" // AzureSkuNameStandardDS14V23TBPS ... AzureSkuNameStandardDS14V23TBPS AzureSkuName = "Standard_DS14_v2+3TB_PS" // AzureSkuNameStandardDS14V24TBPS ... AzureSkuNameStandardDS14V24TBPS AzureSkuName = "Standard_DS14_v2+4TB_PS" // AzureSkuNameStandardE16asV43TBPS ... AzureSkuNameStandardE16asV43TBPS AzureSkuName = "Standard_E16as_v4+3TB_PS" // AzureSkuNameStandardE16asV44TBPS ... AzureSkuNameStandardE16asV44TBPS AzureSkuName = "Standard_E16as_v4+4TB_PS" // AzureSkuNameStandardE16aV4 ... AzureSkuNameStandardE16aV4 AzureSkuName = "Standard_E16a_v4" // AzureSkuNameStandardE2aV4 ... AzureSkuNameStandardE2aV4 AzureSkuName = "Standard_E2a_v4" // AzureSkuNameStandardE4aV4 ... AzureSkuNameStandardE4aV4 AzureSkuName = "Standard_E4a_v4" // AzureSkuNameStandardE64iV3 ... AzureSkuNameStandardE64iV3 AzureSkuName = "Standard_E64i_v3" // AzureSkuNameStandardE80idsV4 ... AzureSkuNameStandardE80idsV4 AzureSkuName = "Standard_E80ids_v4" // AzureSkuNameStandardE8asV41TBPS ... AzureSkuNameStandardE8asV41TBPS AzureSkuName = "Standard_E8as_v4+1TB_PS" // AzureSkuNameStandardE8asV42TBPS ... AzureSkuNameStandardE8asV42TBPS AzureSkuName = "Standard_E8as_v4+2TB_PS" // AzureSkuNameStandardE8aV4 ... AzureSkuNameStandardE8aV4 AzureSkuName = "Standard_E8a_v4" // AzureSkuNameStandardL16s ... AzureSkuNameStandardL16s AzureSkuName = "Standard_L16s" // AzureSkuNameStandardL16sV2 ... AzureSkuNameStandardL16sV2 AzureSkuName = "Standard_L16s_v2" // AzureSkuNameStandardL4s ... AzureSkuNameStandardL4s AzureSkuName = "Standard_L4s" // AzureSkuNameStandardL8s ... AzureSkuNameStandardL8s AzureSkuName = "Standard_L8s" // AzureSkuNameStandardL8sV2 ... AzureSkuNameStandardL8sV2 AzureSkuName = "Standard_L8s_v2" )
func PossibleAzureSkuNameValues ¶
func PossibleAzureSkuNameValues() []AzureSkuName
PossibleAzureSkuNameValues returns an array of possible values for the AzureSkuName const type.
type AzureSkuTier ¶
type AzureSkuTier string
AzureSkuTier enumerates the values for azure sku tier.
const ( // AzureSkuTierBasic ... AzureSkuTierBasic AzureSkuTier = "Basic" // AzureSkuTierStandard ... AzureSkuTierStandard AzureSkuTier = "Standard" )
func PossibleAzureSkuTierValues ¶
func PossibleAzureSkuTierValues() []AzureSkuTier
PossibleAzureSkuTierValues returns an array of possible values for the AzureSkuTier const type.
type BaseClient ¶
BaseClient is the base client for Kusto.
func New ¶
func New(subscriptionID string) BaseClient
New creates an instance of the BaseClient client.
func NewWithBaseURI ¶
func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient
NewWithBaseURI creates an instance of the BaseClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
type BasicDataConnection ¶
type BasicDataConnection interface { AsEventHubDataConnection() (*EventHubDataConnection, bool) AsIotHubDataConnection() (*IotHubDataConnection, bool) AsEventGridDataConnection() (*EventGridDataConnection, bool) AsDataConnection() (*DataConnection, bool) }
BasicDataConnection class representing an data connection.
type BasicDatabase ¶
type BasicDatabase interface { AsReadWriteDatabase() (*ReadWriteDatabase, bool) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool) AsDatabase() (*Database, bool) }
BasicDatabase class representing a Kusto database.
type BlobStorageEventType ¶
type BlobStorageEventType string
BlobStorageEventType enumerates the values for blob storage event type.
const ( // BlobStorageEventTypeMicrosoftStorageBlobCreated ... BlobStorageEventTypeMicrosoftStorageBlobCreated BlobStorageEventType = "Microsoft.Storage.BlobCreated" // BlobStorageEventTypeMicrosoftStorageBlobRenamed ... BlobStorageEventTypeMicrosoftStorageBlobRenamed BlobStorageEventType = "Microsoft.Storage.BlobRenamed" )
func PossibleBlobStorageEventTypeValues ¶
func PossibleBlobStorageEventTypeValues() []BlobStorageEventType
PossibleBlobStorageEventTypeValues returns an array of possible values for the BlobStorageEventType const type.
type CheckNameRequest ¶
type CheckNameRequest struct { // Name - Resource name. Name *string `json:"name,omitempty"` // Type - The type of resource, for instance Microsoft.Kusto/clusters/databases. Possible values include: 'TypeMicrosoftKustoclustersdatabases', 'TypeMicrosoftKustoclustersattachedDatabaseConfigurations' Type Type `json:"type,omitempty"` }
CheckNameRequest the result returned from a database check name availability request.
type CheckNameResult ¶
type CheckNameResult struct { autorest.Response `json:"-"` // NameAvailable - Specifies a Boolean value that indicates if the name is available. NameAvailable *bool `json:"nameAvailable,omitempty"` // Name - The name that was checked. Name *string `json:"name,omitempty"` // Message - Message indicating an unavailable name due to a conflict, or a description of the naming rules that are violated. Message *string `json:"message,omitempty"` // Reason - Message providing the reason why the given name is invalid. Possible values include: 'ReasonInvalid', 'ReasonAlreadyExists' Reason Reason `json:"reason,omitempty"` }
CheckNameResult the result returned from a check name availability request.
type CloudError ¶
type CloudError struct { // Error - An error response from Kusto. Error *CloudErrorBody `json:"error,omitempty"` }
CloudError an error response from Kusto.
type CloudErrorBody ¶
type CloudErrorBody struct { // Code - An identifier for the error. Codes are invariant and are intended to be consumed programmatically. Code *string `json:"code,omitempty"` // Message - A message describing the error, intended to be suitable for displaying in a user interface. Message *string `json:"message,omitempty"` // Target - The target of the particular error. For example, the name of the property in error. Target *string `json:"target,omitempty"` // Details - A list of additional details about the error. Details *[]CloudErrorBody `json:"details,omitempty"` }
CloudErrorBody an error response from Kusto.
type Cluster ¶
type Cluster struct { autorest.Response `json:"-"` // Sku - The SKU of the cluster. Sku *AzureSku `json:"sku,omitempty"` // Zones - The availability zones of the cluster. Zones *[]string `json:"zones,omitempty"` // Identity - The identity of the cluster, if configured. Identity *Identity `json:"identity,omitempty"` // ClusterProperties - The cluster properties. *ClusterProperties `json:"properties,omitempty"` // Etag - READ-ONLY; A unique read-only string that changes whenever the resource is updated. Etag *string `json:"etag,omitempty"` // Tags - Resource tags. Tags map[string]*string `json:"tags"` // Location - The geo-location where the resource lives Location *string `json:"location,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
Cluster class representing a Kusto cluster.
func (Cluster) MarshalJSON ¶
MarshalJSON is the custom marshaler for Cluster.
func (*Cluster) UnmarshalJSON ¶
UnmarshalJSON is the custom unmarshaler for Cluster struct.
type ClusterCheckNameRequest ¶
type ClusterCheckNameRequest struct { // Name - Cluster name. Name *string `json:"name,omitempty"` // Type - The type of resource, Microsoft.Kusto/clusters. Type *string `json:"type,omitempty"` }
ClusterCheckNameRequest the result returned from a cluster check name availability request.
type ClusterListResult ¶
type ClusterListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto clusters. Value *[]Cluster `json:"value,omitempty"` }
ClusterListResult the list Kusto clusters operation response.
type ClusterPrincipalAssignment ¶
type ClusterPrincipalAssignment struct { autorest.Response `json:"-"` // ClusterPrincipalProperties - The cluster principal. *ClusterPrincipalProperties `json:"properties,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
ClusterPrincipalAssignment class representing a cluster principal assignment.
func (ClusterPrincipalAssignment) MarshalJSON ¶
func (cpa ClusterPrincipalAssignment) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterPrincipalAssignment.
func (*ClusterPrincipalAssignment) UnmarshalJSON ¶
func (cpa *ClusterPrincipalAssignment) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for ClusterPrincipalAssignment struct.
type ClusterPrincipalAssignmentCheckNameRequest ¶
type ClusterPrincipalAssignmentCheckNameRequest struct { // Name - Principal Assignment resource name. Name *string `json:"name,omitempty"` // Type - The type of resource, Microsoft.Kusto/clusters/principalAssignments. Type *string `json:"type,omitempty"` }
ClusterPrincipalAssignmentCheckNameRequest a principal assignment check name availability request.
type ClusterPrincipalAssignmentListResult ¶
type ClusterPrincipalAssignmentListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto cluster principal assignments. Value *[]ClusterPrincipalAssignment `json:"value,omitempty"` }
ClusterPrincipalAssignmentListResult the list Kusto cluster principal assignments operation response.
type ClusterPrincipalAssignmentsClient ¶
type ClusterPrincipalAssignmentsClient struct {
BaseClient
}
ClusterPrincipalAssignmentsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewClusterPrincipalAssignmentsClient ¶
func NewClusterPrincipalAssignmentsClient(subscriptionID string) ClusterPrincipalAssignmentsClient
NewClusterPrincipalAssignmentsClient creates an instance of the ClusterPrincipalAssignmentsClient client.
func NewClusterPrincipalAssignmentsClientWithBaseURI ¶
func NewClusterPrincipalAssignmentsClientWithBaseURI(baseURI string, subscriptionID string) ClusterPrincipalAssignmentsClient
NewClusterPrincipalAssignmentsClientWithBaseURI creates an instance of the ClusterPrincipalAssignmentsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ClusterPrincipalAssignmentsClient) CheckNameAvailability ¶
func (client ClusterPrincipalAssignmentsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName ClusterPrincipalAssignmentCheckNameRequest) (result CheckNameResult, err error)
CheckNameAvailability checks that the principal assignment name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the principal assignment.
func (ClusterPrincipalAssignmentsClient) CheckNameAvailabilityPreparer ¶
func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName ClusterPrincipalAssignmentCheckNameRequest) (*http.Request, error)
CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.
func (ClusterPrincipalAssignmentsClient) CheckNameAvailabilityResponder ¶
func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.
func (ClusterPrincipalAssignmentsClient) CheckNameAvailabilitySender ¶
func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.
func (ClusterPrincipalAssignmentsClient) CreateOrUpdate ¶
func (client ClusterPrincipalAssignmentsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string, parameters ClusterPrincipalAssignment) (result ClusterPrincipalAssignmentsCreateOrUpdateFuture, err error)
CreateOrUpdate create a Kusto cluster principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment. parameters - the Kusto cluster principalAssignment's parameters supplied for the operation.
func (ClusterPrincipalAssignmentsClient) CreateOrUpdatePreparer ¶
func (client ClusterPrincipalAssignmentsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string, parameters ClusterPrincipalAssignment) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (ClusterPrincipalAssignmentsClient) CreateOrUpdateResponder ¶
func (client ClusterPrincipalAssignmentsClient) CreateOrUpdateResponder(resp *http.Response) (result ClusterPrincipalAssignment, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (ClusterPrincipalAssignmentsClient) CreateOrUpdateSender ¶
func (client ClusterPrincipalAssignmentsClient) CreateOrUpdateSender(req *http.Request) (future ClusterPrincipalAssignmentsCreateOrUpdateFuture, err error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (ClusterPrincipalAssignmentsClient) Delete ¶
func (client ClusterPrincipalAssignmentsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (result ClusterPrincipalAssignmentsDeleteFuture, err error)
Delete deletes a Kusto cluster principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.
func (ClusterPrincipalAssignmentsClient) DeletePreparer ¶
func (client ClusterPrincipalAssignmentsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ClusterPrincipalAssignmentsClient) DeleteResponder ¶
func (client ClusterPrincipalAssignmentsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (ClusterPrincipalAssignmentsClient) DeleteSender ¶
func (client ClusterPrincipalAssignmentsClient) DeleteSender(req *http.Request) (future ClusterPrincipalAssignmentsDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (ClusterPrincipalAssignmentsClient) Get ¶
func (client ClusterPrincipalAssignmentsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (result ClusterPrincipalAssignment, err error)
Get gets a Kusto cluster principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.
func (ClusterPrincipalAssignmentsClient) GetPreparer ¶
func (client ClusterPrincipalAssignmentsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (ClusterPrincipalAssignmentsClient) GetResponder ¶
func (client ClusterPrincipalAssignmentsClient) GetResponder(resp *http.Response) (result ClusterPrincipalAssignment, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ClusterPrincipalAssignmentsClient) GetSender ¶
func (client ClusterPrincipalAssignmentsClient) GetSender(req *http.Request) (*http.Response, error)
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (ClusterPrincipalAssignmentsClient) List ¶
func (client ClusterPrincipalAssignmentsClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterPrincipalAssignmentListResult, err error)
List lists all Kusto cluster principalAssignments. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClusterPrincipalAssignmentsClient) ListPreparer ¶
func (client ClusterPrincipalAssignmentsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListPreparer prepares the List request.
func (ClusterPrincipalAssignmentsClient) ListResponder ¶
func (client ClusterPrincipalAssignmentsClient) ListResponder(resp *http.Response) (result ClusterPrincipalAssignmentListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (ClusterPrincipalAssignmentsClient) ListSender ¶
func (client ClusterPrincipalAssignmentsClient) ListSender(req *http.Request) (*http.Response, error)
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type ClusterPrincipalAssignmentsCreateOrUpdateFuture ¶
type ClusterPrincipalAssignmentsCreateOrUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClusterPrincipalAssignmentsClient) (ClusterPrincipalAssignment, error) }
ClusterPrincipalAssignmentsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClusterPrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON ¶
func (future *ClusterPrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClusterPrincipalAssignmentsDeleteFuture ¶
type ClusterPrincipalAssignmentsDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClusterPrincipalAssignmentsClient) (autorest.Response, error) }
ClusterPrincipalAssignmentsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClusterPrincipalAssignmentsDeleteFuture) UnmarshalJSON ¶
func (future *ClusterPrincipalAssignmentsDeleteFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClusterPrincipalProperties ¶
type ClusterPrincipalProperties struct { // PrincipalID - The principal ID assigned to the cluster principal. It can be a user email, application ID, or security group name. PrincipalID *string `json:"principalId,omitempty"` // Role - Cluster principal role. Possible values include: 'ClusterPrincipalRoleAllDatabasesAdmin', 'ClusterPrincipalRoleAllDatabasesViewer' Role ClusterPrincipalRole `json:"role,omitempty"` // TenantID - The tenant id of the principal TenantID *string `json:"tenantId,omitempty"` // PrincipalType - Principal type. Possible values include: 'PrincipalTypeApp', 'PrincipalTypeGroup', 'PrincipalTypeUser' PrincipalType PrincipalType `json:"principalType,omitempty"` // TenantName - READ-ONLY; The tenant name of the principal TenantName *string `json:"tenantName,omitempty"` // PrincipalName - READ-ONLY; The principal name PrincipalName *string `json:"principalName,omitempty"` // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` }
ClusterPrincipalProperties a class representing cluster principal property.
func (ClusterPrincipalProperties) MarshalJSON ¶
func (cpp ClusterPrincipalProperties) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterPrincipalProperties.
type ClusterPrincipalRole ¶
type ClusterPrincipalRole string
ClusterPrincipalRole enumerates the values for cluster principal role.
const ( // ClusterPrincipalRoleAllDatabasesAdmin ... ClusterPrincipalRoleAllDatabasesAdmin ClusterPrincipalRole = "AllDatabasesAdmin" // ClusterPrincipalRoleAllDatabasesViewer ... ClusterPrincipalRoleAllDatabasesViewer ClusterPrincipalRole = "AllDatabasesViewer" )
func PossibleClusterPrincipalRoleValues ¶
func PossibleClusterPrincipalRoleValues() []ClusterPrincipalRole
PossibleClusterPrincipalRoleValues returns an array of possible values for the ClusterPrincipalRole const type.
type ClusterProperties ¶
type ClusterProperties struct { // State - READ-ONLY; The state of the resource. Possible values include: 'StateCreating', 'StateUnavailable', 'StateRunning', 'StateDeleting', 'StateDeleted', 'StateStopping', 'StateStopped', 'StateStarting', 'StateUpdating' State State `json:"state,omitempty"` // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` // URI - READ-ONLY; The cluster URI. URI *string `json:"uri,omitempty"` // DataIngestionURI - READ-ONLY; The cluster data ingestion URI. DataIngestionURI *string `json:"dataIngestionUri,omitempty"` // StateReason - READ-ONLY; The reason for the cluster's current state. StateReason *string `json:"stateReason,omitempty"` // TrustedExternalTenants - The cluster's external tenants. TrustedExternalTenants *[]TrustedExternalTenant `json:"trustedExternalTenants,omitempty"` // OptimizedAutoscale - Optimized auto scale definition. OptimizedAutoscale *OptimizedAutoscale `json:"optimizedAutoscale,omitempty"` // EnableDiskEncryption - A boolean value that indicates if the cluster's disks are encrypted. EnableDiskEncryption *bool `json:"enableDiskEncryption,omitempty"` // EnableStreamingIngest - A boolean value that indicates if the streaming ingest is enabled. EnableStreamingIngest *bool `json:"enableStreamingIngest,omitempty"` // VirtualNetworkConfiguration - Virtual network definition. VirtualNetworkConfiguration *VirtualNetworkConfiguration `json:"virtualNetworkConfiguration,omitempty"` // KeyVaultProperties - KeyVault properties for the cluster encryption. KeyVaultProperties *KeyVaultProperties `json:"keyVaultProperties,omitempty"` // EnablePurge - A boolean value that indicates if the purge operations are enabled. EnablePurge *bool `json:"enablePurge,omitempty"` // LanguageExtensions - READ-ONLY; List of the cluster's language extensions. LanguageExtensions *LanguageExtensionsList `json:"languageExtensions,omitempty"` // EnableDoubleEncryption - A boolean value that indicates if double encryption is enabled. EnableDoubleEncryption *bool `json:"enableDoubleEncryption,omitempty"` // EngineType - The engine type. Possible values include: 'EngineTypeV2', 'EngineTypeV3' EngineType EngineType `json:"engineType,omitempty"` }
ClusterProperties class representing the Kusto cluster properties.
func (ClusterProperties) MarshalJSON ¶
func (cp ClusterProperties) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterProperties.
type ClusterUpdate ¶
type ClusterUpdate struct { // Tags - Resource tags. Tags map[string]*string `json:"tags"` // Location - Resource location. Location *string `json:"location,omitempty"` // Sku - The SKU of the cluster. Sku *AzureSku `json:"sku,omitempty"` // Identity - The identity of the cluster, if configured. Identity *Identity `json:"identity,omitempty"` // ClusterProperties - The cluster properties. *ClusterProperties `json:"properties,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
ClusterUpdate class representing an update to a Kusto cluster.
func (ClusterUpdate) MarshalJSON ¶
func (cu ClusterUpdate) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ClusterUpdate.
func (*ClusterUpdate) UnmarshalJSON ¶
func (cu *ClusterUpdate) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for ClusterUpdate struct.
type ClustersAddLanguageExtensionsFuture ¶
type ClustersAddLanguageExtensionsFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersAddLanguageExtensionsFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersAddLanguageExtensionsFuture) UnmarshalJSON ¶
func (future *ClustersAddLanguageExtensionsFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersClient ¶
type ClustersClient struct {
BaseClient
}
ClustersClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewClustersClient ¶
func NewClustersClient(subscriptionID string) ClustersClient
NewClustersClient creates an instance of the ClustersClient client.
func NewClustersClientWithBaseURI ¶
func NewClustersClientWithBaseURI(baseURI string, subscriptionID string) ClustersClient
NewClustersClientWithBaseURI creates an instance of the ClustersClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ClustersClient) AddLanguageExtensions ¶
func (client ClustersClient) AddLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToAdd LanguageExtensionsList) (result ClustersAddLanguageExtensionsFuture, err error)
AddLanguageExtensions add a list of language extensions that can run within KQL queries. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. languageExtensionsToAdd - the language extensions to add.
func (ClustersClient) AddLanguageExtensionsPreparer ¶
func (client ClustersClient) AddLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToAdd LanguageExtensionsList) (*http.Request, error)
AddLanguageExtensionsPreparer prepares the AddLanguageExtensions request.
func (ClustersClient) AddLanguageExtensionsResponder ¶
func (client ClustersClient) AddLanguageExtensionsResponder(resp *http.Response) (result autorest.Response, err error)
AddLanguageExtensionsResponder handles the response to the AddLanguageExtensions request. The method always closes the http.Response Body.
func (ClustersClient) AddLanguageExtensionsSender ¶
func (client ClustersClient) AddLanguageExtensionsSender(req *http.Request) (future ClustersAddLanguageExtensionsFuture, err error)
AddLanguageExtensionsSender sends the AddLanguageExtensions request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) CheckNameAvailability ¶
func (client ClustersClient) CheckNameAvailability(ctx context.Context, location string, clusterName ClusterCheckNameRequest) (result CheckNameResult, err error)
CheckNameAvailability checks that the cluster name is valid and is not already in use. Parameters: location - azure location (region) name. clusterName - the name of the cluster.
func (ClustersClient) CheckNameAvailabilityPreparer ¶
func (client ClustersClient) CheckNameAvailabilityPreparer(ctx context.Context, location string, clusterName ClusterCheckNameRequest) (*http.Request, error)
CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.
func (ClustersClient) CheckNameAvailabilityResponder ¶
func (client ClustersClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.
func (ClustersClient) CheckNameAvailabilitySender ¶
CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) CreateOrUpdate ¶
func (client ClustersClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, ifMatch string, ifNoneMatch string) (result ClustersCreateOrUpdateFuture, err error)
CreateOrUpdate create or update a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. parameters - the Kusto cluster parameters supplied to the CreateOrUpdate operation. ifMatch - the ETag of the cluster. Omit this value to always overwrite the current cluster. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes. ifNoneMatch - set to '*' to allow a new cluster to be created, but to prevent updating an existing cluster. Other values will result in a 412 Pre-condition Failed response.
func (ClustersClient) CreateOrUpdatePreparer ¶
func (client ClustersClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, ifMatch string, ifNoneMatch string) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (ClustersClient) CreateOrUpdateResponder ¶
func (client ClustersClient) CreateOrUpdateResponder(resp *http.Response) (result Cluster, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (ClustersClient) CreateOrUpdateSender ¶
func (client ClustersClient) CreateOrUpdateSender(req *http.Request) (future ClustersCreateOrUpdateFuture, err error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Delete ¶
func (client ClustersClient) Delete(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDeleteFuture, err error)
Delete deletes a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) DeletePreparer ¶
func (client ClustersClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ClustersClient) DeleteResponder ¶
func (client ClustersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (ClustersClient) DeleteSender ¶
func (client ClustersClient) DeleteSender(req *http.Request) (future ClustersDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) DetachFollowerDatabases ¶
func (client ClustersClient) DetachFollowerDatabases(ctx context.Context, resourceGroupName string, clusterName string, followerDatabaseToRemove FollowerDatabaseDefinition) (result ClustersDetachFollowerDatabasesFuture, err error)
DetachFollowerDatabases detaches all followers of a database owned by this cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. followerDatabaseToRemove - the follower databases properties to remove.
func (ClustersClient) DetachFollowerDatabasesPreparer ¶
func (client ClustersClient) DetachFollowerDatabasesPreparer(ctx context.Context, resourceGroupName string, clusterName string, followerDatabaseToRemove FollowerDatabaseDefinition) (*http.Request, error)
DetachFollowerDatabasesPreparer prepares the DetachFollowerDatabases request.
func (ClustersClient) DetachFollowerDatabasesResponder ¶
func (client ClustersClient) DetachFollowerDatabasesResponder(resp *http.Response) (result autorest.Response, err error)
DetachFollowerDatabasesResponder handles the response to the DetachFollowerDatabases request. The method always closes the http.Response Body.
func (ClustersClient) DetachFollowerDatabasesSender ¶
func (client ClustersClient) DetachFollowerDatabasesSender(req *http.Request) (future ClustersDetachFollowerDatabasesFuture, err error)
DetachFollowerDatabasesSender sends the DetachFollowerDatabases request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) DiagnoseVirtualNetwork ¶
func (client ClustersClient) DiagnoseVirtualNetwork(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDiagnoseVirtualNetworkFuture, err error)
DiagnoseVirtualNetwork diagnoses network connectivity status for external resources on which the service is dependent on. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) DiagnoseVirtualNetworkPreparer ¶
func (client ClustersClient) DiagnoseVirtualNetworkPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
DiagnoseVirtualNetworkPreparer prepares the DiagnoseVirtualNetwork request.
func (ClustersClient) DiagnoseVirtualNetworkResponder ¶
func (client ClustersClient) DiagnoseVirtualNetworkResponder(resp *http.Response) (result DiagnoseVirtualNetworkResult, err error)
DiagnoseVirtualNetworkResponder handles the response to the DiagnoseVirtualNetwork request. The method always closes the http.Response Body.
func (ClustersClient) DiagnoseVirtualNetworkSender ¶
func (client ClustersClient) DiagnoseVirtualNetworkSender(req *http.Request) (future ClustersDiagnoseVirtualNetworkFuture, err error)
DiagnoseVirtualNetworkSender sends the DiagnoseVirtualNetwork request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Get ¶
func (client ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string) (result Cluster, err error)
Get gets a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) GetPreparer ¶
func (client ClustersClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (ClustersClient) GetResponder ¶
func (client ClustersClient) GetResponder(resp *http.Response) (result Cluster, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ClustersClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) List ¶
func (client ClustersClient) List(ctx context.Context) (result ClusterListResult, err error)
List lists all Kusto clusters within a subscription.
func (ClustersClient) ListByResourceGroup ¶
func (client ClustersClient) ListByResourceGroup(ctx context.Context, resourceGroupName string) (result ClusterListResult, err error)
ListByResourceGroup lists all Kusto clusters within a resource group. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster.
func (ClustersClient) ListByResourceGroupPreparer ¶
func (client ClustersClient) ListByResourceGroupPreparer(ctx context.Context, resourceGroupName string) (*http.Request, error)
ListByResourceGroupPreparer prepares the ListByResourceGroup request.
func (ClustersClient) ListByResourceGroupResponder ¶
func (client ClustersClient) ListByResourceGroupResponder(resp *http.Response) (result ClusterListResult, err error)
ListByResourceGroupResponder handles the response to the ListByResourceGroup request. The method always closes the http.Response Body.
func (ClustersClient) ListByResourceGroupSender ¶
ListByResourceGroupSender sends the ListByResourceGroup request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) ListFollowerDatabases ¶
func (client ClustersClient) ListFollowerDatabases(ctx context.Context, resourceGroupName string, clusterName string) (result FollowerDatabaseListResult, err error)
ListFollowerDatabases returns a list of databases that are owned by this cluster and were followed by another cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) ListFollowerDatabasesPreparer ¶
func (client ClustersClient) ListFollowerDatabasesPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListFollowerDatabasesPreparer prepares the ListFollowerDatabases request.
func (ClustersClient) ListFollowerDatabasesResponder ¶
func (client ClustersClient) ListFollowerDatabasesResponder(resp *http.Response) (result FollowerDatabaseListResult, err error)
ListFollowerDatabasesResponder handles the response to the ListFollowerDatabases request. The method always closes the http.Response Body.
func (ClustersClient) ListFollowerDatabasesSender ¶
ListFollowerDatabasesSender sends the ListFollowerDatabases request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) ListLanguageExtensions ¶
func (client ClustersClient) ListLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string) (result LanguageExtensionsList, err error)
ListLanguageExtensions returns a list of language extensions that can run within KQL queries. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) ListLanguageExtensionsPreparer ¶
func (client ClustersClient) ListLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListLanguageExtensionsPreparer prepares the ListLanguageExtensions request.
func (ClustersClient) ListLanguageExtensionsResponder ¶
func (client ClustersClient) ListLanguageExtensionsResponder(resp *http.Response) (result LanguageExtensionsList, err error)
ListLanguageExtensionsResponder handles the response to the ListLanguageExtensions request. The method always closes the http.Response Body.
func (ClustersClient) ListLanguageExtensionsSender ¶
func (client ClustersClient) ListLanguageExtensionsSender(req *http.Request) (*http.Response, error)
ListLanguageExtensionsSender sends the ListLanguageExtensions request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) ListPreparer ¶
ListPreparer prepares the List request.
func (ClustersClient) ListResponder ¶
func (client ClustersClient) ListResponder(resp *http.Response) (result ClusterListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (ClustersClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) ListSkus ¶
func (client ClustersClient) ListSkus(ctx context.Context) (result SkuDescriptionList, err error)
ListSkus lists eligible SKUs for Kusto resource provider.
func (ClustersClient) ListSkusByResource ¶
func (client ClustersClient) ListSkusByResource(ctx context.Context, resourceGroupName string, clusterName string) (result ListResourceSkusResult, err error)
ListSkusByResource returns the SKUs available for the provided resource. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) ListSkusByResourcePreparer ¶
func (client ClustersClient) ListSkusByResourcePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListSkusByResourcePreparer prepares the ListSkusByResource request.
func (ClustersClient) ListSkusByResourceResponder ¶
func (client ClustersClient) ListSkusByResourceResponder(resp *http.Response) (result ListResourceSkusResult, err error)
ListSkusByResourceResponder handles the response to the ListSkusByResource request. The method always closes the http.Response Body.
func (ClustersClient) ListSkusByResourceSender ¶
ListSkusByResourceSender sends the ListSkusByResource request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) ListSkusPreparer ¶
ListSkusPreparer prepares the ListSkus request.
func (ClustersClient) ListSkusResponder ¶
func (client ClustersClient) ListSkusResponder(resp *http.Response) (result SkuDescriptionList, err error)
ListSkusResponder handles the response to the ListSkus request. The method always closes the http.Response Body.
func (ClustersClient) ListSkusSender ¶
ListSkusSender sends the ListSkus request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) RemoveLanguageExtensions ¶
func (client ClustersClient) RemoveLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToRemove LanguageExtensionsList) (result ClustersRemoveLanguageExtensionsFuture, err error)
RemoveLanguageExtensions remove a list of language extensions that can run within KQL queries. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. languageExtensionsToRemove - the language extensions to remove.
func (ClustersClient) RemoveLanguageExtensionsPreparer ¶
func (client ClustersClient) RemoveLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToRemove LanguageExtensionsList) (*http.Request, error)
RemoveLanguageExtensionsPreparer prepares the RemoveLanguageExtensions request.
func (ClustersClient) RemoveLanguageExtensionsResponder ¶
func (client ClustersClient) RemoveLanguageExtensionsResponder(resp *http.Response) (result autorest.Response, err error)
RemoveLanguageExtensionsResponder handles the response to the RemoveLanguageExtensions request. The method always closes the http.Response Body.
func (ClustersClient) RemoveLanguageExtensionsSender ¶
func (client ClustersClient) RemoveLanguageExtensionsSender(req *http.Request) (future ClustersRemoveLanguageExtensionsFuture, err error)
RemoveLanguageExtensionsSender sends the RemoveLanguageExtensions request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Start ¶
func (client ClustersClient) Start(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersStartFuture, err error)
Start starts a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) StartPreparer ¶
func (client ClustersClient) StartPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
StartPreparer prepares the Start request.
func (ClustersClient) StartResponder ¶
func (client ClustersClient) StartResponder(resp *http.Response) (result autorest.Response, err error)
StartResponder handles the response to the Start request. The method always closes the http.Response Body.
func (ClustersClient) StartSender ¶
func (client ClustersClient) StartSender(req *http.Request) (future ClustersStartFuture, err error)
StartSender sends the Start request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Stop ¶
func (client ClustersClient) Stop(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersStopFuture, err error)
Stop stops a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (ClustersClient) StopPreparer ¶
func (client ClustersClient) StopPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
StopPreparer prepares the Stop request.
func (ClustersClient) StopResponder ¶
func (client ClustersClient) StopResponder(resp *http.Response) (result autorest.Response, err error)
StopResponder handles the response to the Stop request. The method always closes the http.Response Body.
func (ClustersClient) StopSender ¶
func (client ClustersClient) StopSender(req *http.Request) (future ClustersStopFuture, err error)
StopSender sends the Stop request. The method will close the http.Response Body if it receives an error.
func (ClustersClient) Update ¶
func (client ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterUpdate, ifMatch string) (result ClustersUpdateFuture, err error)
Update update a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. parameters - the Kusto cluster parameters supplied to the Update operation. ifMatch - the ETag of the cluster. Omit this value to always overwrite the current cluster. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.
func (ClustersClient) UpdatePreparer ¶
func (client ClustersClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterUpdate, ifMatch string) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (ClustersClient) UpdateResponder ¶
func (client ClustersClient) UpdateResponder(resp *http.Response) (result Cluster, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (ClustersClient) UpdateSender ¶
func (client ClustersClient) UpdateSender(req *http.Request) (future ClustersUpdateFuture, err error)
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type ClustersCreateOrUpdateFuture ¶
type ClustersCreateOrUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (Cluster, error) }
ClustersCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersCreateOrUpdateFuture) UnmarshalJSON ¶
func (future *ClustersCreateOrUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersDeleteFuture ¶
type ClustersDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersDeleteFuture) UnmarshalJSON ¶
func (future *ClustersDeleteFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersDetachFollowerDatabasesFuture ¶
type ClustersDetachFollowerDatabasesFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersDetachFollowerDatabasesFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersDetachFollowerDatabasesFuture) UnmarshalJSON ¶
func (future *ClustersDetachFollowerDatabasesFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersDiagnoseVirtualNetworkFuture ¶
type ClustersDiagnoseVirtualNetworkFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (DiagnoseVirtualNetworkResult, error) }
ClustersDiagnoseVirtualNetworkFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersDiagnoseVirtualNetworkFuture) UnmarshalJSON ¶
func (future *ClustersDiagnoseVirtualNetworkFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersRemoveLanguageExtensionsFuture ¶
type ClustersRemoveLanguageExtensionsFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersRemoveLanguageExtensionsFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersRemoveLanguageExtensionsFuture) UnmarshalJSON ¶
func (future *ClustersRemoveLanguageExtensionsFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersStartFuture ¶
type ClustersStartFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersStartFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersStartFuture) UnmarshalJSON ¶
func (future *ClustersStartFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersStopFuture ¶
type ClustersStopFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (autorest.Response, error) }
ClustersStopFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersStopFuture) UnmarshalJSON ¶
func (future *ClustersStopFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ClustersUpdateFuture ¶
type ClustersUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ClustersClient) (Cluster, error) }
ClustersUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersUpdateFuture) UnmarshalJSON ¶
func (future *ClustersUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type Compression ¶
type Compression string
Compression enumerates the values for compression.
const ( // CompressionGZip ... CompressionGZip Compression = "GZip" // CompressionNone ... CompressionNone Compression = "None" )
func PossibleCompressionValues ¶
func PossibleCompressionValues() []Compression
PossibleCompressionValues returns an array of possible values for the Compression const type.
type CreatedByType ¶
type CreatedByType string
CreatedByType enumerates the values for created by type.
const ( // CreatedByTypeApplication ... CreatedByTypeApplication CreatedByType = "Application" // CreatedByTypeKey ... CreatedByTypeKey CreatedByType = "Key" // CreatedByTypeManagedIdentity ... CreatedByTypeManagedIdentity CreatedByType = "ManagedIdentity" // CreatedByTypeUser ... CreatedByTypeUser CreatedByType = "User" )
func PossibleCreatedByTypeValues ¶
func PossibleCreatedByTypeValues() []CreatedByType
PossibleCreatedByTypeValues returns an array of possible values for the CreatedByType const type.
type DataConnection ¶
type DataConnection struct { autorest.Response `json:"-"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid' Kind KindBasicDataConnection `json:"kind,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
DataConnection class representing an data connection.
func (DataConnection) AsBasicDataConnection ¶
func (dc DataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
AsBasicDataConnection is the BasicDataConnection implementation for DataConnection.
func (DataConnection) AsDataConnection ¶
func (dc DataConnection) AsDataConnection() (*DataConnection, bool)
AsDataConnection is the BasicDataConnection implementation for DataConnection.
func (DataConnection) AsEventGridDataConnection ¶
func (dc DataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
AsEventGridDataConnection is the BasicDataConnection implementation for DataConnection.
func (DataConnection) AsEventHubDataConnection ¶
func (dc DataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
AsEventHubDataConnection is the BasicDataConnection implementation for DataConnection.
func (DataConnection) AsIotHubDataConnection ¶
func (dc DataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
AsIotHubDataConnection is the BasicDataConnection implementation for DataConnection.
func (DataConnection) MarshalJSON ¶
func (dc DataConnection) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for DataConnection.
type DataConnectionCheckNameRequest ¶
type DataConnectionCheckNameRequest struct { // Name - Data Connection name. Name *string `json:"name,omitempty"` // Type - The type of resource, Microsoft.Kusto/clusters/databases/dataConnections. Type *string `json:"type,omitempty"` }
DataConnectionCheckNameRequest a data connection check name availability request.
type DataConnectionListResult ¶
type DataConnectionListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto data connections. Value *[]BasicDataConnection `json:"value,omitempty"` }
DataConnectionListResult the list Kusto data connections operation response.
func (*DataConnectionListResult) UnmarshalJSON ¶
func (dclr *DataConnectionListResult) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for DataConnectionListResult struct.
type DataConnectionModel ¶
type DataConnectionModel struct { autorest.Response `json:"-"` Value BasicDataConnection `json:"value,omitempty"` }
DataConnectionModel ...
func (*DataConnectionModel) UnmarshalJSON ¶
func (dcm *DataConnectionModel) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for DataConnectionModel struct.
type DataConnectionValidation ¶
type DataConnectionValidation struct { // DataConnectionName - The name of the data connection. DataConnectionName *string `json:"dataConnectionName,omitempty"` // Properties - The data connection properties to validate. Properties BasicDataConnection `json:"properties,omitempty"` }
DataConnectionValidation class representing an data connection validation.
func (*DataConnectionValidation) UnmarshalJSON ¶
func (dcv *DataConnectionValidation) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for DataConnectionValidation struct.
type DataConnectionValidationListResult ¶
type DataConnectionValidationListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto data connection validation errors. Value *[]DataConnectionValidationResult `json:"value,omitempty"` }
DataConnectionValidationListResult the list Kusto data connection validation result.
type DataConnectionValidationResult ¶
type DataConnectionValidationResult struct { // ErrorMessage - A message which indicates a problem in data connection validation. ErrorMessage *string `json:"errorMessage,omitempty"` }
DataConnectionValidationResult the result returned from a data connection validation request.
type DataConnectionsClient ¶
type DataConnectionsClient struct {
BaseClient
}
DataConnectionsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewDataConnectionsClient ¶
func NewDataConnectionsClient(subscriptionID string) DataConnectionsClient
NewDataConnectionsClient creates an instance of the DataConnectionsClient client.
func NewDataConnectionsClientWithBaseURI ¶
func NewDataConnectionsClientWithBaseURI(baseURI string, subscriptionID string) DataConnectionsClient
NewDataConnectionsClientWithBaseURI creates an instance of the DataConnectionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (DataConnectionsClient) CheckNameAvailability ¶
func (client DataConnectionsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName DataConnectionCheckNameRequest) (result CheckNameResult, err error)
CheckNameAvailability checks that the data connection name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection.
func (DataConnectionsClient) CheckNameAvailabilityPreparer ¶
func (client DataConnectionsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName DataConnectionCheckNameRequest) (*http.Request, error)
CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.
func (DataConnectionsClient) CheckNameAvailabilityResponder ¶
func (client DataConnectionsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.
func (DataConnectionsClient) CheckNameAvailabilitySender ¶
func (client DataConnectionsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.
func (DataConnectionsClient) CreateOrUpdate ¶
func (client DataConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (result DataConnectionsCreateOrUpdateFuture, err error)
CreateOrUpdate creates or updates a data connection. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection. parameters - the data connection parameters supplied to the CreateOrUpdate operation.
func (DataConnectionsClient) CreateOrUpdatePreparer ¶
func (client DataConnectionsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (DataConnectionsClient) CreateOrUpdateResponder ¶
func (client DataConnectionsClient) CreateOrUpdateResponder(resp *http.Response) (result DataConnectionModel, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (DataConnectionsClient) CreateOrUpdateSender ¶
func (client DataConnectionsClient) CreateOrUpdateSender(req *http.Request) (future DataConnectionsCreateOrUpdateFuture, err error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (DataConnectionsClient) DataConnectionValidationMethod ¶
func (client DataConnectionsClient) DataConnectionValidationMethod(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters DataConnectionValidation) (result DataConnectionsDataConnectionValidationMethodFuture, err error)
DataConnectionValidationMethod checks that the data connection parameters are valid. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. parameters - the data connection parameters supplied to the CreateOrUpdate operation.
func (DataConnectionsClient) DataConnectionValidationMethodPreparer ¶
func (client DataConnectionsClient) DataConnectionValidationMethodPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters DataConnectionValidation) (*http.Request, error)
DataConnectionValidationMethodPreparer prepares the DataConnectionValidationMethod request.
func (DataConnectionsClient) DataConnectionValidationMethodResponder ¶
func (client DataConnectionsClient) DataConnectionValidationMethodResponder(resp *http.Response) (result DataConnectionValidationListResult, err error)
DataConnectionValidationMethodResponder handles the response to the DataConnectionValidationMethod request. The method always closes the http.Response Body.
func (DataConnectionsClient) DataConnectionValidationMethodSender ¶
func (client DataConnectionsClient) DataConnectionValidationMethodSender(req *http.Request) (future DataConnectionsDataConnectionValidationMethodFuture, err error)
DataConnectionValidationMethodSender sends the DataConnectionValidationMethod request. The method will close the http.Response Body if it receives an error.
func (DataConnectionsClient) Delete ¶
func (client DataConnectionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (result DataConnectionsDeleteFuture, err error)
Delete deletes the data connection with the given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection.
func (DataConnectionsClient) DeletePreparer ¶
func (client DataConnectionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (DataConnectionsClient) DeleteResponder ¶
func (client DataConnectionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (DataConnectionsClient) DeleteSender ¶
func (client DataConnectionsClient) DeleteSender(req *http.Request) (future DataConnectionsDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (DataConnectionsClient) Get ¶
func (client DataConnectionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (result DataConnectionModel, err error)
Get returns a data connection. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection.
func (DataConnectionsClient) GetPreparer ¶
func (client DataConnectionsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (DataConnectionsClient) GetResponder ¶
func (client DataConnectionsClient) GetResponder(resp *http.Response) (result DataConnectionModel, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (DataConnectionsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (DataConnectionsClient) ListByDatabase ¶
func (client DataConnectionsClient) ListByDatabase(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DataConnectionListResult, err error)
ListByDatabase returns the list of data connections of the given Kusto database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.
func (DataConnectionsClient) ListByDatabasePreparer ¶
func (client DataConnectionsClient) ListByDatabasePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)
ListByDatabasePreparer prepares the ListByDatabase request.
func (DataConnectionsClient) ListByDatabaseResponder ¶
func (client DataConnectionsClient) ListByDatabaseResponder(resp *http.Response) (result DataConnectionListResult, err error)
ListByDatabaseResponder handles the response to the ListByDatabase request. The method always closes the http.Response Body.
func (DataConnectionsClient) ListByDatabaseSender ¶
ListByDatabaseSender sends the ListByDatabase request. The method will close the http.Response Body if it receives an error.
func (DataConnectionsClient) Update ¶
func (client DataConnectionsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (result DataConnectionsUpdateFuture, err error)
Update updates a data connection. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection. parameters - the data connection parameters supplied to the Update operation.
func (DataConnectionsClient) UpdatePreparer ¶
func (client DataConnectionsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (DataConnectionsClient) UpdateResponder ¶
func (client DataConnectionsClient) UpdateResponder(resp *http.Response) (result DataConnectionModel, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (DataConnectionsClient) UpdateSender ¶
func (client DataConnectionsClient) UpdateSender(req *http.Request) (future DataConnectionsUpdateFuture, err error)
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type DataConnectionsCreateOrUpdateFuture ¶
type DataConnectionsCreateOrUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DataConnectionsClient) (DataConnectionModel, error) }
DataConnectionsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DataConnectionsCreateOrUpdateFuture) UnmarshalJSON ¶
func (future *DataConnectionsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DataConnectionsDataConnectionValidationMethodFuture ¶
type DataConnectionsDataConnectionValidationMethodFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DataConnectionsClient) (DataConnectionValidationListResult, error) }
DataConnectionsDataConnectionValidationMethodFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DataConnectionsDataConnectionValidationMethodFuture) UnmarshalJSON ¶
func (future *DataConnectionsDataConnectionValidationMethodFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DataConnectionsDeleteFuture ¶
type DataConnectionsDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DataConnectionsClient) (autorest.Response, error) }
DataConnectionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DataConnectionsDeleteFuture) UnmarshalJSON ¶
func (future *DataConnectionsDeleteFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DataConnectionsUpdateFuture ¶
type DataConnectionsUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DataConnectionsClient) (DataConnectionModel, error) }
DataConnectionsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DataConnectionsUpdateFuture) UnmarshalJSON ¶
func (future *DataConnectionsUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type Database ¶
type Database struct { autorest.Response `json:"-"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindDatabase', 'KindReadWrite', 'KindReadOnlyFollowing' Kind Kind `json:"kind,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
Database class representing a Kusto database.
func (Database) AsBasicDatabase ¶
func (d Database) AsBasicDatabase() (BasicDatabase, bool)
AsBasicDatabase is the BasicDatabase implementation for Database.
func (Database) AsDatabase ¶
AsDatabase is the BasicDatabase implementation for Database.
func (Database) AsReadOnlyFollowingDatabase ¶
func (d Database) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)
AsReadOnlyFollowingDatabase is the BasicDatabase implementation for Database.
func (Database) AsReadWriteDatabase ¶
func (d Database) AsReadWriteDatabase() (*ReadWriteDatabase, bool)
AsReadWriteDatabase is the BasicDatabase implementation for Database.
func (Database) MarshalJSON ¶
MarshalJSON is the custom marshaler for Database.
type DatabaseListResult ¶
type DatabaseListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto databases. Value *[]BasicDatabase `json:"value,omitempty"` }
DatabaseListResult the list Kusto databases operation response.
func (*DatabaseListResult) UnmarshalJSON ¶
func (dlr *DatabaseListResult) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for DatabaseListResult struct.
type DatabaseModel ¶
type DatabaseModel struct { autorest.Response `json:"-"` Value BasicDatabase `json:"value,omitempty"` }
DatabaseModel ...
func (*DatabaseModel) UnmarshalJSON ¶
func (dm *DatabaseModel) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for DatabaseModel struct.
type DatabasePrincipal ¶
type DatabasePrincipal struct { // Role - Database principal role. Possible values include: 'DatabasePrincipalRoleAdmin', 'DatabasePrincipalRoleIngestor', 'DatabasePrincipalRoleMonitor', 'DatabasePrincipalRoleUser', 'DatabasePrincipalRoleUnrestrictedViewer', 'DatabasePrincipalRoleViewer' Role DatabasePrincipalRole `json:"role,omitempty"` // Name - Database principal name. Name *string `json:"name,omitempty"` // Type - Database principal type. Possible values include: 'DatabasePrincipalTypeApp', 'DatabasePrincipalTypeGroup', 'DatabasePrincipalTypeUser' Type DatabasePrincipalType `json:"type,omitempty"` // Fqn - Database principal fully qualified name. Fqn *string `json:"fqn,omitempty"` // Email - Database principal email if exists. Email *string `json:"email,omitempty"` // AppID - Application id - relevant only for application principal type. AppID *string `json:"appId,omitempty"` // TenantName - READ-ONLY; The tenant name of the principal TenantName *string `json:"tenantName,omitempty"` }
DatabasePrincipal a class representing database principal entity.
func (DatabasePrincipal) MarshalJSON ¶
func (dp DatabasePrincipal) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for DatabasePrincipal.
type DatabasePrincipalAssignment ¶
type DatabasePrincipalAssignment struct { autorest.Response `json:"-"` // DatabasePrincipalProperties - The database principal. *DatabasePrincipalProperties `json:"properties,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
DatabasePrincipalAssignment class representing a database principal assignment.
func (DatabasePrincipalAssignment) MarshalJSON ¶
func (dpa DatabasePrincipalAssignment) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for DatabasePrincipalAssignment.
func (*DatabasePrincipalAssignment) UnmarshalJSON ¶
func (dpa *DatabasePrincipalAssignment) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for DatabasePrincipalAssignment struct.
type DatabasePrincipalAssignmentCheckNameRequest ¶
type DatabasePrincipalAssignmentCheckNameRequest struct { // Name - Principal Assignment resource name. Name *string `json:"name,omitempty"` // Type - The type of resource, Microsoft.Kusto/clusters/databases/principalAssignments. Type *string `json:"type,omitempty"` }
DatabasePrincipalAssignmentCheckNameRequest a principal assignment check name availability request.
type DatabasePrincipalAssignmentListResult ¶
type DatabasePrincipalAssignmentListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto database principal assignments. Value *[]DatabasePrincipalAssignment `json:"value,omitempty"` }
DatabasePrincipalAssignmentListResult the list Kusto database principal assignments operation response.
type DatabasePrincipalAssignmentsClient ¶
type DatabasePrincipalAssignmentsClient struct {
BaseClient
}
DatabasePrincipalAssignmentsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewDatabasePrincipalAssignmentsClient ¶
func NewDatabasePrincipalAssignmentsClient(subscriptionID string) DatabasePrincipalAssignmentsClient
NewDatabasePrincipalAssignmentsClient creates an instance of the DatabasePrincipalAssignmentsClient client.
func NewDatabasePrincipalAssignmentsClientWithBaseURI ¶
func NewDatabasePrincipalAssignmentsClientWithBaseURI(baseURI string, subscriptionID string) DatabasePrincipalAssignmentsClient
NewDatabasePrincipalAssignmentsClientWithBaseURI creates an instance of the DatabasePrincipalAssignmentsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (DatabasePrincipalAssignmentsClient) CheckNameAvailability ¶
func (client DatabasePrincipalAssignmentsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName DatabasePrincipalAssignmentCheckNameRequest) (result CheckNameResult, err error)
CheckNameAvailability checks that the database principal assignment is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the resource.
func (DatabasePrincipalAssignmentsClient) CheckNameAvailabilityPreparer ¶
func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName DatabasePrincipalAssignmentCheckNameRequest) (*http.Request, error)
CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.
func (DatabasePrincipalAssignmentsClient) CheckNameAvailabilityResponder ¶
func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.
func (DatabasePrincipalAssignmentsClient) CheckNameAvailabilitySender ¶
func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.
func (DatabasePrincipalAssignmentsClient) CreateOrUpdate ¶
func (client DatabasePrincipalAssignmentsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string, parameters DatabasePrincipalAssignment) (result DatabasePrincipalAssignmentsCreateOrUpdateFuture, err error)
CreateOrUpdate creates a Kusto cluster database principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment. parameters - the Kusto principalAssignments parameters supplied for the operation.
func (DatabasePrincipalAssignmentsClient) CreateOrUpdatePreparer ¶
func (client DatabasePrincipalAssignmentsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string, parameters DatabasePrincipalAssignment) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (DatabasePrincipalAssignmentsClient) CreateOrUpdateResponder ¶
func (client DatabasePrincipalAssignmentsClient) CreateOrUpdateResponder(resp *http.Response) (result DatabasePrincipalAssignment, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (DatabasePrincipalAssignmentsClient) CreateOrUpdateSender ¶
func (client DatabasePrincipalAssignmentsClient) CreateOrUpdateSender(req *http.Request) (future DatabasePrincipalAssignmentsCreateOrUpdateFuture, err error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (DatabasePrincipalAssignmentsClient) Delete ¶
func (client DatabasePrincipalAssignmentsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (result DatabasePrincipalAssignmentsDeleteFuture, err error)
Delete deletes a Kusto principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.
func (DatabasePrincipalAssignmentsClient) DeletePreparer ¶
func (client DatabasePrincipalAssignmentsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (DatabasePrincipalAssignmentsClient) DeleteResponder ¶
func (client DatabasePrincipalAssignmentsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (DatabasePrincipalAssignmentsClient) DeleteSender ¶
func (client DatabasePrincipalAssignmentsClient) DeleteSender(req *http.Request) (future DatabasePrincipalAssignmentsDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (DatabasePrincipalAssignmentsClient) Get ¶
func (client DatabasePrincipalAssignmentsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (result DatabasePrincipalAssignment, err error)
Get gets a Kusto cluster database principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.
func (DatabasePrincipalAssignmentsClient) GetPreparer ¶
func (client DatabasePrincipalAssignmentsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (DatabasePrincipalAssignmentsClient) GetResponder ¶
func (client DatabasePrincipalAssignmentsClient) GetResponder(resp *http.Response) (result DatabasePrincipalAssignment, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (DatabasePrincipalAssignmentsClient) GetSender ¶
func (client DatabasePrincipalAssignmentsClient) GetSender(req *http.Request) (*http.Response, error)
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (DatabasePrincipalAssignmentsClient) List ¶
func (client DatabasePrincipalAssignmentsClient) List(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DatabasePrincipalAssignmentListResult, err error)
List lists all Kusto cluster database principalAssignments. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.
func (DatabasePrincipalAssignmentsClient) ListPreparer ¶
func (client DatabasePrincipalAssignmentsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)
ListPreparer prepares the List request.
func (DatabasePrincipalAssignmentsClient) ListResponder ¶
func (client DatabasePrincipalAssignmentsClient) ListResponder(resp *http.Response) (result DatabasePrincipalAssignmentListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (DatabasePrincipalAssignmentsClient) ListSender ¶
func (client DatabasePrincipalAssignmentsClient) ListSender(req *http.Request) (*http.Response, error)
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type DatabasePrincipalAssignmentsCreateOrUpdateFuture ¶
type DatabasePrincipalAssignmentsCreateOrUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DatabasePrincipalAssignmentsClient) (DatabasePrincipalAssignment, error) }
DatabasePrincipalAssignmentsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasePrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON ¶
func (future *DatabasePrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DatabasePrincipalAssignmentsDeleteFuture ¶
type DatabasePrincipalAssignmentsDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DatabasePrincipalAssignmentsClient) (autorest.Response, error) }
DatabasePrincipalAssignmentsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasePrincipalAssignmentsDeleteFuture) UnmarshalJSON ¶
func (future *DatabasePrincipalAssignmentsDeleteFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DatabasePrincipalListRequest ¶
type DatabasePrincipalListRequest struct { // Value - The list of Kusto database principals. Value *[]DatabasePrincipal `json:"value,omitempty"` }
DatabasePrincipalListRequest the list Kusto database principals operation request.
type DatabasePrincipalListResult ¶
type DatabasePrincipalListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto database principals. Value *[]DatabasePrincipal `json:"value,omitempty"` }
DatabasePrincipalListResult the list Kusto database principals operation response.
type DatabasePrincipalProperties ¶
type DatabasePrincipalProperties struct { // PrincipalID - The principal ID assigned to the database principal. It can be a user email, application ID, or security group name. PrincipalID *string `json:"principalId,omitempty"` // Role - Database principal role. Possible values include: 'DatabasePrincipalRoleAdmin', 'DatabasePrincipalRoleIngestor', 'DatabasePrincipalRoleMonitor', 'DatabasePrincipalRoleUser', 'DatabasePrincipalRoleUnrestrictedViewer', 'DatabasePrincipalRoleViewer' Role DatabasePrincipalRole `json:"role,omitempty"` // TenantID - The tenant id of the principal TenantID *string `json:"tenantId,omitempty"` // PrincipalType - Principal type. Possible values include: 'PrincipalTypeApp', 'PrincipalTypeGroup', 'PrincipalTypeUser' PrincipalType PrincipalType `json:"principalType,omitempty"` // TenantName - READ-ONLY; The tenant name of the principal TenantName *string `json:"tenantName,omitempty"` // PrincipalName - READ-ONLY; The principal name PrincipalName *string `json:"principalName,omitempty"` // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` }
DatabasePrincipalProperties a class representing database principal property.
func (DatabasePrincipalProperties) MarshalJSON ¶
func (dpp DatabasePrincipalProperties) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for DatabasePrincipalProperties.
type DatabasePrincipalRole ¶
type DatabasePrincipalRole string
DatabasePrincipalRole enumerates the values for database principal role.
const ( // DatabasePrincipalRoleAdmin ... DatabasePrincipalRoleAdmin DatabasePrincipalRole = "Admin" // DatabasePrincipalRoleIngestor ... DatabasePrincipalRoleIngestor DatabasePrincipalRole = "Ingestor" // DatabasePrincipalRoleMonitor ... DatabasePrincipalRoleMonitor DatabasePrincipalRole = "Monitor" // DatabasePrincipalRoleUnrestrictedViewer ... DatabasePrincipalRoleUnrestrictedViewer DatabasePrincipalRole = "UnrestrictedViewer" // DatabasePrincipalRoleUser ... DatabasePrincipalRoleUser DatabasePrincipalRole = "User" // DatabasePrincipalRoleViewer ... DatabasePrincipalRoleViewer DatabasePrincipalRole = "Viewer" )
func PossibleDatabasePrincipalRoleValues ¶
func PossibleDatabasePrincipalRoleValues() []DatabasePrincipalRole
PossibleDatabasePrincipalRoleValues returns an array of possible values for the DatabasePrincipalRole const type.
type DatabasePrincipalType ¶
type DatabasePrincipalType string
DatabasePrincipalType enumerates the values for database principal type.
const ( // DatabasePrincipalTypeApp ... DatabasePrincipalTypeApp DatabasePrincipalType = "App" // DatabasePrincipalTypeGroup ... DatabasePrincipalTypeGroup DatabasePrincipalType = "Group" // DatabasePrincipalTypeUser ... DatabasePrincipalTypeUser DatabasePrincipalType = "User" )
func PossibleDatabasePrincipalTypeValues ¶
func PossibleDatabasePrincipalTypeValues() []DatabasePrincipalType
PossibleDatabasePrincipalTypeValues returns an array of possible values for the DatabasePrincipalType const type.
type DatabaseStatistics ¶
type DatabaseStatistics struct { // Size - The database size - the total size of compressed data and index in bytes. Size *float64 `json:"size,omitempty"` }
DatabaseStatistics a class that contains database statistics information.
type DatabasesClient ¶
type DatabasesClient struct {
BaseClient
}
DatabasesClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewDatabasesClient ¶
func NewDatabasesClient(subscriptionID string) DatabasesClient
NewDatabasesClient creates an instance of the DatabasesClient client.
func NewDatabasesClientWithBaseURI ¶
func NewDatabasesClientWithBaseURI(baseURI string, subscriptionID string) DatabasesClient
NewDatabasesClientWithBaseURI creates an instance of the DatabasesClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (DatabasesClient) AddPrincipals ¶
func (client DatabasesClient) AddPrincipals(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, databasePrincipalsToAdd DatabasePrincipalListRequest) (result DatabasePrincipalListResult, err error)
AddPrincipals add Database principals permissions. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. databasePrincipalsToAdd - list of database principals to add.
func (DatabasesClient) AddPrincipalsPreparer ¶
func (client DatabasesClient) AddPrincipalsPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, databasePrincipalsToAdd DatabasePrincipalListRequest) (*http.Request, error)
AddPrincipalsPreparer prepares the AddPrincipals request.
func (DatabasesClient) AddPrincipalsResponder ¶
func (client DatabasesClient) AddPrincipalsResponder(resp *http.Response) (result DatabasePrincipalListResult, err error)
AddPrincipalsResponder handles the response to the AddPrincipals request. The method always closes the http.Response Body.
func (DatabasesClient) AddPrincipalsSender ¶
AddPrincipalsSender sends the AddPrincipals request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) CheckNameAvailability ¶
func (client DatabasesClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, resourceName CheckNameRequest) (result CheckNameResult, err error)
CheckNameAvailability checks that the database name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. resourceName - the name of the resource.
func (DatabasesClient) CheckNameAvailabilityPreparer ¶
func (client DatabasesClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, resourceName CheckNameRequest) (*http.Request, error)
CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.
func (DatabasesClient) CheckNameAvailabilityResponder ¶
func (client DatabasesClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.
func (DatabasesClient) CheckNameAvailabilitySender ¶
func (client DatabasesClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)
CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) CreateOrUpdate ¶
func (client DatabasesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (result DatabasesCreateOrUpdateFuture, err error)
CreateOrUpdate creates or updates a database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. parameters - the database parameters supplied to the CreateOrUpdate operation.
func (DatabasesClient) CreateOrUpdatePreparer ¶
func (client DatabasesClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (DatabasesClient) CreateOrUpdateResponder ¶
func (client DatabasesClient) CreateOrUpdateResponder(resp *http.Response) (result DatabaseModel, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (DatabasesClient) CreateOrUpdateSender ¶
func (client DatabasesClient) CreateOrUpdateSender(req *http.Request) (future DatabasesCreateOrUpdateFuture, err error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) Delete ¶
func (client DatabasesClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DatabasesDeleteFuture, err error)
Delete deletes the database with the given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.
func (DatabasesClient) DeletePreparer ¶
func (client DatabasesClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (DatabasesClient) DeleteResponder ¶
func (client DatabasesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (DatabasesClient) DeleteSender ¶
func (client DatabasesClient) DeleteSender(req *http.Request) (future DatabasesDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) Get ¶
func (client DatabasesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DatabaseModel, err error)
Get returns a database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.
func (DatabasesClient) GetPreparer ¶
func (client DatabasesClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (DatabasesClient) GetResponder ¶
func (client DatabasesClient) GetResponder(resp *http.Response) (result DatabaseModel, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (DatabasesClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) ListByCluster ¶
func (client DatabasesClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result DatabaseListResult, err error)
ListByCluster returns the list of databases of the given Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.
func (DatabasesClient) ListByClusterPreparer ¶
func (client DatabasesClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)
ListByClusterPreparer prepares the ListByCluster request.
func (DatabasesClient) ListByClusterResponder ¶
func (client DatabasesClient) ListByClusterResponder(resp *http.Response) (result DatabaseListResult, err error)
ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.
func (DatabasesClient) ListByClusterSender ¶
ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) ListPrincipals ¶
func (client DatabasesClient) ListPrincipals(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DatabasePrincipalListResult, err error)
ListPrincipals returns a list of database principals of the given Kusto cluster and database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.
func (DatabasesClient) ListPrincipalsPreparer ¶
func (client DatabasesClient) ListPrincipalsPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)
ListPrincipalsPreparer prepares the ListPrincipals request.
func (DatabasesClient) ListPrincipalsResponder ¶
func (client DatabasesClient) ListPrincipalsResponder(resp *http.Response) (result DatabasePrincipalListResult, err error)
ListPrincipalsResponder handles the response to the ListPrincipals request. The method always closes the http.Response Body.
func (DatabasesClient) ListPrincipalsSender ¶
ListPrincipalsSender sends the ListPrincipals request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) RemovePrincipals ¶
func (client DatabasesClient) RemovePrincipals(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, databasePrincipalsToRemove DatabasePrincipalListRequest) (result DatabasePrincipalListResult, err error)
RemovePrincipals remove Database principals permissions. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. databasePrincipalsToRemove - list of database principals to remove.
func (DatabasesClient) RemovePrincipalsPreparer ¶
func (client DatabasesClient) RemovePrincipalsPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, databasePrincipalsToRemove DatabasePrincipalListRequest) (*http.Request, error)
RemovePrincipalsPreparer prepares the RemovePrincipals request.
func (DatabasesClient) RemovePrincipalsResponder ¶
func (client DatabasesClient) RemovePrincipalsResponder(resp *http.Response) (result DatabasePrincipalListResult, err error)
RemovePrincipalsResponder handles the response to the RemovePrincipals request. The method always closes the http.Response Body.
func (DatabasesClient) RemovePrincipalsSender ¶
RemovePrincipalsSender sends the RemovePrincipals request. The method will close the http.Response Body if it receives an error.
func (DatabasesClient) Update ¶
func (client DatabasesClient) Update(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (result DatabasesUpdateFuture, err error)
Update updates a database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. parameters - the database parameters supplied to the Update operation.
func (DatabasesClient) UpdatePreparer ¶
func (client DatabasesClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (DatabasesClient) UpdateResponder ¶
func (client DatabasesClient) UpdateResponder(resp *http.Response) (result DatabaseModel, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (DatabasesClient) UpdateSender ¶
func (client DatabasesClient) UpdateSender(req *http.Request) (future DatabasesUpdateFuture, err error)
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type DatabasesCreateOrUpdateFuture ¶
type DatabasesCreateOrUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DatabasesClient) (DatabaseModel, error) }
DatabasesCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasesCreateOrUpdateFuture) UnmarshalJSON ¶
func (future *DatabasesCreateOrUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DatabasesDeleteFuture ¶
type DatabasesDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DatabasesClient) (autorest.Response, error) }
DatabasesDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasesDeleteFuture) UnmarshalJSON ¶
func (future *DatabasesDeleteFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DatabasesUpdateFuture ¶
type DatabasesUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(DatabasesClient) (DatabaseModel, error) }
DatabasesUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasesUpdateFuture) UnmarshalJSON ¶
func (future *DatabasesUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type DefaultPrincipalsModificationKind ¶
type DefaultPrincipalsModificationKind string
DefaultPrincipalsModificationKind enumerates the values for default principals modification kind.
const ( // DefaultPrincipalsModificationKindNone ... DefaultPrincipalsModificationKindNone DefaultPrincipalsModificationKind = "None" // DefaultPrincipalsModificationKindReplace ... DefaultPrincipalsModificationKindReplace DefaultPrincipalsModificationKind = "Replace" // DefaultPrincipalsModificationKindUnion ... DefaultPrincipalsModificationKindUnion DefaultPrincipalsModificationKind = "Union" )
func PossibleDefaultPrincipalsModificationKindValues ¶
func PossibleDefaultPrincipalsModificationKindValues() []DefaultPrincipalsModificationKind
PossibleDefaultPrincipalsModificationKindValues returns an array of possible values for the DefaultPrincipalsModificationKind const type.
type DiagnoseVirtualNetworkResult ¶
type DiagnoseVirtualNetworkResult struct { autorest.Response `json:"-"` // Findings - The list of network connectivity diagnostic finding Findings *[]string `json:"findings,omitempty"` }
DiagnoseVirtualNetworkResult ...
type EngineType ¶
type EngineType string
EngineType enumerates the values for engine type.
const ( // EngineTypeV2 ... EngineTypeV2 EngineType = "V2" // EngineTypeV3 ... EngineTypeV3 EngineType = "V3" )
func PossibleEngineTypeValues ¶
func PossibleEngineTypeValues() []EngineType
PossibleEngineTypeValues returns an array of possible values for the EngineType const type.
type EventGridConnectionProperties ¶
type EventGridConnectionProperties struct { // StorageAccountResourceID - The resource ID of the storage account where the data resides. StorageAccountResourceID *string `json:"storageAccountResourceId,omitempty"` // EventHubResourceID - The resource ID where the event grid is configured to send events. EventHubResourceID *string `json:"eventHubResourceId,omitempty"` // ConsumerGroup - The event hub consumer group. ConsumerGroup *string `json:"consumerGroup,omitempty"` // TableName - The table where the data should be ingested. Optionally the table information can be added to each message. TableName *string `json:"tableName,omitempty"` // MappingRuleName - The mapping rule to be used to ingest the data. Optionally the mapping information can be added to each message. MappingRuleName *string `json:"mappingRuleName,omitempty"` // DataFormat - The data format of the message. Optionally the data format can be added to each message. Possible values include: 'EventGridDataFormatMULTIJSON', 'EventGridDataFormatJSON', 'EventGridDataFormatCSV', 'EventGridDataFormatTSV', 'EventGridDataFormatSCSV', 'EventGridDataFormatSOHSV', 'EventGridDataFormatPSV', 'EventGridDataFormatTXT', 'EventGridDataFormatRAW', 'EventGridDataFormatSINGLEJSON', 'EventGridDataFormatAVRO', 'EventGridDataFormatTSVE', 'EventGridDataFormatPARQUET', 'EventGridDataFormatORC', 'EventGridDataFormatAPACHEAVRO', 'EventGridDataFormatW3CLOGFILE' DataFormat EventGridDataFormat `json:"dataFormat,omitempty"` // IgnoreFirstRecord - A Boolean value that, if set to true, indicates that ingestion should ignore the first record of every file IgnoreFirstRecord *bool `json:"ignoreFirstRecord,omitempty"` // BlobStorageEventType - The name of blob storage event type to process. Possible values include: 'BlobStorageEventTypeMicrosoftStorageBlobCreated', 'BlobStorageEventTypeMicrosoftStorageBlobRenamed' BlobStorageEventType BlobStorageEventType `json:"blobStorageEventType,omitempty"` // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` }
EventGridConnectionProperties class representing the Kusto event grid connection properties.
type EventGridDataConnection ¶
type EventGridDataConnection struct { // EventGridConnectionProperties - The properties of the Event Grid data connection. *EventGridConnectionProperties `json:"properties,omitempty"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid' Kind KindBasicDataConnection `json:"kind,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
EventGridDataConnection class representing an Event Grid data connection.
func (EventGridDataConnection) AsBasicDataConnection ¶
func (egdc EventGridDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
AsBasicDataConnection is the BasicDataConnection implementation for EventGridDataConnection.
func (EventGridDataConnection) AsDataConnection ¶
func (egdc EventGridDataConnection) AsDataConnection() (*DataConnection, bool)
AsDataConnection is the BasicDataConnection implementation for EventGridDataConnection.
func (EventGridDataConnection) AsEventGridDataConnection ¶
func (egdc EventGridDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
AsEventGridDataConnection is the BasicDataConnection implementation for EventGridDataConnection.
func (EventGridDataConnection) AsEventHubDataConnection ¶
func (egdc EventGridDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
AsEventHubDataConnection is the BasicDataConnection implementation for EventGridDataConnection.
func (EventGridDataConnection) AsIotHubDataConnection ¶
func (egdc EventGridDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
AsIotHubDataConnection is the BasicDataConnection implementation for EventGridDataConnection.
func (EventGridDataConnection) MarshalJSON ¶
func (egdc EventGridDataConnection) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for EventGridDataConnection.
func (*EventGridDataConnection) UnmarshalJSON ¶
func (egdc *EventGridDataConnection) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for EventGridDataConnection struct.
type EventGridDataFormat ¶
type EventGridDataFormat string
EventGridDataFormat enumerates the values for event grid data format.
const ( // EventGridDataFormatAPACHEAVRO ... EventGridDataFormatAPACHEAVRO EventGridDataFormat = "APACHEAVRO" // EventGridDataFormatAVRO ... EventGridDataFormatAVRO EventGridDataFormat = "AVRO" // EventGridDataFormatCSV ... EventGridDataFormatCSV EventGridDataFormat = "CSV" // EventGridDataFormatJSON ... EventGridDataFormatJSON EventGridDataFormat = "JSON" // EventGridDataFormatMULTIJSON ... EventGridDataFormatMULTIJSON EventGridDataFormat = "MULTIJSON" // EventGridDataFormatORC ... EventGridDataFormatORC EventGridDataFormat = "ORC" // EventGridDataFormatPARQUET ... EventGridDataFormatPARQUET EventGridDataFormat = "PARQUET" // EventGridDataFormatPSV ... EventGridDataFormatPSV EventGridDataFormat = "PSV" // EventGridDataFormatRAW ... EventGridDataFormatRAW EventGridDataFormat = "RAW" // EventGridDataFormatSCSV ... EventGridDataFormatSCSV EventGridDataFormat = "SCSV" // EventGridDataFormatSINGLEJSON ... EventGridDataFormatSINGLEJSON EventGridDataFormat = "SINGLEJSON" // EventGridDataFormatSOHSV ... EventGridDataFormatSOHSV EventGridDataFormat = "SOHSV" // EventGridDataFormatTSV ... EventGridDataFormatTSV EventGridDataFormat = "TSV" // EventGridDataFormatTSVE ... EventGridDataFormatTSVE EventGridDataFormat = "TSVE" // EventGridDataFormatTXT ... EventGridDataFormatTXT EventGridDataFormat = "TXT" // EventGridDataFormatW3CLOGFILE ... EventGridDataFormatW3CLOGFILE EventGridDataFormat = "W3CLOGFILE" )
func PossibleEventGridDataFormatValues ¶
func PossibleEventGridDataFormatValues() []EventGridDataFormat
PossibleEventGridDataFormatValues returns an array of possible values for the EventGridDataFormat const type.
type EventHubConnectionProperties ¶
type EventHubConnectionProperties struct { // EventHubResourceID - The resource ID of the event hub to be used to create a data connection. EventHubResourceID *string `json:"eventHubResourceId,omitempty"` // ConsumerGroup - The event hub consumer group. ConsumerGroup *string `json:"consumerGroup,omitempty"` // TableName - The table where the data should be ingested. Optionally the table information can be added to each message. TableName *string `json:"tableName,omitempty"` // MappingRuleName - The mapping rule to be used to ingest the data. Optionally the mapping information can be added to each message. MappingRuleName *string `json:"mappingRuleName,omitempty"` // DataFormat - The data format of the message. Optionally the data format can be added to each message. Possible values include: 'EventHubDataFormatMULTIJSON', 'EventHubDataFormatJSON', 'EventHubDataFormatCSV', 'EventHubDataFormatTSV', 'EventHubDataFormatSCSV', 'EventHubDataFormatSOHSV', 'EventHubDataFormatPSV', 'EventHubDataFormatTXT', 'EventHubDataFormatRAW', 'EventHubDataFormatSINGLEJSON', 'EventHubDataFormatAVRO', 'EventHubDataFormatTSVE', 'EventHubDataFormatPARQUET', 'EventHubDataFormatORC', 'EventHubDataFormatAPACHEAVRO', 'EventHubDataFormatW3CLOGFILE' DataFormat EventHubDataFormat `json:"dataFormat,omitempty"` // EventSystemProperties - System properties of the event hub EventSystemProperties *[]string `json:"eventSystemProperties,omitempty"` // Compression - The event hub messages compression type. Possible values include: 'CompressionNone', 'CompressionGZip' Compression Compression `json:"compression,omitempty"` // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` // ManagedIdentityResourceID - The resource ID of a managed identity (system or user assigned) to be used to authenticate with event hub. ManagedIdentityResourceID *string `json:"managedIdentityResourceId,omitempty"` }
EventHubConnectionProperties class representing the Kusto event hub connection properties.
type EventHubDataConnection ¶
type EventHubDataConnection struct { // EventHubConnectionProperties - The Event Hub data connection properties to validate. *EventHubConnectionProperties `json:"properties,omitempty"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid' Kind KindBasicDataConnection `json:"kind,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
EventHubDataConnection class representing an event hub data connection.
func (EventHubDataConnection) AsBasicDataConnection ¶
func (ehdc EventHubDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
AsBasicDataConnection is the BasicDataConnection implementation for EventHubDataConnection.
func (EventHubDataConnection) AsDataConnection ¶
func (ehdc EventHubDataConnection) AsDataConnection() (*DataConnection, bool)
AsDataConnection is the BasicDataConnection implementation for EventHubDataConnection.
func (EventHubDataConnection) AsEventGridDataConnection ¶
func (ehdc EventHubDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
AsEventGridDataConnection is the BasicDataConnection implementation for EventHubDataConnection.
func (EventHubDataConnection) AsEventHubDataConnection ¶
func (ehdc EventHubDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
AsEventHubDataConnection is the BasicDataConnection implementation for EventHubDataConnection.
func (EventHubDataConnection) AsIotHubDataConnection ¶
func (ehdc EventHubDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
AsIotHubDataConnection is the BasicDataConnection implementation for EventHubDataConnection.
func (EventHubDataConnection) MarshalJSON ¶
func (ehdc EventHubDataConnection) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for EventHubDataConnection.
func (*EventHubDataConnection) UnmarshalJSON ¶
func (ehdc *EventHubDataConnection) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for EventHubDataConnection struct.
type EventHubDataFormat ¶
type EventHubDataFormat string
EventHubDataFormat enumerates the values for event hub data format.
const ( // EventHubDataFormatAPACHEAVRO ... EventHubDataFormatAPACHEAVRO EventHubDataFormat = "APACHEAVRO" // EventHubDataFormatAVRO ... EventHubDataFormatAVRO EventHubDataFormat = "AVRO" // EventHubDataFormatCSV ... EventHubDataFormatCSV EventHubDataFormat = "CSV" // EventHubDataFormatJSON ... EventHubDataFormatJSON EventHubDataFormat = "JSON" // EventHubDataFormatMULTIJSON ... EventHubDataFormatMULTIJSON EventHubDataFormat = "MULTIJSON" // EventHubDataFormatORC ... EventHubDataFormatORC EventHubDataFormat = "ORC" // EventHubDataFormatPARQUET ... EventHubDataFormatPARQUET EventHubDataFormat = "PARQUET" // EventHubDataFormatPSV ... EventHubDataFormatPSV EventHubDataFormat = "PSV" // EventHubDataFormatRAW ... EventHubDataFormatRAW EventHubDataFormat = "RAW" // EventHubDataFormatSCSV ... EventHubDataFormatSCSV EventHubDataFormat = "SCSV" // EventHubDataFormatSINGLEJSON ... EventHubDataFormatSINGLEJSON EventHubDataFormat = "SINGLEJSON" // EventHubDataFormatSOHSV ... EventHubDataFormatSOHSV EventHubDataFormat = "SOHSV" // EventHubDataFormatTSV ... EventHubDataFormatTSV EventHubDataFormat = "TSV" // EventHubDataFormatTSVE ... EventHubDataFormatTSVE EventHubDataFormat = "TSVE" // EventHubDataFormatTXT ... EventHubDataFormatTXT EventHubDataFormat = "TXT" // EventHubDataFormatW3CLOGFILE ... EventHubDataFormatW3CLOGFILE EventHubDataFormat = "W3CLOGFILE" )
func PossibleEventHubDataFormatValues ¶
func PossibleEventHubDataFormatValues() []EventHubDataFormat
PossibleEventHubDataFormatValues returns an array of possible values for the EventHubDataFormat const type.
type FollowerDatabaseDefinition ¶
type FollowerDatabaseDefinition struct { // ClusterResourceID - Resource id of the cluster that follows a database owned by this cluster. ClusterResourceID *string `json:"clusterResourceId,omitempty"` // AttachedDatabaseConfigurationName - Resource name of the attached database configuration in the follower cluster. AttachedDatabaseConfigurationName *string `json:"attachedDatabaseConfigurationName,omitempty"` // DatabaseName - READ-ONLY; The database name owned by this cluster that was followed. * in case following all databases. DatabaseName *string `json:"databaseName,omitempty"` }
FollowerDatabaseDefinition a class representing follower database request.
func (FollowerDatabaseDefinition) MarshalJSON ¶
func (fdd FollowerDatabaseDefinition) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for FollowerDatabaseDefinition.
type FollowerDatabaseListResult ¶
type FollowerDatabaseListResult struct { autorest.Response `json:"-"` // Value - The list of follower database result. Value *[]FollowerDatabaseDefinition `json:"value,omitempty"` }
FollowerDatabaseListResult the list Kusto database principals operation response.
type Identity ¶
type Identity struct { // PrincipalID - READ-ONLY; The principal ID of resource identity. PrincipalID *string `json:"principalId,omitempty"` // TenantID - READ-ONLY; The tenant ID of resource. TenantID *string `json:"tenantId,omitempty"` // Type - The type of managed identity used. The type 'SystemAssigned, UserAssigned' includes both an implicitly created identity and a set of user-assigned identities. The type 'None' will remove all identities. Possible values include: 'IdentityTypeNone', 'IdentityTypeSystemAssigned', 'IdentityTypeUserAssigned', 'IdentityTypeSystemAssignedUserAssigned' Type IdentityType `json:"type,omitempty"` // UserAssignedIdentities - The list of user identities associated with the Kusto cluster. The user identity dictionary key references will be ARM resource ids in the form: '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ManagedIdentity/userAssignedIdentities/{identityName}'. UserAssignedIdentities map[string]*IdentityUserAssignedIdentitiesValue `json:"userAssignedIdentities"` }
Identity identity for the resource.
func (Identity) MarshalJSON ¶
MarshalJSON is the custom marshaler for Identity.
type IdentityType ¶
type IdentityType string
IdentityType enumerates the values for identity type.
const ( // IdentityTypeNone ... IdentityTypeNone IdentityType = "None" // IdentityTypeSystemAssigned ... IdentityTypeSystemAssigned IdentityType = "SystemAssigned" // IdentityTypeSystemAssignedUserAssigned ... IdentityTypeSystemAssignedUserAssigned IdentityType = "SystemAssigned, UserAssigned" // IdentityTypeUserAssigned ... IdentityTypeUserAssigned IdentityType = "UserAssigned" )
func PossibleIdentityTypeValues ¶
func PossibleIdentityTypeValues() []IdentityType
PossibleIdentityTypeValues returns an array of possible values for the IdentityType const type.
type IdentityUserAssignedIdentitiesValue ¶
type IdentityUserAssignedIdentitiesValue struct { // PrincipalID - READ-ONLY; The principal id of user assigned identity. PrincipalID *string `json:"principalId,omitempty"` // ClientID - READ-ONLY; The client id of user assigned identity. ClientID *string `json:"clientId,omitempty"` }
IdentityUserAssignedIdentitiesValue ...
func (IdentityUserAssignedIdentitiesValue) MarshalJSON ¶
func (iAiv IdentityUserAssignedIdentitiesValue) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for IdentityUserAssignedIdentitiesValue.
type IotHubConnectionProperties ¶
type IotHubConnectionProperties struct { // IotHubResourceID - The resource ID of the Iot hub to be used to create a data connection. IotHubResourceID *string `json:"iotHubResourceId,omitempty"` // ConsumerGroup - The iot hub consumer group. ConsumerGroup *string `json:"consumerGroup,omitempty"` // TableName - The table where the data should be ingested. Optionally the table information can be added to each message. TableName *string `json:"tableName,omitempty"` // MappingRuleName - The mapping rule to be used to ingest the data. Optionally the mapping information can be added to each message. MappingRuleName *string `json:"mappingRuleName,omitempty"` // DataFormat - The data format of the message. Optionally the data format can be added to each message. Possible values include: 'IotHubDataFormatMULTIJSON', 'IotHubDataFormatJSON', 'IotHubDataFormatCSV', 'IotHubDataFormatTSV', 'IotHubDataFormatSCSV', 'IotHubDataFormatSOHSV', 'IotHubDataFormatPSV', 'IotHubDataFormatTXT', 'IotHubDataFormatRAW', 'IotHubDataFormatSINGLEJSON', 'IotHubDataFormatAVRO', 'IotHubDataFormatTSVE', 'IotHubDataFormatPARQUET', 'IotHubDataFormatORC', 'IotHubDataFormatAPACHEAVRO', 'IotHubDataFormatW3CLOGFILE' DataFormat IotHubDataFormat `json:"dataFormat,omitempty"` // EventSystemProperties - System properties of the iot hub EventSystemProperties *[]string `json:"eventSystemProperties,omitempty"` SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"` // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` }
IotHubConnectionProperties class representing the Kusto Iot hub connection properties.
type IotHubDataConnection ¶
type IotHubDataConnection struct { // IotHubConnectionProperties - The Iot Hub data connection properties. *IotHubConnectionProperties `json:"properties,omitempty"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid' Kind KindBasicDataConnection `json:"kind,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
IotHubDataConnection class representing an iot hub data connection.
func (IotHubDataConnection) AsBasicDataConnection ¶
func (ihdc IotHubDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)
AsBasicDataConnection is the BasicDataConnection implementation for IotHubDataConnection.
func (IotHubDataConnection) AsDataConnection ¶
func (ihdc IotHubDataConnection) AsDataConnection() (*DataConnection, bool)
AsDataConnection is the BasicDataConnection implementation for IotHubDataConnection.
func (IotHubDataConnection) AsEventGridDataConnection ¶
func (ihdc IotHubDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)
AsEventGridDataConnection is the BasicDataConnection implementation for IotHubDataConnection.
func (IotHubDataConnection) AsEventHubDataConnection ¶
func (ihdc IotHubDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)
AsEventHubDataConnection is the BasicDataConnection implementation for IotHubDataConnection.
func (IotHubDataConnection) AsIotHubDataConnection ¶
func (ihdc IotHubDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)
AsIotHubDataConnection is the BasicDataConnection implementation for IotHubDataConnection.
func (IotHubDataConnection) MarshalJSON ¶
func (ihdc IotHubDataConnection) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for IotHubDataConnection.
func (*IotHubDataConnection) UnmarshalJSON ¶
func (ihdc *IotHubDataConnection) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for IotHubDataConnection struct.
type IotHubDataFormat ¶
type IotHubDataFormat string
IotHubDataFormat enumerates the values for iot hub data format.
const ( // IotHubDataFormatAPACHEAVRO ... IotHubDataFormatAPACHEAVRO IotHubDataFormat = "APACHEAVRO" // IotHubDataFormatAVRO ... IotHubDataFormatAVRO IotHubDataFormat = "AVRO" // IotHubDataFormatCSV ... IotHubDataFormatCSV IotHubDataFormat = "CSV" // IotHubDataFormatJSON ... IotHubDataFormatJSON IotHubDataFormat = "JSON" // IotHubDataFormatMULTIJSON ... IotHubDataFormatMULTIJSON IotHubDataFormat = "MULTIJSON" // IotHubDataFormatORC ... IotHubDataFormatORC IotHubDataFormat = "ORC" // IotHubDataFormatPARQUET ... IotHubDataFormatPARQUET IotHubDataFormat = "PARQUET" // IotHubDataFormatPSV ... IotHubDataFormatPSV IotHubDataFormat = "PSV" // IotHubDataFormatRAW ... IotHubDataFormatRAW IotHubDataFormat = "RAW" // IotHubDataFormatSCSV ... IotHubDataFormatSCSV IotHubDataFormat = "SCSV" // IotHubDataFormatSINGLEJSON ... IotHubDataFormatSINGLEJSON IotHubDataFormat = "SINGLEJSON" // IotHubDataFormatSOHSV ... IotHubDataFormatSOHSV IotHubDataFormat = "SOHSV" // IotHubDataFormatTSV ... IotHubDataFormatTSV IotHubDataFormat = "TSV" // IotHubDataFormatTSVE ... IotHubDataFormatTSVE IotHubDataFormat = "TSVE" // IotHubDataFormatTXT ... IotHubDataFormatTXT IotHubDataFormat = "TXT" // IotHubDataFormatW3CLOGFILE ... IotHubDataFormatW3CLOGFILE IotHubDataFormat = "W3CLOGFILE" )
func PossibleIotHubDataFormatValues ¶
func PossibleIotHubDataFormatValues() []IotHubDataFormat
PossibleIotHubDataFormatValues returns an array of possible values for the IotHubDataFormat const type.
type KeyVaultProperties ¶
type KeyVaultProperties struct { // KeyName - The name of the key vault key. KeyName *string `json:"keyName,omitempty"` // KeyVersion - The version of the key vault key. KeyVersion *string `json:"keyVersion,omitempty"` // KeyVaultURI - The Uri of the key vault. KeyVaultURI *string `json:"keyVaultUri,omitempty"` // UserIdentity - The user assigned identity (ARM resource id) that has access to the key. UserIdentity *string `json:"userIdentity,omitempty"` }
KeyVaultProperties properties of the key vault.
type Kind ¶
type Kind string
Kind enumerates the values for kind.
func PossibleKindValues ¶
func PossibleKindValues() []Kind
PossibleKindValues returns an array of possible values for the Kind const type.
type KindBasicDataConnection ¶
type KindBasicDataConnection string
KindBasicDataConnection enumerates the values for kind basic data connection.
const ( // KindBasicDataConnectionKindDataConnection ... KindBasicDataConnectionKindDataConnection KindBasicDataConnection = "DataConnection" // KindBasicDataConnectionKindEventGrid ... KindBasicDataConnectionKindEventGrid KindBasicDataConnection = "EventGrid" // KindBasicDataConnectionKindEventHub ... KindBasicDataConnectionKindEventHub KindBasicDataConnection = "EventHub" // KindBasicDataConnectionKindIotHub ... KindBasicDataConnectionKindIotHub KindBasicDataConnection = "IotHub" )
func PossibleKindBasicDataConnectionValues ¶
func PossibleKindBasicDataConnectionValues() []KindBasicDataConnection
PossibleKindBasicDataConnectionValues returns an array of possible values for the KindBasicDataConnection const type.
type LanguageExtension ¶
type LanguageExtension struct { // LanguageExtensionName - The language extension name. Possible values include: 'LanguageExtensionNamePYTHON', 'LanguageExtensionNameR' LanguageExtensionName LanguageExtensionName `json:"languageExtensionName,omitempty"` }
LanguageExtension the language extension object.
type LanguageExtensionName ¶
type LanguageExtensionName string
LanguageExtensionName enumerates the values for language extension name.
const ( // LanguageExtensionNamePYTHON ... LanguageExtensionNamePYTHON LanguageExtensionName = "PYTHON" // LanguageExtensionNameR ... LanguageExtensionNameR LanguageExtensionName = "R" )
func PossibleLanguageExtensionNameValues ¶
func PossibleLanguageExtensionNameValues() []LanguageExtensionName
PossibleLanguageExtensionNameValues returns an array of possible values for the LanguageExtensionName const type.
type LanguageExtensionsList ¶
type LanguageExtensionsList struct { autorest.Response `json:"-"` // Value - The list of language extensions. Value *[]LanguageExtension `json:"value,omitempty"` }
LanguageExtensionsList the list of language extension objects.
type ListResourceSkusResult ¶
type ListResourceSkusResult struct { autorest.Response `json:"-"` // Value - The collection of available SKUs for an existing resource. Value *[]AzureResourceSku `json:"value,omitempty"` }
ListResourceSkusResult list of available SKUs for a Kusto Cluster.
type Operation ¶
type Operation struct { // Name - This is of the format {provider}/{resource}/{operation}. Name *string `json:"name,omitempty"` Display *OperationDisplay `json:"display,omitempty"` Origin *string `json:"origin,omitempty"` Properties interface{} `json:"properties,omitempty"` }
Operation ...
type OperationDisplay ¶
type OperationDisplay struct { Provider *string `json:"provider,omitempty"` // Operation - For example: read, write, delete. Operation *string `json:"operation,omitempty"` Resource *string `json:"resource,omitempty"` Description *string `json:"description,omitempty"` }
OperationDisplay ...
type OperationListResult ¶
type OperationListResult struct { autorest.Response `json:"-"` Value *[]Operation `json:"value,omitempty"` NextLink *string `json:"nextLink,omitempty"` }
OperationListResult ...
func (OperationListResult) IsEmpty ¶
func (olr OperationListResult) IsEmpty() bool
IsEmpty returns true if the ListResult contains no values.
type OperationListResultIterator ¶
type OperationListResultIterator struct {
// contains filtered or unexported fields
}
OperationListResultIterator provides access to a complete listing of Operation values.
func NewOperationListResultIterator ¶
func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator
Creates a new instance of the OperationListResultIterator type.
func (*OperationListResultIterator) Next ¶
func (iter *OperationListResultIterator) Next() error
Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*OperationListResultIterator) NextWithContext ¶
func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.
func (OperationListResultIterator) NotDone ¶
func (iter OperationListResultIterator) NotDone() bool
NotDone returns true if the enumeration should be started or is not yet complete.
func (OperationListResultIterator) Response ¶
func (iter OperationListResultIterator) Response() OperationListResult
Response returns the raw server response from the last page request.
func (OperationListResultIterator) Value ¶
func (iter OperationListResultIterator) Value() Operation
Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.
type OperationListResultPage ¶
type OperationListResultPage struct {
// contains filtered or unexported fields
}
OperationListResultPage contains a page of Operation values.
func NewOperationListResultPage ¶
func NewOperationListResultPage(cur OperationListResult, getNextPage func(context.Context, OperationListResult) (OperationListResult, error)) OperationListResultPage
Creates a new instance of the OperationListResultPage type.
func (*OperationListResultPage) Next ¶
func (page *OperationListResultPage) Next() error
Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.
func (*OperationListResultPage) NextWithContext ¶
func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error)
NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.
func (OperationListResultPage) NotDone ¶
func (page OperationListResultPage) NotDone() bool
NotDone returns true if the page enumeration should be started or is not yet complete.
func (OperationListResultPage) Response ¶
func (page OperationListResultPage) Response() OperationListResult
Response returns the raw server response from the last page request.
func (OperationListResultPage) Values ¶
func (page OperationListResultPage) Values() []Operation
Values returns the slice of values for the current page or nil if there are no values.
type OperationResult ¶
type OperationResult struct { autorest.Response `json:"-"` // ID - READ-ONLY; ID of the resource. ID *string `json:"id,omitempty"` // Name - READ-ONLY; Name of the resource. Name *string `json:"name,omitempty"` // Status - status of the Operation result. Possible values include: 'StatusSucceeded', 'StatusCanceled', 'StatusFailed', 'StatusRunning' Status Status `json:"status,omitempty"` // StartTime - The operation start time StartTime *date.Time `json:"startTime,omitempty"` // EndTime - The operation end time EndTime *date.Time `json:"endTime,omitempty"` // PercentComplete - Percentage completed. PercentComplete *float64 `json:"percentComplete,omitempty"` // OperationResultProperties - Properties of the operation results *OperationResultProperties `json:"properties,omitempty"` // OperationResultErrorProperties - Object that contains the error code and message if the operation failed. *OperationResultErrorProperties `json:"error,omitempty"` }
OperationResult operation Result Entity.
func (OperationResult) MarshalJSON ¶
func (or OperationResult) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for OperationResult.
func (*OperationResult) UnmarshalJSON ¶
func (or *OperationResult) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for OperationResult struct.
type OperationResultErrorProperties ¶
type OperationResultErrorProperties struct { // Code - The code of the error. Code *string `json:"code,omitempty"` // Message - The error message. Message *string `json:"message,omitempty"` }
OperationResultErrorProperties operation result error properties
type OperationResultProperties ¶
type OperationResultProperties struct { // OperationKind - The kind of the operation. OperationKind *string `json:"operationKind,omitempty"` // OperationState - The state of the operation. OperationState *string `json:"operationState,omitempty"` }
OperationResultProperties operation result properties
type OperationsClient ¶
type OperationsClient struct {
BaseClient
}
OperationsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewOperationsClient ¶
func NewOperationsClient(subscriptionID string) OperationsClient
NewOperationsClient creates an instance of the OperationsClient client.
func NewOperationsClientWithBaseURI ¶
func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient
NewOperationsClientWithBaseURI creates an instance of the OperationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (OperationsClient) List ¶
func (client OperationsClient) List(ctx context.Context) (result OperationListResultPage, err error)
List lists available operations for the Microsoft.Kusto provider.
func (OperationsClient) ListComplete ¶
func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error)
ListComplete enumerates all values, automatically crossing page boundaries as required.
func (OperationsClient) ListPreparer ¶
ListPreparer prepares the List request.
func (OperationsClient) ListResponder ¶
func (client OperationsClient) ListResponder(resp *http.Response) (result OperationListResult, err error)
ListResponder handles the response to the List request. The method always closes the http.Response Body.
func (OperationsClient) ListSender ¶
ListSender sends the List request. The method will close the http.Response Body if it receives an error.
type OperationsResultsClient ¶
type OperationsResultsClient struct {
BaseClient
}
OperationsResultsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewOperationsResultsClient ¶
func NewOperationsResultsClient(subscriptionID string) OperationsResultsClient
NewOperationsResultsClient creates an instance of the OperationsResultsClient client.
func NewOperationsResultsClientWithBaseURI ¶
func NewOperationsResultsClientWithBaseURI(baseURI string, subscriptionID string) OperationsResultsClient
NewOperationsResultsClientWithBaseURI creates an instance of the OperationsResultsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (OperationsResultsClient) Get ¶
func (client OperationsResultsClient) Get(ctx context.Context, location string, operationID string) (result OperationResult, err error)
Get returns operation results. Parameters: location - azure location (region) name. operationID - the Guid of the operation ID
func (OperationsResultsClient) GetPreparer ¶
func (client OperationsResultsClient) GetPreparer(ctx context.Context, location string, operationID string) (*http.Request, error)
GetPreparer prepares the Get request.
func (OperationsResultsClient) GetResponder ¶
func (client OperationsResultsClient) GetResponder(resp *http.Response) (result OperationResult, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
type OptimizedAutoscale ¶
type OptimizedAutoscale struct { // Version - The version of the template defined, for instance 1. Version *int32 `json:"version,omitempty"` // IsEnabled - A boolean value that indicate if the optimized autoscale feature is enabled or not. IsEnabled *bool `json:"isEnabled,omitempty"` // Minimum - Minimum allowed instances count. Minimum *int32 `json:"minimum,omitempty"` // Maximum - Maximum allowed instances count. Maximum *int32 `json:"maximum,omitempty"` }
OptimizedAutoscale a class that contains the optimized auto scale definition.
type PrincipalType ¶
type PrincipalType string
PrincipalType enumerates the values for principal type.
const ( // PrincipalTypeApp ... PrincipalTypeApp PrincipalType = "App" // PrincipalTypeGroup ... PrincipalTypeGroup PrincipalType = "Group" // PrincipalTypeUser ... PrincipalTypeUser PrincipalType = "User" )
func PossiblePrincipalTypeValues ¶
func PossiblePrincipalTypeValues() []PrincipalType
PossiblePrincipalTypeValues returns an array of possible values for the PrincipalType const type.
type PrincipalsModificationKind ¶
type PrincipalsModificationKind string
PrincipalsModificationKind enumerates the values for principals modification kind.
const ( // PrincipalsModificationKindNone ... PrincipalsModificationKindNone PrincipalsModificationKind = "None" // PrincipalsModificationKindReplace ... PrincipalsModificationKindReplace PrincipalsModificationKind = "Replace" // PrincipalsModificationKindUnion ... PrincipalsModificationKindUnion PrincipalsModificationKind = "Union" )
func PossiblePrincipalsModificationKindValues ¶
func PossiblePrincipalsModificationKindValues() []PrincipalsModificationKind
PossiblePrincipalsModificationKindValues returns an array of possible values for the PrincipalsModificationKind const type.
type ProvisioningState ¶
type ProvisioningState string
ProvisioningState enumerates the values for provisioning state.
const ( // ProvisioningStateCreating ... ProvisioningStateCreating ProvisioningState = "Creating" // ProvisioningStateDeleting ... ProvisioningStateDeleting ProvisioningState = "Deleting" // ProvisioningStateFailed ... ProvisioningStateFailed ProvisioningState = "Failed" // ProvisioningStateMoving ... ProvisioningStateMoving ProvisioningState = "Moving" // ProvisioningStateRunning ... ProvisioningStateRunning ProvisioningState = "Running" // ProvisioningStateSucceeded ... ProvisioningStateSucceeded ProvisioningState = "Succeeded" )
func PossibleProvisioningStateValues ¶
func PossibleProvisioningStateValues() []ProvisioningState
PossibleProvisioningStateValues returns an array of possible values for the ProvisioningState const type.
type ProxyResource ¶
type ProxyResource struct { // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
ProxyResource the resource model definition for a Azure Resource Manager proxy resource. It will not have tags and a location
func (ProxyResource) MarshalJSON ¶
func (pr ProxyResource) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ProxyResource.
type ReadOnlyFollowingDatabase ¶
type ReadOnlyFollowingDatabase struct { // ReadOnlyFollowingDatabaseProperties - The database properties. *ReadOnlyFollowingDatabaseProperties `json:"properties,omitempty"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindDatabase', 'KindReadWrite', 'KindReadOnlyFollowing' Kind Kind `json:"kind,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
ReadOnlyFollowingDatabase class representing a read only following database.
func (ReadOnlyFollowingDatabase) AsBasicDatabase ¶
func (rofd ReadOnlyFollowingDatabase) AsBasicDatabase() (BasicDatabase, bool)
AsBasicDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.
func (ReadOnlyFollowingDatabase) AsDatabase ¶
func (rofd ReadOnlyFollowingDatabase) AsDatabase() (*Database, bool)
AsDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.
func (ReadOnlyFollowingDatabase) AsReadOnlyFollowingDatabase ¶
func (rofd ReadOnlyFollowingDatabase) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)
AsReadOnlyFollowingDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.
func (ReadOnlyFollowingDatabase) AsReadWriteDatabase ¶
func (rofd ReadOnlyFollowingDatabase) AsReadWriteDatabase() (*ReadWriteDatabase, bool)
AsReadWriteDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.
func (ReadOnlyFollowingDatabase) MarshalJSON ¶
func (rofd ReadOnlyFollowingDatabase) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ReadOnlyFollowingDatabase.
func (*ReadOnlyFollowingDatabase) UnmarshalJSON ¶
func (rofd *ReadOnlyFollowingDatabase) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for ReadOnlyFollowingDatabase struct.
type ReadOnlyFollowingDatabaseProperties ¶
type ReadOnlyFollowingDatabaseProperties struct { // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` // SoftDeletePeriod - READ-ONLY; The time the data should be kept before it stops being accessible to queries in TimeSpan. SoftDeletePeriod *string `json:"softDeletePeriod,omitempty"` // HotCachePeriod - The time the data should be kept in cache for fast queries in TimeSpan. HotCachePeriod *string `json:"hotCachePeriod,omitempty"` // Statistics - The statistics of the database. Statistics *DatabaseStatistics `json:"statistics,omitempty"` // LeaderClusterResourceID - READ-ONLY; The name of the leader cluster LeaderClusterResourceID *string `json:"leaderClusterResourceId,omitempty"` // AttachedDatabaseConfigurationName - READ-ONLY; The name of the attached database configuration cluster AttachedDatabaseConfigurationName *string `json:"attachedDatabaseConfigurationName,omitempty"` // PrincipalsModificationKind - READ-ONLY; The principals modification kind of the database. Possible values include: 'PrincipalsModificationKindUnion', 'PrincipalsModificationKindReplace', 'PrincipalsModificationKindNone' PrincipalsModificationKind PrincipalsModificationKind `json:"principalsModificationKind,omitempty"` }
ReadOnlyFollowingDatabaseProperties class representing the Kusto database properties.
func (ReadOnlyFollowingDatabaseProperties) MarshalJSON ¶
func (rofdp ReadOnlyFollowingDatabaseProperties) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ReadOnlyFollowingDatabaseProperties.
type ReadWriteDatabase ¶
type ReadWriteDatabase struct { // ReadWriteDatabaseProperties - The database properties. *ReadWriteDatabaseProperties `json:"properties,omitempty"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindDatabase', 'KindReadWrite', 'KindReadOnlyFollowing' Kind Kind `json:"kind,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
ReadWriteDatabase class representing a read write database.
func (ReadWriteDatabase) AsBasicDatabase ¶
func (rwd ReadWriteDatabase) AsBasicDatabase() (BasicDatabase, bool)
AsBasicDatabase is the BasicDatabase implementation for ReadWriteDatabase.
func (ReadWriteDatabase) AsDatabase ¶
func (rwd ReadWriteDatabase) AsDatabase() (*Database, bool)
AsDatabase is the BasicDatabase implementation for ReadWriteDatabase.
func (ReadWriteDatabase) AsReadOnlyFollowingDatabase ¶
func (rwd ReadWriteDatabase) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)
AsReadOnlyFollowingDatabase is the BasicDatabase implementation for ReadWriteDatabase.
func (ReadWriteDatabase) AsReadWriteDatabase ¶
func (rwd ReadWriteDatabase) AsReadWriteDatabase() (*ReadWriteDatabase, bool)
AsReadWriteDatabase is the BasicDatabase implementation for ReadWriteDatabase.
func (ReadWriteDatabase) MarshalJSON ¶
func (rwd ReadWriteDatabase) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ReadWriteDatabase.
func (*ReadWriteDatabase) UnmarshalJSON ¶
func (rwd *ReadWriteDatabase) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for ReadWriteDatabase struct.
type ReadWriteDatabaseProperties ¶
type ReadWriteDatabaseProperties struct { // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` // SoftDeletePeriod - The time the data should be kept before it stops being accessible to queries in TimeSpan. SoftDeletePeriod *string `json:"softDeletePeriod,omitempty"` // HotCachePeriod - The time the data should be kept in cache for fast queries in TimeSpan. HotCachePeriod *string `json:"hotCachePeriod,omitempty"` // Statistics - The statistics of the database. Statistics *DatabaseStatistics `json:"statistics,omitempty"` // IsFollowed - READ-ONLY; Indicates whether the database is followed. IsFollowed *bool `json:"isFollowed,omitempty"` }
ReadWriteDatabaseProperties class representing the Kusto database properties.
func (ReadWriteDatabaseProperties) MarshalJSON ¶
func (rwdp ReadWriteDatabaseProperties) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for ReadWriteDatabaseProperties.
type Reason ¶
type Reason string
Reason enumerates the values for reason.
func PossibleReasonValues ¶
func PossibleReasonValues() []Reason
PossibleReasonValues returns an array of possible values for the Reason const type.
type Resource ¶
type Resource struct { // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
Resource common fields that are returned in the response for all Azure Resource Manager resources
func (Resource) MarshalJSON ¶
MarshalJSON is the custom marshaler for Resource.
type Script ¶
type Script struct { autorest.Response `json:"-"` // ScriptProperties - The database script. *ScriptProperties `json:"properties,omitempty"` // SystemData - READ-ONLY SystemData *SystemData `json:"systemData,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
Script class representing a database script.
func (Script) MarshalJSON ¶
MarshalJSON is the custom marshaler for Script.
func (*Script) UnmarshalJSON ¶
UnmarshalJSON is the custom unmarshaler for Script struct.
type ScriptCheckNameRequest ¶
type ScriptCheckNameRequest struct { // Name - Script name. Name *string `json:"name,omitempty"` // Type - The type of resource, Microsoft.Kusto/clusters/databases/scripts. Type *string `json:"type,omitempty"` }
ScriptCheckNameRequest a script name availability request.
type ScriptListResult ¶
type ScriptListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto scripts. Value *[]Script `json:"value,omitempty"` }
ScriptListResult the list Kusto database script operation response.
type ScriptProperties ¶
type ScriptProperties struct { // ScriptURL - The url to the KQL script blob file. ScriptURL *string `json:"scriptUrl,omitempty"` // ScriptURLSasToken - The SaS token. ScriptURLSasToken *string `json:"scriptUrlSasToken,omitempty"` // ForceUpdateTag - A unique string. If changed the script will be applied again. ForceUpdateTag *string `json:"forceUpdateTag,omitempty"` // ContinueOnErrors - Flag that indicates whether to continue if one of the command fails. ContinueOnErrors *bool `json:"continueOnErrors,omitempty"` // ProvisioningState - The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` }
ScriptProperties a class representing database script property.
type ScriptsClient ¶
type ScriptsClient struct {
BaseClient
}
ScriptsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.
func NewScriptsClient ¶
func NewScriptsClient(subscriptionID string) ScriptsClient
NewScriptsClient creates an instance of the ScriptsClient client.
func NewScriptsClientWithBaseURI ¶
func NewScriptsClientWithBaseURI(baseURI string, subscriptionID string) ScriptsClient
NewScriptsClientWithBaseURI creates an instance of the ScriptsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).
func (ScriptsClient) CheckNameAvailability ¶
func (client ScriptsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName ScriptCheckNameRequest) (result CheckNameResult, err error)
CheckNameAvailability checks that the script name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the script.
func (ScriptsClient) CheckNameAvailabilityPreparer ¶
func (client ScriptsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName ScriptCheckNameRequest) (*http.Request, error)
CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.
func (ScriptsClient) CheckNameAvailabilityResponder ¶
func (client ScriptsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)
CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.
func (ScriptsClient) CheckNameAvailabilitySender ¶
CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.
func (ScriptsClient) CreateOrUpdate ¶
func (client ScriptsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (result ScriptsCreateOrUpdateFuture, err error)
CreateOrUpdate creates a Kusto database script. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script. parameters - the Kusto Script parameters contains the KQL to run.
func (ScriptsClient) CreateOrUpdatePreparer ¶
func (client ScriptsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (ScriptsClient) CreateOrUpdateResponder ¶
func (client ScriptsClient) CreateOrUpdateResponder(resp *http.Response) (result Script, err error)
CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.
func (ScriptsClient) CreateOrUpdateSender ¶
func (client ScriptsClient) CreateOrUpdateSender(req *http.Request) (future ScriptsCreateOrUpdateFuture, err error)
CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.
func (ScriptsClient) Delete ¶
func (client ScriptsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (result ScriptsDeleteFuture, err error)
Delete deletes a Kusto principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script.
func (ScriptsClient) DeletePreparer ¶
func (client ScriptsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (*http.Request, error)
DeletePreparer prepares the Delete request.
func (ScriptsClient) DeleteResponder ¶
func (client ScriptsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)
DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.
func (ScriptsClient) DeleteSender ¶
func (client ScriptsClient) DeleteSender(req *http.Request) (future ScriptsDeleteFuture, err error)
DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.
func (ScriptsClient) Get ¶
func (client ScriptsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (result Script, err error)
Get gets a Kusto cluster database script. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script.
func (ScriptsClient) GetPreparer ¶
func (client ScriptsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (*http.Request, error)
GetPreparer prepares the Get request.
func (ScriptsClient) GetResponder ¶
func (client ScriptsClient) GetResponder(resp *http.Response) (result Script, err error)
GetResponder handles the response to the Get request. The method always closes the http.Response Body.
func (ScriptsClient) GetSender ¶
GetSender sends the Get request. The method will close the http.Response Body if it receives an error.
func (ScriptsClient) ListByDatabase ¶
func (client ScriptsClient) ListByDatabase(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result ScriptListResult, err error)
ListByDatabase returns the list of database scripts for given database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.
func (ScriptsClient) ListByDatabasePreparer ¶
func (client ScriptsClient) ListByDatabasePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)
ListByDatabasePreparer prepares the ListByDatabase request.
func (ScriptsClient) ListByDatabaseResponder ¶
func (client ScriptsClient) ListByDatabaseResponder(resp *http.Response) (result ScriptListResult, err error)
ListByDatabaseResponder handles the response to the ListByDatabase request. The method always closes the http.Response Body.
func (ScriptsClient) ListByDatabaseSender ¶
ListByDatabaseSender sends the ListByDatabase request. The method will close the http.Response Body if it receives an error.
func (ScriptsClient) Update ¶
func (client ScriptsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (result ScriptsUpdateFuture, err error)
Update updates a database script. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script. parameters - the Kusto Script parameters contains to the KQL to run.
func (ScriptsClient) UpdatePreparer ¶
func (client ScriptsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (ScriptsClient) UpdateResponder ¶
func (client ScriptsClient) UpdateResponder(resp *http.Response) (result Script, err error)
UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.
func (ScriptsClient) UpdateSender ¶
func (client ScriptsClient) UpdateSender(req *http.Request) (future ScriptsUpdateFuture, err error)
UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.
type ScriptsCreateOrUpdateFuture ¶
type ScriptsCreateOrUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ScriptsClient) (Script, error) }
ScriptsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ScriptsCreateOrUpdateFuture) UnmarshalJSON ¶
func (future *ScriptsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ScriptsDeleteFuture ¶
type ScriptsDeleteFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ScriptsClient) (autorest.Response, error) }
ScriptsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ScriptsDeleteFuture) UnmarshalJSON ¶
func (future *ScriptsDeleteFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type ScriptsUpdateFuture ¶
type ScriptsUpdateFuture struct { azure.FutureAPI // Result returns the result of the asynchronous operation. // If the operation has not completed it will return an error. Result func(ScriptsClient) (Script, error) }
ScriptsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ScriptsUpdateFuture) UnmarshalJSON ¶
func (future *ScriptsUpdateFuture) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaller for CreateFuture.
type SkuDescription ¶
type SkuDescription struct { // ResourceType - READ-ONLY; The resource type ResourceType *string `json:"resourceType,omitempty"` // Name - READ-ONLY; The name of the SKU Name *string `json:"name,omitempty"` // Tier - READ-ONLY; The tier of the SKU Tier *string `json:"tier,omitempty"` // Locations - READ-ONLY; The set of locations that the SKU is available Locations *[]string `json:"locations,omitempty"` // LocationInfo - READ-ONLY; Locations and zones LocationInfo *[]SkuLocationInfoItem `json:"locationInfo,omitempty"` // Restrictions - READ-ONLY; The restrictions because of which SKU cannot be used Restrictions *[]interface{} `json:"restrictions,omitempty"` }
SkuDescription the Kusto SKU description of given resource type
func (SkuDescription) MarshalJSON ¶
func (sd SkuDescription) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for SkuDescription.
type SkuDescriptionList ¶
type SkuDescriptionList struct { autorest.Response `json:"-"` // Value - READ-ONLY; SKU descriptions Value *[]SkuDescription `json:"value,omitempty"` }
SkuDescriptionList the list of the EngagementFabric SKU descriptions
func (SkuDescriptionList) MarshalJSON ¶
func (sdl SkuDescriptionList) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for SkuDescriptionList.
type SkuLocationInfoItem ¶
type SkuLocationInfoItem struct { // Location - The available location of the SKU. Location *string `json:"location,omitempty"` // Zones - The available zone of the SKU. Zones *[]string `json:"zones,omitempty"` }
SkuLocationInfoItem the locations and zones info for SKU.
type State ¶
type State string
State enumerates the values for state.
const ( // StateCreating ... StateCreating State = "Creating" // StateDeleted ... StateDeleted State = "Deleted" // StateDeleting ... StateDeleting State = "Deleting" // StateRunning ... StateRunning State = "Running" // StateStarting ... StateStarting State = "Starting" // StateStopped ... StateStopped State = "Stopped" // StateStopping ... StateStopping State = "Stopping" StateUnavailable State = "Unavailable" // StateUpdating ... StateUpdating State = "Updating" )
func PossibleStateValues ¶
func PossibleStateValues() []State
PossibleStateValues returns an array of possible values for the State const type.
type Status ¶
type Status string
Status enumerates the values for status.
func PossibleStatusValues ¶
func PossibleStatusValues() []Status
PossibleStatusValues returns an array of possible values for the Status const type.
type SystemData ¶
type SystemData struct { // CreatedBy - The identity that created the resource. CreatedBy *string `json:"createdBy,omitempty"` // CreatedByType - The type of identity that created the resource. Possible values include: 'CreatedByTypeUser', 'CreatedByTypeApplication', 'CreatedByTypeManagedIdentity', 'CreatedByTypeKey' CreatedByType CreatedByType `json:"createdByType,omitempty"` // CreatedAt - The timestamp of resource creation (UTC). CreatedAt *date.Time `json:"createdAt,omitempty"` // LastModifiedBy - The identity that last modified the resource. LastModifiedBy *string `json:"lastModifiedBy,omitempty"` // LastModifiedByType - The type of identity that last modified the resource. Possible values include: 'CreatedByTypeUser', 'CreatedByTypeApplication', 'CreatedByTypeManagedIdentity', 'CreatedByTypeKey' LastModifiedByType CreatedByType `json:"lastModifiedByType,omitempty"` // LastModifiedAt - The timestamp of resource last modification (UTC) LastModifiedAt *date.Time `json:"lastModifiedAt,omitempty"` }
SystemData metadata pertaining to creation and last modification of the resource.
type TableLevelSharingProperties ¶
type TableLevelSharingProperties struct { // TablesToInclude - List of tables to include in the follower database TablesToInclude *[]string `json:"tablesToInclude,omitempty"` // TablesToExclude - List of tables to exclude from the follower database TablesToExclude *[]string `json:"tablesToExclude,omitempty"` // ExternalTablesToInclude - List of external tables to include in the follower database ExternalTablesToInclude *[]string `json:"externalTablesToInclude,omitempty"` // ExternalTablesToExclude - List of external tables exclude from the follower database ExternalTablesToExclude *[]string `json:"externalTablesToExclude,omitempty"` // MaterializedViewsToInclude - List of materialized views to include in the follower database MaterializedViewsToInclude *[]string `json:"materializedViewsToInclude,omitempty"` // MaterializedViewsToExclude - List of materialized views exclude from the follower database MaterializedViewsToExclude *[]string `json:"materializedViewsToExclude,omitempty"` }
TableLevelSharingProperties tables that will be included and excluded in the follower database
type TrackedResource ¶
type TrackedResource struct { // Tags - Resource tags. Tags map[string]*string `json:"tags"` // Location - The geo-location where the resource lives Location *string `json:"location,omitempty"` // ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - READ-ONLY; The name of the resource Name *string `json:"name,omitempty"` // Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts" Type *string `json:"type,omitempty"` }
TrackedResource the resource model definition for an Azure Resource Manager tracked top level resource which has 'tags' and a 'location'
func (TrackedResource) MarshalJSON ¶
func (tr TrackedResource) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for TrackedResource.
type TrustedExternalTenant ¶
type TrustedExternalTenant struct { // Value - GUID representing an external tenant. Value *string `json:"value,omitempty"` }
TrustedExternalTenant represents a tenant ID that is trusted by the cluster.
type Type ¶
type Type string
Type enumerates the values for type.
const ( // TypeMicrosoftKustoclustersattachedDatabaseConfigurations ... TypeMicrosoftKustoclustersattachedDatabaseConfigurations Type = "Microsoft.Kusto/clusters/attachedDatabaseConfigurations" // TypeMicrosoftKustoclustersdatabases ... TypeMicrosoftKustoclustersdatabases Type = "Microsoft.Kusto/clusters/databases" )
func PossibleTypeValues ¶
func PossibleTypeValues() []Type
PossibleTypeValues returns an array of possible values for the Type const type.
type VirtualNetworkConfiguration ¶
type VirtualNetworkConfiguration struct { // SubnetID - The subnet resource id. SubnetID *string `json:"subnetId,omitempty"` // EnginePublicIPID - Engine service's public IP address resource id. EnginePublicIPID *string `json:"enginePublicIpId,omitempty"` // DataManagementPublicIPID - Data management's service public IP address resource id. DataManagementPublicIPID *string `json:"dataManagementPublicIpId,omitempty"` }
VirtualNetworkConfiguration a class that contains virtual network definition.