Documentation ¶
Overview ¶
Package kusto implements the Azure ARM Kusto service API version 2019-01-21.
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 AzureCapacity
- type AzureEntityResource
- type AzureResourceSku
- type AzureScaleType
- type AzureSku
- type AzureSkuName
- type BaseClient
- type BasicDataConnection
- type CheckNameResult
- type CloudError
- type CloudErrorBody
- type Cluster
- type ClusterCheckNameRequest
- type ClusterListResult
- type ClusterProperties
- type ClusterUpdate
- type ClustersClient
- 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) 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) 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 ListSkusResult, 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 ListSkusResult, err error)
- func (client ClustersClient) ListSkusSender(req *http.Request) (*http.Response, 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 ClustersStartFuture
- type ClustersStopFuture
- type ClustersUpdateFuture
- 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) MarshalJSON() ([]byte, error)
- type DataConnectionListResult
- type DataConnectionModel
- type DataConnectionValidation
- type DataConnectionValidationListResult
- type DataConnectionValidationResult
- type DataConnectionsClient
- 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 DataConnectionValidationListResult, 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) (*http.Response, 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 DataConnectionsDeleteFuture
- type DataConnectionsUpdateFuture
- type DataFormat
- type Database
- type DatabaseCheckNameRequest
- type DatabaseListResult
- type DatabasePrincipal
- type DatabasePrincipalListRequest
- type DatabasePrincipalListResult
- type DatabasePrincipalRole
- type DatabasePrincipalType
- type DatabaseProperties
- type DatabaseStatistics
- type DatabaseUpdate
- 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 Database, 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 Database, err error)
- func (client DatabasesClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, ...) (*http.Request, error)
- func (client DatabasesClient) GetResponder(resp *http.Response) (result Database, 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 Database, err error)
- func (client DatabasesClient) UpdateSender(req *http.Request) (future DatabasesUpdateFuture, err error)
- type DatabasesCreateOrUpdateFuture
- type DatabasesDeleteFuture
- type DatabasesUpdateFuture
- 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) MarshalJSON() ([]byte, error)
- func (egdc *EventGridDataConnection) UnmarshalJSON(body []byte) error
- 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) MarshalJSON() ([]byte, error)
- func (ehdc *EventHubDataConnection) UnmarshalJSON(body []byte) error
- type Kind
- type ListResourceSkusResult
- type ListSkusResult
- 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 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 ProvisioningState
- type ProxyResource
- type Resource
- type State
- type TrackedResource
- type TrustedExternalTenant
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 AzureCapacity ¶
type AzureCapacity struct { // ScaleType - Scale type. Possible values include: 'Automatic', 'Manual', 'None' 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 - Resource Etag. Etag *string `json:"etag,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts. Type *string `json:"type,omitempty"` }
AzureEntityResource the resource model definition for a Azure Resource Manager resource with an etag.
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 SKU capacity. Capacity *AzureCapacity `json:"capacity,omitempty"` }
AzureResourceSku azure resource SKU definition.
type AzureScaleType ¶
type AzureScaleType string
AzureScaleType enumerates the values for azure scale type.
const ( // Automatic ... Automatic AzureScaleType = "automatic" // Manual ... Manual AzureScaleType = "manual" // None ... None 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: 'D13V2', 'D14V2', 'L8', 'L16', 'D11V2', 'D12V2', 'L4' Name AzureSkuName `json:"name,omitempty"` // Capacity - SKU capacity. Capacity *int32 `json:"capacity,omitempty"` // Tier - SKU tier. Tier *string `json:"tier,omitempty"` }
AzureSku azure SKU definition.
type AzureSkuName ¶
type AzureSkuName string
AzureSkuName enumerates the values for azure sku name.
const ( // D11V2 ... D11V2 AzureSkuName = "D11_v2" // D12V2 ... D12V2 AzureSkuName = "D12_v2" // D13V2 ... D13V2 AzureSkuName = "D13_v2" // D14V2 ... D14V2 AzureSkuName = "D14_v2" // L16 ... L16 AzureSkuName = "L16" // L4 ... L4 AzureSkuName = "L4" // L8 ... L8 AzureSkuName = "L8" )
func PossibleAzureSkuNameValues ¶
func PossibleAzureSkuNameValues() []AzureSkuName
PossibleAzureSkuNameValues returns an array of possible values for the AzureSkuName 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.
type BasicDataConnection ¶
type BasicDataConnection interface { AsEventHubDataConnection() (*EventHubDataConnection, bool) AsEventGridDataConnection() (*EventGridDataConnection, bool) AsDataConnection() (*DataConnection, bool) }
BasicDataConnection class representing an data connection.
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"` }
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"` // ClusterProperties - The cluster properties. *ClusterProperties `json:"properties,omitempty"` // Tags - Resource tags. Tags map[string]*string `json:"tags"` // Location - The geo-location where the resource lives Location *string `json:"location,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- 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 ClusterProperties ¶
type ClusterProperties struct { // State - 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: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed' ProvisioningState ProvisioningState `json:"provisioningState,omitempty"` // URI - The cluster URI. URI *string `json:"uri,omitempty"` // DataIngestionURI - The cluster data ingestion URI. DataIngestionURI *string `json:"dataIngestionUri,omitempty"` // TrustedExternalTenants - The cluster's external tenants. TrustedExternalTenants *[]TrustedExternalTenant `json:"trustedExternalTenants,omitempty"` }
ClusterProperties class representing the Kusto cluster properties.
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"` // ClusterProperties - The cluster properties. *ClusterProperties `json:"properties,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- 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 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.
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. 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) (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.
func (ClustersClient) CreateOrUpdatePreparer ¶
func (client ClustersClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster) (*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) 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) 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 ListSkusResult, 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 ListSkusResult, 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) 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) (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.
func (ClustersClient) UpdatePreparer ¶
func (client ClustersClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterUpdate) (*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 ¶
ClustersCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersCreateOrUpdateFuture) Result ¶
func (future *ClustersCreateOrUpdateFuture) Result(client ClustersClient) (c Cluster, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ClustersDeleteFuture ¶
ClustersDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersDeleteFuture) Result ¶
func (future *ClustersDeleteFuture) Result(client ClustersClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ClustersStartFuture ¶
ClustersStartFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersStartFuture) Result ¶
func (future *ClustersStartFuture) Result(client ClustersClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ClustersStopFuture ¶
ClustersStopFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersStopFuture) Result ¶
func (future *ClustersStopFuture) Result(client ClustersClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type ClustersUpdateFuture ¶
ClustersUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*ClustersUpdateFuture) Result ¶
func (future *ClustersUpdateFuture) Result(client ClustersClient) (c Cluster, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type DataConnection ¶
type DataConnection struct { autorest.Response `json:"-"` // Location - Resource location. Location *string `json:"location,omitempty"` // Kind - Possible values include: 'KindDataConnection', 'KindEventHub', 'KindEventGrid' Kind Kind `json:"kind,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- 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) MarshalJSON ¶
func (dc DataConnection) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for DataConnection.
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.
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 DataConnectionValidationListResult, 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) (*http.Response, 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 ¶
DataConnectionsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DataConnectionsCreateOrUpdateFuture) Result ¶
func (future *DataConnectionsCreateOrUpdateFuture) Result(client DataConnectionsClient) (dcm DataConnectionModel, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type DataConnectionsDeleteFuture ¶
DataConnectionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DataConnectionsDeleteFuture) Result ¶
func (future *DataConnectionsDeleteFuture) Result(client DataConnectionsClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type DataConnectionsUpdateFuture ¶
DataConnectionsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DataConnectionsUpdateFuture) Result ¶
func (future *DataConnectionsUpdateFuture) Result(client DataConnectionsClient) (dcm DataConnectionModel, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type DataFormat ¶
type DataFormat string
DataFormat enumerates the values for data format.
const ( // AVRO ... AVRO DataFormat = "AVRO" // CSV ... CSV DataFormat = "CSV" // JSON ... JSON DataFormat = "JSON" // MULTIJSON ... MULTIJSON DataFormat = "MULTIJSON" // PSV ... PSV DataFormat = "PSV" // RAW ... RAW DataFormat = "RAW" // SCSV ... SCSV DataFormat = "SCSV" // SINGLEJSON ... SINGLEJSON DataFormat = "SINGLEJSON" // SOHSV ... SOHSV DataFormat = "SOHSV" // TSV ... TSV DataFormat = "TSV" // TXT ... TXT DataFormat = "TXT" )
func PossibleDataFormatValues ¶
func PossibleDataFormatValues() []DataFormat
PossibleDataFormatValues returns an array of possible values for the DataFormat const type.
type Database ¶
type Database struct { autorest.Response `json:"-"` // Location - Resource location. Location *string `json:"location,omitempty"` // DatabaseProperties - The database properties. *DatabaseProperties `json:"properties,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts. Type *string `json:"type,omitempty"` }
Database class representing a Kusto database.
func (Database) MarshalJSON ¶
MarshalJSON is the custom marshaler for Database.
func (*Database) UnmarshalJSON ¶
UnmarshalJSON is the custom unmarshaler for Database struct.
type DatabaseCheckNameRequest ¶
type DatabaseCheckNameRequest struct { // Name - Database name. Name *string `json:"name,omitempty"` // Type - The type of resource, Microsoft.Kusto/clusters/databases. Type *string `json:"type,omitempty"` }
DatabaseCheckNameRequest the result returned from a database check name availability request.
type DatabaseListResult ¶
type DatabaseListResult struct { autorest.Response `json:"-"` // Value - The list of Kusto databases. Value *[]Database `json:"value,omitempty"` }
DatabaseListResult the list Kusto databases operation response.
type DatabasePrincipal ¶
type DatabasePrincipal struct { // Role - Database principal role. Possible values include: 'Admin', 'Ingestor', 'Monitor', 'User', 'UnrestrictedViewers', 'Viewer' 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"` }
DatabasePrincipal a class representing database principal entity.
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 DatabasePrincipalRole ¶
type DatabasePrincipalRole string
DatabasePrincipalRole enumerates the values for database principal role.
const ( // Admin ... Admin DatabasePrincipalRole = "Admin" // Ingestor ... Ingestor DatabasePrincipalRole = "Ingestor" // Monitor ... Monitor DatabasePrincipalRole = "Monitor" // UnrestrictedViewers ... UnrestrictedViewers DatabasePrincipalRole = "UnrestrictedViewers" // User ... User DatabasePrincipalRole = "User" // Viewer ... Viewer 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 DatabaseProperties ¶
type DatabaseProperties struct { // ProvisioningState - The provisioned state of the resource. Possible values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed' 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 that 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"` }
DatabaseProperties class representing the Kusto database properties.
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 DatabaseUpdate ¶
type DatabaseUpdate struct { // Location - Resource location. Location *string `json:"location,omitempty"` // DatabaseProperties - The properties of the updated database. *DatabaseProperties `json:"properties,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts. Type *string `json:"type,omitempty"` }
DatabaseUpdate class representing an update to a Kusto database.
func (DatabaseUpdate) MarshalJSON ¶
func (du DatabaseUpdate) MarshalJSON() ([]byte, error)
MarshalJSON is the custom marshaler for DatabaseUpdate.
func (*DatabaseUpdate) UnmarshalJSON ¶
func (du *DatabaseUpdate) UnmarshalJSON(body []byte) error
UnmarshalJSON is the custom unmarshaler for DatabaseUpdate struct.
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.
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, databaseName DatabaseCheckNameRequest) (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. databaseName - the name of the database.
func (DatabasesClient) CheckNameAvailabilityPreparer ¶
func (client DatabasesClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName DatabaseCheckNameRequest) (*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 Database) (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 Database) (*http.Request, error)
CreateOrUpdatePreparer prepares the CreateOrUpdate request.
func (DatabasesClient) CreateOrUpdateResponder ¶
func (client DatabasesClient) CreateOrUpdateResponder(resp *http.Response) (result Database, 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 Database, 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 Database, 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 DatabaseUpdate) (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 DatabaseUpdate) (*http.Request, error)
UpdatePreparer prepares the Update request.
func (DatabasesClient) UpdateResponder ¶
func (client DatabasesClient) UpdateResponder(resp *http.Response) (result Database, 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 ¶
DatabasesCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasesCreateOrUpdateFuture) Result ¶
func (future *DatabasesCreateOrUpdateFuture) Result(client DatabasesClient) (d Database, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type DatabasesDeleteFuture ¶
DatabasesDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasesDeleteFuture) Result ¶
func (future *DatabasesDeleteFuture) Result(client DatabasesClient) (ar autorest.Response, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
type DatabasesUpdateFuture ¶
DatabasesUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.
func (*DatabasesUpdateFuture) Result ¶
func (future *DatabasesUpdateFuture) Result(client DatabasesClient) (d Database, err error)
Result returns the result of the asynchronous operation. If the operation has not completed it will return an error.
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: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO' DataFormat DataFormat `json:"dataFormat,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: 'KindDataConnection', 'KindEventHub', 'KindEventGrid' Kind Kind `json:"kind,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- 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) 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 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: 'MULTIJSON', 'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON', 'AVRO' DataFormat DataFormat `json:"dataFormat,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: 'KindDataConnection', 'KindEventHub', 'KindEventGrid' Kind Kind `json:"kind,omitempty"` // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- 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) 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 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 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 an existing Kusto Cluster.
type ListSkusResult ¶
type ListSkusResult struct { autorest.Response `json:"-"` // Value - The collection of available SKUs for new resources. Value *[]AzureSku `json:"value,omitempty"` }
ListSkusResult list of available SKUs for a new 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(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 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.
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 ProvisioningState ¶
type ProvisioningState string
ProvisioningState enumerates the values for provisioning state.
const ( // Creating ... Creating ProvisioningState = "Creating" // Deleting ... Deleting ProvisioningState = "Deleting" // Failed ... Failed ProvisioningState = "Failed" // Running ... Running ProvisioningState = "Running" // Succeeded ... Succeeded 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 - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts. Type *string `json:"type,omitempty"` }
ProxyResource the resource model definition for a ARM proxy resource. It will have everything other than required location and tags
type Resource ¶
type Resource struct { // ID - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts. Type *string `json:"type,omitempty"` }
Resource ...
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 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 - Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName} ID *string `json:"id,omitempty"` // Name - The name of the resource Name *string `json:"name,omitempty"` // Type - The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts. Type *string `json:"type,omitempty"` }
TrackedResource the resource model definition for a ARM tracked top level resource
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.