kusto

package
v63.1.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 5, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Package kusto implements the Azure ARM Kusto service API version 2022-02-01.

The Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

Index

Constants

View Source 
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 AcceptedAudiences 

type AcceptedAudiences struct {
	// Value - GUID or valid URL representing an accepted audience.
	Value *string `json:"value,omitempty"`
}

AcceptedAudiences represents an accepted audience trusted by the cluster.

type AttachedDatabaseConfiguration 

type AttachedDatabaseConfiguration struct {
	autorest.Response `json:"-"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// AttachedDatabaseConfigurationProperties - The properties of the attached database configuration.
	*AttachedDatabaseConfigurationProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

AttachedDatabaseConfiguration class representing an attached database configuration.

func (AttachedDatabaseConfiguration) MarshalJSON 

func (adc AttachedDatabaseConfiguration) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AttachedDatabaseConfiguration.

func (*AttachedDatabaseConfiguration) UnmarshalJSON 

func (adc *AttachedDatabaseConfiguration) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for AttachedDatabaseConfiguration struct.

type AttachedDatabaseConfigurationListResult 

type AttachedDatabaseConfigurationListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of attached database configurations.
	Value *[]AttachedDatabaseConfiguration `json:"value,omitempty"`
}

AttachedDatabaseConfigurationListResult the list attached database configurations operation response.

type AttachedDatabaseConfigurationProperties 

type AttachedDatabaseConfigurationProperties struct {
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// DatabaseName - The name of the database which you would like to attach, use * if you want to follow all current and future databases.
	DatabaseName *string `json:"databaseName,omitempty"`
	// ClusterResourceID - The resource id of the cluster where the databases you would like to attach reside.
	ClusterResourceID *string `json:"clusterResourceId,omitempty"`
	// AttachedDatabaseNames - READ-ONLY; The list of databases from the clusterResourceId which are currently attached to the cluster.
	AttachedDatabaseNames *[]string `json:"attachedDatabaseNames,omitempty"`
	// DefaultPrincipalsModificationKind - The default principals modification kind. Possible values include: 'DefaultPrincipalsModificationKindUnion', 'DefaultPrincipalsModificationKindReplace', 'DefaultPrincipalsModificationKindNone'
	DefaultPrincipalsModificationKind DefaultPrincipalsModificationKind `json:"defaultPrincipalsModificationKind,omitempty"`
	// TableLevelSharingProperties - Table level sharing specifications
	TableLevelSharingProperties *TableLevelSharingProperties `json:"tableLevelSharingProperties,omitempty"`
}

AttachedDatabaseConfigurationProperties class representing the an attached database configuration properties of kind specific.

func (AttachedDatabaseConfigurationProperties) MarshalJSON 

func (adcp AttachedDatabaseConfigurationProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AttachedDatabaseConfigurationProperties.

type AttachedDatabaseConfigurationsCheckNameRequest 

type AttachedDatabaseConfigurationsCheckNameRequest struct {
	// Name - Attached database resource name.
	Name *string `json:"name,omitempty"`
	// Type - The type of resource, for instance Microsoft.Kusto/clusters/attachedDatabaseConfigurations.
	Type *string `json:"type,omitempty"`
}

AttachedDatabaseConfigurationsCheckNameRequest the result returned from a AttachedDatabaseConfigurations check name availability request.

type AttachedDatabaseConfigurationsClient 

type AttachedDatabaseConfigurationsClient struct {
	BaseClient
}

AttachedDatabaseConfigurationsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewAttachedDatabaseConfigurationsClient 

func NewAttachedDatabaseConfigurationsClient(subscriptionID string) AttachedDatabaseConfigurationsClient

NewAttachedDatabaseConfigurationsClient creates an instance of the AttachedDatabaseConfigurationsClient client.

func NewAttachedDatabaseConfigurationsClientWithBaseURI 

func NewAttachedDatabaseConfigurationsClientWithBaseURI(baseURI string, subscriptionID string) AttachedDatabaseConfigurationsClient

NewAttachedDatabaseConfigurationsClientWithBaseURI creates an instance of the AttachedDatabaseConfigurationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (AttachedDatabaseConfigurationsClient) CheckNameAvailability 

func (client AttachedDatabaseConfigurationsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, resourceName AttachedDatabaseConfigurationsCheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the attached database configuration resource name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. resourceName - the name of the resource.

func (AttachedDatabaseConfigurationsClient) CheckNameAvailabilityPreparer 

func (client AttachedDatabaseConfigurationsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, resourceName AttachedDatabaseConfigurationsCheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (AttachedDatabaseConfigurationsClient) CheckNameAvailabilityResponder 

func (client AttachedDatabaseConfigurationsClient) 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 (AttachedDatabaseConfigurationsClient) CheckNameAvailabilitySender 

func (client AttachedDatabaseConfigurationsClient) 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 (AttachedDatabaseConfigurationsClient) CreateOrUpdate 

func (client AttachedDatabaseConfigurationsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string, parameters AttachedDatabaseConfiguration) (result AttachedDatabaseConfigurationsCreateOrUpdateFuture, err error)

CreateOrUpdate creates or updates an attached database configuration. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. attachedDatabaseConfigurationName - the name of the attached database configuration. parameters - the database parameters supplied to the CreateOrUpdate operation.

func (AttachedDatabaseConfigurationsClient) CreateOrUpdatePreparer 

func (client AttachedDatabaseConfigurationsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string, parameters AttachedDatabaseConfiguration) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (AttachedDatabaseConfigurationsClient) CreateOrUpdateResponder 

func (client AttachedDatabaseConfigurationsClient) CreateOrUpdateResponder(resp *http.Response) (result AttachedDatabaseConfiguration, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (AttachedDatabaseConfigurationsClient) CreateOrUpdateSender 

func (client AttachedDatabaseConfigurationsClient) CreateOrUpdateSender(req *http.Request) (future AttachedDatabaseConfigurationsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (AttachedDatabaseConfigurationsClient) Delete 

func (client AttachedDatabaseConfigurationsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (result AttachedDatabaseConfigurationsDeleteFuture, err error)

Delete deletes the attached database configuration with the given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. attachedDatabaseConfigurationName - the name of the attached database configuration.

func (AttachedDatabaseConfigurationsClient) DeletePreparer 

func (client AttachedDatabaseConfigurationsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (AttachedDatabaseConfigurationsClient) DeleteResponder 

func (client AttachedDatabaseConfigurationsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (AttachedDatabaseConfigurationsClient) DeleteSender 

func (client AttachedDatabaseConfigurationsClient) DeleteSender(req *http.Request) (future AttachedDatabaseConfigurationsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (AttachedDatabaseConfigurationsClient) Get 

func (client AttachedDatabaseConfigurationsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (result AttachedDatabaseConfiguration, err error)

Get returns an attached database configuration. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. attachedDatabaseConfigurationName - the name of the attached database configuration.

func (AttachedDatabaseConfigurationsClient) GetPreparer 

func (client AttachedDatabaseConfigurationsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, attachedDatabaseConfigurationName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (AttachedDatabaseConfigurationsClient) GetResponder 

func (client AttachedDatabaseConfigurationsClient) GetResponder(resp *http.Response) (result AttachedDatabaseConfiguration, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (AttachedDatabaseConfigurationsClient) GetSender 

func (client AttachedDatabaseConfigurationsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (AttachedDatabaseConfigurationsClient) ListByCluster 

func (client AttachedDatabaseConfigurationsClient) ListByCluster(ctx context.Context, resourceGroupName string, clusterName string) (result AttachedDatabaseConfigurationListResult, err error)

ListByCluster returns the list of attached database configurations of the given Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (AttachedDatabaseConfigurationsClient) ListByClusterPreparer 

func (client AttachedDatabaseConfigurationsClient) ListByClusterPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListByClusterPreparer prepares the ListByCluster request.

func (AttachedDatabaseConfigurationsClient) ListByClusterResponder 

func (client AttachedDatabaseConfigurationsClient) ListByClusterResponder(resp *http.Response) (result AttachedDatabaseConfigurationListResult, err error)

ListByClusterResponder handles the response to the ListByCluster request. The method always closes the http.Response Body.

func (AttachedDatabaseConfigurationsClient) ListByClusterSender 

func (client AttachedDatabaseConfigurationsClient) ListByClusterSender(req *http.Request) (*http.Response, error)

ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.

type AttachedDatabaseConfigurationsCreateOrUpdateFuture 

type AttachedDatabaseConfigurationsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(AttachedDatabaseConfigurationsClient) (AttachedDatabaseConfiguration, error)
}

AttachedDatabaseConfigurationsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*AttachedDatabaseConfigurationsCreateOrUpdateFuture) UnmarshalJSON 

func (future *AttachedDatabaseConfigurationsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type AttachedDatabaseConfigurationsDeleteFuture 

type AttachedDatabaseConfigurationsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(AttachedDatabaseConfigurationsClient) (autorest.Response, error)
}

AttachedDatabaseConfigurationsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*AttachedDatabaseConfigurationsDeleteFuture) UnmarshalJSON 

func (future *AttachedDatabaseConfigurationsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type AzureCapacity 

type AzureCapacity struct {
	// ScaleType - Scale type. Possible values include: 'AzureScaleTypeAutomatic', 'AzureScaleTypeManual', 'AzureScaleTypeNone'
	ScaleType AzureScaleType `json:"scaleType,omitempty"`
	// Minimum - Minimum allowed capacity.
	Minimum *int32 `json:"minimum,omitempty"`
	// Maximum - Maximum allowed capacity.
	Maximum *int32 `json:"maximum,omitempty"`
	// Default - The default capacity that would be used.
	Default *int32 `json:"default,omitempty"`
}

AzureCapacity azure capacity definition.

type AzureEntityResource 

type AzureEntityResource struct {
	// Etag - READ-ONLY; Resource Etag.
	Etag *string `json:"etag,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

AzureEntityResource the resource model definition for an Azure Resource Manager resource with an etag.

func (AzureEntityResource) MarshalJSON 

func (aer AzureEntityResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for AzureEntityResource.

type AzureResourceSku 

type AzureResourceSku struct {
	// ResourceType - Resource Namespace and Type.
	ResourceType *string `json:"resourceType,omitempty"`
	// Sku - The SKU details.
	Sku *AzureSku `json:"sku,omitempty"`
	// Capacity - The number of instances of the cluster.
	Capacity *AzureCapacity `json:"capacity,omitempty"`
}

AzureResourceSku azure resource SKU definition.

type AzureScaleType 

type AzureScaleType string

AzureScaleType enumerates the values for azure scale type. 

const (
	// AzureScaleTypeAutomatic ...
	AzureScaleTypeAutomatic AzureScaleType = "automatic"
	// AzureScaleTypeManual ...
	AzureScaleTypeManual AzureScaleType = "manual"
	// AzureScaleTypeNone ...
	AzureScaleTypeNone AzureScaleType = "none"
)

func PossibleAzureScaleTypeValues 

func PossibleAzureScaleTypeValues() []AzureScaleType

PossibleAzureScaleTypeValues returns an array of possible values for the AzureScaleType const type.

type AzureSku 

type AzureSku struct {
	// Name - SKU name. Possible values include: 'AzureSkuNameDevNoSLAStandardD11V2', 'AzureSkuNameDevNoSLAStandardE2aV4', 'AzureSkuNameStandardD11V2', 'AzureSkuNameStandardD12V2', 'AzureSkuNameStandardD13V2', 'AzureSkuNameStandardD14V2', 'AzureSkuNameStandardD32dV4', 'AzureSkuNameStandardD16dV5', 'AzureSkuNameStandardD32dV5', 'AzureSkuNameStandardDS13V21TBPS', 'AzureSkuNameStandardDS13V22TBPS', 'AzureSkuNameStandardDS14V23TBPS', 'AzureSkuNameStandardDS14V24TBPS', 'AzureSkuNameStandardL4s', 'AzureSkuNameStandardL8s', 'AzureSkuNameStandardL16s', 'AzureSkuNameStandardL8sV2', 'AzureSkuNameStandardL16sV2', 'AzureSkuNameStandardE64iV3', 'AzureSkuNameStandardE80idsV4', 'AzureSkuNameStandardE2aV4', 'AzureSkuNameStandardE4aV4', 'AzureSkuNameStandardE8aV4', 'AzureSkuNameStandardE16aV4', 'AzureSkuNameStandardE8asV41TBPS', 'AzureSkuNameStandardE8asV42TBPS', 'AzureSkuNameStandardE16asV43TBPS', 'AzureSkuNameStandardE16asV44TBPS', 'AzureSkuNameStandardE8asV51TBPS', 'AzureSkuNameStandardE8asV52TBPS', 'AzureSkuNameStandardE16asV53TBPS', 'AzureSkuNameStandardE16asV54TBPS', 'AzureSkuNameStandardE2adsV5', 'AzureSkuNameStandardE4adsV5', 'AzureSkuNameStandardE8adsV5', 'AzureSkuNameStandardE16adsV5', 'AzureSkuNameStandardE8sV41TBPS', 'AzureSkuNameStandardE8sV42TBPS', 'AzureSkuNameStandardE16sV43TBPS', 'AzureSkuNameStandardE16sV44TBPS', 'AzureSkuNameStandardE8sV51TBPS', 'AzureSkuNameStandardE8sV52TBPS', 'AzureSkuNameStandardE16sV53TBPS', 'AzureSkuNameStandardE16sV54TBPS'
	Name AzureSkuName `json:"name,omitempty"`
	// Capacity - The number of instances of the cluster.
	Capacity *int32 `json:"capacity,omitempty"`
	// Tier - SKU tier. Possible values include: 'AzureSkuTierBasic', 'AzureSkuTierStandard'
	Tier AzureSkuTier `json:"tier,omitempty"`
}

AzureSku azure SKU definition.

type AzureSkuName 

type AzureSkuName string

AzureSkuName enumerates the values for azure sku name. 

const (
	// AzureSkuNameDevNoSLAStandardD11V2 ...
	AzureSkuNameDevNoSLAStandardD11V2 AzureSkuName = "Dev(No SLA)_Standard_D11_v2"
	// AzureSkuNameDevNoSLAStandardE2aV4 ...
	AzureSkuNameDevNoSLAStandardE2aV4 AzureSkuName = "Dev(No SLA)_Standard_E2a_v4"
	// AzureSkuNameStandardD11V2 ...
	AzureSkuNameStandardD11V2 AzureSkuName = "Standard_D11_v2"
	// AzureSkuNameStandardD12V2 ...
	AzureSkuNameStandardD12V2 AzureSkuName = "Standard_D12_v2"
	// AzureSkuNameStandardD13V2 ...
	AzureSkuNameStandardD13V2 AzureSkuName = "Standard_D13_v2"
	// AzureSkuNameStandardD14V2 ...
	AzureSkuNameStandardD14V2 AzureSkuName = "Standard_D14_v2"
	// AzureSkuNameStandardD16dV5 ...
	AzureSkuNameStandardD16dV5 AzureSkuName = "Standard_D16d_v5"
	// AzureSkuNameStandardD32dV4 ...
	AzureSkuNameStandardD32dV4 AzureSkuName = "Standard_D32d_v4"
	// AzureSkuNameStandardD32dV5 ...
	AzureSkuNameStandardD32dV5 AzureSkuName = "Standard_D32d_v5"
	// AzureSkuNameStandardDS13V21TBPS ...
	AzureSkuNameStandardDS13V21TBPS AzureSkuName = "Standard_DS13_v2+1TB_PS"
	// AzureSkuNameStandardDS13V22TBPS ...
	AzureSkuNameStandardDS13V22TBPS AzureSkuName = "Standard_DS13_v2+2TB_PS"
	// AzureSkuNameStandardDS14V23TBPS ...
	AzureSkuNameStandardDS14V23TBPS AzureSkuName = "Standard_DS14_v2+3TB_PS"
	// AzureSkuNameStandardDS14V24TBPS ...
	AzureSkuNameStandardDS14V24TBPS AzureSkuName = "Standard_DS14_v2+4TB_PS"
	// AzureSkuNameStandardE16adsV5 ...
	AzureSkuNameStandardE16adsV5 AzureSkuName = "Standard_E16ads_v5"
	// AzureSkuNameStandardE16asV43TBPS ...
	AzureSkuNameStandardE16asV43TBPS AzureSkuName = "Standard_E16as_v4+3TB_PS"
	// AzureSkuNameStandardE16asV44TBPS ...
	AzureSkuNameStandardE16asV44TBPS AzureSkuName = "Standard_E16as_v4+4TB_PS"
	// AzureSkuNameStandardE16asV53TBPS ...
	AzureSkuNameStandardE16asV53TBPS AzureSkuName = "Standard_E16as_v5+3TB_PS"
	// AzureSkuNameStandardE16asV54TBPS ...
	AzureSkuNameStandardE16asV54TBPS AzureSkuName = "Standard_E16as_v5+4TB_PS"
	// AzureSkuNameStandardE16aV4 ...
	AzureSkuNameStandardE16aV4 AzureSkuName = "Standard_E16a_v4"
	// AzureSkuNameStandardE16sV43TBPS ...
	AzureSkuNameStandardE16sV43TBPS AzureSkuName = "Standard_E16s_v4+3TB_PS"
	// AzureSkuNameStandardE16sV44TBPS ...
	AzureSkuNameStandardE16sV44TBPS AzureSkuName = "Standard_E16s_v4+4TB_PS"
	// AzureSkuNameStandardE16sV53TBPS ...
	AzureSkuNameStandardE16sV53TBPS AzureSkuName = "Standard_E16s_v5+3TB_PS"
	// AzureSkuNameStandardE16sV54TBPS ...
	AzureSkuNameStandardE16sV54TBPS AzureSkuName = "Standard_E16s_v5+4TB_PS"
	// AzureSkuNameStandardE2adsV5 ...
	AzureSkuNameStandardE2adsV5 AzureSkuName = "Standard_E2ads_v5"
	// AzureSkuNameStandardE2aV4 ...
	AzureSkuNameStandardE2aV4 AzureSkuName = "Standard_E2a_v4"
	// AzureSkuNameStandardE4adsV5 ...
	AzureSkuNameStandardE4adsV5 AzureSkuName = "Standard_E4ads_v5"
	// AzureSkuNameStandardE4aV4 ...
	AzureSkuNameStandardE4aV4 AzureSkuName = "Standard_E4a_v4"
	// AzureSkuNameStandardE64iV3 ...
	AzureSkuNameStandardE64iV3 AzureSkuName = "Standard_E64i_v3"
	// AzureSkuNameStandardE80idsV4 ...
	AzureSkuNameStandardE80idsV4 AzureSkuName = "Standard_E80ids_v4"
	// AzureSkuNameStandardE8adsV5 ...
	AzureSkuNameStandardE8adsV5 AzureSkuName = "Standard_E8ads_v5"
	// AzureSkuNameStandardE8asV41TBPS ...
	AzureSkuNameStandardE8asV41TBPS AzureSkuName = "Standard_E8as_v4+1TB_PS"
	// AzureSkuNameStandardE8asV42TBPS ...
	AzureSkuNameStandardE8asV42TBPS AzureSkuName = "Standard_E8as_v4+2TB_PS"
	// AzureSkuNameStandardE8asV51TBPS ...
	AzureSkuNameStandardE8asV51TBPS AzureSkuName = "Standard_E8as_v5+1TB_PS"
	// AzureSkuNameStandardE8asV52TBPS ...
	AzureSkuNameStandardE8asV52TBPS AzureSkuName = "Standard_E8as_v5+2TB_PS"
	// AzureSkuNameStandardE8aV4 ...
	AzureSkuNameStandardE8aV4 AzureSkuName = "Standard_E8a_v4"
	// AzureSkuNameStandardE8sV41TBPS ...
	AzureSkuNameStandardE8sV41TBPS AzureSkuName = "Standard_E8s_v4+1TB_PS"
	// AzureSkuNameStandardE8sV42TBPS ...
	AzureSkuNameStandardE8sV42TBPS AzureSkuName = "Standard_E8s_v4+2TB_PS"
	// AzureSkuNameStandardE8sV51TBPS ...
	AzureSkuNameStandardE8sV51TBPS AzureSkuName = "Standard_E8s_v5+1TB_PS"
	// AzureSkuNameStandardE8sV52TBPS ...
	AzureSkuNameStandardE8sV52TBPS AzureSkuName = "Standard_E8s_v5+2TB_PS"
	// AzureSkuNameStandardL16s ...
	AzureSkuNameStandardL16s AzureSkuName = "Standard_L16s"
	// AzureSkuNameStandardL16sV2 ...
	AzureSkuNameStandardL16sV2 AzureSkuName = "Standard_L16s_v2"
	// AzureSkuNameStandardL4s ...
	AzureSkuNameStandardL4s AzureSkuName = "Standard_L4s"
	// AzureSkuNameStandardL8s ...
	AzureSkuNameStandardL8s AzureSkuName = "Standard_L8s"
	// AzureSkuNameStandardL8sV2 ...
	AzureSkuNameStandardL8sV2 AzureSkuName = "Standard_L8s_v2"
)

func PossibleAzureSkuNameValues 

func PossibleAzureSkuNameValues() []AzureSkuName

PossibleAzureSkuNameValues returns an array of possible values for the AzureSkuName const type.

type AzureSkuTier 

type AzureSkuTier string

AzureSkuTier enumerates the values for azure sku tier. 

const (
	// AzureSkuTierBasic ...
	AzureSkuTierBasic AzureSkuTier = "Basic"
	// AzureSkuTierStandard ...
	AzureSkuTierStandard AzureSkuTier = "Standard"
)

func PossibleAzureSkuTierValues 

func PossibleAzureSkuTierValues() []AzureSkuTier

PossibleAzureSkuTierValues returns an array of possible values for the AzureSkuTier const type.

type BaseClient 

type BaseClient struct {
	autorest.Client
	BaseURI        string
	SubscriptionID string
}

BaseClient is the base client for Kusto.

func New 

func New(subscriptionID string) BaseClient

New creates an instance of the BaseClient client.

func NewWithBaseURI 

func NewWithBaseURI(baseURI string, subscriptionID string) BaseClient

NewWithBaseURI creates an instance of the BaseClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

type BasicDataConnection 

type BasicDataConnection interface {
	AsEventHubDataConnection() (*EventHubDataConnection, bool)
	AsIotHubDataConnection() (*IotHubDataConnection, bool)
	AsEventGridDataConnection() (*EventGridDataConnection, bool)
	AsDataConnection() (*DataConnection, bool)
}

BasicDataConnection class representing an data connection.

type BasicDatabase 

type BasicDatabase interface {
	AsReadWriteDatabase() (*ReadWriteDatabase, bool)
	AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)
	AsDatabase() (*Database, bool)
}

BasicDatabase class representing a Kusto database.

type BlobStorageEventType 

type BlobStorageEventType string

BlobStorageEventType enumerates the values for blob storage event type. 

const (
	// BlobStorageEventTypeMicrosoftStorageBlobCreated ...
	BlobStorageEventTypeMicrosoftStorageBlobCreated BlobStorageEventType = "Microsoft.Storage.BlobCreated"
	// BlobStorageEventTypeMicrosoftStorageBlobRenamed ...
	BlobStorageEventTypeMicrosoftStorageBlobRenamed BlobStorageEventType = "Microsoft.Storage.BlobRenamed"
)

func PossibleBlobStorageEventTypeValues 

func PossibleBlobStorageEventTypeValues() []BlobStorageEventType

PossibleBlobStorageEventTypeValues returns an array of possible values for the BlobStorageEventType const type.

type CheckNameRequest 

type CheckNameRequest struct {
	// Name - Resource name.
	Name *string `json:"name,omitempty"`
	// Type - The type of resource, for instance Microsoft.Kusto/clusters/databases. Possible values include: 'TypeMicrosoftKustoclustersdatabases', 'TypeMicrosoftKustoclustersattachedDatabaseConfigurations'
	Type Type `json:"type,omitempty"`
}

CheckNameRequest the result returned from a database check name availability request.

type CheckNameResult 

type CheckNameResult struct {
	autorest.Response `json:"-"`
	// NameAvailable - Specifies a Boolean value that indicates if the name is available.
	NameAvailable *bool `json:"nameAvailable,omitempty"`
	// Name - The name that was checked.
	Name *string `json:"name,omitempty"`
	// Message - Message indicating an unavailable name due to a conflict, or a description of the naming rules that are violated.
	Message *string `json:"message,omitempty"`
	// Reason - Message providing the reason why the given name is invalid. Possible values include: 'ReasonInvalid', 'ReasonAlreadyExists'
	Reason Reason `json:"reason,omitempty"`
}

CheckNameResult the result returned from a check name availability request.

type CloudError 

type CloudError struct {
	// Error - An error response from Kusto.
	Error *CloudErrorBody `json:"error,omitempty"`
}

CloudError an error response from Kusto.

type CloudErrorBody 

type CloudErrorBody struct {
	// Code - An identifier for the error. Codes are invariant and are intended to be consumed programmatically.
	Code *string `json:"code,omitempty"`
	// Message - A message describing the error, intended to be suitable for displaying in a user interface.
	Message *string `json:"message,omitempty"`
	// Target - The target of the particular error. For example, the name of the property in error.
	Target *string `json:"target,omitempty"`
	// Details - A list of additional details about the error.
	Details *[]CloudErrorBody `json:"details,omitempty"`
}

CloudErrorBody an error response from Kusto.

type Cluster 

type Cluster struct {
	autorest.Response `json:"-"`
	// Sku - The SKU of the cluster.
	Sku *AzureSku `json:"sku,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// Zones - The availability zones of the cluster.
	Zones *[]string `json:"zones,omitempty"`
	// Identity - The identity of the cluster, if configured.
	Identity *Identity `json:"identity,omitempty"`
	// ClusterProperties - The cluster properties.
	*ClusterProperties `json:"properties,omitempty"`
	// Etag - READ-ONLY; A unique read-only string that changes whenever the resource is updated.
	Etag *string `json:"etag,omitempty"`
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - The geo-location where the resource lives
	Location *string `json:"location,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

Cluster class representing a Kusto cluster.

func (Cluster) MarshalJSON 

func (c Cluster) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Cluster.

func (*Cluster) UnmarshalJSON 

func (c *Cluster) UnmarshalJSON(body []byte) error

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 ClusterNetworkAccessFlag 

type ClusterNetworkAccessFlag string

ClusterNetworkAccessFlag enumerates the values for cluster network access flag. 

const (
	// ClusterNetworkAccessFlagDisabled ...
	ClusterNetworkAccessFlagDisabled ClusterNetworkAccessFlag = "Disabled"
	// ClusterNetworkAccessFlagEnabled ...
	ClusterNetworkAccessFlagEnabled ClusterNetworkAccessFlag = "Enabled"
)

func PossibleClusterNetworkAccessFlagValues 

func PossibleClusterNetworkAccessFlagValues() []ClusterNetworkAccessFlag

PossibleClusterNetworkAccessFlagValues returns an array of possible values for the ClusterNetworkAccessFlag const type.

type ClusterPrincipalAssignment 

type ClusterPrincipalAssignment struct {
	autorest.Response `json:"-"`
	// ClusterPrincipalProperties - The cluster principal.
	*ClusterPrincipalProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

ClusterPrincipalAssignment class representing a cluster principal assignment.

func (ClusterPrincipalAssignment) MarshalJSON 

func (cpa ClusterPrincipalAssignment) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterPrincipalAssignment.

func (*ClusterPrincipalAssignment) UnmarshalJSON 

func (cpa *ClusterPrincipalAssignment) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ClusterPrincipalAssignment struct.

type ClusterPrincipalAssignmentCheckNameRequest 

type ClusterPrincipalAssignmentCheckNameRequest struct {
	// Name - Principal Assignment resource name.
	Name *string `json:"name,omitempty"`
	// Type - The type of resource, Microsoft.Kusto/clusters/principalAssignments.
	Type *string `json:"type,omitempty"`
}

ClusterPrincipalAssignmentCheckNameRequest a principal assignment check name availability request.

type ClusterPrincipalAssignmentListResult 

type ClusterPrincipalAssignmentListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Kusto cluster principal assignments.
	Value *[]ClusterPrincipalAssignment `json:"value,omitempty"`
}

ClusterPrincipalAssignmentListResult the list Kusto cluster principal assignments operation response.

type ClusterPrincipalAssignmentsClient 

type ClusterPrincipalAssignmentsClient struct {
	BaseClient
}

ClusterPrincipalAssignmentsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewClusterPrincipalAssignmentsClient 

func NewClusterPrincipalAssignmentsClient(subscriptionID string) ClusterPrincipalAssignmentsClient

NewClusterPrincipalAssignmentsClient creates an instance of the ClusterPrincipalAssignmentsClient client.

func NewClusterPrincipalAssignmentsClientWithBaseURI 

func NewClusterPrincipalAssignmentsClientWithBaseURI(baseURI string, subscriptionID string) ClusterPrincipalAssignmentsClient

NewClusterPrincipalAssignmentsClientWithBaseURI creates an instance of the ClusterPrincipalAssignmentsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ClusterPrincipalAssignmentsClient) CheckNameAvailability 

func (client ClusterPrincipalAssignmentsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName ClusterPrincipalAssignmentCheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the principal assignment name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the principal assignment.

func (ClusterPrincipalAssignmentsClient) CheckNameAvailabilityPreparer 

func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName ClusterPrincipalAssignmentCheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (ClusterPrincipalAssignmentsClient) CheckNameAvailabilityResponder 

func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (ClusterPrincipalAssignmentsClient) CheckNameAvailabilitySender 

func (client ClusterPrincipalAssignmentsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)

CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.

func (ClusterPrincipalAssignmentsClient) CreateOrUpdate 

func (client ClusterPrincipalAssignmentsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string, parameters ClusterPrincipalAssignment) (result ClusterPrincipalAssignmentsCreateOrUpdateFuture, err error)

CreateOrUpdate create a Kusto cluster principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment. parameters - the Kusto cluster principalAssignment's parameters supplied for the operation.

func (ClusterPrincipalAssignmentsClient) CreateOrUpdatePreparer 

func (client ClusterPrincipalAssignmentsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string, parameters ClusterPrincipalAssignment) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (ClusterPrincipalAssignmentsClient) CreateOrUpdateResponder 

func (client ClusterPrincipalAssignmentsClient) CreateOrUpdateResponder(resp *http.Response) (result ClusterPrincipalAssignment, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (ClusterPrincipalAssignmentsClient) CreateOrUpdateSender 

func (client ClusterPrincipalAssignmentsClient) CreateOrUpdateSender(req *http.Request) (future ClusterPrincipalAssignmentsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (ClusterPrincipalAssignmentsClient) Delete 

func (client ClusterPrincipalAssignmentsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (result ClusterPrincipalAssignmentsDeleteFuture, err error)

Delete deletes a Kusto cluster principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.

func (ClusterPrincipalAssignmentsClient) DeletePreparer 

func (client ClusterPrincipalAssignmentsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ClusterPrincipalAssignmentsClient) DeleteResponder 

func (client ClusterPrincipalAssignmentsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (ClusterPrincipalAssignmentsClient) DeleteSender 

func (client ClusterPrincipalAssignmentsClient) DeleteSender(req *http.Request) (future ClusterPrincipalAssignmentsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ClusterPrincipalAssignmentsClient) Get 

func (client ClusterPrincipalAssignmentsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (result ClusterPrincipalAssignment, err error)

Get gets a Kusto cluster principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.

func (ClusterPrincipalAssignmentsClient) GetPreparer 

func (client ClusterPrincipalAssignmentsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, principalAssignmentName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ClusterPrincipalAssignmentsClient) GetResponder 

func (client ClusterPrincipalAssignmentsClient) GetResponder(resp *http.Response) (result ClusterPrincipalAssignment, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ClusterPrincipalAssignmentsClient) GetSender 

func (client ClusterPrincipalAssignmentsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (ClusterPrincipalAssignmentsClient) List 

func (client ClusterPrincipalAssignmentsClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result ClusterPrincipalAssignmentListResult, err error)

List lists all Kusto cluster principalAssignments. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClusterPrincipalAssignmentsClient) ListPreparer 

func (client ClusterPrincipalAssignmentsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListPreparer prepares the List request.

func (ClusterPrincipalAssignmentsClient) ListResponder 

func (client ClusterPrincipalAssignmentsClient) ListResponder(resp *http.Response) (result ClusterPrincipalAssignmentListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (ClusterPrincipalAssignmentsClient) ListSender 

func (client ClusterPrincipalAssignmentsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type ClusterPrincipalAssignmentsCreateOrUpdateFuture 

type ClusterPrincipalAssignmentsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClusterPrincipalAssignmentsClient) (ClusterPrincipalAssignment, error)
}

ClusterPrincipalAssignmentsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClusterPrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON 

func (future *ClusterPrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClusterPrincipalAssignmentsDeleteFuture 

type ClusterPrincipalAssignmentsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClusterPrincipalAssignmentsClient) (autorest.Response, error)
}

ClusterPrincipalAssignmentsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClusterPrincipalAssignmentsDeleteFuture) UnmarshalJSON 

func (future *ClusterPrincipalAssignmentsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClusterPrincipalProperties 

type ClusterPrincipalProperties struct {
	// PrincipalID - The principal ID assigned to the cluster principal. It can be a user email, application ID, or security group name.
	PrincipalID *string `json:"principalId,omitempty"`
	// Role - Cluster principal role. Possible values include: 'ClusterPrincipalRoleAllDatabasesAdmin', 'ClusterPrincipalRoleAllDatabasesViewer'
	Role ClusterPrincipalRole `json:"role,omitempty"`
	// TenantID - The tenant id of the principal
	TenantID *string `json:"tenantId,omitempty"`
	// PrincipalType - Principal type. Possible values include: 'PrincipalTypeApp', 'PrincipalTypeGroup', 'PrincipalTypeUser'
	PrincipalType PrincipalType `json:"principalType,omitempty"`
	// TenantName - READ-ONLY; The tenant name of the principal
	TenantName *string `json:"tenantName,omitempty"`
	// PrincipalName - READ-ONLY; The principal name
	PrincipalName *string `json:"principalName,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// AadObjectID - READ-ONLY; The service principal object id in AAD (Azure active directory)
	AadObjectID *string `json:"aadObjectId,omitempty"`
}

ClusterPrincipalProperties a class representing cluster principal property.

func (ClusterPrincipalProperties) MarshalJSON 

func (cpp ClusterPrincipalProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterPrincipalProperties.

type ClusterPrincipalRole 

type ClusterPrincipalRole string

ClusterPrincipalRole enumerates the values for cluster principal role. 

const (
	// ClusterPrincipalRoleAllDatabasesAdmin ...
	ClusterPrincipalRoleAllDatabasesAdmin ClusterPrincipalRole = "AllDatabasesAdmin"
	// ClusterPrincipalRoleAllDatabasesViewer ...
	ClusterPrincipalRoleAllDatabasesViewer ClusterPrincipalRole = "AllDatabasesViewer"
)

func PossibleClusterPrincipalRoleValues 

func PossibleClusterPrincipalRoleValues() []ClusterPrincipalRole

PossibleClusterPrincipalRoleValues returns an array of possible values for the ClusterPrincipalRole const type.

type ClusterProperties 

type ClusterProperties struct {
	// State - READ-ONLY; The state of the resource. Possible values include: 'StateCreating', 'StateUnavailable', 'StateRunning', 'StateDeleting', 'StateDeleted', 'StateStopping', 'StateStopped', 'StateStarting', 'StateUpdating'
	State State `json:"state,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// URI - READ-ONLY; The cluster URI.
	URI *string `json:"uri,omitempty"`
	// DataIngestionURI - READ-ONLY; The cluster data ingestion URI.
	DataIngestionURI *string `json:"dataIngestionUri,omitempty"`
	// StateReason - READ-ONLY; The reason for the cluster's current state.
	StateReason *string `json:"stateReason,omitempty"`
	// TrustedExternalTenants - The cluster's external tenants.
	TrustedExternalTenants *[]TrustedExternalTenant `json:"trustedExternalTenants,omitempty"`
	// OptimizedAutoscale - Optimized auto scale definition.
	OptimizedAutoscale *OptimizedAutoscale `json:"optimizedAutoscale,omitempty"`
	// EnableDiskEncryption - A boolean value that indicates if the cluster's disks are encrypted.
	EnableDiskEncryption *bool `json:"enableDiskEncryption,omitempty"`
	// EnableStreamingIngest - A boolean value that indicates if the streaming ingest is enabled.
	EnableStreamingIngest *bool `json:"enableStreamingIngest,omitempty"`
	// VirtualNetworkConfiguration - Virtual network definition.
	VirtualNetworkConfiguration *VirtualNetworkConfiguration `json:"virtualNetworkConfiguration,omitempty"`
	// KeyVaultProperties - KeyVault properties for the cluster encryption.
	KeyVaultProperties *KeyVaultProperties `json:"keyVaultProperties,omitempty"`
	// EnablePurge - A boolean value that indicates if the purge operations are enabled.
	EnablePurge *bool `json:"enablePurge,omitempty"`
	// LanguageExtensions - READ-ONLY; List of the cluster's language extensions.
	LanguageExtensions *LanguageExtensionsList `json:"languageExtensions,omitempty"`
	// EnableDoubleEncryption - A boolean value that indicates if double encryption is enabled.
	EnableDoubleEncryption *bool `json:"enableDoubleEncryption,omitempty"`
	// PublicNetworkAccess - Public network access to the cluster is enabled by default. When disabled, only private endpoint connection to the cluster is allowed. Possible values include: 'PublicNetworkAccessEnabled', 'PublicNetworkAccessDisabled'
	PublicNetworkAccess PublicNetworkAccess `json:"publicNetworkAccess,omitempty"`
	// AllowedIPRangeList - The list of ips in the format of CIDR allowed to connect to the cluster.
	AllowedIPRangeList *[]string `json:"allowedIpRangeList,omitempty"`
	// EngineType - The engine type. Possible values include: 'EngineTypeV2', 'EngineTypeV3'
	EngineType EngineType `json:"engineType,omitempty"`
	// AcceptedAudiences - The cluster's accepted audiences.
	AcceptedAudiences *[]AcceptedAudiences `json:"acceptedAudiences,omitempty"`
	// EnableAutoStop - A boolean value that indicates if the cluster could be automatically stopped (due to lack of data or no activity for many days).
	EnableAutoStop *bool `json:"enableAutoStop,omitempty"`
	// RestrictOutboundNetworkAccess - Whether or not to restrict outbound network access.  Value is optional but if passed in, must be 'Enabled' or 'Disabled'. Possible values include: 'ClusterNetworkAccessFlagEnabled', 'ClusterNetworkAccessFlagDisabled'
	RestrictOutboundNetworkAccess ClusterNetworkAccessFlag `json:"restrictOutboundNetworkAccess,omitempty"`
	// AllowedFqdnList - List of allowed FQDNs(Fully Qualified Domain Name) for egress from Cluster.
	AllowedFqdnList *[]string `json:"allowedFqdnList,omitempty"`
	// PublicIPType - Indicates what public IP type to create - IPv4 (default), or DualStack (both IPv4 and IPv6). Possible values include: 'PublicIPTypeIPv4', 'PublicIPTypeDualStack'
	PublicIPType PublicIPType `json:"publicIPType,omitempty"`
	// VirtualClusterGraduationProperties - Virtual Cluster graduation properties
	VirtualClusterGraduationProperties *string `json:"virtualClusterGraduationProperties,omitempty"`
	// PrivateEndpointConnections - READ-ONLY; A list of private endpoint connections.
	PrivateEndpointConnections *[]PrivateEndpointConnection `json:"privateEndpointConnections,omitempty"`
}

ClusterProperties class representing the Kusto cluster properties.

func (ClusterProperties) MarshalJSON 

func (cp ClusterProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterProperties.

type ClusterUpdate 

type ClusterUpdate struct {
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Sku - The SKU of the cluster.
	Sku *AzureSku `json:"sku,omitempty"`
	// Identity - The identity of the cluster, if configured.
	Identity *Identity `json:"identity,omitempty"`
	// ClusterProperties - The cluster properties.
	*ClusterProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

ClusterUpdate class representing an update to a Kusto cluster.

func (ClusterUpdate) MarshalJSON 

func (cu ClusterUpdate) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ClusterUpdate.

func (*ClusterUpdate) UnmarshalJSON 

func (cu *ClusterUpdate) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ClusterUpdate struct.

type ClustersAddLanguageExtensionsFuture 

type ClustersAddLanguageExtensionsFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersAddLanguageExtensionsFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersAddLanguageExtensionsFuture) UnmarshalJSON 

func (future *ClustersAddLanguageExtensionsFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersClient 

type ClustersClient struct {
	BaseClient
}

ClustersClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewClustersClient 

func NewClustersClient(subscriptionID string) ClustersClient

NewClustersClient creates an instance of the ClustersClient client.

func NewClustersClientWithBaseURI 

func NewClustersClientWithBaseURI(baseURI string, subscriptionID string) ClustersClient

NewClustersClientWithBaseURI creates an instance of the ClustersClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ClustersClient) AddLanguageExtensions 

func (client ClustersClient) AddLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToAdd LanguageExtensionsList) (result ClustersAddLanguageExtensionsFuture, err error)

AddLanguageExtensions add a list of language extensions that can run within KQL queries. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. languageExtensionsToAdd - the language extensions to add.

func (ClustersClient) AddLanguageExtensionsPreparer 

func (client ClustersClient) AddLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToAdd LanguageExtensionsList) (*http.Request, error)

AddLanguageExtensionsPreparer prepares the AddLanguageExtensions request.

func (ClustersClient) AddLanguageExtensionsResponder 

func (client ClustersClient) AddLanguageExtensionsResponder(resp *http.Response) (result autorest.Response, err error)

AddLanguageExtensionsResponder handles the response to the AddLanguageExtensions request. The method always closes the http.Response Body.

func (ClustersClient) AddLanguageExtensionsSender 

func (client ClustersClient) AddLanguageExtensionsSender(req *http.Request) (future ClustersAddLanguageExtensionsFuture, err error)

AddLanguageExtensionsSender sends the AddLanguageExtensions request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) CheckNameAvailability 

func (client ClustersClient) CheckNameAvailability(ctx context.Context, location string, clusterName ClusterCheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the cluster name is valid and is not already in use. Parameters: location - azure location (region) name. clusterName - the name of the cluster.

func (ClustersClient) CheckNameAvailabilityPreparer 

func (client ClustersClient) CheckNameAvailabilityPreparer(ctx context.Context, location string, clusterName ClusterCheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (ClustersClient) CheckNameAvailabilityResponder 

func (client ClustersClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (ClustersClient) CheckNameAvailabilitySender 

func (client ClustersClient) 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 (ClustersClient) CreateOrUpdate 

func (client ClustersClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, ifMatch string, ifNoneMatch string) (result ClustersCreateOrUpdateFuture, err error)

CreateOrUpdate create or update a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. parameters - the Kusto cluster parameters supplied to the CreateOrUpdate operation. ifMatch - the ETag of the cluster. Omit this value to always overwrite the current cluster. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes. ifNoneMatch - set to '*' to allow a new cluster to be created, but to prevent updating an existing cluster. Other values will result in a 412 Pre-condition Failed response.

func (ClustersClient) CreateOrUpdatePreparer 

func (client ClustersClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters Cluster, ifMatch string, ifNoneMatch string) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (ClustersClient) CreateOrUpdateResponder 

func (client ClustersClient) CreateOrUpdateResponder(resp *http.Response) (result Cluster, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (ClustersClient) CreateOrUpdateSender 

func (client ClustersClient) CreateOrUpdateSender(req *http.Request) (future ClustersCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Delete 

func (client ClustersClient) Delete(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDeleteFuture, err error)

Delete deletes a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) DeletePreparer 

func (client ClustersClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ClustersClient) DeleteResponder 

func (client ClustersClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (ClustersClient) DeleteSender 

func (client ClustersClient) DeleteSender(req *http.Request) (future ClustersDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) DetachFollowerDatabases 

func (client ClustersClient) DetachFollowerDatabases(ctx context.Context, resourceGroupName string, clusterName string, followerDatabaseToRemove FollowerDatabaseDefinition) (result ClustersDetachFollowerDatabasesFuture, err error)

DetachFollowerDatabases detaches all followers of a database owned by this cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. followerDatabaseToRemove - the follower databases properties to remove.

func (ClustersClient) DetachFollowerDatabasesPreparer 

func (client ClustersClient) DetachFollowerDatabasesPreparer(ctx context.Context, resourceGroupName string, clusterName string, followerDatabaseToRemove FollowerDatabaseDefinition) (*http.Request, error)

DetachFollowerDatabasesPreparer prepares the DetachFollowerDatabases request.

func (ClustersClient) DetachFollowerDatabasesResponder 

func (client ClustersClient) DetachFollowerDatabasesResponder(resp *http.Response) (result autorest.Response, err error)

DetachFollowerDatabasesResponder handles the response to the DetachFollowerDatabases request. The method always closes the http.Response Body.

func (ClustersClient) DetachFollowerDatabasesSender 

func (client ClustersClient) DetachFollowerDatabasesSender(req *http.Request) (future ClustersDetachFollowerDatabasesFuture, err error)

DetachFollowerDatabasesSender sends the DetachFollowerDatabases request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) DiagnoseVirtualNetwork 

func (client ClustersClient) DiagnoseVirtualNetwork(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersDiagnoseVirtualNetworkFuture, err error)

DiagnoseVirtualNetwork diagnoses network connectivity status for external resources on which the service is dependent on. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) DiagnoseVirtualNetworkPreparer 

func (client ClustersClient) DiagnoseVirtualNetworkPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

DiagnoseVirtualNetworkPreparer prepares the DiagnoseVirtualNetwork request.

func (ClustersClient) DiagnoseVirtualNetworkResponder 

func (client ClustersClient) DiagnoseVirtualNetworkResponder(resp *http.Response) (result DiagnoseVirtualNetworkResult, err error)

DiagnoseVirtualNetworkResponder handles the response to the DiagnoseVirtualNetwork request. The method always closes the http.Response Body.

func (ClustersClient) DiagnoseVirtualNetworkSender 

func (client ClustersClient) DiagnoseVirtualNetworkSender(req *http.Request) (future ClustersDiagnoseVirtualNetworkFuture, err error)

DiagnoseVirtualNetworkSender sends the DiagnoseVirtualNetwork request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Get 

func (client ClustersClient) Get(ctx context.Context, resourceGroupName string, clusterName string) (result Cluster, err error)

Get gets a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) GetPreparer 

func (client ClustersClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ClustersClient) GetResponder 

func (client ClustersClient) GetResponder(resp *http.Response) (result Cluster, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ClustersClient) GetSender 

func (client ClustersClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (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 

func (client ClustersClient) ListByResourceGroupSender(req *http.Request) (*http.Response, error)

ListByResourceGroupSender sends the ListByResourceGroup request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ListFollowerDatabases 

func (client ClustersClient) ListFollowerDatabases(ctx context.Context, resourceGroupName string, clusterName string) (result FollowerDatabaseListResult, err error)

ListFollowerDatabases returns a list of databases that are owned by this cluster and were followed by another cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) ListFollowerDatabasesPreparer 

func (client ClustersClient) ListFollowerDatabasesPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListFollowerDatabasesPreparer prepares the ListFollowerDatabases request.

func (ClustersClient) ListFollowerDatabasesResponder 

func (client ClustersClient) ListFollowerDatabasesResponder(resp *http.Response) (result FollowerDatabaseListResult, err error)

ListFollowerDatabasesResponder handles the response to the ListFollowerDatabases request. The method always closes the http.Response Body.

func (ClustersClient) ListFollowerDatabasesSender 

func (client ClustersClient) ListFollowerDatabasesSender(req *http.Request) (*http.Response, error)

ListFollowerDatabasesSender sends the ListFollowerDatabases request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ListLanguageExtensions 

func (client ClustersClient) ListLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string) (result LanguageExtensionsList, err error)

ListLanguageExtensions returns a list of language extensions that can run within KQL queries. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) ListLanguageExtensionsPreparer 

func (client ClustersClient) ListLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListLanguageExtensionsPreparer prepares the ListLanguageExtensions request.

func (ClustersClient) ListLanguageExtensionsResponder 

func (client ClustersClient) ListLanguageExtensionsResponder(resp *http.Response) (result LanguageExtensionsList, err error)

ListLanguageExtensionsResponder handles the response to the ListLanguageExtensions request. The method always closes the http.Response Body.

func (ClustersClient) ListLanguageExtensionsSender 

func (client ClustersClient) ListLanguageExtensionsSender(req *http.Request) (*http.Response, error)

ListLanguageExtensionsSender sends the ListLanguageExtensions request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ListOutboundNetworkDependenciesEndpoints 

func (client ClustersClient) ListOutboundNetworkDependenciesEndpoints(ctx context.Context, resourceGroupName string, clusterName string) (result OutboundNetworkDependenciesEndpointListResultPage, err error)

ListOutboundNetworkDependenciesEndpoints gets the network endpoints of all outbound dependencies of a Kusto cluster Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) ListOutboundNetworkDependenciesEndpointsComplete 

func (client ClustersClient) ListOutboundNetworkDependenciesEndpointsComplete(ctx context.Context, resourceGroupName string, clusterName string) (result OutboundNetworkDependenciesEndpointListResultIterator, err error)

ListOutboundNetworkDependenciesEndpointsComplete enumerates all values, automatically crossing page boundaries as required.

func (ClustersClient) ListOutboundNetworkDependenciesEndpointsPreparer 

func (client ClustersClient) ListOutboundNetworkDependenciesEndpointsPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListOutboundNetworkDependenciesEndpointsPreparer prepares the ListOutboundNetworkDependenciesEndpoints request.

func (ClustersClient) ListOutboundNetworkDependenciesEndpointsResponder 

func (client ClustersClient) ListOutboundNetworkDependenciesEndpointsResponder(resp *http.Response) (result OutboundNetworkDependenciesEndpointListResult, err error)

ListOutboundNetworkDependenciesEndpointsResponder handles the response to the ListOutboundNetworkDependenciesEndpoints request. The method always closes the http.Response Body.

func (ClustersClient) ListOutboundNetworkDependenciesEndpointsSender 

func (client ClustersClient) ListOutboundNetworkDependenciesEndpointsSender(req *http.Request) (*http.Response, error)

ListOutboundNetworkDependenciesEndpointsSender sends the ListOutboundNetworkDependenciesEndpoints request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ListPreparer 

func (client ClustersClient) ListPreparer(ctx context.Context) (*http.Request, error)

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 

func (client ClustersClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ListSkus 

func (client ClustersClient) ListSkus(ctx context.Context) (result SkuDescriptionList, err error)

ListSkus lists eligible SKUs for Kusto resource provider.

func (ClustersClient) ListSkusByResource 

func (client ClustersClient) ListSkusByResource(ctx context.Context, resourceGroupName string, clusterName string) (result ListResourceSkusResult, err error)

ListSkusByResource returns the SKUs available for the provided resource. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) ListSkusByResourcePreparer 

func (client ClustersClient) ListSkusByResourcePreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListSkusByResourcePreparer prepares the ListSkusByResource request.

func (ClustersClient) ListSkusByResourceResponder 

func (client ClustersClient) ListSkusByResourceResponder(resp *http.Response) (result ListResourceSkusResult, err error)

ListSkusByResourceResponder handles the response to the ListSkusByResource request. The method always closes the http.Response Body.

func (ClustersClient) ListSkusByResourceSender 

func (client ClustersClient) ListSkusByResourceSender(req *http.Request) (*http.Response, error)

ListSkusByResourceSender sends the ListSkusByResource request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) ListSkusPreparer 

func (client ClustersClient) ListSkusPreparer(ctx context.Context) (*http.Request, error)

ListSkusPreparer prepares the ListSkus request.

func (ClustersClient) ListSkusResponder 

func (client ClustersClient) ListSkusResponder(resp *http.Response) (result SkuDescriptionList, err error)

ListSkusResponder handles the response to the ListSkus request. The method always closes the http.Response Body.

func (ClustersClient) ListSkusSender 

func (client ClustersClient) ListSkusSender(req *http.Request) (*http.Response, error)

ListSkusSender sends the ListSkus request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) RemoveLanguageExtensions 

func (client ClustersClient) RemoveLanguageExtensions(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToRemove LanguageExtensionsList) (result ClustersRemoveLanguageExtensionsFuture, err error)

RemoveLanguageExtensions remove a list of language extensions that can run within KQL queries. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. languageExtensionsToRemove - the language extensions to remove.

func (ClustersClient) RemoveLanguageExtensionsPreparer 

func (client ClustersClient) RemoveLanguageExtensionsPreparer(ctx context.Context, resourceGroupName string, clusterName string, languageExtensionsToRemove LanguageExtensionsList) (*http.Request, error)

RemoveLanguageExtensionsPreparer prepares the RemoveLanguageExtensions request.

func (ClustersClient) RemoveLanguageExtensionsResponder 

func (client ClustersClient) RemoveLanguageExtensionsResponder(resp *http.Response) (result autorest.Response, err error)

RemoveLanguageExtensionsResponder handles the response to the RemoveLanguageExtensions request. The method always closes the http.Response Body.

func (ClustersClient) RemoveLanguageExtensionsSender 

func (client ClustersClient) RemoveLanguageExtensionsSender(req *http.Request) (future ClustersRemoveLanguageExtensionsFuture, err error)

RemoveLanguageExtensionsSender sends the RemoveLanguageExtensions request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Start 

func (client ClustersClient) Start(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersStartFuture, err error)

Start starts a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) StartPreparer 

func (client ClustersClient) StartPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

StartPreparer prepares the Start request.

func (ClustersClient) StartResponder 

func (client ClustersClient) StartResponder(resp *http.Response) (result autorest.Response, err error)

StartResponder handles the response to the Start request. The method always closes the http.Response Body.

func (ClustersClient) StartSender 

func (client ClustersClient) StartSender(req *http.Request) (future ClustersStartFuture, err error)

StartSender sends the Start request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Stop 

func (client ClustersClient) Stop(ctx context.Context, resourceGroupName string, clusterName string) (result ClustersStopFuture, err error)

Stop stops a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ClustersClient) StopPreparer 

func (client ClustersClient) StopPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

StopPreparer prepares the Stop request.

func (ClustersClient) StopResponder 

func (client ClustersClient) StopResponder(resp *http.Response) (result autorest.Response, err error)

StopResponder handles the response to the Stop request. The method always closes the http.Response Body.

func (ClustersClient) StopSender 

func (client ClustersClient) StopSender(req *http.Request) (future ClustersStopFuture, err error)

StopSender sends the Stop request. The method will close the http.Response Body if it receives an error.

func (ClustersClient) Update 

func (client ClustersClient) Update(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterUpdate, ifMatch string) (result ClustersUpdateFuture, err error)

Update update a Kusto cluster. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. parameters - the Kusto cluster parameters supplied to the Update operation. ifMatch - the ETag of the cluster. Omit this value to always overwrite the current cluster. Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.

func (ClustersClient) UpdatePreparer 

func (client ClustersClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, parameters ClusterUpdate, ifMatch string) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (ClustersClient) UpdateResponder 

func (client ClustersClient) UpdateResponder(resp *http.Response) (result Cluster, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (ClustersClient) UpdateSender 

func (client ClustersClient) UpdateSender(req *http.Request) (future ClustersUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type ClustersCreateOrUpdateFuture 

type ClustersCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (Cluster, error)
}

ClustersCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersCreateOrUpdateFuture) UnmarshalJSON 

func (future *ClustersCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersDeleteFuture 

type ClustersDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersDeleteFuture) UnmarshalJSON 

func (future *ClustersDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersDetachFollowerDatabasesFuture 

type ClustersDetachFollowerDatabasesFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersDetachFollowerDatabasesFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersDetachFollowerDatabasesFuture) UnmarshalJSON 

func (future *ClustersDetachFollowerDatabasesFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersDiagnoseVirtualNetworkFuture 

type ClustersDiagnoseVirtualNetworkFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (DiagnoseVirtualNetworkResult, error)
}

ClustersDiagnoseVirtualNetworkFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersDiagnoseVirtualNetworkFuture) UnmarshalJSON 

func (future *ClustersDiagnoseVirtualNetworkFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersRemoveLanguageExtensionsFuture 

type ClustersRemoveLanguageExtensionsFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersRemoveLanguageExtensionsFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersRemoveLanguageExtensionsFuture) UnmarshalJSON 

func (future *ClustersRemoveLanguageExtensionsFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersStartFuture 

type ClustersStartFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersStartFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersStartFuture) UnmarshalJSON 

func (future *ClustersStartFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersStopFuture 

type ClustersStopFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (autorest.Response, error)
}

ClustersStopFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersStopFuture) UnmarshalJSON 

func (future *ClustersStopFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ClustersUpdateFuture 

type ClustersUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ClustersClient) (Cluster, error)
}

ClustersUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ClustersUpdateFuture) UnmarshalJSON 

func (future *ClustersUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type Compression 

type Compression string

Compression enumerates the values for compression. 

const (
	// CompressionGZip ...
	CompressionGZip Compression = "GZip"
	// CompressionNone ...
	CompressionNone Compression = "None"
)

func PossibleCompressionValues 

func PossibleCompressionValues() []Compression

PossibleCompressionValues returns an array of possible values for the Compression const type.

type CreatedByType 

type CreatedByType string

CreatedByType enumerates the values for created by type. 

const (
	// CreatedByTypeApplication ...
	CreatedByTypeApplication CreatedByType = "Application"
	// CreatedByTypeKey ...
	CreatedByTypeKey CreatedByType = "Key"
	// CreatedByTypeManagedIdentity ...
	CreatedByTypeManagedIdentity CreatedByType = "ManagedIdentity"
	// CreatedByTypeUser ...
	CreatedByTypeUser CreatedByType = "User"
)

func PossibleCreatedByTypeValues 

func PossibleCreatedByTypeValues() []CreatedByType

PossibleCreatedByTypeValues returns an array of possible values for the CreatedByType const type.

type DataConnection 

type DataConnection struct {
	autorest.Response `json:"-"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid'
	Kind KindBasicDataConnection `json:"kind,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

DataConnection class representing an data connection.

func (DataConnection) AsBasicDataConnection 

func (dc DataConnection) AsBasicDataConnection() (BasicDataConnection, bool)

AsBasicDataConnection is the BasicDataConnection implementation for DataConnection.

func (DataConnection) AsDataConnection 

func (dc DataConnection) AsDataConnection() (*DataConnection, bool)

AsDataConnection is the BasicDataConnection implementation for DataConnection.

func (DataConnection) AsEventGridDataConnection 

func (dc DataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)

AsEventGridDataConnection is the BasicDataConnection implementation for DataConnection.

func (DataConnection) AsEventHubDataConnection 

func (dc DataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)

AsEventHubDataConnection is the BasicDataConnection implementation for DataConnection.

func (DataConnection) AsIotHubDataConnection 

func (dc DataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)

AsIotHubDataConnection is the BasicDataConnection implementation for DataConnection.

func (DataConnection) MarshalJSON 

func (dc DataConnection) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DataConnection.

type DataConnectionCheckNameRequest 

type DataConnectionCheckNameRequest struct {
	// Name - Data Connection name.
	Name *string `json:"name,omitempty"`
	// Type - The type of resource, Microsoft.Kusto/clusters/databases/dataConnections.
	Type *string `json:"type,omitempty"`
}

DataConnectionCheckNameRequest a data connection check name availability request.

type DataConnectionListResult 

type DataConnectionListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Kusto data connections.
	Value *[]BasicDataConnection `json:"value,omitempty"`
}

DataConnectionListResult the list Kusto data connections operation response.

func (*DataConnectionListResult) UnmarshalJSON 

func (dclr *DataConnectionListResult) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for DataConnectionListResult struct.

type DataConnectionModel 

type DataConnectionModel struct {
	autorest.Response `json:"-"`
	Value             BasicDataConnection `json:"value,omitempty"`
}

DataConnectionModel ...

func (*DataConnectionModel) UnmarshalJSON 

func (dcm *DataConnectionModel) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for DataConnectionModel struct.

type DataConnectionValidation 

type DataConnectionValidation struct {
	// DataConnectionName - The name of the data connection.
	DataConnectionName *string `json:"dataConnectionName,omitempty"`
	// Properties - The data connection properties to validate.
	Properties BasicDataConnection `json:"properties,omitempty"`
}

DataConnectionValidation class representing an data connection validation.

func (*DataConnectionValidation) UnmarshalJSON 

func (dcv *DataConnectionValidation) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for DataConnectionValidation struct.

type DataConnectionValidationListResult 

type DataConnectionValidationListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Kusto data connection validation errors.
	Value *[]DataConnectionValidationResult `json:"value,omitempty"`
}

DataConnectionValidationListResult the list Kusto data connection validation result.

type DataConnectionValidationResult 

type DataConnectionValidationResult struct {
	// ErrorMessage - A message which indicates a problem in data connection validation.
	ErrorMessage *string `json:"errorMessage,omitempty"`
}

DataConnectionValidationResult the result returned from a data connection validation request.

type DataConnectionsClient 

type DataConnectionsClient struct {
	BaseClient
}

DataConnectionsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewDataConnectionsClient 

func NewDataConnectionsClient(subscriptionID string) DataConnectionsClient

NewDataConnectionsClient creates an instance of the DataConnectionsClient client.

func NewDataConnectionsClientWithBaseURI 

func NewDataConnectionsClientWithBaseURI(baseURI string, subscriptionID string) DataConnectionsClient

NewDataConnectionsClientWithBaseURI creates an instance of the DataConnectionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (DataConnectionsClient) CheckNameAvailability 

func (client DataConnectionsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName DataConnectionCheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the data connection name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection.

func (DataConnectionsClient) CheckNameAvailabilityPreparer 

func (client DataConnectionsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName DataConnectionCheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (DataConnectionsClient) CheckNameAvailabilityResponder 

func (client DataConnectionsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (DataConnectionsClient) CheckNameAvailabilitySender 

func (client DataConnectionsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)

CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.

func (DataConnectionsClient) CreateOrUpdate 

func (client DataConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (result DataConnectionsCreateOrUpdateFuture, err error)

CreateOrUpdate creates or updates a data connection. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection. parameters - the data connection parameters supplied to the CreateOrUpdate operation.

func (DataConnectionsClient) CreateOrUpdatePreparer 

func (client DataConnectionsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (DataConnectionsClient) CreateOrUpdateResponder 

func (client DataConnectionsClient) CreateOrUpdateResponder(resp *http.Response) (result DataConnectionModel, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (DataConnectionsClient) CreateOrUpdateSender 

func (client DataConnectionsClient) CreateOrUpdateSender(req *http.Request) (future DataConnectionsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (DataConnectionsClient) DataConnectionValidationMethod 

func (client DataConnectionsClient) DataConnectionValidationMethod(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters DataConnectionValidation) (result DataConnectionsDataConnectionValidationMethodFuture, err error)

DataConnectionValidationMethod checks that the data connection parameters are valid. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. parameters - the data connection parameters supplied to the CreateOrUpdate operation.

func (DataConnectionsClient) DataConnectionValidationMethodPreparer 

func (client DataConnectionsClient) DataConnectionValidationMethodPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters DataConnectionValidation) (*http.Request, error)

DataConnectionValidationMethodPreparer prepares the DataConnectionValidationMethod request.

func (DataConnectionsClient) DataConnectionValidationMethodResponder 

func (client DataConnectionsClient) DataConnectionValidationMethodResponder(resp *http.Response) (result DataConnectionValidationListResult, err error)

DataConnectionValidationMethodResponder handles the response to the DataConnectionValidationMethod request. The method always closes the http.Response Body.

func (DataConnectionsClient) DataConnectionValidationMethodSender 

func (client DataConnectionsClient) DataConnectionValidationMethodSender(req *http.Request) (future DataConnectionsDataConnectionValidationMethodFuture, err error)

DataConnectionValidationMethodSender sends the DataConnectionValidationMethod request. The method will close the http.Response Body if it receives an error.

func (DataConnectionsClient) Delete 

func (client DataConnectionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (result DataConnectionsDeleteFuture, err error)

Delete deletes the data connection with the given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection.

func (DataConnectionsClient) DeletePreparer 

func (client DataConnectionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (DataConnectionsClient) DeleteResponder 

func (client DataConnectionsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (DataConnectionsClient) DeleteSender 

func (client DataConnectionsClient) DeleteSender(req *http.Request) (future DataConnectionsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (DataConnectionsClient) Get 

func (client DataConnectionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (result DataConnectionModel, err error)

Get returns a data connection. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection.

func (DataConnectionsClient) GetPreparer 

func (client DataConnectionsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (DataConnectionsClient) GetResponder 

func (client DataConnectionsClient) GetResponder(resp *http.Response) (result DataConnectionModel, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (DataConnectionsClient) GetSender 

func (client DataConnectionsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (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 

func (client DataConnectionsClient) ListByDatabaseSender(req *http.Request) (*http.Response, error)

ListByDatabaseSender sends the ListByDatabase request. The method will close the http.Response Body if it receives an error.

func (DataConnectionsClient) Update 

func (client DataConnectionsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (result DataConnectionsUpdateFuture, err error)

Update updates a data connection. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. dataConnectionName - the name of the data connection. parameters - the data connection parameters supplied to the Update operation.

func (DataConnectionsClient) UpdatePreparer 

func (client DataConnectionsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, dataConnectionName string, parameters BasicDataConnection) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (DataConnectionsClient) UpdateResponder 

func (client DataConnectionsClient) UpdateResponder(resp *http.Response) (result DataConnectionModel, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (DataConnectionsClient) UpdateSender 

func (client DataConnectionsClient) UpdateSender(req *http.Request) (future DataConnectionsUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type DataConnectionsCreateOrUpdateFuture 

type DataConnectionsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DataConnectionsClient) (DataConnectionModel, error)
}

DataConnectionsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DataConnectionsCreateOrUpdateFuture) UnmarshalJSON 

func (future *DataConnectionsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DataConnectionsDataConnectionValidationMethodFuture 

type DataConnectionsDataConnectionValidationMethodFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DataConnectionsClient) (DataConnectionValidationListResult, error)
}

DataConnectionsDataConnectionValidationMethodFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DataConnectionsDataConnectionValidationMethodFuture) UnmarshalJSON 

func (future *DataConnectionsDataConnectionValidationMethodFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DataConnectionsDeleteFuture 

type DataConnectionsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DataConnectionsClient) (autorest.Response, error)
}

DataConnectionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DataConnectionsDeleteFuture) UnmarshalJSON 

func (future *DataConnectionsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DataConnectionsUpdateFuture 

type DataConnectionsUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DataConnectionsClient) (DataConnectionModel, error)
}

DataConnectionsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DataConnectionsUpdateFuture) UnmarshalJSON 

func (future *DataConnectionsUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type Database 

type Database struct {
	autorest.Response `json:"-"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Kind - Possible values include: 'KindDatabase', 'KindReadWrite', 'KindReadOnlyFollowing'
	Kind Kind `json:"kind,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

Database class representing a Kusto database.

func (Database) AsBasicDatabase 

func (d Database) AsBasicDatabase() (BasicDatabase, bool)

AsBasicDatabase is the BasicDatabase implementation for Database.

func (Database) AsDatabase 

func (d Database) AsDatabase() (*Database, bool)

AsDatabase is the BasicDatabase implementation for Database.

func (Database) AsReadOnlyFollowingDatabase 

func (d Database) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)

AsReadOnlyFollowingDatabase is the BasicDatabase implementation for Database.

func (Database) AsReadWriteDatabase 

func (d Database) AsReadWriteDatabase() (*ReadWriteDatabase, bool)

AsReadWriteDatabase is the BasicDatabase implementation for Database.

func (Database) MarshalJSON 

func (d Database) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Database.

type DatabaseListResult 

type DatabaseListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Kusto databases.
	Value *[]BasicDatabase `json:"value,omitempty"`
}

DatabaseListResult the list Kusto databases operation response.

func (*DatabaseListResult) UnmarshalJSON 

func (dlr *DatabaseListResult) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for DatabaseListResult struct.

type DatabaseModel 

type DatabaseModel struct {
	autorest.Response `json:"-"`
	Value             BasicDatabase `json:"value,omitempty"`
}

DatabaseModel ...

func (*DatabaseModel) UnmarshalJSON 

func (dm *DatabaseModel) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for DatabaseModel struct.

type DatabasePrincipal 

type DatabasePrincipal struct {
	// Role - Database principal role. Possible values include: 'DatabasePrincipalRoleAdmin', 'DatabasePrincipalRoleIngestor', 'DatabasePrincipalRoleMonitor', 'DatabasePrincipalRoleUser', 'DatabasePrincipalRoleUnrestrictedViewer', 'DatabasePrincipalRoleViewer'
	Role DatabasePrincipalRole `json:"role,omitempty"`
	// Name - Database principal name.
	Name *string `json:"name,omitempty"`
	// Type - Database principal type. Possible values include: 'DatabasePrincipalTypeApp', 'DatabasePrincipalTypeGroup', 'DatabasePrincipalTypeUser'
	Type DatabasePrincipalType `json:"type,omitempty"`
	// Fqn - Database principal fully qualified name.
	Fqn *string `json:"fqn,omitempty"`
	// Email - Database principal email if exists.
	Email *string `json:"email,omitempty"`
	// AppID - Application id - relevant only for application principal type.
	AppID *string `json:"appId,omitempty"`
	// TenantName - READ-ONLY; The tenant name of the principal
	TenantName *string `json:"tenantName,omitempty"`
}

DatabasePrincipal a class representing database principal entity.

func (DatabasePrincipal) MarshalJSON 

func (dp DatabasePrincipal) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DatabasePrincipal.

type DatabasePrincipalAssignment 

type DatabasePrincipalAssignment struct {
	autorest.Response `json:"-"`
	// DatabasePrincipalProperties - The database principal.
	*DatabasePrincipalProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

DatabasePrincipalAssignment class representing a database principal assignment.

func (DatabasePrincipalAssignment) MarshalJSON 

func (dpa DatabasePrincipalAssignment) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DatabasePrincipalAssignment.

func (*DatabasePrincipalAssignment) UnmarshalJSON 

func (dpa *DatabasePrincipalAssignment) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for DatabasePrincipalAssignment struct.

type DatabasePrincipalAssignmentCheckNameRequest 

type DatabasePrincipalAssignmentCheckNameRequest struct {
	// Name - Principal Assignment resource name.
	Name *string `json:"name,omitempty"`
	// Type - The type of resource, Microsoft.Kusto/clusters/databases/principalAssignments.
	Type *string `json:"type,omitempty"`
}

DatabasePrincipalAssignmentCheckNameRequest a principal assignment check name availability request.

type DatabasePrincipalAssignmentListResult 

type DatabasePrincipalAssignmentListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Kusto database principal assignments.
	Value *[]DatabasePrincipalAssignment `json:"value,omitempty"`
}

DatabasePrincipalAssignmentListResult the list Kusto database principal assignments operation response.

type DatabasePrincipalAssignmentsClient 

type DatabasePrincipalAssignmentsClient struct {
	BaseClient
}

DatabasePrincipalAssignmentsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewDatabasePrincipalAssignmentsClient 

func NewDatabasePrincipalAssignmentsClient(subscriptionID string) DatabasePrincipalAssignmentsClient

NewDatabasePrincipalAssignmentsClient creates an instance of the DatabasePrincipalAssignmentsClient client.

func NewDatabasePrincipalAssignmentsClientWithBaseURI 

func NewDatabasePrincipalAssignmentsClientWithBaseURI(baseURI string, subscriptionID string) DatabasePrincipalAssignmentsClient

NewDatabasePrincipalAssignmentsClientWithBaseURI creates an instance of the DatabasePrincipalAssignmentsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (DatabasePrincipalAssignmentsClient) CheckNameAvailability 

func (client DatabasePrincipalAssignmentsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName DatabasePrincipalAssignmentCheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the database principal assignment is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the resource.

func (DatabasePrincipalAssignmentsClient) CheckNameAvailabilityPreparer 

func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName DatabasePrincipalAssignmentCheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (DatabasePrincipalAssignmentsClient) CheckNameAvailabilityResponder 

func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (DatabasePrincipalAssignmentsClient) CheckNameAvailabilitySender 

func (client DatabasePrincipalAssignmentsClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)

CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.

func (DatabasePrincipalAssignmentsClient) CreateOrUpdate 

func (client DatabasePrincipalAssignmentsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string, parameters DatabasePrincipalAssignment) (result DatabasePrincipalAssignmentsCreateOrUpdateFuture, err error)

CreateOrUpdate creates a Kusto cluster database principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment. parameters - the Kusto principalAssignments parameters supplied for the operation.

func (DatabasePrincipalAssignmentsClient) CreateOrUpdatePreparer 

func (client DatabasePrincipalAssignmentsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string, parameters DatabasePrincipalAssignment) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (DatabasePrincipalAssignmentsClient) CreateOrUpdateResponder 

func (client DatabasePrincipalAssignmentsClient) CreateOrUpdateResponder(resp *http.Response) (result DatabasePrincipalAssignment, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (DatabasePrincipalAssignmentsClient) CreateOrUpdateSender 

func (client DatabasePrincipalAssignmentsClient) CreateOrUpdateSender(req *http.Request) (future DatabasePrincipalAssignmentsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (DatabasePrincipalAssignmentsClient) Delete 

func (client DatabasePrincipalAssignmentsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (result DatabasePrincipalAssignmentsDeleteFuture, err error)

Delete deletes a Kusto principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.

func (DatabasePrincipalAssignmentsClient) DeletePreparer 

func (client DatabasePrincipalAssignmentsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (DatabasePrincipalAssignmentsClient) DeleteResponder 

func (client DatabasePrincipalAssignmentsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (DatabasePrincipalAssignmentsClient) DeleteSender 

func (client DatabasePrincipalAssignmentsClient) DeleteSender(req *http.Request) (future DatabasePrincipalAssignmentsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (DatabasePrincipalAssignmentsClient) Get 

func (client DatabasePrincipalAssignmentsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (result DatabasePrincipalAssignment, err error)

Get gets a Kusto cluster database principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. principalAssignmentName - the name of the Kusto principalAssignment.

func (DatabasePrincipalAssignmentsClient) GetPreparer 

func (client DatabasePrincipalAssignmentsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, principalAssignmentName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (DatabasePrincipalAssignmentsClient) GetResponder 

func (client DatabasePrincipalAssignmentsClient) GetResponder(resp *http.Response) (result DatabasePrincipalAssignment, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (DatabasePrincipalAssignmentsClient) GetSender 

func (client DatabasePrincipalAssignmentsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (DatabasePrincipalAssignmentsClient) List 

func (client DatabasePrincipalAssignmentsClient) List(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DatabasePrincipalAssignmentListResult, err error)

List lists all Kusto cluster database principalAssignments. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.

func (DatabasePrincipalAssignmentsClient) ListPreparer 

func (client DatabasePrincipalAssignmentsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)

ListPreparer prepares the List request.

func (DatabasePrincipalAssignmentsClient) ListResponder 

func (client DatabasePrincipalAssignmentsClient) ListResponder(resp *http.Response) (result DatabasePrincipalAssignmentListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (DatabasePrincipalAssignmentsClient) ListSender 

func (client DatabasePrincipalAssignmentsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type DatabasePrincipalAssignmentsCreateOrUpdateFuture 

type DatabasePrincipalAssignmentsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DatabasePrincipalAssignmentsClient) (DatabasePrincipalAssignment, error)
}

DatabasePrincipalAssignmentsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DatabasePrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON 

func (future *DatabasePrincipalAssignmentsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DatabasePrincipalAssignmentsDeleteFuture 

type DatabasePrincipalAssignmentsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DatabasePrincipalAssignmentsClient) (autorest.Response, error)
}

DatabasePrincipalAssignmentsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DatabasePrincipalAssignmentsDeleteFuture) UnmarshalJSON 

func (future *DatabasePrincipalAssignmentsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DatabasePrincipalListRequest 

type DatabasePrincipalListRequest struct {
	// Value - The list of Kusto database principals.
	Value *[]DatabasePrincipal `json:"value,omitempty"`
}

DatabasePrincipalListRequest the list Kusto database principals operation request.

type DatabasePrincipalListResult 

type DatabasePrincipalListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Kusto database principals.
	Value *[]DatabasePrincipal `json:"value,omitempty"`
}

DatabasePrincipalListResult the list Kusto database principals operation response.

type DatabasePrincipalProperties 

type DatabasePrincipalProperties struct {
	// PrincipalID - The principal ID assigned to the database principal. It can be a user email, application ID, or security group name.
	PrincipalID *string `json:"principalId,omitempty"`
	// Role - Database principal role. Possible values include: 'DatabasePrincipalRoleAdmin', 'DatabasePrincipalRoleIngestor', 'DatabasePrincipalRoleMonitor', 'DatabasePrincipalRoleUser', 'DatabasePrincipalRoleUnrestrictedViewer', 'DatabasePrincipalRoleViewer'
	Role DatabasePrincipalRole `json:"role,omitempty"`
	// TenantID - The tenant id of the principal
	TenantID *string `json:"tenantId,omitempty"`
	// PrincipalType - Principal type. Possible values include: 'PrincipalTypeApp', 'PrincipalTypeGroup', 'PrincipalTypeUser'
	PrincipalType PrincipalType `json:"principalType,omitempty"`
	// TenantName - READ-ONLY; The tenant name of the principal
	TenantName *string `json:"tenantName,omitempty"`
	// PrincipalName - READ-ONLY; The principal name
	PrincipalName *string `json:"principalName,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// AadObjectID - READ-ONLY; The service principal object id in AAD (Azure active directory)
	AadObjectID *string `json:"aadObjectId,omitempty"`
}

DatabasePrincipalProperties a class representing database principal property.

func (DatabasePrincipalProperties) MarshalJSON 

func (dpp DatabasePrincipalProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for DatabasePrincipalProperties.

type DatabasePrincipalRole 

type DatabasePrincipalRole string

DatabasePrincipalRole enumerates the values for database principal role. 

const (
	// DatabasePrincipalRoleAdmin ...
	DatabasePrincipalRoleAdmin DatabasePrincipalRole = "Admin"
	// DatabasePrincipalRoleIngestor ...
	DatabasePrincipalRoleIngestor DatabasePrincipalRole = "Ingestor"
	// DatabasePrincipalRoleMonitor ...
	DatabasePrincipalRoleMonitor DatabasePrincipalRole = "Monitor"
	// DatabasePrincipalRoleUnrestrictedViewer ...
	DatabasePrincipalRoleUnrestrictedViewer DatabasePrincipalRole = "UnrestrictedViewer"
	// DatabasePrincipalRoleUser ...
	DatabasePrincipalRoleUser DatabasePrincipalRole = "User"
	// DatabasePrincipalRoleViewer ...
	DatabasePrincipalRoleViewer DatabasePrincipalRole = "Viewer"
)

func PossibleDatabasePrincipalRoleValues 

func PossibleDatabasePrincipalRoleValues() []DatabasePrincipalRole

PossibleDatabasePrincipalRoleValues returns an array of possible values for the DatabasePrincipalRole const type.

type DatabasePrincipalType 

type DatabasePrincipalType string

DatabasePrincipalType enumerates the values for database principal type. 

const (
	// DatabasePrincipalTypeApp ...
	DatabasePrincipalTypeApp DatabasePrincipalType = "App"
	// DatabasePrincipalTypeGroup ...
	DatabasePrincipalTypeGroup DatabasePrincipalType = "Group"
	// DatabasePrincipalTypeUser ...
	DatabasePrincipalTypeUser DatabasePrincipalType = "User"
)

func PossibleDatabasePrincipalTypeValues 

func PossibleDatabasePrincipalTypeValues() []DatabasePrincipalType

PossibleDatabasePrincipalTypeValues returns an array of possible values for the DatabasePrincipalType const type.

type DatabaseRouting 

type DatabaseRouting string

DatabaseRouting enumerates the values for database routing. 

const (
	// DatabaseRoutingMulti ...
	DatabaseRoutingMulti DatabaseRouting = "Multi"
	// DatabaseRoutingSingle ...
	DatabaseRoutingSingle DatabaseRouting = "Single"
)

func PossibleDatabaseRoutingValues 

func PossibleDatabaseRoutingValues() []DatabaseRouting

PossibleDatabaseRoutingValues returns an array of possible values for the DatabaseRouting const type.

type DatabaseStatistics 

type DatabaseStatistics struct {
	// Size - The database size - the total size of compressed data and index in bytes.
	Size *float64 `json:"size,omitempty"`
}

DatabaseStatistics a class that contains database statistics information.

type DatabasesClient 

type DatabasesClient struct {
	BaseClient
}

DatabasesClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewDatabasesClient 

func NewDatabasesClient(subscriptionID string) DatabasesClient

NewDatabasesClient creates an instance of the DatabasesClient client.

func NewDatabasesClientWithBaseURI 

func NewDatabasesClientWithBaseURI(baseURI string, subscriptionID string) DatabasesClient

NewDatabasesClientWithBaseURI creates an instance of the DatabasesClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (DatabasesClient) AddPrincipals 

func (client DatabasesClient) AddPrincipals(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, databasePrincipalsToAdd DatabasePrincipalListRequest) (result DatabasePrincipalListResult, err error)

AddPrincipals add Database principals permissions. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. databasePrincipalsToAdd - list of database principals to add.

func (DatabasesClient) AddPrincipalsPreparer 

func (client DatabasesClient) AddPrincipalsPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, databasePrincipalsToAdd DatabasePrincipalListRequest) (*http.Request, error)

AddPrincipalsPreparer prepares the AddPrincipals request.

func (DatabasesClient) AddPrincipalsResponder 

func (client DatabasesClient) AddPrincipalsResponder(resp *http.Response) (result DatabasePrincipalListResult, err error)

AddPrincipalsResponder handles the response to the AddPrincipals request. The method always closes the http.Response Body.

func (DatabasesClient) AddPrincipalsSender 

func (client DatabasesClient) AddPrincipalsSender(req *http.Request) (*http.Response, error)

AddPrincipalsSender sends the AddPrincipals request. The method will close the http.Response Body if it receives an error.

func (DatabasesClient) CheckNameAvailability 

func (client DatabasesClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, resourceName CheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the databases resource name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. resourceName - the name of the resource.

func (DatabasesClient) CheckNameAvailabilityPreparer 

func (client DatabasesClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, resourceName CheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (DatabasesClient) CheckNameAvailabilityResponder 

func (client DatabasesClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (DatabasesClient) CheckNameAvailabilitySender 

func (client DatabasesClient) CheckNameAvailabilitySender(req *http.Request) (*http.Response, error)

CheckNameAvailabilitySender sends the CheckNameAvailability request. The method will close the http.Response Body if it receives an error.

func (DatabasesClient) CreateOrUpdate 

func (client DatabasesClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (result DatabasesCreateOrUpdateFuture, err error)

CreateOrUpdate creates or updates a database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. parameters - the database parameters supplied to the CreateOrUpdate operation.

func (DatabasesClient) CreateOrUpdatePreparer 

func (client DatabasesClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (DatabasesClient) CreateOrUpdateResponder 

func (client DatabasesClient) CreateOrUpdateResponder(resp *http.Response) (result DatabaseModel, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (DatabasesClient) CreateOrUpdateSender 

func (client DatabasesClient) CreateOrUpdateSender(req *http.Request) (future DatabasesCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (DatabasesClient) Delete 

func (client DatabasesClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DatabasesDeleteFuture, err error)

Delete deletes the database with the given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.

func (DatabasesClient) DeletePreparer 

func (client DatabasesClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (DatabasesClient) DeleteResponder 

func (client DatabasesClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (DatabasesClient) DeleteSender 

func (client DatabasesClient) DeleteSender(req *http.Request) (future DatabasesDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (DatabasesClient) Get 

func (client DatabasesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result DatabaseModel, err error)

Get returns a database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.

func (DatabasesClient) GetPreparer 

func (client DatabasesClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (DatabasesClient) GetResponder 

func (client DatabasesClient) GetResponder(resp *http.Response) (result DatabaseModel, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (DatabasesClient) GetSender 

func (client DatabasesClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (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 

func (client DatabasesClient) ListByClusterSender(req *http.Request) (*http.Response, error)

ListByClusterSender sends the ListByCluster request. The method will close the http.Response Body if it receives an error.

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 

func (client DatabasesClient) ListPrincipalsSender(req *http.Request) (*http.Response, error)

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 

func (client DatabasesClient) RemovePrincipalsSender(req *http.Request) (*http.Response, error)

RemovePrincipalsSender sends the RemovePrincipals request. The method will close the http.Response Body if it receives an error.

func (DatabasesClient) Update 

func (client DatabasesClient) Update(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (result DatabasesUpdateFuture, err error)

Update updates a database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. parameters - the database parameters supplied to the Update operation.

func (DatabasesClient) UpdatePreparer 

func (client DatabasesClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, parameters BasicDatabase) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (DatabasesClient) UpdateResponder 

func (client DatabasesClient) UpdateResponder(resp *http.Response) (result DatabaseModel, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (DatabasesClient) UpdateSender 

func (client DatabasesClient) UpdateSender(req *http.Request) (future DatabasesUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type DatabasesCreateOrUpdateFuture 

type DatabasesCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DatabasesClient) (DatabaseModel, error)
}

DatabasesCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DatabasesCreateOrUpdateFuture) UnmarshalJSON 

func (future *DatabasesCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DatabasesDeleteFuture 

type DatabasesDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DatabasesClient) (autorest.Response, error)
}

DatabasesDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DatabasesDeleteFuture) UnmarshalJSON 

func (future *DatabasesDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DatabasesUpdateFuture 

type DatabasesUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(DatabasesClient) (DatabaseModel, error)
}

DatabasesUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*DatabasesUpdateFuture) UnmarshalJSON 

func (future *DatabasesUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type DefaultPrincipalsModificationKind 

type DefaultPrincipalsModificationKind string

DefaultPrincipalsModificationKind enumerates the values for default principals modification kind. 

const (
	// DefaultPrincipalsModificationKindNone ...
	DefaultPrincipalsModificationKindNone DefaultPrincipalsModificationKind = "None"
	// DefaultPrincipalsModificationKindReplace ...
	DefaultPrincipalsModificationKindReplace DefaultPrincipalsModificationKind = "Replace"
	// DefaultPrincipalsModificationKindUnion ...
	DefaultPrincipalsModificationKindUnion DefaultPrincipalsModificationKind = "Union"
)

func PossibleDefaultPrincipalsModificationKindValues 

func PossibleDefaultPrincipalsModificationKindValues() []DefaultPrincipalsModificationKind

PossibleDefaultPrincipalsModificationKindValues returns an array of possible values for the DefaultPrincipalsModificationKind const type.

type DiagnoseVirtualNetworkResult 

type DiagnoseVirtualNetworkResult struct {
	autorest.Response `json:"-"`
	// Findings - The list of network connectivity diagnostic finding
	Findings *[]string `json:"findings,omitempty"`
}

DiagnoseVirtualNetworkResult ...

type EndpointDependency 

type EndpointDependency struct {
	// DomainName - The domain name of the dependency.
	DomainName *string `json:"domainName,omitempty"`
	// EndpointDetails - The ports used when connecting to DomainName.
	EndpointDetails *[]EndpointDetail `json:"endpointDetails,omitempty"`
}

EndpointDependency a domain name that a service is reached at, including details of the current connection status.

type EndpointDetail 

type EndpointDetail struct {
	// Port - The port an endpoint is connected to.
	Port *int32 `json:"port,omitempty"`
}

EndpointDetail current TCP connectivity information from the Kusto cluster to a single endpoint.

type EngineType 

type EngineType string

EngineType enumerates the values for engine type. 

const (
	// EngineTypeV2 ...
	EngineTypeV2 EngineType = "V2"
	// EngineTypeV3 ...
	EngineTypeV3 EngineType = "V3"
)

func PossibleEngineTypeValues 

func PossibleEngineTypeValues() []EngineType

PossibleEngineTypeValues returns an array of possible values for the EngineType const type.

type EventGridConnectionProperties 

type EventGridConnectionProperties struct {
	// StorageAccountResourceID - The resource ID of the storage account where the data resides.
	StorageAccountResourceID *string `json:"storageAccountResourceId,omitempty"`
	// EventGridResourceID - The resource ID of the event grid that is subscribed to the storage account events.
	EventGridResourceID *string `json:"eventGridResourceId,omitempty"`
	// EventHubResourceID - The resource ID where the event grid is configured to send events.
	EventHubResourceID *string `json:"eventHubResourceId,omitempty"`
	// ConsumerGroup - The event hub consumer group.
	ConsumerGroup *string `json:"consumerGroup,omitempty"`
	// TableName - The table where the data should be ingested. Optionally the table information can be added to each message.
	TableName *string `json:"tableName,omitempty"`
	// MappingRuleName - The mapping rule to be used to ingest the data. Optionally the mapping information can be added to each message.
	MappingRuleName *string `json:"mappingRuleName,omitempty"`
	// DataFormat - The data format of the message. Optionally the data format can be added to each message. Possible values include: 'EventGridDataFormatMULTIJSON', 'EventGridDataFormatJSON', 'EventGridDataFormatCSV', 'EventGridDataFormatTSV', 'EventGridDataFormatSCSV', 'EventGridDataFormatSOHSV', 'EventGridDataFormatPSV', 'EventGridDataFormatTXT', 'EventGridDataFormatRAW', 'EventGridDataFormatSINGLEJSON', 'EventGridDataFormatAVRO', 'EventGridDataFormatTSVE', 'EventGridDataFormatPARQUET', 'EventGridDataFormatORC', 'EventGridDataFormatAPACHEAVRO', 'EventGridDataFormatW3CLOGFILE'
	DataFormat EventGridDataFormat `json:"dataFormat,omitempty"`
	// IgnoreFirstRecord - A Boolean value that, if set to true, indicates that ingestion should ignore the first record of every file
	IgnoreFirstRecord *bool `json:"ignoreFirstRecord,omitempty"`
	// BlobStorageEventType - The name of blob storage event type to process. Possible values include: 'BlobStorageEventTypeMicrosoftStorageBlobCreated', 'BlobStorageEventTypeMicrosoftStorageBlobRenamed'
	BlobStorageEventType BlobStorageEventType `json:"blobStorageEventType,omitempty"`
	// ManagedIdentityResourceID - The resource ID of a managed identity (system or user assigned) to be used to authenticate with event hub and storage account.
	ManagedIdentityResourceID *string `json:"managedIdentityResourceId,omitempty"`
	// ManagedIdentityObjectID - READ-ONLY; The object ID of managedIdentityResourceId
	ManagedIdentityObjectID *string `json:"managedIdentityObjectId,omitempty"`
	// DatabaseRouting - Indication for database routing information from the data connection, by default only database routing information is allowed. Possible values include: 'DatabaseRoutingSingle', 'DatabaseRoutingMulti'
	DatabaseRouting DatabaseRouting `json:"databaseRouting,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
}

EventGridConnectionProperties class representing the Kusto event grid connection properties.

func (EventGridConnectionProperties) MarshalJSON 

func (egcp EventGridConnectionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventGridConnectionProperties.

type EventGridDataConnection 

type EventGridDataConnection struct {
	// EventGridConnectionProperties - The properties of the Event Grid data connection.
	*EventGridConnectionProperties `json:"properties,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid'
	Kind KindBasicDataConnection `json:"kind,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

EventGridDataConnection class representing an Event Grid data connection.

func (EventGridDataConnection) AsBasicDataConnection 

func (egdc EventGridDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)

AsBasicDataConnection is the BasicDataConnection implementation for EventGridDataConnection.

func (EventGridDataConnection) AsDataConnection 

func (egdc EventGridDataConnection) AsDataConnection() (*DataConnection, bool)

AsDataConnection is the BasicDataConnection implementation for EventGridDataConnection.

func (EventGridDataConnection) AsEventGridDataConnection 

func (egdc EventGridDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)

AsEventGridDataConnection is the BasicDataConnection implementation for EventGridDataConnection.

func (EventGridDataConnection) AsEventHubDataConnection 

func (egdc EventGridDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)

AsEventHubDataConnection is the BasicDataConnection implementation for EventGridDataConnection.

func (EventGridDataConnection) AsIotHubDataConnection 

func (egdc EventGridDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)

AsIotHubDataConnection is the BasicDataConnection implementation for EventGridDataConnection.

func (EventGridDataConnection) MarshalJSON 

func (egdc EventGridDataConnection) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventGridDataConnection.

func (*EventGridDataConnection) UnmarshalJSON 

func (egdc *EventGridDataConnection) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventGridDataConnection struct.

type EventGridDataFormat 

type EventGridDataFormat string

EventGridDataFormat enumerates the values for event grid data format. 

const (
	// EventGridDataFormatAPACHEAVRO ...
	EventGridDataFormatAPACHEAVRO EventGridDataFormat = "APACHEAVRO"
	// EventGridDataFormatAVRO ...
	EventGridDataFormatAVRO EventGridDataFormat = "AVRO"
	// EventGridDataFormatCSV ...
	EventGridDataFormatCSV EventGridDataFormat = "CSV"
	// EventGridDataFormatJSON ...
	EventGridDataFormatJSON EventGridDataFormat = "JSON"
	// EventGridDataFormatMULTIJSON ...
	EventGridDataFormatMULTIJSON EventGridDataFormat = "MULTIJSON"
	// EventGridDataFormatORC ...
	EventGridDataFormatORC EventGridDataFormat = "ORC"
	// EventGridDataFormatPARQUET ...
	EventGridDataFormatPARQUET EventGridDataFormat = "PARQUET"
	// EventGridDataFormatPSV ...
	EventGridDataFormatPSV EventGridDataFormat = "PSV"
	// EventGridDataFormatRAW ...
	EventGridDataFormatRAW EventGridDataFormat = "RAW"
	// EventGridDataFormatSCSV ...
	EventGridDataFormatSCSV EventGridDataFormat = "SCSV"
	// EventGridDataFormatSINGLEJSON ...
	EventGridDataFormatSINGLEJSON EventGridDataFormat = "SINGLEJSON"
	// EventGridDataFormatSOHSV ...
	EventGridDataFormatSOHSV EventGridDataFormat = "SOHSV"
	// EventGridDataFormatTSV ...
	EventGridDataFormatTSV EventGridDataFormat = "TSV"
	// EventGridDataFormatTSVE ...
	EventGridDataFormatTSVE EventGridDataFormat = "TSVE"
	// EventGridDataFormatTXT ...
	EventGridDataFormatTXT EventGridDataFormat = "TXT"
	// EventGridDataFormatW3CLOGFILE ...
	EventGridDataFormatW3CLOGFILE EventGridDataFormat = "W3CLOGFILE"
)

func PossibleEventGridDataFormatValues 

func PossibleEventGridDataFormatValues() []EventGridDataFormat

PossibleEventGridDataFormatValues returns an array of possible values for the EventGridDataFormat const type.

type EventHubConnectionProperties 

type EventHubConnectionProperties struct {
	// EventHubResourceID - The resource ID of the event hub to be used to create a data connection.
	EventHubResourceID *string `json:"eventHubResourceId,omitempty"`
	// ConsumerGroup - The event hub consumer group.
	ConsumerGroup *string `json:"consumerGroup,omitempty"`
	// TableName - The table where the data should be ingested. Optionally the table information can be added to each message.
	TableName *string `json:"tableName,omitempty"`
	// MappingRuleName - The mapping rule to be used to ingest the data. Optionally the mapping information can be added to each message.
	MappingRuleName *string `json:"mappingRuleName,omitempty"`
	// DataFormat - The data format of the message. Optionally the data format can be added to each message. Possible values include: 'EventHubDataFormatMULTIJSON', 'EventHubDataFormatJSON', 'EventHubDataFormatCSV', 'EventHubDataFormatTSV', 'EventHubDataFormatSCSV', 'EventHubDataFormatSOHSV', 'EventHubDataFormatPSV', 'EventHubDataFormatTXT', 'EventHubDataFormatRAW', 'EventHubDataFormatSINGLEJSON', 'EventHubDataFormatAVRO', 'EventHubDataFormatTSVE', 'EventHubDataFormatPARQUET', 'EventHubDataFormatORC', 'EventHubDataFormatAPACHEAVRO', 'EventHubDataFormatW3CLOGFILE'
	DataFormat EventHubDataFormat `json:"dataFormat,omitempty"`
	// EventSystemProperties - System properties of the event hub
	EventSystemProperties *[]string `json:"eventSystemProperties,omitempty"`
	// Compression - The event hub messages compression type. Possible values include: 'CompressionNone', 'CompressionGZip'
	Compression Compression `json:"compression,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// ManagedIdentityResourceID - Empty for non-managed identity based data connection. For system assigned identity, provide cluster resource Id.  For user assigned identity (UAI) provide the UAI resource Id.
	ManagedIdentityResourceID *string `json:"managedIdentityResourceId,omitempty"`
	// ManagedIdentityObjectID - READ-ONLY; The object ID of the managedIdentityResourceId
	ManagedIdentityObjectID *string `json:"managedIdentityObjectId,omitempty"`
	// DatabaseRouting - Indication for database routing information from the data connection, by default only database routing information is allowed. Possible values include: 'DatabaseRoutingSingle', 'DatabaseRoutingMulti'
	DatabaseRouting DatabaseRouting `json:"databaseRouting,omitempty"`
}

EventHubConnectionProperties class representing the Kusto event hub connection properties.

func (EventHubConnectionProperties) MarshalJSON 

func (ehcp EventHubConnectionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventHubConnectionProperties.

type EventHubDataConnection 

type EventHubDataConnection struct {
	// EventHubConnectionProperties - The Event Hub data connection properties to validate.
	*EventHubConnectionProperties `json:"properties,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid'
	Kind KindBasicDataConnection `json:"kind,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

EventHubDataConnection class representing an event hub data connection.

func (EventHubDataConnection) AsBasicDataConnection 

func (ehdc EventHubDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)

AsBasicDataConnection is the BasicDataConnection implementation for EventHubDataConnection.

func (EventHubDataConnection) AsDataConnection 

func (ehdc EventHubDataConnection) AsDataConnection() (*DataConnection, bool)

AsDataConnection is the BasicDataConnection implementation for EventHubDataConnection.

func (EventHubDataConnection) AsEventGridDataConnection 

func (ehdc EventHubDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)

AsEventGridDataConnection is the BasicDataConnection implementation for EventHubDataConnection.

func (EventHubDataConnection) AsEventHubDataConnection 

func (ehdc EventHubDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)

AsEventHubDataConnection is the BasicDataConnection implementation for EventHubDataConnection.

func (EventHubDataConnection) AsIotHubDataConnection 

func (ehdc EventHubDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)

AsIotHubDataConnection is the BasicDataConnection implementation for EventHubDataConnection.

func (EventHubDataConnection) MarshalJSON 

func (ehdc EventHubDataConnection) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for EventHubDataConnection.

func (*EventHubDataConnection) UnmarshalJSON 

func (ehdc *EventHubDataConnection) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for EventHubDataConnection struct.

type EventHubDataFormat 

type EventHubDataFormat string

EventHubDataFormat enumerates the values for event hub data format. 

const (
	// EventHubDataFormatAPACHEAVRO ...
	EventHubDataFormatAPACHEAVRO EventHubDataFormat = "APACHEAVRO"
	// EventHubDataFormatAVRO ...
	EventHubDataFormatAVRO EventHubDataFormat = "AVRO"
	// EventHubDataFormatCSV ...
	EventHubDataFormatCSV EventHubDataFormat = "CSV"
	// EventHubDataFormatJSON ...
	EventHubDataFormatJSON EventHubDataFormat = "JSON"
	// EventHubDataFormatMULTIJSON ...
	EventHubDataFormatMULTIJSON EventHubDataFormat = "MULTIJSON"
	// EventHubDataFormatORC ...
	EventHubDataFormatORC EventHubDataFormat = "ORC"
	// EventHubDataFormatPARQUET ...
	EventHubDataFormatPARQUET EventHubDataFormat = "PARQUET"
	// EventHubDataFormatPSV ...
	EventHubDataFormatPSV EventHubDataFormat = "PSV"
	// EventHubDataFormatRAW ...
	EventHubDataFormatRAW EventHubDataFormat = "RAW"
	// EventHubDataFormatSCSV ...
	EventHubDataFormatSCSV EventHubDataFormat = "SCSV"
	// EventHubDataFormatSINGLEJSON ...
	EventHubDataFormatSINGLEJSON EventHubDataFormat = "SINGLEJSON"
	// EventHubDataFormatSOHSV ...
	EventHubDataFormatSOHSV EventHubDataFormat = "SOHSV"
	// EventHubDataFormatTSV ...
	EventHubDataFormatTSV EventHubDataFormat = "TSV"
	// EventHubDataFormatTSVE ...
	EventHubDataFormatTSVE EventHubDataFormat = "TSVE"
	// EventHubDataFormatTXT ...
	EventHubDataFormatTXT EventHubDataFormat = "TXT"
	// EventHubDataFormatW3CLOGFILE ...
	EventHubDataFormatW3CLOGFILE EventHubDataFormat = "W3CLOGFILE"
)

func PossibleEventHubDataFormatValues 

func PossibleEventHubDataFormatValues() []EventHubDataFormat

PossibleEventHubDataFormatValues returns an array of possible values for the EventHubDataFormat const type.

type FollowerDatabaseDefinition 

type FollowerDatabaseDefinition struct {
	// ClusterResourceID - Resource id of the cluster that follows a database owned by this cluster.
	ClusterResourceID *string `json:"clusterResourceId,omitempty"`
	// AttachedDatabaseConfigurationName - Resource name of the attached database configuration in the follower cluster.
	AttachedDatabaseConfigurationName *string `json:"attachedDatabaseConfigurationName,omitempty"`
	// DatabaseName - READ-ONLY; The database name owned by this cluster that was followed. * in case following all databases.
	DatabaseName *string `json:"databaseName,omitempty"`
}

FollowerDatabaseDefinition a class representing follower database request.

func (FollowerDatabaseDefinition) MarshalJSON 

func (fdd FollowerDatabaseDefinition) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for FollowerDatabaseDefinition.

type FollowerDatabaseListResult 

type FollowerDatabaseListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of follower database result.
	Value *[]FollowerDatabaseDefinition `json:"value,omitempty"`
}

FollowerDatabaseListResult the list Kusto database principals operation response.

type Identity 

type Identity struct {
	// PrincipalID - READ-ONLY; The principal ID of resource identity.
	PrincipalID *string `json:"principalId,omitempty"`
	// TenantID - READ-ONLY; The tenant ID of resource.
	TenantID *string `json:"tenantId,omitempty"`
	// Type - The type of managed identity used. The type 'SystemAssigned, UserAssigned' includes both an implicitly created identity and a set of user-assigned identities. The type 'None' will remove all identities. Possible values include: 'IdentityTypeNone', 'IdentityTypeSystemAssigned', 'IdentityTypeUserAssigned', 'IdentityTypeSystemAssignedUserAssigned'
	Type IdentityType `json:"type,omitempty"`
	// UserAssignedIdentities - The list of user identities associated with the Kusto cluster. The user identity dictionary key references will be ARM resource ids in the form: '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ManagedIdentity/userAssignedIdentities/{identityName}'.
	UserAssignedIdentities map[string]*IdentityUserAssignedIdentitiesValue `json:"userAssignedIdentities"`
}

Identity identity for the resource.

func (Identity) MarshalJSON 

func (i Identity) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Identity.

type IdentityType 

type IdentityType string

IdentityType enumerates the values for identity type. 

const (
	// IdentityTypeNone ...
	IdentityTypeNone IdentityType = "None"
	// IdentityTypeSystemAssigned ...
	IdentityTypeSystemAssigned IdentityType = "SystemAssigned"
	// IdentityTypeSystemAssignedUserAssigned ...
	IdentityTypeSystemAssignedUserAssigned IdentityType = "SystemAssigned, UserAssigned"
	// IdentityTypeUserAssigned ...
	IdentityTypeUserAssigned IdentityType = "UserAssigned"
)

func PossibleIdentityTypeValues 

func PossibleIdentityTypeValues() []IdentityType

PossibleIdentityTypeValues returns an array of possible values for the IdentityType const type.

type IdentityUserAssignedIdentitiesValue 

type IdentityUserAssignedIdentitiesValue struct {
	// PrincipalID - READ-ONLY; The principal id of user assigned identity.
	PrincipalID *string `json:"principalId,omitempty"`
	// ClientID - READ-ONLY; The client id of user assigned identity.
	ClientID *string `json:"clientId,omitempty"`
}

IdentityUserAssignedIdentitiesValue ...

func (IdentityUserAssignedIdentitiesValue) MarshalJSON 

func (iAiv IdentityUserAssignedIdentitiesValue) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for IdentityUserAssignedIdentitiesValue.

type IotHubConnectionProperties 

type IotHubConnectionProperties struct {
	// IotHubResourceID - The resource ID of the Iot hub to be used to create a data connection.
	IotHubResourceID *string `json:"iotHubResourceId,omitempty"`
	// ConsumerGroup - The iot hub consumer group.
	ConsumerGroup *string `json:"consumerGroup,omitempty"`
	// TableName - The table where the data should be ingested. Optionally the table information can be added to each message.
	TableName *string `json:"tableName,omitempty"`
	// MappingRuleName - The mapping rule to be used to ingest the data. Optionally the mapping information can be added to each message.
	MappingRuleName *string `json:"mappingRuleName,omitempty"`
	// DataFormat - The data format of the message. Optionally the data format can be added to each message. Possible values include: 'IotHubDataFormatMULTIJSON', 'IotHubDataFormatJSON', 'IotHubDataFormatCSV', 'IotHubDataFormatTSV', 'IotHubDataFormatSCSV', 'IotHubDataFormatSOHSV', 'IotHubDataFormatPSV', 'IotHubDataFormatTXT', 'IotHubDataFormatRAW', 'IotHubDataFormatSINGLEJSON', 'IotHubDataFormatAVRO', 'IotHubDataFormatTSVE', 'IotHubDataFormatPARQUET', 'IotHubDataFormatORC', 'IotHubDataFormatAPACHEAVRO', 'IotHubDataFormatW3CLOGFILE'
	DataFormat IotHubDataFormat `json:"dataFormat,omitempty"`
	// EventSystemProperties - System properties of the iot hub
	EventSystemProperties *[]string `json:"eventSystemProperties,omitempty"`
	// SharedAccessPolicyName - The name of the share access policy
	SharedAccessPolicyName *string `json:"sharedAccessPolicyName,omitempty"`
	// DatabaseRouting - Indication for database routing information from the data connection, by default only database routing information is allowed. Possible values include: 'DatabaseRoutingSingle', 'DatabaseRoutingMulti'
	DatabaseRouting DatabaseRouting `json:"databaseRouting,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
}

IotHubConnectionProperties class representing the Kusto Iot hub connection properties.

func (IotHubConnectionProperties) MarshalJSON 

func (ihcp IotHubConnectionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for IotHubConnectionProperties.

type IotHubDataConnection 

type IotHubDataConnection struct {
	// IotHubConnectionProperties - The Iot Hub data connection properties.
	*IotHubConnectionProperties `json:"properties,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Kind - Possible values include: 'KindBasicDataConnectionKindDataConnection', 'KindBasicDataConnectionKindEventHub', 'KindBasicDataConnectionKindIotHub', 'KindBasicDataConnectionKindEventGrid'
	Kind KindBasicDataConnection `json:"kind,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

IotHubDataConnection class representing an iot hub data connection.

func (IotHubDataConnection) AsBasicDataConnection 

func (ihdc IotHubDataConnection) AsBasicDataConnection() (BasicDataConnection, bool)

AsBasicDataConnection is the BasicDataConnection implementation for IotHubDataConnection.

func (IotHubDataConnection) AsDataConnection 

func (ihdc IotHubDataConnection) AsDataConnection() (*DataConnection, bool)

AsDataConnection is the BasicDataConnection implementation for IotHubDataConnection.

func (IotHubDataConnection) AsEventGridDataConnection 

func (ihdc IotHubDataConnection) AsEventGridDataConnection() (*EventGridDataConnection, bool)

AsEventGridDataConnection is the BasicDataConnection implementation for IotHubDataConnection.

func (IotHubDataConnection) AsEventHubDataConnection 

func (ihdc IotHubDataConnection) AsEventHubDataConnection() (*EventHubDataConnection, bool)

AsEventHubDataConnection is the BasicDataConnection implementation for IotHubDataConnection.

func (IotHubDataConnection) AsIotHubDataConnection 

func (ihdc IotHubDataConnection) AsIotHubDataConnection() (*IotHubDataConnection, bool)

AsIotHubDataConnection is the BasicDataConnection implementation for IotHubDataConnection.

func (IotHubDataConnection) MarshalJSON 

func (ihdc IotHubDataConnection) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for IotHubDataConnection.

func (*IotHubDataConnection) UnmarshalJSON 

func (ihdc *IotHubDataConnection) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for IotHubDataConnection struct.

type IotHubDataFormat 

type IotHubDataFormat string

IotHubDataFormat enumerates the values for iot hub data format. 

const (
	// IotHubDataFormatAPACHEAVRO ...
	IotHubDataFormatAPACHEAVRO IotHubDataFormat = "APACHEAVRO"
	// IotHubDataFormatAVRO ...
	IotHubDataFormatAVRO IotHubDataFormat = "AVRO"
	// IotHubDataFormatCSV ...
	IotHubDataFormatCSV IotHubDataFormat = "CSV"
	// IotHubDataFormatJSON ...
	IotHubDataFormatJSON IotHubDataFormat = "JSON"
	// IotHubDataFormatMULTIJSON ...
	IotHubDataFormatMULTIJSON IotHubDataFormat = "MULTIJSON"
	// IotHubDataFormatORC ...
	IotHubDataFormatORC IotHubDataFormat = "ORC"
	// IotHubDataFormatPARQUET ...
	IotHubDataFormatPARQUET IotHubDataFormat = "PARQUET"
	// IotHubDataFormatPSV ...
	IotHubDataFormatPSV IotHubDataFormat = "PSV"
	// IotHubDataFormatRAW ...
	IotHubDataFormatRAW IotHubDataFormat = "RAW"
	// IotHubDataFormatSCSV ...
	IotHubDataFormatSCSV IotHubDataFormat = "SCSV"
	// IotHubDataFormatSINGLEJSON ...
	IotHubDataFormatSINGLEJSON IotHubDataFormat = "SINGLEJSON"
	// IotHubDataFormatSOHSV ...
	IotHubDataFormatSOHSV IotHubDataFormat = "SOHSV"
	// IotHubDataFormatTSV ...
	IotHubDataFormatTSV IotHubDataFormat = "TSV"
	// IotHubDataFormatTSVE ...
	IotHubDataFormatTSVE IotHubDataFormat = "TSVE"
	// IotHubDataFormatTXT ...
	IotHubDataFormatTXT IotHubDataFormat = "TXT"
	// IotHubDataFormatW3CLOGFILE ...
	IotHubDataFormatW3CLOGFILE IotHubDataFormat = "W3CLOGFILE"
)

func PossibleIotHubDataFormatValues 

func PossibleIotHubDataFormatValues() []IotHubDataFormat

PossibleIotHubDataFormatValues returns an array of possible values for the IotHubDataFormat const type.

type KeyVaultProperties 

type KeyVaultProperties struct {
	// KeyName - The name of the key vault key.
	KeyName *string `json:"keyName,omitempty"`
	// KeyVersion - The version of the key vault key.
	KeyVersion *string `json:"keyVersion,omitempty"`
	// KeyVaultURI - The Uri of the key vault.
	KeyVaultURI *string `json:"keyVaultUri,omitempty"`
	// UserIdentity - The user assigned identity (ARM resource id) that has access to the key.
	UserIdentity *string `json:"userIdentity,omitempty"`
}

KeyVaultProperties properties of the key vault.

type Kind 

type Kind string

Kind enumerates the values for kind. 

const (
	// KindDatabase ...
	KindDatabase Kind = "Database"
	// KindReadOnlyFollowing ...
	KindReadOnlyFollowing Kind = "ReadOnlyFollowing"
	// KindReadWrite ...
	KindReadWrite Kind = "ReadWrite"
)

func PossibleKindValues 

func PossibleKindValues() []Kind

PossibleKindValues returns an array of possible values for the Kind const type.

type KindBasicDataConnection 

type KindBasicDataConnection string

KindBasicDataConnection enumerates the values for kind basic data connection. 

const (
	// KindBasicDataConnectionKindDataConnection ...
	KindBasicDataConnectionKindDataConnection KindBasicDataConnection = "DataConnection"
	// KindBasicDataConnectionKindEventGrid ...
	KindBasicDataConnectionKindEventGrid KindBasicDataConnection = "EventGrid"
	// KindBasicDataConnectionKindEventHub ...
	KindBasicDataConnectionKindEventHub KindBasicDataConnection = "EventHub"
	// KindBasicDataConnectionKindIotHub ...
	KindBasicDataConnectionKindIotHub KindBasicDataConnection = "IotHub"
)

func PossibleKindBasicDataConnectionValues 

func PossibleKindBasicDataConnectionValues() []KindBasicDataConnection

PossibleKindBasicDataConnectionValues returns an array of possible values for the KindBasicDataConnection const type.

type LanguageExtension 

type LanguageExtension struct {
	// LanguageExtensionName - The language extension name. Possible values include: 'LanguageExtensionNamePYTHON', 'LanguageExtensionNameR'
	LanguageExtensionName LanguageExtensionName `json:"languageExtensionName,omitempty"`
}

LanguageExtension the language extension object.

type LanguageExtensionName 

type LanguageExtensionName string

LanguageExtensionName enumerates the values for language extension name. 

const (
	// LanguageExtensionNamePYTHON ...
	LanguageExtensionNamePYTHON LanguageExtensionName = "PYTHON"
	// LanguageExtensionNameR ...
	LanguageExtensionNameR LanguageExtensionName = "R"
)

func PossibleLanguageExtensionNameValues 

func PossibleLanguageExtensionNameValues() []LanguageExtensionName

PossibleLanguageExtensionNameValues returns an array of possible values for the LanguageExtensionName const type.

type LanguageExtensionsList 

type LanguageExtensionsList struct {
	autorest.Response `json:"-"`
	// Value - The list of language extensions.
	Value *[]LanguageExtension `json:"value,omitempty"`
}

LanguageExtensionsList the list of language extension objects.

type ListResourceSkusResult 

type ListResourceSkusResult struct {
	autorest.Response `json:"-"`
	// Value - The collection of available SKUs for an existing resource.
	Value *[]AzureResourceSku `json:"value,omitempty"`
}

ListResourceSkusResult list of available SKUs for a Kusto Cluster.

type ManagedPrivateEndpoint 

type ManagedPrivateEndpoint struct {
	autorest.Response `json:"-"`
	// ManagedPrivateEndpointProperties - A managed private endpoint.
	*ManagedPrivateEndpointProperties `json:"properties,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

ManagedPrivateEndpoint class representing a managed private endpoint.

func (ManagedPrivateEndpoint) MarshalJSON 

func (mpe ManagedPrivateEndpoint) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ManagedPrivateEndpoint.

func (*ManagedPrivateEndpoint) UnmarshalJSON 

func (mpe *ManagedPrivateEndpoint) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ManagedPrivateEndpoint struct.

type ManagedPrivateEndpointListResult 

type ManagedPrivateEndpointListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of managed private endpoints.
	Value *[]ManagedPrivateEndpoint `json:"value,omitempty"`
}

ManagedPrivateEndpointListResult the list managed private endpoints operation response.

type ManagedPrivateEndpointProperties 

type ManagedPrivateEndpointProperties struct {
	// PrivateLinkResourceID - The ARM resource ID of the resource for which the managed private endpoint is created.
	PrivateLinkResourceID *string `json:"privateLinkResourceId,omitempty"`
	// PrivateLinkResourceRegion - The region of the resource to which the managed private endpoint is created.
	PrivateLinkResourceRegion *string `json:"privateLinkResourceRegion,omitempty"`
	// GroupID - The groupId in which the managed private endpoint is created.
	GroupID *string `json:"groupId,omitempty"`
	// RequestMessage - The user request message.
	RequestMessage *string `json:"requestMessage,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
}

ManagedPrivateEndpointProperties a class representing the properties of a managed private endpoint object.

func (ManagedPrivateEndpointProperties) MarshalJSON 

func (mpep ManagedPrivateEndpointProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ManagedPrivateEndpointProperties.

type ManagedPrivateEndpointsCheckNameRequest 

type ManagedPrivateEndpointsCheckNameRequest struct {
	// Name - Managed private endpoint resource name.
	Name *string `json:"name,omitempty"`
	// Type - The type of resource, for instance Microsoft.Kusto/clusters/managedPrivateEndpoints.
	Type *string `json:"type,omitempty"`
}

ManagedPrivateEndpointsCheckNameRequest the result returned from a managedPrivateEndpoints check name availability request.

type ManagedPrivateEndpointsClient 

type ManagedPrivateEndpointsClient struct {
	BaseClient
}

ManagedPrivateEndpointsClient 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 NewManagedPrivateEndpointsClient 

func NewManagedPrivateEndpointsClient(subscriptionID string) ManagedPrivateEndpointsClient

NewManagedPrivateEndpointsClient creates an instance of the ManagedPrivateEndpointsClient client.

func NewManagedPrivateEndpointsClientWithBaseURI 

func NewManagedPrivateEndpointsClientWithBaseURI(baseURI string, subscriptionID string) ManagedPrivateEndpointsClient

NewManagedPrivateEndpointsClientWithBaseURI creates an instance of the ManagedPrivateEndpointsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ManagedPrivateEndpointsClient) CheckNameAvailability 

func (client ManagedPrivateEndpointsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, resourceName ManagedPrivateEndpointsCheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the managed private endpoints resource name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. resourceName - the name of the resource.

func (ManagedPrivateEndpointsClient) CheckNameAvailabilityPreparer 

func (client ManagedPrivateEndpointsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, resourceName ManagedPrivateEndpointsCheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (ManagedPrivateEndpointsClient) CheckNameAvailabilityResponder 

func (client ManagedPrivateEndpointsClient) 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 (ManagedPrivateEndpointsClient) CheckNameAvailabilitySender 

func (client ManagedPrivateEndpointsClient) 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 (ManagedPrivateEndpointsClient) CreateOrUpdate 

func (client ManagedPrivateEndpointsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string, parameters ManagedPrivateEndpoint) (result ManagedPrivateEndpointsCreateOrUpdateFuture, err error)

CreateOrUpdate creates a managed private endpoint. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. managedPrivateEndpointName - the name of the managed private endpoint. parameters - the managed private endpoint parameters.

func (ManagedPrivateEndpointsClient) CreateOrUpdatePreparer 

func (client ManagedPrivateEndpointsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string, parameters ManagedPrivateEndpoint) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (ManagedPrivateEndpointsClient) CreateOrUpdateResponder 

func (client ManagedPrivateEndpointsClient) CreateOrUpdateResponder(resp *http.Response) (result ManagedPrivateEndpoint, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (ManagedPrivateEndpointsClient) CreateOrUpdateSender 

func (client ManagedPrivateEndpointsClient) CreateOrUpdateSender(req *http.Request) (future ManagedPrivateEndpointsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (ManagedPrivateEndpointsClient) Delete 

func (client ManagedPrivateEndpointsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string) (result ManagedPrivateEndpointsDeleteFuture, err error)

Delete deletes a managed private endpoint. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. managedPrivateEndpointName - the name of the managed private endpoint.

func (ManagedPrivateEndpointsClient) DeletePreparer 

func (client ManagedPrivateEndpointsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ManagedPrivateEndpointsClient) DeleteResponder 

func (client ManagedPrivateEndpointsClient) 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 (ManagedPrivateEndpointsClient) DeleteSender 

func (client ManagedPrivateEndpointsClient) DeleteSender(req *http.Request) (future ManagedPrivateEndpointsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ManagedPrivateEndpointsClient) Get 

func (client ManagedPrivateEndpointsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string) (result ManagedPrivateEndpoint, err error)

Get gets a managed private endpoint. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. managedPrivateEndpointName - the name of the managed private endpoint.

func (ManagedPrivateEndpointsClient) GetPreparer 

func (client ManagedPrivateEndpointsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ManagedPrivateEndpointsClient) GetResponder 

func (client ManagedPrivateEndpointsClient) GetResponder(resp *http.Response) (result ManagedPrivateEndpoint, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ManagedPrivateEndpointsClient) GetSender 

func (client ManagedPrivateEndpointsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (ManagedPrivateEndpointsClient) List 

func (client ManagedPrivateEndpointsClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result ManagedPrivateEndpointListResult, err error)

List returns the list of managed private endpoints. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (ManagedPrivateEndpointsClient) ListPreparer 

func (client ManagedPrivateEndpointsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListPreparer prepares the List request.

func (ManagedPrivateEndpointsClient) ListResponder 

func (client ManagedPrivateEndpointsClient) ListResponder(resp *http.Response) (result ManagedPrivateEndpointListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (ManagedPrivateEndpointsClient) ListSender 

func (client ManagedPrivateEndpointsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

func (ManagedPrivateEndpointsClient) Update 

func (client ManagedPrivateEndpointsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string, parameters ManagedPrivateEndpoint) (result ManagedPrivateEndpointsUpdateFuture, err error)

Update updates a managed private endpoint. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. managedPrivateEndpointName - the name of the managed private endpoint. parameters - the managed private endpoint parameters.

func (ManagedPrivateEndpointsClient) UpdatePreparer 

func (client ManagedPrivateEndpointsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, managedPrivateEndpointName string, parameters ManagedPrivateEndpoint) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (ManagedPrivateEndpointsClient) UpdateResponder 

func (client ManagedPrivateEndpointsClient) UpdateResponder(resp *http.Response) (result ManagedPrivateEndpoint, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (ManagedPrivateEndpointsClient) UpdateSender 

func (client ManagedPrivateEndpointsClient) UpdateSender(req *http.Request) (future ManagedPrivateEndpointsUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type ManagedPrivateEndpointsCreateOrUpdateFuture 

type ManagedPrivateEndpointsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ManagedPrivateEndpointsClient) (ManagedPrivateEndpoint, error)
}

ManagedPrivateEndpointsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ManagedPrivateEndpointsCreateOrUpdateFuture) UnmarshalJSON 

func (future *ManagedPrivateEndpointsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ManagedPrivateEndpointsDeleteFuture 

type ManagedPrivateEndpointsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ManagedPrivateEndpointsClient) (autorest.Response, error)
}

ManagedPrivateEndpointsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ManagedPrivateEndpointsDeleteFuture) UnmarshalJSON 

func (future *ManagedPrivateEndpointsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ManagedPrivateEndpointsUpdateFuture 

type ManagedPrivateEndpointsUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ManagedPrivateEndpointsClient) (ManagedPrivateEndpoint, error)
}

ManagedPrivateEndpointsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ManagedPrivateEndpointsUpdateFuture) UnmarshalJSON 

func (future *ManagedPrivateEndpointsUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type Operation 

type Operation struct {
	// Name - This is of the format {provider}/{resource}/{operation}.
	Name       *string           `json:"name,omitempty"`
	Display    *OperationDisplay `json:"display,omitempty"`
	Origin     *string           `json:"origin,omitempty"`
	Properties interface{}       `json:"properties,omitempty"`
}

Operation ...

type OperationDisplay 

type OperationDisplay struct {
	Provider *string `json:"provider,omitempty"`
	// Operation - For example: read, write, delete.
	Operation   *string `json:"operation,omitempty"`
	Resource    *string `json:"resource,omitempty"`
	Description *string `json:"description,omitempty"`
}

OperationDisplay ...

type OperationListResult 

type OperationListResult struct {
	autorest.Response `json:"-"`
	Value             *[]Operation `json:"value,omitempty"`
	NextLink          *string      `json:"nextLink,omitempty"`
}

OperationListResult ...

func (OperationListResult) IsEmpty 

func (olr OperationListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

type OperationListResultIterator 

type OperationListResultIterator struct {
	// contains filtered or unexported fields
}

OperationListResultIterator provides access to a complete listing of Operation values.

func NewOperationListResultIterator 

func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator

Creates a new instance of the OperationListResultIterator type.

func (*OperationListResultIterator) Next 

func (iter *OperationListResultIterator) Next() error

Next advances to the next value. If there was an error making the request the iterator does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultIterator) NextWithContext 

func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next value. If there was an error making the request the iterator does not advance and the error is returned.

func (OperationListResultIterator) NotDone 

func (iter OperationListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (OperationListResultIterator) Response 

func (iter OperationListResultIterator) Response() OperationListResult

Response returns the raw server response from the last page request.

func (OperationListResultIterator) Value 

func (iter OperationListResultIterator) Value() Operation

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type OperationListResultPage 

type OperationListResultPage struct {
	// contains filtered or unexported fields
}

OperationListResultPage contains a page of Operation values.

func NewOperationListResultPage 

func NewOperationListResultPage(cur OperationListResult, getNextPage func(context.Context, OperationListResult) (OperationListResult, error)) OperationListResultPage

Creates a new instance of the OperationListResultPage type.

func (*OperationListResultPage) Next 

func (page *OperationListResultPage) Next() error

Next advances to the next page of values. If there was an error making the request the page does not advance and the error is returned. Deprecated: Use NextWithContext() instead.

func (*OperationListResultPage) NextWithContext 

func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error)

NextWithContext advances to the next page of values. If there was an error making the request the page does not advance and the error is returned.

func (OperationListResultPage) NotDone 

func (page OperationListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (OperationListResultPage) Response 

func (page OperationListResultPage) Response() OperationListResult

Response returns the raw server response from the last page request.

func (OperationListResultPage) Values 

func (page OperationListResultPage) Values() []Operation

Values returns the slice of values for the current page or nil if there are no values.

type OperationResult 

type OperationResult struct {
	autorest.Response `json:"-"`
	// ID - READ-ONLY; ID of the resource.
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; Name of the resource.
	Name *string `json:"name,omitempty"`
	// Status - status of the Operation result. Possible values include: 'StatusSucceeded', 'StatusCanceled', 'StatusFailed', 'StatusRunning'
	Status Status `json:"status,omitempty"`
	// StartTime - The operation start time
	StartTime *date.Time `json:"startTime,omitempty"`
	// EndTime - The operation end time
	EndTime *date.Time `json:"endTime,omitempty"`
	// PercentComplete - Percentage completed.
	PercentComplete *float64 `json:"percentComplete,omitempty"`
	// OperationResultProperties - Properties of the operation results
	*OperationResultProperties `json:"properties,omitempty"`
	// OperationResultErrorProperties - Object that contains the error code and message if the operation failed.
	*OperationResultErrorProperties `json:"error,omitempty"`
}

OperationResult operation Result Entity.

func (OperationResult) MarshalJSON 

func (or OperationResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OperationResult.

func (*OperationResult) UnmarshalJSON 

func (or *OperationResult) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for OperationResult struct.

type OperationResultErrorProperties 

type OperationResultErrorProperties struct {
	// Code - The code of the error.
	Code *string `json:"code,omitempty"`
	// Message - The error message.
	Message *string `json:"message,omitempty"`
}

OperationResultErrorProperties operation result error properties

type OperationResultProperties 

type OperationResultProperties struct {
	// OperationKind - The kind of the operation.
	OperationKind *string `json:"operationKind,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// OperationState - The state of the operation.
	OperationState *string `json:"operationState,omitempty"`
}

OperationResultProperties operation result properties

func (OperationResultProperties) MarshalJSON 

func (orp OperationResultProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OperationResultProperties.

type OperationsClient 

type OperationsClient struct {
	BaseClient
}

OperationsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewOperationsClient 

func NewOperationsClient(subscriptionID string) OperationsClient

NewOperationsClient creates an instance of the OperationsClient client.

func NewOperationsClientWithBaseURI 

func NewOperationsClientWithBaseURI(baseURI string, subscriptionID string) OperationsClient

NewOperationsClientWithBaseURI creates an instance of the OperationsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (OperationsClient) List 

func (client OperationsClient) List(ctx context.Context) (result OperationListResultPage, err error)

List lists available operations for the Microsoft.Kusto provider.

func (OperationsClient) ListComplete 

func (client OperationsClient) ListComplete(ctx context.Context) (result OperationListResultIterator, err error)

ListComplete enumerates all values, automatically crossing page boundaries as required.

func (OperationsClient) ListPreparer 

func (client OperationsClient) ListPreparer(ctx context.Context) (*http.Request, error)

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 

func (client OperationsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type OperationsResultsClient 

type OperationsResultsClient struct {
	BaseClient
}

OperationsResultsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewOperationsResultsClient 

func NewOperationsResultsClient(subscriptionID string) OperationsResultsClient

NewOperationsResultsClient creates an instance of the OperationsResultsClient client.

func NewOperationsResultsClientWithBaseURI 

func NewOperationsResultsClientWithBaseURI(baseURI string, subscriptionID string) OperationsResultsClient

NewOperationsResultsClientWithBaseURI creates an instance of the OperationsResultsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (OperationsResultsClient) Get 

func (client OperationsResultsClient) Get(ctx context.Context, location string, operationID string) (result OperationResult, err error)

Get returns operation results. Parameters: location - azure location (region) name. operationID - the Guid of the operation ID

func (OperationsResultsClient) GetPreparer 

func (client OperationsResultsClient) GetPreparer(ctx context.Context, location string, operationID string) (*http.Request, error)

GetPreparer prepares the Get request.

func (OperationsResultsClient) GetResponder 

func (client OperationsResultsClient) GetResponder(resp *http.Response) (result OperationResult, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (OperationsResultsClient) GetSender 

func (client OperationsResultsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

type OperationsResultsLocationClient 

type OperationsResultsLocationClient struct {
	BaseClient
}

OperationsResultsLocationClient 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 NewOperationsResultsLocationClient 

func NewOperationsResultsLocationClient(subscriptionID string) OperationsResultsLocationClient

NewOperationsResultsLocationClient creates an instance of the OperationsResultsLocationClient client.

func NewOperationsResultsLocationClientWithBaseURI 

func NewOperationsResultsLocationClientWithBaseURI(baseURI string, subscriptionID string) OperationsResultsLocationClient

NewOperationsResultsLocationClientWithBaseURI creates an instance of the OperationsResultsLocationClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (OperationsResultsLocationClient) Get 

func (client OperationsResultsLocationClient) Get(ctx context.Context, location string, operationID string) (result autorest.Response, err error)

Get returns operation results. Parameters: location - azure location (region) name. operationID - the Guid of the operation ID

func (OperationsResultsLocationClient) GetPreparer 

func (client OperationsResultsLocationClient) GetPreparer(ctx context.Context, location string, operationID string) (*http.Request, error)

GetPreparer prepares the Get request.

func (OperationsResultsLocationClient) GetResponder 

func (client OperationsResultsLocationClient) GetResponder(resp *http.Response) (result autorest.Response, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (OperationsResultsLocationClient) GetSender 

func (client OperationsResultsLocationClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

type OptimizedAutoscale 

type OptimizedAutoscale struct {
	// Version - The version of the template defined, for instance 1.
	Version *int32 `json:"version,omitempty"`
	// IsEnabled - A boolean value that indicate if the optimized autoscale feature is enabled or not.
	IsEnabled *bool `json:"isEnabled,omitempty"`
	// Minimum - Minimum allowed instances count.
	Minimum *int32 `json:"minimum,omitempty"`
	// Maximum - Maximum allowed instances count.
	Maximum *int32 `json:"maximum,omitempty"`
}

OptimizedAutoscale a class that contains the optimized auto scale definition.

type OutboundNetworkDependenciesEndpoint 

type OutboundNetworkDependenciesEndpoint struct {
	// OutboundNetworkDependenciesEndpointProperties - The outbound environment endpoint properties.
	*OutboundNetworkDependenciesEndpointProperties `json:"properties,omitempty"`
	// Etag - READ-ONLY; A unique read-only string that changes whenever the resource is updated.
	Etag *string `json:"etag,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

OutboundNetworkDependenciesEndpoint endpoints accessed for a common purpose that the Kusto Service Environment requires outbound network access to.

func (OutboundNetworkDependenciesEndpoint) MarshalJSON 

func (onde OutboundNetworkDependenciesEndpoint) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OutboundNetworkDependenciesEndpoint.

func (*OutboundNetworkDependenciesEndpoint) UnmarshalJSON 

func (onde *OutboundNetworkDependenciesEndpoint) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for OutboundNetworkDependenciesEndpoint struct.

type OutboundNetworkDependenciesEndpointListResult 

type OutboundNetworkDependenciesEndpointListResult struct {
	autorest.Response `json:"-"`
	// Value - Collection of resources.
	Value *[]OutboundNetworkDependenciesEndpoint `json:"value,omitempty"`
	// NextLink - READ-ONLY; Link to next page of resources.
	NextLink *string `json:"nextLink,omitempty"`
}

OutboundNetworkDependenciesEndpointListResult collection of Outbound Environment Endpoints

func (OutboundNetworkDependenciesEndpointListResult) IsEmpty 

func (ondelr OutboundNetworkDependenciesEndpointListResult) IsEmpty() bool

IsEmpty returns true if the ListResult contains no values.

func (OutboundNetworkDependenciesEndpointListResult) MarshalJSON 

func (ondelr OutboundNetworkDependenciesEndpointListResult) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OutboundNetworkDependenciesEndpointListResult.

type OutboundNetworkDependenciesEndpointListResultIterator 

type OutboundNetworkDependenciesEndpointListResultIterator struct {
	// contains filtered or unexported fields
}

OutboundNetworkDependenciesEndpointListResultIterator provides access to a complete listing of OutboundNetworkDependenciesEndpoint values.

func NewOutboundNetworkDependenciesEndpointListResultIterator 

func NewOutboundNetworkDependenciesEndpointListResultIterator(page OutboundNetworkDependenciesEndpointListResultPage) OutboundNetworkDependenciesEndpointListResultIterator

Creates a new instance of the OutboundNetworkDependenciesEndpointListResultIterator type.

func (*OutboundNetworkDependenciesEndpointListResultIterator) Next 

func (iter *OutboundNetworkDependenciesEndpointListResultIterator) 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 (*OutboundNetworkDependenciesEndpointListResultIterator) NextWithContext 

func (iter *OutboundNetworkDependenciesEndpointListResultIterator) 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 (OutboundNetworkDependenciesEndpointListResultIterator) NotDone 

func (iter OutboundNetworkDependenciesEndpointListResultIterator) NotDone() bool

NotDone returns true if the enumeration should be started or is not yet complete.

func (OutboundNetworkDependenciesEndpointListResultIterator) Response 

func (iter OutboundNetworkDependenciesEndpointListResultIterator) Response() OutboundNetworkDependenciesEndpointListResult

Response returns the raw server response from the last page request.

func (OutboundNetworkDependenciesEndpointListResultIterator) Value 

func (iter OutboundNetworkDependenciesEndpointListResultIterator) Value() OutboundNetworkDependenciesEndpoint

Value returns the current value or a zero-initialized value if the iterator has advanced beyond the end of the collection.

type OutboundNetworkDependenciesEndpointListResultPage 

type OutboundNetworkDependenciesEndpointListResultPage struct {
	// contains filtered or unexported fields
}

OutboundNetworkDependenciesEndpointListResultPage contains a page of OutboundNetworkDependenciesEndpoint values.

func NewOutboundNetworkDependenciesEndpointListResultPage 

func NewOutboundNetworkDependenciesEndpointListResultPage(cur OutboundNetworkDependenciesEndpointListResult, getNextPage func(context.Context, OutboundNetworkDependenciesEndpointListResult) (OutboundNetworkDependenciesEndpointListResult, error)) OutboundNetworkDependenciesEndpointListResultPage

Creates a new instance of the OutboundNetworkDependenciesEndpointListResultPage type.

func (*OutboundNetworkDependenciesEndpointListResultPage) Next 

func (page *OutboundNetworkDependenciesEndpointListResultPage) 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 (*OutboundNetworkDependenciesEndpointListResultPage) NextWithContext 

func (page *OutboundNetworkDependenciesEndpointListResultPage) 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 (OutboundNetworkDependenciesEndpointListResultPage) NotDone 

func (page OutboundNetworkDependenciesEndpointListResultPage) NotDone() bool

NotDone returns true if the page enumeration should be started or is not yet complete.

func (OutboundNetworkDependenciesEndpointListResultPage) Response 

func (page OutboundNetworkDependenciesEndpointListResultPage) Response() OutboundNetworkDependenciesEndpointListResult

Response returns the raw server response from the last page request.

func (OutboundNetworkDependenciesEndpointListResultPage) Values 

func (page OutboundNetworkDependenciesEndpointListResultPage) Values() []OutboundNetworkDependenciesEndpoint

Values returns the slice of values for the current page or nil if there are no values.

type OutboundNetworkDependenciesEndpointProperties 

type OutboundNetworkDependenciesEndpointProperties struct {
	// Category - The type of service accessed by the Kusto Service Environment, e.g., Azure Storage, Azure SQL Database, and Azure Active Directory.
	Category *string `json:"category,omitempty"`
	// Endpoints - The endpoints that the Kusto Service Environment reaches the service at.
	Endpoints *[]EndpointDependency `json:"endpoints,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
}

OutboundNetworkDependenciesEndpointProperties endpoints accessed for a common purpose that the Kusto Service Environment requires outbound network access to.

func (OutboundNetworkDependenciesEndpointProperties) MarshalJSON 

func (ondep OutboundNetworkDependenciesEndpointProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for OutboundNetworkDependenciesEndpointProperties.

type PrincipalType 

type PrincipalType string

PrincipalType enumerates the values for principal type. 

const (
	// PrincipalTypeApp ...
	PrincipalTypeApp PrincipalType = "App"
	// PrincipalTypeGroup ...
	PrincipalTypeGroup PrincipalType = "Group"
	// PrincipalTypeUser ...
	PrincipalTypeUser PrincipalType = "User"
)

func PossiblePrincipalTypeValues 

func PossiblePrincipalTypeValues() []PrincipalType

PossiblePrincipalTypeValues returns an array of possible values for the PrincipalType const type.

type PrincipalsModificationKind 

type PrincipalsModificationKind string

PrincipalsModificationKind enumerates the values for principals modification kind. 

const (
	// PrincipalsModificationKindNone ...
	PrincipalsModificationKindNone PrincipalsModificationKind = "None"
	// PrincipalsModificationKindReplace ...
	PrincipalsModificationKindReplace PrincipalsModificationKind = "Replace"
	// PrincipalsModificationKindUnion ...
	PrincipalsModificationKindUnion PrincipalsModificationKind = "Union"
)

func PossiblePrincipalsModificationKindValues 

func PossiblePrincipalsModificationKindValues() []PrincipalsModificationKind

PossiblePrincipalsModificationKindValues returns an array of possible values for the PrincipalsModificationKind const type.

type PrivateEndpointConnection 

type PrivateEndpointConnection struct {
	autorest.Response `json:"-"`
	// PrivateEndpointConnectionProperties - Resource properties.
	*PrivateEndpointConnectionProperties `json:"properties,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

PrivateEndpointConnection a private endpoint connection

func (PrivateEndpointConnection) MarshalJSON 

func (pec PrivateEndpointConnection) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointConnection.

func (*PrivateEndpointConnection) UnmarshalJSON 

func (pec *PrivateEndpointConnection) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for PrivateEndpointConnection struct.

type PrivateEndpointConnectionListResult 

type PrivateEndpointConnectionListResult struct {
	autorest.Response `json:"-"`
	// Value - Array of private endpoint connections
	Value *[]PrivateEndpointConnection `json:"value,omitempty"`
}

PrivateEndpointConnectionListResult a list of private endpoint connections

type PrivateEndpointConnectionProperties 

type PrivateEndpointConnectionProperties struct {
	// PrivateEndpoint - READ-ONLY; Private endpoint which the connection belongs to.
	PrivateEndpoint *PrivateEndpointProperty `json:"privateEndpoint,omitempty"`
	// PrivateLinkServiceConnectionState - Connection State of the Private Endpoint Connection.
	PrivateLinkServiceConnectionState *PrivateLinkServiceConnectionStateProperty `json:"privateLinkServiceConnectionState,omitempty"`
	// GroupID - READ-ONLY; Group id of the private endpoint.
	GroupID *string `json:"groupId,omitempty"`
	// ProvisioningState - READ-ONLY; Provisioning state of the private endpoint.
	ProvisioningState *string `json:"provisioningState,omitempty"`
}

PrivateEndpointConnectionProperties properties of a private endpoint connection.

func (PrivateEndpointConnectionProperties) MarshalJSON 

func (pecp PrivateEndpointConnectionProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointConnectionProperties.

type PrivateEndpointConnectionsClient 

type PrivateEndpointConnectionsClient struct {
	BaseClient
}

PrivateEndpointConnectionsClient 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 NewPrivateEndpointConnectionsClient 

func NewPrivateEndpointConnectionsClient(subscriptionID string) PrivateEndpointConnectionsClient

NewPrivateEndpointConnectionsClient creates an instance of the PrivateEndpointConnectionsClient client.

func NewPrivateEndpointConnectionsClientWithBaseURI 

func NewPrivateEndpointConnectionsClientWithBaseURI(baseURI string, subscriptionID string) PrivateEndpointConnectionsClient

NewPrivateEndpointConnectionsClientWithBaseURI creates an instance of the PrivateEndpointConnectionsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (PrivateEndpointConnectionsClient) CreateOrUpdate 

func (client PrivateEndpointConnectionsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection) (result PrivateEndpointConnectionsCreateOrUpdateFuture, err error)

CreateOrUpdate approve or reject a private endpoint connection with a given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. privateEndpointConnectionName - the name of the private endpoint connection.

func (PrivateEndpointConnectionsClient) CreateOrUpdatePreparer 

func (client PrivateEndpointConnectionsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string, parameters PrivateEndpointConnection) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (PrivateEndpointConnectionsClient) CreateOrUpdateResponder 

func (client PrivateEndpointConnectionsClient) CreateOrUpdateResponder(resp *http.Response) (result PrivateEndpointConnection, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (PrivateEndpointConnectionsClient) CreateOrUpdateSender 

func (client PrivateEndpointConnectionsClient) CreateOrUpdateSender(req *http.Request) (future PrivateEndpointConnectionsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (PrivateEndpointConnectionsClient) Delete 

func (client PrivateEndpointConnectionsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (result PrivateEndpointConnectionsDeleteFuture, err error)

Delete deletes a private endpoint connection with a given name. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. privateEndpointConnectionName - the name of the private endpoint connection.

func (PrivateEndpointConnectionsClient) DeletePreparer 

func (client PrivateEndpointConnectionsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (PrivateEndpointConnectionsClient) DeleteResponder 

func (client PrivateEndpointConnectionsClient) 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 (PrivateEndpointConnectionsClient) DeleteSender 

func (client PrivateEndpointConnectionsClient) DeleteSender(req *http.Request) (future PrivateEndpointConnectionsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (PrivateEndpointConnectionsClient) Get 

func (client PrivateEndpointConnectionsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (result PrivateEndpointConnection, err error)

Get gets a private endpoint connection. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. privateEndpointConnectionName - the name of the private endpoint connection.

func (PrivateEndpointConnectionsClient) GetPreparer 

func (client PrivateEndpointConnectionsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, privateEndpointConnectionName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (PrivateEndpointConnectionsClient) GetResponder 

func (client PrivateEndpointConnectionsClient) GetResponder(resp *http.Response) (result PrivateEndpointConnection, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (PrivateEndpointConnectionsClient) GetSender 

func (client PrivateEndpointConnectionsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (PrivateEndpointConnectionsClient) List 

func (client PrivateEndpointConnectionsClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result PrivateEndpointConnectionListResult, err error)

List returns the list of private endpoint connections. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (PrivateEndpointConnectionsClient) ListPreparer 

func (client PrivateEndpointConnectionsClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListPreparer prepares the List request.

func (PrivateEndpointConnectionsClient) ListResponder 

func (client PrivateEndpointConnectionsClient) ListResponder(resp *http.Response) (result PrivateEndpointConnectionListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (PrivateEndpointConnectionsClient) ListSender 

func (client PrivateEndpointConnectionsClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type PrivateEndpointConnectionsCreateOrUpdateFuture 

type PrivateEndpointConnectionsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(PrivateEndpointConnectionsClient) (PrivateEndpointConnection, error)
}

PrivateEndpointConnectionsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*PrivateEndpointConnectionsCreateOrUpdateFuture) UnmarshalJSON 

func (future *PrivateEndpointConnectionsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type PrivateEndpointConnectionsDeleteFuture 

type PrivateEndpointConnectionsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(PrivateEndpointConnectionsClient) (autorest.Response, error)
}

PrivateEndpointConnectionsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*PrivateEndpointConnectionsDeleteFuture) UnmarshalJSON 

func (future *PrivateEndpointConnectionsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type PrivateEndpointProperty 

type PrivateEndpointProperty struct {
	// ID - READ-ONLY; Resource id of the private endpoint.
	ID *string `json:"id,omitempty"`
}

PrivateEndpointProperty private endpoint which the connection belongs to.

func (PrivateEndpointProperty) MarshalJSON 

func (pep PrivateEndpointProperty) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateEndpointProperty.

type PrivateLinkResource 

type PrivateLinkResource struct {
	autorest.Response `json:"-"`
	// PrivateLinkResourceProperties - Resource properties.
	*PrivateLinkResourceProperties `json:"properties,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

PrivateLinkResource a private link resource

func (PrivateLinkResource) MarshalJSON 

func (plr PrivateLinkResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkResource.

func (*PrivateLinkResource) UnmarshalJSON 

func (plr *PrivateLinkResource) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for PrivateLinkResource struct.

type PrivateLinkResourceListResult 

type PrivateLinkResourceListResult struct {
	autorest.Response `json:"-"`
	// Value - Array of private link resources
	Value *[]PrivateLinkResource `json:"value,omitempty"`
}

PrivateLinkResourceListResult a list of private link resources

type PrivateLinkResourceProperties 

type PrivateLinkResourceProperties struct {
	// GroupID - READ-ONLY; The private link resource group id.
	GroupID *string `json:"groupId,omitempty"`
	// RequiredMembers - READ-ONLY; The private link resource required member names.
	RequiredMembers *[]string `json:"requiredMembers,omitempty"`
	// RequiredZoneNames - READ-ONLY; The private link resource required zone names.
	RequiredZoneNames *[]string `json:"requiredZoneNames,omitempty"`
}

PrivateLinkResourceProperties properties of a private link resource.

func (PrivateLinkResourceProperties) MarshalJSON 

func (plrp PrivateLinkResourceProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkResourceProperties.

type PrivateLinkResourcesClient 

type PrivateLinkResourcesClient struct {
	BaseClient
}

PrivateLinkResourcesClient 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 NewPrivateLinkResourcesClient 

func NewPrivateLinkResourcesClient(subscriptionID string) PrivateLinkResourcesClient

NewPrivateLinkResourcesClient creates an instance of the PrivateLinkResourcesClient client.

func NewPrivateLinkResourcesClientWithBaseURI 

func NewPrivateLinkResourcesClientWithBaseURI(baseURI string, subscriptionID string) PrivateLinkResourcesClient

NewPrivateLinkResourcesClientWithBaseURI creates an instance of the PrivateLinkResourcesClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (PrivateLinkResourcesClient) Get 

func (client PrivateLinkResourcesClient) Get(ctx context.Context, resourceGroupName string, clusterName string, privateLinkResourceName string) (result PrivateLinkResource, err error)

Get gets a private link resource. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. privateLinkResourceName - the name of the private link resource.

func (PrivateLinkResourcesClient) GetPreparer 

func (client PrivateLinkResourcesClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, privateLinkResourceName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (PrivateLinkResourcesClient) GetResponder 

func (client PrivateLinkResourcesClient) GetResponder(resp *http.Response) (result PrivateLinkResource, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (PrivateLinkResourcesClient) GetSender 

func (client PrivateLinkResourcesClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (PrivateLinkResourcesClient) List 

func (client PrivateLinkResourcesClient) List(ctx context.Context, resourceGroupName string, clusterName string) (result PrivateLinkResourceListResult, err error)

List returns the list of private link resources. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster.

func (PrivateLinkResourcesClient) ListPreparer 

func (client PrivateLinkResourcesClient) ListPreparer(ctx context.Context, resourceGroupName string, clusterName string) (*http.Request, error)

ListPreparer prepares the List request.

func (PrivateLinkResourcesClient) ListResponder 

func (client PrivateLinkResourcesClient) ListResponder(resp *http.Response) (result PrivateLinkResourceListResult, err error)

ListResponder handles the response to the List request. The method always closes the http.Response Body.

func (PrivateLinkResourcesClient) ListSender 

func (client PrivateLinkResourcesClient) ListSender(req *http.Request) (*http.Response, error)

ListSender sends the List request. The method will close the http.Response Body if it receives an error.

type PrivateLinkServiceConnectionStateProperty 

type PrivateLinkServiceConnectionStateProperty struct {
	// Status - The private link service connection status.
	Status *string `json:"status,omitempty"`
	// Description - The private link service connection description.
	Description *string `json:"description,omitempty"`
	// ActionsRequired - READ-ONLY; Any action that is required beyond basic workflow (approve/ reject/ disconnect)
	ActionsRequired *string `json:"actionsRequired,omitempty"`
}

PrivateLinkServiceConnectionStateProperty connection State of the Private Endpoint Connection.

func (PrivateLinkServiceConnectionStateProperty) MarshalJSON 

func (plscsp PrivateLinkServiceConnectionStateProperty) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for PrivateLinkServiceConnectionStateProperty.

type ProvisioningState 

type ProvisioningState string

ProvisioningState enumerates the values for provisioning state. 

const (
	// ProvisioningStateCreating ...
	ProvisioningStateCreating ProvisioningState = "Creating"
	// ProvisioningStateDeleting ...
	ProvisioningStateDeleting ProvisioningState = "Deleting"
	// ProvisioningStateFailed ...
	ProvisioningStateFailed ProvisioningState = "Failed"
	// ProvisioningStateMoving ...
	ProvisioningStateMoving ProvisioningState = "Moving"
	// ProvisioningStateRunning ...
	ProvisioningStateRunning ProvisioningState = "Running"
	// ProvisioningStateSucceeded ...
	ProvisioningStateSucceeded ProvisioningState = "Succeeded"
)

func PossibleProvisioningStateValues 

func PossibleProvisioningStateValues() []ProvisioningState

PossibleProvisioningStateValues returns an array of possible values for the ProvisioningState const type.

type ProxyResource 

type ProxyResource struct {
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

ProxyResource the resource model definition for a Azure Resource Manager proxy resource. It will not have tags and a location

func (ProxyResource) MarshalJSON 

func (pr ProxyResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ProxyResource.

type PublicIPType 

type PublicIPType string

PublicIPType enumerates the values for public ip type. 

const (
	// PublicIPTypeDualStack ...
	PublicIPTypeDualStack PublicIPType = "DualStack"
	// PublicIPTypeIPv4 ...
	PublicIPTypeIPv4 PublicIPType = "IPv4"
)

func PossiblePublicIPTypeValues 

func PossiblePublicIPTypeValues() []PublicIPType

PossiblePublicIPTypeValues returns an array of possible values for the PublicIPType const type.

type PublicNetworkAccess 

type PublicNetworkAccess string

PublicNetworkAccess enumerates the values for public network access. 

const (
	// PublicNetworkAccessDisabled ...
	PublicNetworkAccessDisabled PublicNetworkAccess = "Disabled"
	// PublicNetworkAccessEnabled ...
	PublicNetworkAccessEnabled PublicNetworkAccess = "Enabled"
)

func PossiblePublicNetworkAccessValues 

func PossiblePublicNetworkAccessValues() []PublicNetworkAccess

PossiblePublicNetworkAccessValues returns an array of possible values for the PublicNetworkAccess const type.

type ReadOnlyFollowingDatabase 

type ReadOnlyFollowingDatabase struct {
	// ReadOnlyFollowingDatabaseProperties - The database properties.
	*ReadOnlyFollowingDatabaseProperties `json:"properties,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Kind - Possible values include: 'KindDatabase', 'KindReadWrite', 'KindReadOnlyFollowing'
	Kind Kind `json:"kind,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

ReadOnlyFollowingDatabase class representing a read only following database.

func (ReadOnlyFollowingDatabase) AsBasicDatabase 

func (rofd ReadOnlyFollowingDatabase) AsBasicDatabase() (BasicDatabase, bool)

AsBasicDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.

func (ReadOnlyFollowingDatabase) AsDatabase 

func (rofd ReadOnlyFollowingDatabase) AsDatabase() (*Database, bool)

AsDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.

func (ReadOnlyFollowingDatabase) AsReadOnlyFollowingDatabase 

func (rofd ReadOnlyFollowingDatabase) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)

AsReadOnlyFollowingDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.

func (ReadOnlyFollowingDatabase) AsReadWriteDatabase 

func (rofd ReadOnlyFollowingDatabase) AsReadWriteDatabase() (*ReadWriteDatabase, bool)

AsReadWriteDatabase is the BasicDatabase implementation for ReadOnlyFollowingDatabase.

func (ReadOnlyFollowingDatabase) MarshalJSON 

func (rofd ReadOnlyFollowingDatabase) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ReadOnlyFollowingDatabase.

func (*ReadOnlyFollowingDatabase) UnmarshalJSON 

func (rofd *ReadOnlyFollowingDatabase) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ReadOnlyFollowingDatabase struct.

type ReadOnlyFollowingDatabaseProperties 

type ReadOnlyFollowingDatabaseProperties struct {
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// SoftDeletePeriod - READ-ONLY; The time the data should be kept before it stops being accessible to queries in TimeSpan.
	SoftDeletePeriod *string `json:"softDeletePeriod,omitempty"`
	// HotCachePeriod - The time the data should be kept in cache for fast queries in TimeSpan.
	HotCachePeriod *string `json:"hotCachePeriod,omitempty"`
	// Statistics - READ-ONLY; The statistics of the database.
	Statistics *DatabaseStatistics `json:"statistics,omitempty"`
	// LeaderClusterResourceID - READ-ONLY; The name of the leader cluster
	LeaderClusterResourceID *string `json:"leaderClusterResourceId,omitempty"`
	// AttachedDatabaseConfigurationName - READ-ONLY; The name of the attached database configuration cluster
	AttachedDatabaseConfigurationName *string `json:"attachedDatabaseConfigurationName,omitempty"`
	// PrincipalsModificationKind - READ-ONLY; The principals modification kind of the database. Possible values include: 'PrincipalsModificationKindUnion', 'PrincipalsModificationKindReplace', 'PrincipalsModificationKindNone'
	PrincipalsModificationKind PrincipalsModificationKind `json:"principalsModificationKind,omitempty"`
}

ReadOnlyFollowingDatabaseProperties class representing the Kusto database properties.

func (ReadOnlyFollowingDatabaseProperties) MarshalJSON 

func (rofdp ReadOnlyFollowingDatabaseProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ReadOnlyFollowingDatabaseProperties.

type ReadWriteDatabase 

type ReadWriteDatabase struct {
	// ReadWriteDatabaseProperties - The database properties.
	*ReadWriteDatabaseProperties `json:"properties,omitempty"`
	// Location - Resource location.
	Location *string `json:"location,omitempty"`
	// Kind - Possible values include: 'KindDatabase', 'KindReadWrite', 'KindReadOnlyFollowing'
	Kind Kind `json:"kind,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

ReadWriteDatabase class representing a read write database.

func (ReadWriteDatabase) AsBasicDatabase 

func (rwd ReadWriteDatabase) AsBasicDatabase() (BasicDatabase, bool)

AsBasicDatabase is the BasicDatabase implementation for ReadWriteDatabase.

func (ReadWriteDatabase) AsDatabase 

func (rwd ReadWriteDatabase) AsDatabase() (*Database, bool)

AsDatabase is the BasicDatabase implementation for ReadWriteDatabase.

func (ReadWriteDatabase) AsReadOnlyFollowingDatabase 

func (rwd ReadWriteDatabase) AsReadOnlyFollowingDatabase() (*ReadOnlyFollowingDatabase, bool)

AsReadOnlyFollowingDatabase is the BasicDatabase implementation for ReadWriteDatabase.

func (ReadWriteDatabase) AsReadWriteDatabase 

func (rwd ReadWriteDatabase) AsReadWriteDatabase() (*ReadWriteDatabase, bool)

AsReadWriteDatabase is the BasicDatabase implementation for ReadWriteDatabase.

func (ReadWriteDatabase) MarshalJSON 

func (rwd ReadWriteDatabase) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ReadWriteDatabase.

func (*ReadWriteDatabase) UnmarshalJSON 

func (rwd *ReadWriteDatabase) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for ReadWriteDatabase struct.

type ReadWriteDatabaseProperties 

type ReadWriteDatabaseProperties struct {
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
	// SoftDeletePeriod - The time the data should be kept before it stops being accessible to queries in TimeSpan.
	SoftDeletePeriod *string `json:"softDeletePeriod,omitempty"`
	// HotCachePeriod - The time the data should be kept in cache for fast queries in TimeSpan.
	HotCachePeriod *string `json:"hotCachePeriod,omitempty"`
	// Statistics - READ-ONLY; The statistics of the database.
	Statistics *DatabaseStatistics `json:"statistics,omitempty"`
	// IsFollowed - READ-ONLY; Indicates whether the database is followed.
	IsFollowed *bool `json:"isFollowed,omitempty"`
}

ReadWriteDatabaseProperties class representing the Kusto database properties.

func (ReadWriteDatabaseProperties) MarshalJSON 

func (rwdp ReadWriteDatabaseProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ReadWriteDatabaseProperties.

type Reason 

type Reason string

Reason enumerates the values for reason. 

const (
	// ReasonAlreadyExists ...
	ReasonAlreadyExists Reason = "AlreadyExists"
	// ReasonInvalid ...
	ReasonInvalid Reason = "Invalid"
)

func PossibleReasonValues 

func PossibleReasonValues() []Reason

PossibleReasonValues returns an array of possible values for the Reason const type.

type Resource 

type Resource struct {
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

Resource common fields that are returned in the response for all Azure Resource Manager resources

func (Resource) MarshalJSON 

func (r Resource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Resource.

type Script 

type Script struct {
	autorest.Response `json:"-"`
	// ScriptProperties - The database script.
	*ScriptProperties `json:"properties,omitempty"`
	// SystemData - READ-ONLY
	SystemData *SystemData `json:"systemData,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

Script class representing a database script.

func (Script) MarshalJSON 

func (s Script) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for Script.

func (*Script) UnmarshalJSON 

func (s *Script) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaler for Script struct.

type ScriptCheckNameRequest 

type ScriptCheckNameRequest struct {
	// Name - Script name.
	Name *string `json:"name,omitempty"`
	// Type - The type of resource, Microsoft.Kusto/clusters/databases/scripts.
	Type *string `json:"type,omitempty"`
}

ScriptCheckNameRequest a script name availability request.

type ScriptListResult 

type ScriptListResult struct {
	autorest.Response `json:"-"`
	// Value - The list of Kusto scripts.
	Value *[]Script `json:"value,omitempty"`
}

ScriptListResult the list Kusto database script operation response.

type ScriptProperties 

type ScriptProperties struct {
	// ScriptURL - The url to the KQL script blob file. Must not be used together with scriptContent property
	ScriptURL *string `json:"scriptUrl,omitempty"`
	// ScriptURLSasToken - The SaS token that provide read access to the file which contain the script. Must be provided when using scriptUrl property.
	ScriptURLSasToken *string `json:"scriptUrlSasToken,omitempty"`
	// ScriptContent - The script content. This property should be used when the script is provide inline and not through file in a SA. Must not be used together with scriptUrl and scriptUrlSasToken properties.
	ScriptContent *string `json:"scriptContent,omitempty"`
	// ForceUpdateTag - A unique string. If changed the script will be applied again.
	ForceUpdateTag *string `json:"forceUpdateTag,omitempty"`
	// ContinueOnErrors - Flag that indicates whether to continue if one of the command fails.
	ContinueOnErrors *bool `json:"continueOnErrors,omitempty"`
	// ProvisioningState - READ-ONLY; The provisioned state of the resource. Possible values include: 'ProvisioningStateRunning', 'ProvisioningStateCreating', 'ProvisioningStateDeleting', 'ProvisioningStateSucceeded', 'ProvisioningStateFailed', 'ProvisioningStateMoving'
	ProvisioningState ProvisioningState `json:"provisioningState,omitempty"`
}

ScriptProperties a class representing database script property.

func (ScriptProperties) MarshalJSON 

func (sp ScriptProperties) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for ScriptProperties.

type ScriptsClient 

type ScriptsClient struct {
	BaseClient
}

ScriptsClient is the the Azure Kusto management API provides a RESTful set of web services that interact with Azure Kusto services to manage your clusters and databases. The API enables you to create, update, and delete clusters and databases.

func NewScriptsClient 

func NewScriptsClient(subscriptionID string) ScriptsClient

NewScriptsClient creates an instance of the ScriptsClient client.

func NewScriptsClientWithBaseURI 

func NewScriptsClientWithBaseURI(baseURI string, subscriptionID string) ScriptsClient

NewScriptsClientWithBaseURI creates an instance of the ScriptsClient client using a custom endpoint. Use this when interacting with an Azure cloud that uses a non-standard base URI (sovereign clouds, Azure stack).

func (ScriptsClient) CheckNameAvailability 

func (client ScriptsClient) CheckNameAvailability(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName ScriptCheckNameRequest) (result CheckNameResult, err error)

CheckNameAvailability checks that the script name is valid and is not already in use. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the script.

func (ScriptsClient) CheckNameAvailabilityPreparer 

func (client ScriptsClient) CheckNameAvailabilityPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName ScriptCheckNameRequest) (*http.Request, error)

CheckNameAvailabilityPreparer prepares the CheckNameAvailability request.

func (ScriptsClient) CheckNameAvailabilityResponder 

func (client ScriptsClient) CheckNameAvailabilityResponder(resp *http.Response) (result CheckNameResult, err error)

CheckNameAvailabilityResponder handles the response to the CheckNameAvailability request. The method always closes the http.Response Body.

func (ScriptsClient) CheckNameAvailabilitySender 

func (client ScriptsClient) 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 (ScriptsClient) CreateOrUpdate 

func (client ScriptsClient) CreateOrUpdate(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (result ScriptsCreateOrUpdateFuture, err error)

CreateOrUpdate creates a Kusto database script. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script. parameters - the Kusto Script parameters contains the KQL to run.

func (ScriptsClient) CreateOrUpdatePreparer 

func (client ScriptsClient) CreateOrUpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (*http.Request, error)

CreateOrUpdatePreparer prepares the CreateOrUpdate request.

func (ScriptsClient) CreateOrUpdateResponder 

func (client ScriptsClient) CreateOrUpdateResponder(resp *http.Response) (result Script, err error)

CreateOrUpdateResponder handles the response to the CreateOrUpdate request. The method always closes the http.Response Body.

func (ScriptsClient) CreateOrUpdateSender 

func (client ScriptsClient) CreateOrUpdateSender(req *http.Request) (future ScriptsCreateOrUpdateFuture, err error)

CreateOrUpdateSender sends the CreateOrUpdate request. The method will close the http.Response Body if it receives an error.

func (ScriptsClient) Delete 

func (client ScriptsClient) Delete(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (result ScriptsDeleteFuture, err error)

Delete deletes a Kusto principalAssignment. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script.

func (ScriptsClient) DeletePreparer 

func (client ScriptsClient) DeletePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (*http.Request, error)

DeletePreparer prepares the Delete request.

func (ScriptsClient) DeleteResponder 

func (client ScriptsClient) DeleteResponder(resp *http.Response) (result autorest.Response, err error)

DeleteResponder handles the response to the Delete request. The method always closes the http.Response Body.

func (ScriptsClient) DeleteSender 

func (client ScriptsClient) DeleteSender(req *http.Request) (future ScriptsDeleteFuture, err error)

DeleteSender sends the Delete request. The method will close the http.Response Body if it receives an error.

func (ScriptsClient) Get 

func (client ScriptsClient) Get(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (result Script, err error)

Get gets a Kusto cluster database script. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script.

func (ScriptsClient) GetPreparer 

func (client ScriptsClient) GetPreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string) (*http.Request, error)

GetPreparer prepares the Get request.

func (ScriptsClient) GetResponder 

func (client ScriptsClient) GetResponder(resp *http.Response) (result Script, err error)

GetResponder handles the response to the Get request. The method always closes the http.Response Body.

func (ScriptsClient) GetSender 

func (client ScriptsClient) GetSender(req *http.Request) (*http.Response, error)

GetSender sends the Get request. The method will close the http.Response Body if it receives an error.

func (ScriptsClient) ListByDatabase 

func (client ScriptsClient) ListByDatabase(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (result ScriptListResult, err error)

ListByDatabase returns the list of database scripts for given database. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster.

func (ScriptsClient) ListByDatabasePreparer 

func (client ScriptsClient) ListByDatabasePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string) (*http.Request, error)

ListByDatabasePreparer prepares the ListByDatabase request.

func (ScriptsClient) ListByDatabaseResponder 

func (client ScriptsClient) ListByDatabaseResponder(resp *http.Response) (result ScriptListResult, err error)

ListByDatabaseResponder handles the response to the ListByDatabase request. The method always closes the http.Response Body.

func (ScriptsClient) ListByDatabaseSender 

func (client ScriptsClient) ListByDatabaseSender(req *http.Request) (*http.Response, error)

ListByDatabaseSender sends the ListByDatabase request. The method will close the http.Response Body if it receives an error.

func (ScriptsClient) Update 

func (client ScriptsClient) Update(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (result ScriptsUpdateFuture, err error)

Update updates a database script. Parameters: resourceGroupName - the name of the resource group containing the Kusto cluster. clusterName - the name of the Kusto cluster. databaseName - the name of the database in the Kusto cluster. scriptName - the name of the Kusto database script. parameters - the Kusto Script parameters contains to the KQL to run.

func (ScriptsClient) UpdatePreparer 

func (client ScriptsClient) UpdatePreparer(ctx context.Context, resourceGroupName string, clusterName string, databaseName string, scriptName string, parameters Script) (*http.Request, error)

UpdatePreparer prepares the Update request.

func (ScriptsClient) UpdateResponder 

func (client ScriptsClient) UpdateResponder(resp *http.Response) (result Script, err error)

UpdateResponder handles the response to the Update request. The method always closes the http.Response Body.

func (ScriptsClient) UpdateSender 

func (client ScriptsClient) UpdateSender(req *http.Request) (future ScriptsUpdateFuture, err error)

UpdateSender sends the Update request. The method will close the http.Response Body if it receives an error.

type ScriptsCreateOrUpdateFuture 

type ScriptsCreateOrUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ScriptsClient) (Script, error)
}

ScriptsCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ScriptsCreateOrUpdateFuture) UnmarshalJSON 

func (future *ScriptsCreateOrUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ScriptsDeleteFuture 

type ScriptsDeleteFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ScriptsClient) (autorest.Response, error)
}

ScriptsDeleteFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ScriptsDeleteFuture) UnmarshalJSON 

func (future *ScriptsDeleteFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type ScriptsUpdateFuture 

type ScriptsUpdateFuture struct {
	azure.FutureAPI
	// Result returns the result of the asynchronous operation.
	// If the operation has not completed it will return an error.
	Result func(ScriptsClient) (Script, error)
}

ScriptsUpdateFuture an abstraction for monitoring and retrieving the results of a long-running operation.

func (*ScriptsUpdateFuture) UnmarshalJSON 

func (future *ScriptsUpdateFuture) UnmarshalJSON(body []byte) error

UnmarshalJSON is the custom unmarshaller for CreateFuture.

type SkuDescription 

type SkuDescription struct {
	// ResourceType - READ-ONLY; The resource type
	ResourceType *string `json:"resourceType,omitempty"`
	// Name - READ-ONLY; The name of the SKU
	Name *string `json:"name,omitempty"`
	// Tier - READ-ONLY; The tier of the SKU
	Tier *string `json:"tier,omitempty"`
	// Locations - READ-ONLY; The set of locations that the SKU is available
	Locations *[]string `json:"locations,omitempty"`
	// LocationInfo - READ-ONLY; Locations and zones
	LocationInfo *[]SkuLocationInfoItem `json:"locationInfo,omitempty"`
	// Restrictions - READ-ONLY; The restrictions because of which SKU cannot be used
	Restrictions *[]interface{} `json:"restrictions,omitempty"`
}

SkuDescription the Kusto SKU description of given resource type

func (SkuDescription) MarshalJSON 

func (sd SkuDescription) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SkuDescription.

type SkuDescriptionList 

type SkuDescriptionList struct {
	autorest.Response `json:"-"`
	// Value - READ-ONLY; SKU descriptions
	Value *[]SkuDescription `json:"value,omitempty"`
}

SkuDescriptionList the list of the EngagementFabric SKU descriptions

func (SkuDescriptionList) MarshalJSON 

func (sdl SkuDescriptionList) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for SkuDescriptionList.

type SkuLocationInfoItem 

type SkuLocationInfoItem struct {
	// Location - The available location of the SKU.
	Location *string `json:"location,omitempty"`
	// Zones - The available zone of the SKU.
	Zones *[]string `json:"zones,omitempty"`
}

SkuLocationInfoItem the locations and zones info for SKU.

type State 

type State string

State enumerates the values for state. 

const (
	// StateCreating ...
	StateCreating State = "Creating"
	// StateDeleted ...
	StateDeleted State = "Deleted"
	// StateDeleting ...
	StateDeleting State = "Deleting"
	// StateRunning ...
	StateRunning State = "Running"
	// StateStarting ...
	StateStarting State = "Starting"
	// StateStopped ...
	StateStopped State = "Stopped"
	// StateStopping ...
	StateStopping State = "Stopping"
	// StateUnavailable ...
	StateUnavailable State = "Unavailable"
	// StateUpdating ...
	StateUpdating State = "Updating"
)

func PossibleStateValues 

func PossibleStateValues() []State

PossibleStateValues returns an array of possible values for the State const type.

type Status 

type Status string

Status enumerates the values for status. 

const (
	// StatusCanceled ...
	StatusCanceled Status = "Canceled"
	// StatusFailed ...
	StatusFailed Status = "Failed"
	// StatusRunning ...
	StatusRunning Status = "Running"
	// StatusSucceeded ...
	StatusSucceeded Status = "Succeeded"
)

func PossibleStatusValues 

func PossibleStatusValues() []Status

PossibleStatusValues returns an array of possible values for the Status const type.

type SystemData 

type SystemData struct {
	// CreatedBy - The identity that created the resource.
	CreatedBy *string `json:"createdBy,omitempty"`
	// CreatedByType - The type of identity that created the resource. Possible values include: 'CreatedByTypeUser', 'CreatedByTypeApplication', 'CreatedByTypeManagedIdentity', 'CreatedByTypeKey'
	CreatedByType CreatedByType `json:"createdByType,omitempty"`
	// CreatedAt - The timestamp of resource creation (UTC).
	CreatedAt *date.Time `json:"createdAt,omitempty"`
	// LastModifiedBy - The identity that last modified the resource.
	LastModifiedBy *string `json:"lastModifiedBy,omitempty"`
	// LastModifiedByType - The type of identity that last modified the resource. Possible values include: 'CreatedByTypeUser', 'CreatedByTypeApplication', 'CreatedByTypeManagedIdentity', 'CreatedByTypeKey'
	LastModifiedByType CreatedByType `json:"lastModifiedByType,omitempty"`
	// LastModifiedAt - The timestamp of resource last modification (UTC)
	LastModifiedAt *date.Time `json:"lastModifiedAt,omitempty"`
}

SystemData metadata pertaining to creation and last modification of the resource.

type TableLevelSharingProperties 

type TableLevelSharingProperties struct {
	// TablesToInclude - List of tables to include in the follower database
	TablesToInclude *[]string `json:"tablesToInclude,omitempty"`
	// TablesToExclude - List of tables to exclude from the follower database
	TablesToExclude *[]string `json:"tablesToExclude,omitempty"`
	// ExternalTablesToInclude - List of external tables to include in the follower database
	ExternalTablesToInclude *[]string `json:"externalTablesToInclude,omitempty"`
	// ExternalTablesToExclude - List of external tables exclude from the follower database
	ExternalTablesToExclude *[]string `json:"externalTablesToExclude,omitempty"`
	// MaterializedViewsToInclude - List of materialized views to include in the follower database
	MaterializedViewsToInclude *[]string `json:"materializedViewsToInclude,omitempty"`
	// MaterializedViewsToExclude - List of materialized views exclude from the follower database
	MaterializedViewsToExclude *[]string `json:"materializedViewsToExclude,omitempty"`
}

TableLevelSharingProperties tables that will be included and excluded in the follower database

type TrackedResource 

type TrackedResource struct {
	// Tags - Resource tags.
	Tags map[string]*string `json:"tags"`
	// Location - The geo-location where the resource lives
	Location *string `json:"location,omitempty"`
	// ID - READ-ONLY; Fully qualified resource ID for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
	ID *string `json:"id,omitempty"`
	// Name - READ-ONLY; The name of the resource
	Name *string `json:"name,omitempty"`
	// Type - READ-ONLY; The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
	Type *string `json:"type,omitempty"`
}

TrackedResource the resource model definition for an Azure Resource Manager tracked top level resource which has 'tags' and a 'location'

func (TrackedResource) MarshalJSON 

func (tr TrackedResource) MarshalJSON() ([]byte, error)

MarshalJSON is the custom marshaler for TrackedResource.

type TrustedExternalTenant 

type TrustedExternalTenant struct {
	// Value - GUID representing an external tenant.
	Value *string `json:"value,omitempty"`
}

TrustedExternalTenant represents a tenant ID that is trusted by the cluster.

type Type 

type Type string

Type enumerates the values for type. 

const (
	// TypeMicrosoftKustoclustersattachedDatabaseConfigurations ...
	TypeMicrosoftKustoclustersattachedDatabaseConfigurations Type = "Microsoft.Kusto/clusters/attachedDatabaseConfigurations"
	// TypeMicrosoftKustoclustersdatabases ...
	TypeMicrosoftKustoclustersdatabases Type = "Microsoft.Kusto/clusters/databases"
)

func PossibleTypeValues 

func PossibleTypeValues() []Type

PossibleTypeValues returns an array of possible values for the Type const type.

type VirtualNetworkConfiguration 

type VirtualNetworkConfiguration struct {
	// SubnetID - The subnet resource id.
	SubnetID *string `json:"subnetId,omitempty"`
	// EnginePublicIPID - Engine service's public IP address resource id.
	EnginePublicIPID *string `json:"enginePublicIpId,omitempty"`
	// DataManagementPublicIPID - Data management's service public IP address resource id.
	DataManagementPublicIPID *string `json:"dataManagementPublicIpId,omitempty"`
}

VirtualNetworkConfiguration a class that contains virtual network definition.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.