Documentation ¶
Index ¶
- type AvailableProviderOperation
- type AvailableProviderOperationDisplay
- type AvailableProviderOperations
- type CustomerSecret
- type DataManager
- type DataManagerList
- type DataManagerUpdateParameter
- type DataManagersClient
- func (client *DataManagersClient) BeginCreate(ctx context.Context, resourceGroupName string, dataManagerName string, ...) (*runtime.Poller[DataManagersClientCreateResponse], error)
- func (client *DataManagersClient) BeginDelete(ctx context.Context, resourceGroupName string, dataManagerName string, ...) (*runtime.Poller[DataManagersClientDeleteResponse], error)
- func (client *DataManagersClient) BeginUpdate(ctx context.Context, resourceGroupName string, dataManagerName string, ...) (*runtime.Poller[DataManagersClientUpdateResponse], error)
- func (client *DataManagersClient) Get(ctx context.Context, resourceGroupName string, dataManagerName string, ...) (DataManagersClientGetResponse, error)
- func (client *DataManagersClient) NewListByResourceGroupPager(resourceGroupName string, ...) *runtime.Pager[DataManagersClientListByResourceGroupResponse]
- func (client *DataManagersClient) NewListPager(options *DataManagersClientListOptions) *runtime.Pager[DataManagersClientListResponse]
- type DataManagersClientBeginCreateOptions
- type DataManagersClientBeginDeleteOptions
- type DataManagersClientBeginUpdateOptions
- type DataManagersClientCreateResponse
- type DataManagersClientDeleteResponse
- type DataManagersClientGetOptions
- type DataManagersClientGetResponse
- type DataManagersClientListByResourceGroupOptions
- type DataManagersClientListByResourceGroupResponse
- type DataManagersClientListOptions
- type DataManagersClientListResponse
- type DataManagersClientUpdateResponse
- type DataService
- type DataServiceList
- type DataServiceProperties
- type DataServicesClient
- func (client *DataServicesClient) Get(ctx context.Context, dataServiceName string, resourceGroupName string, ...) (DataServicesClientGetResponse, error)
- func (client *DataServicesClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, ...) *runtime.Pager[DataServicesClientListByDataManagerResponse]
- type DataServicesClientGetOptions
- type DataServicesClientGetResponse
- type DataServicesClientListByDataManagerOptions
- type DataServicesClientListByDataManagerResponse
- type DataStore
- type DataStoreFilter
- type DataStoreList
- type DataStoreProperties
- type DataStoreType
- type DataStoreTypeList
- type DataStoreTypeProperties
- type DataStoreTypesClient
- func (client *DataStoreTypesClient) Get(ctx context.Context, dataStoreTypeName string, resourceGroupName string, ...) (DataStoreTypesClientGetResponse, error)
- func (client *DataStoreTypesClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, ...) *runtime.Pager[DataStoreTypesClientListByDataManagerResponse]
- type DataStoreTypesClientGetOptions
- type DataStoreTypesClientGetResponse
- type DataStoreTypesClientListByDataManagerOptions
- type DataStoreTypesClientListByDataManagerResponse
- type DataStoresClient
- func (client *DataStoresClient) BeginCreateOrUpdate(ctx context.Context, dataStoreName string, resourceGroupName string, ...) (*runtime.Poller[DataStoresClientCreateOrUpdateResponse], error)
- func (client *DataStoresClient) BeginDelete(ctx context.Context, dataStoreName string, resourceGroupName string, ...) (*runtime.Poller[DataStoresClientDeleteResponse], error)
- func (client *DataStoresClient) Get(ctx context.Context, dataStoreName string, resourceGroupName string, ...) (DataStoresClientGetResponse, error)
- func (client *DataStoresClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, ...) *runtime.Pager[DataStoresClientListByDataManagerResponse]
- type DataStoresClientBeginCreateOrUpdateOptions
- type DataStoresClientBeginDeleteOptions
- type DataStoresClientCreateOrUpdateResponse
- type DataStoresClientDeleteResponse
- type DataStoresClientGetOptions
- type DataStoresClientGetResponse
- type DataStoresClientListByDataManagerOptions
- type DataStoresClientListByDataManagerResponse
- type DmsBaseObject
- type Error
- type ErrorDetails
- type IsJobCancellable
- type Job
- type JobDefinition
- type JobDefinitionFilter
- type JobDefinitionList
- type JobDefinitionProperties
- type JobDefinitionsClient
- func (client *JobDefinitionsClient) BeginCreateOrUpdate(ctx context.Context, dataServiceName string, jobDefinitionName string, ...) (*runtime.Poller[JobDefinitionsClientCreateOrUpdateResponse], error)
- func (client *JobDefinitionsClient) BeginDelete(ctx context.Context, dataServiceName string, jobDefinitionName string, ...) (*runtime.Poller[JobDefinitionsClientDeleteResponse], error)
- func (client *JobDefinitionsClient) BeginRun(ctx context.Context, dataServiceName string, jobDefinitionName string, ...) (*runtime.Poller[JobDefinitionsClientRunResponse], error)
- func (client *JobDefinitionsClient) Get(ctx context.Context, dataServiceName string, jobDefinitionName string, ...) (JobDefinitionsClientGetResponse, error)
- func (client *JobDefinitionsClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, ...) *runtime.Pager[JobDefinitionsClientListByDataManagerResponse]
- func (client *JobDefinitionsClient) NewListByDataServicePager(dataServiceName string, resourceGroupName string, dataManagerName string, ...) *runtime.Pager[JobDefinitionsClientListByDataServiceResponse]
- type JobDefinitionsClientBeginCreateOrUpdateOptions
- type JobDefinitionsClientBeginDeleteOptions
- type JobDefinitionsClientBeginRunOptions
- type JobDefinitionsClientCreateOrUpdateResponse
- type JobDefinitionsClientDeleteResponse
- type JobDefinitionsClientGetOptions
- type JobDefinitionsClientGetResponse
- type JobDefinitionsClientListByDataManagerOptions
- type JobDefinitionsClientListByDataManagerResponse
- type JobDefinitionsClientListByDataServiceOptions
- type JobDefinitionsClientListByDataServiceResponse
- type JobDefinitionsClientRunResponse
- type JobDetails
- type JobFilter
- type JobList
- type JobProperties
- type JobStages
- type JobStatus
- type JobsClient
- func (client *JobsClient) BeginCancel(ctx context.Context, dataServiceName string, jobDefinitionName string, ...) (*runtime.Poller[JobsClientCancelResponse], error)
- func (client *JobsClient) BeginResume(ctx context.Context, dataServiceName string, jobDefinitionName string, ...) (*runtime.Poller[JobsClientResumeResponse], error)
- func (client *JobsClient) Get(ctx context.Context, dataServiceName string, jobDefinitionName string, ...) (JobsClientGetResponse, error)
- func (client *JobsClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, ...) *runtime.Pager[JobsClientListByDataManagerResponse]
- func (client *JobsClient) NewListByDataServicePager(dataServiceName string, resourceGroupName string, dataManagerName string, ...) *runtime.Pager[JobsClientListByDataServiceResponse]
- func (client *JobsClient) NewListByJobDefinitionPager(dataServiceName string, jobDefinitionName string, resourceGroupName string, ...) *runtime.Pager[JobsClientListByJobDefinitionResponse]
- type JobsClientBeginCancelOptions
- type JobsClientBeginResumeOptions
- type JobsClientCancelResponse
- type JobsClientGetOptions
- type JobsClientGetResponse
- type JobsClientListByDataManagerOptions
- type JobsClientListByDataManagerResponse
- type JobsClientListByDataServiceOptions
- type JobsClientListByDataServiceResponse
- type JobsClientListByJobDefinitionOptions
- type JobsClientListByJobDefinitionResponse
- type JobsClientResumeResponse
- type Key
- type OperationsClient
- type OperationsClientListOptions
- type OperationsClientListResponse
- type PublicKey
- type PublicKeyList
- type PublicKeyProperties
- type PublicKeysClient
- func (client *PublicKeysClient) Get(ctx context.Context, publicKeyName string, resourceGroupName string, ...) (PublicKeysClientGetResponse, error)
- func (client *PublicKeysClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, ...) *runtime.Pager[PublicKeysClientListByDataManagerResponse]
- type PublicKeysClientGetOptions
- type PublicKeysClientGetResponse
- type PublicKeysClientListByDataManagerOptions
- type PublicKeysClientListByDataManagerResponse
- type Resource
- type RunLocation
- type RunParameters
- type SKU
- type Schedule
- type State
- type SupportedAlgorithm
- type UserConfirmation
Examples ¶
- DataManagersClient.BeginCreate
- DataManagersClient.BeginDelete
- DataManagersClient.BeginUpdate
- DataManagersClient.Get
- DataManagersClient.NewListByResourceGroupPager
- DataManagersClient.NewListPager
- DataServicesClient.Get
- DataServicesClient.NewListByDataManagerPager
- DataStoreTypesClient.Get
- DataStoreTypesClient.NewListByDataManagerPager
- DataStoresClient.BeginCreateOrUpdate
- DataStoresClient.BeginDelete
- DataStoresClient.Get
- DataStoresClient.NewListByDataManagerPager
- JobDefinitionsClient.BeginCreateOrUpdate
- JobDefinitionsClient.BeginDelete
- JobDefinitionsClient.BeginRun
- JobDefinitionsClient.Get
- JobDefinitionsClient.NewListByDataManagerPager
- JobDefinitionsClient.NewListByDataServicePager
- JobsClient.BeginCancel
- JobsClient.BeginResume
- JobsClient.Get
- JobsClient.NewListByDataManagerPager
- JobsClient.NewListByDataServicePager
- JobsClient.NewListByJobDefinitionPager
- OperationsClient.NewListPager
- PublicKeysClient.Get
- PublicKeysClient.NewListByDataManagerPager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AvailableProviderOperation ¶
type AvailableProviderOperation struct { // REQUIRED; Gets or Sets Name of the operations Name *string `json:"name,omitempty"` // Gets or sets Display information Contains the localized display information for this particular operation/action Display *AvailableProviderOperationDisplay `json:"display,omitempty"` // Gets or sets Origin The intended executor of the operation; governs the display of the operation in the RBAC UX and the // audit logs UX. Default value is “user,system” Origin *string `json:"origin,omitempty"` // Gets or sets Properties Reserved for future use Properties interface{} `json:"properties,omitempty"` }
AvailableProviderOperation - Class represents provider operation
type AvailableProviderOperationDisplay ¶
type AvailableProviderOperationDisplay struct { // Gets or sets Description The localized friendly description for the operation, as it should be shown to the user. It should // be thorough, yet concise – it will be used in tool tips and detailed views. Description *string `json:"description,omitempty"` // Gets or sets Operation The localized friendly name for the operation, as it should be shown to the user. It should be concise // (to fit in drop downs) but clear (i.e. self-documenting). It should use // Title Casing and include the entity/resource to which it applies. Operation *string `json:"operation,omitempty"` // Gets or sets Provider The localized friendly form of the resource provider name – it is expected to also include the publisher/company // responsible. It should use Title Casing and begin with // “Microsoft” for 1st party services. Provider *string `json:"provider,omitempty"` // Gets or sets Resource The localized friendly form of the resource type related to this action/operation – it should match // the public documentation for the resource provider. It should use Title Casing // – for examples, please refer to the “name” section. Resource *string `json:"resource,omitempty"` }
AvailableProviderOperationDisplay - Contains the localized display information for this particular operation / action. These value will be used by several clients for (1) custom role definitions for RBAC; (2) complex query filters for the event service; and (3) audit history / records for management operations.
type AvailableProviderOperations ¶
type AvailableProviderOperations struct { // Link for the next set of operations. NextLink *string `json:"nextLink,omitempty"` // List of operations. Value []*AvailableProviderOperation `json:"value,omitempty"` }
AvailableProviderOperations - Class for set of operations used for discovery of available provider operations.
type CustomerSecret ¶
type CustomerSecret struct { // REQUIRED; The encryption algorithm used to encrypt data. Algorithm *SupportedAlgorithm `json:"algorithm,omitempty"` // REQUIRED; The identifier to the data service input object which this secret corresponds to. KeyIdentifier *string `json:"keyIdentifier,omitempty"` // REQUIRED; It contains the encrypted customer secret. KeyValue *string `json:"keyValue,omitempty"` }
CustomerSecret - The pair of customer secret.
type DataManager ¶
type DataManager struct { // REQUIRED; The location of the resource. This will be one of the supported and registered Azure Geo Regions (e.g. West US, // East US, Southeast Asia, etc.). The geo region of a resource cannot be changed once it // is created, but if an identical geo region is specified on update the request will succeed. Location *string `json:"location,omitempty"` // Etag of the Resource. Etag *string `json:"etag,omitempty"` // The sku type. SKU *SKU `json:"sku,omitempty"` // The list of key value pairs that describe the resource. These tags can be used in viewing and grouping this resource (across // resource groups). Tags map[string]*string `json:"tags,omitempty"` // READ-ONLY; The Resource Id. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The Resource Name. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The Resource type. Type *string `json:"type,omitempty" azure:"ro"` }
DataManager - The DataManager resource.
func (DataManager) MarshalJSON ¶
func (d DataManager) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type DataManager.
type DataManagerList ¶
type DataManagerList struct { // Link for the next set of data stores. NextLink *string `json:"nextLink,omitempty"` // List of data manager resources. Value []*DataManager `json:"value,omitempty"` }
DataManagerList - DataManager resources Collection.
type DataManagerUpdateParameter ¶
type DataManagerUpdateParameter struct { // The sku type. SKU *SKU `json:"sku,omitempty"` // The list of key value pairs that describe the resource. These tags can be used in viewing and grouping this resource (across // resource groups). Tags map[string]*string `json:"tags,omitempty"` }
DataManagerUpdateParameter - The DataManagerUpdateParameter.
func (DataManagerUpdateParameter) MarshalJSON ¶
func (d DataManagerUpdateParameter) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type DataManagerUpdateParameter.
type DataManagersClient ¶
type DataManagersClient struct {
// contains filtered or unexported fields
}
DataManagersClient contains the methods for the DataManagers group. Don't use this type directly, use NewDataManagersClient() instead.
func NewDataManagersClient ¶
func NewDataManagersClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*DataManagersClient, error)
NewDataManagersClient creates a new instance of DataManagersClient with the specified values. subscriptionID - The Subscription Id credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*DataManagersClient) BeginCreate ¶
func (client *DataManagersClient) BeginCreate(ctx context.Context, resourceGroupName string, dataManagerName string, dataManager DataManager, options *DataManagersClientBeginCreateOptions) (*runtime.Poller[DataManagersClientCreateResponse], error)
BeginCreate - Creates a new data manager resource with the specified parameters. Existing resources cannot be updated with this API and should instead be updated with the Update data manager resource API. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only dataManager - Data manager resource details from request body. options - DataManagersClientBeginCreateOptions contains the optional parameters for the DataManagersClient.BeginCreate method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataManagers_Create-PUT-example-41.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataManagersClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginCreate(ctx, "ResourceGroupForSDKTest", "TestAzureSDKOperations", armhybriddatamanager.DataManager{ Location: to.Ptr("westus"), }, nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } res, err := poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } // TODO: use response item _ = res }
Output:
func (*DataManagersClient) BeginDelete ¶
func (client *DataManagersClient) BeginDelete(ctx context.Context, resourceGroupName string, dataManagerName string, options *DataManagersClientBeginDeleteOptions) (*runtime.Poller[DataManagersClientDeleteResponse], error)
BeginDelete - Deletes a data manager resource in Microsoft Azure. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataManagersClientBeginDeleteOptions contains the optional parameters for the DataManagersClient.BeginDelete method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataManagers_Delete-DELETE-example-41.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataManagersClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginDelete(ctx, "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } _, err = poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } }
Output:
func (*DataManagersClient) BeginUpdate ¶
func (client *DataManagersClient) BeginUpdate(ctx context.Context, resourceGroupName string, dataManagerName string, dataManagerUpdateParameter DataManagerUpdateParameter, options *DataManagersClientBeginUpdateOptions) (*runtime.Poller[DataManagersClientUpdateResponse], error)
BeginUpdate - Updates the properties of an existing data manager resource. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only dataManagerUpdateParameter - Data manager resource details from request body. options - DataManagersClientBeginUpdateOptions contains the optional parameters for the DataManagersClient.BeginUpdate method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataManagers_Update-PATCH-example-43.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataManagersClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginUpdate(ctx, "ResourceGroupForSDKTest", "TestAzureSDKOperations", armhybriddatamanager.DataManagerUpdateParameter{ SKU: &armhybriddatamanager.SKU{ Name: to.Ptr("DS0"), Tier: to.Ptr("Standard"), }, Tags: map[string]*string{ "UpdateDateTime": to.Ptr("05-Feb-20 2:17:22 PM"), }, }, &armhybriddatamanager.DataManagersClientBeginUpdateOptions{IfMatch: nil}) if err != nil { log.Fatalf("failed to finish the request: %v", err) } res, err := poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } // TODO: use response item _ = res }
Output:
func (*DataManagersClient) Get ¶
func (client *DataManagersClient) Get(ctx context.Context, resourceGroupName string, dataManagerName string, options *DataManagersClientGetOptions) (DataManagersClientGetResponse, error)
Get - Gets information about the specified data manager resource. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataManagersClientGetOptions contains the optional parameters for the DataManagersClient.Get method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataManagers_Get-GET-example-41.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataManagersClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } res, err := client.Get(ctx, "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } // TODO: use response item _ = res }
Output:
func (*DataManagersClient) NewListByResourceGroupPager ¶ added in v0.4.0
func (client *DataManagersClient) NewListByResourceGroupPager(resourceGroupName string, options *DataManagersClientListByResourceGroupOptions) *runtime.Pager[DataManagersClientListByResourceGroupResponse]
NewListByResourceGroupPager - Lists all the data manager resources available under the given resource group. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name options - DataManagersClientListByResourceGroupOptions contains the optional parameters for the DataManagersClient.ListByResourceGroup method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataManagers_ListByResourceGroup-GET-example-31.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataManagersClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByResourceGroupPager("ResourceGroupForSDKTest", nil) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
func (*DataManagersClient) NewListPager ¶ added in v0.4.0
func (client *DataManagersClient) NewListPager(options *DataManagersClientListOptions) *runtime.Pager[DataManagersClientListResponse]
NewListPager - Lists all the data manager resources available under the subscription. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 options - DataManagersClientListOptions contains the optional parameters for the DataManagersClient.List method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataManagers_List-GET-example-21.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataManagersClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListPager(nil) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type DataManagersClientBeginCreateOptions ¶ added in v0.2.0
type DataManagersClientBeginCreateOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
DataManagersClientBeginCreateOptions contains the optional parameters for the DataManagersClient.BeginCreate method.
type DataManagersClientBeginDeleteOptions ¶ added in v0.2.0
type DataManagersClientBeginDeleteOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
DataManagersClientBeginDeleteOptions contains the optional parameters for the DataManagersClient.BeginDelete method.
type DataManagersClientBeginUpdateOptions ¶ added in v0.2.0
type DataManagersClientBeginUpdateOptions struct { // Defines the If-Match condition. The patch will be performed only if the ETag of the data manager resource on the server // matches this value. IfMatch *string // Resumes the LRO from the provided token. ResumeToken string }
DataManagersClientBeginUpdateOptions contains the optional parameters for the DataManagersClient.BeginUpdate method.
type DataManagersClientCreateResponse ¶ added in v0.2.0
type DataManagersClientCreateResponse struct {
DataManager
}
DataManagersClientCreateResponse contains the response from method DataManagersClient.Create.
type DataManagersClientDeleteResponse ¶ added in v0.2.0
type DataManagersClientDeleteResponse struct { }
DataManagersClientDeleteResponse contains the response from method DataManagersClient.Delete.
type DataManagersClientGetOptions ¶ added in v0.2.0
type DataManagersClientGetOptions struct { }
DataManagersClientGetOptions contains the optional parameters for the DataManagersClient.Get method.
type DataManagersClientGetResponse ¶ added in v0.2.0
type DataManagersClientGetResponse struct {
DataManager
}
DataManagersClientGetResponse contains the response from method DataManagersClient.Get.
type DataManagersClientListByResourceGroupOptions ¶ added in v0.2.0
type DataManagersClientListByResourceGroupOptions struct { }
DataManagersClientListByResourceGroupOptions contains the optional parameters for the DataManagersClient.ListByResourceGroup method.
type DataManagersClientListByResourceGroupResponse ¶ added in v0.2.0
type DataManagersClientListByResourceGroupResponse struct {
DataManagerList
}
DataManagersClientListByResourceGroupResponse contains the response from method DataManagersClient.ListByResourceGroup.
type DataManagersClientListOptions ¶ added in v0.2.0
type DataManagersClientListOptions struct { }
DataManagersClientListOptions contains the optional parameters for the DataManagersClient.List method.
type DataManagersClientListResponse ¶ added in v0.2.0
type DataManagersClientListResponse struct {
DataManagerList
}
DataManagersClientListResponse contains the response from method DataManagersClient.List.
type DataManagersClientUpdateResponse ¶ added in v0.2.0
type DataManagersClientUpdateResponse struct {
DataManager
}
DataManagersClientUpdateResponse contains the response from method DataManagersClient.Update.
type DataService ¶
type DataService struct { // REQUIRED; DataService properties. Properties *DataServiceProperties `json:"properties,omitempty"` // READ-ONLY; Id of the object. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; Name of the object. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; Type of the object. Type *string `json:"type,omitempty" azure:"ro"` }
DataService - Data Service.
type DataServiceList ¶
type DataServiceList struct { // Link for the next set of data services. NextLink *string `json:"nextLink,omitempty"` // List of data services. Value []*DataService `json:"value,omitempty"` }
DataServiceList - Data Service Collection.
type DataServiceProperties ¶
type DataServiceProperties struct { // REQUIRED; State of the data service. State *State `json:"state,omitempty"` // Supported data store types which can be used as a sink. SupportedDataSinkTypes []*string `json:"supportedDataSinkTypes,omitempty"` // Supported data store types which can be used as a source. SupportedDataSourceTypes []*string `json:"supportedDataSourceTypes,omitempty"` }
DataServiceProperties - Data Service properties.
func (DataServiceProperties) MarshalJSON ¶
func (d DataServiceProperties) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type DataServiceProperties.
type DataServicesClient ¶
type DataServicesClient struct {
// contains filtered or unexported fields
}
DataServicesClient contains the methods for the DataServices group. Don't use this type directly, use NewDataServicesClient() instead.
func NewDataServicesClient ¶
func NewDataServicesClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*DataServicesClient, error)
NewDataServicesClient creates a new instance of DataServicesClient with the specified values. subscriptionID - The Subscription Id credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*DataServicesClient) Get ¶
func (client *DataServicesClient) Get(ctx context.Context, dataServiceName string, resourceGroupName string, dataManagerName string, options *DataServicesClientGetOptions) (DataServicesClientGetResponse, error)
Get - Gets the data service that matches the data service name given. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The name of the data service that is being queried. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataServicesClientGetOptions contains the optional parameters for the DataServicesClient.Get method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataServices_Get-GET-example-62.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataServicesClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } res, err := client.Get(ctx, "DataTransformation", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } // TODO: use response item _ = res }
Output:
func (*DataServicesClient) NewListByDataManagerPager ¶ added in v0.4.0
func (client *DataServicesClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, options *DataServicesClientListByDataManagerOptions) *runtime.Pager[DataServicesClientListByDataManagerResponse]
NewListByDataManagerPager - This method gets all the data services. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataServicesClientListByDataManagerOptions contains the optional parameters for the DataServicesClient.ListByDataManager method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataServices_ListByDataManager-GET-example-51.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataServicesClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataManagerPager("ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type DataServicesClientGetOptions ¶ added in v0.2.0
type DataServicesClientGetOptions struct { }
DataServicesClientGetOptions contains the optional parameters for the DataServicesClient.Get method.
type DataServicesClientGetResponse ¶ added in v0.2.0
type DataServicesClientGetResponse struct {
DataService
}
DataServicesClientGetResponse contains the response from method DataServicesClient.Get.
type DataServicesClientListByDataManagerOptions ¶ added in v0.2.0
type DataServicesClientListByDataManagerOptions struct { }
DataServicesClientListByDataManagerOptions contains the optional parameters for the DataServicesClient.ListByDataManager method.
type DataServicesClientListByDataManagerResponse ¶ added in v0.2.0
type DataServicesClientListByDataManagerResponse struct {
DataServiceList
}
DataServicesClientListByDataManagerResponse contains the response from method DataServicesClient.ListByDataManager.
type DataStore ¶
type DataStore struct { // REQUIRED; DataStore properties. Properties *DataStoreProperties `json:"properties,omitempty"` // READ-ONLY; Id of the object. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; Name of the object. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; Type of the object. Type *string `json:"type,omitempty" azure:"ro"` }
DataStore - Data store.
type DataStoreFilter ¶
type DataStoreFilter struct { // The data store type id. DataStoreTypeID *string `json:"dataStoreTypeId,omitempty"` }
DataStoreFilter - Contains the information about the filters for the DataStore.
type DataStoreList ¶
type DataStoreList struct { // Link for the next set of data stores. NextLink *string `json:"nextLink,omitempty"` // List of data stores. Value []*DataStore `json:"value,omitempty"` }
DataStoreList - Data Store Collection.
type DataStoreProperties ¶
type DataStoreProperties struct { // REQUIRED; The arm id of the data store type. DataStoreTypeID *string `json:"dataStoreTypeId,omitempty"` // REQUIRED; State of the data source. State *State `json:"state,omitempty"` // List of customer secrets containing a key identifier and key value. The key identifier is a way for the specific data source // to understand the key. Value contains customer secret encrypted by the // encryptionKeys. CustomerSecrets []*CustomerSecret `json:"customerSecrets,omitempty"` // A generic json used differently by each data source type. ExtendedProperties interface{} `json:"extendedProperties,omitempty"` // Arm Id for the manager resource to which the data source is associated. This is optional. RepositoryID *string `json:"repositoryId,omitempty"` }
DataStoreProperties - Data Store for sources and sinks
func (DataStoreProperties) MarshalJSON ¶
func (d DataStoreProperties) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type DataStoreProperties.
type DataStoreType ¶
type DataStoreType struct { // REQUIRED; DataStoreType properties. Properties *DataStoreTypeProperties `json:"properties,omitempty"` // READ-ONLY; Id of the object. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; Name of the object. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; Type of the object. Type *string `json:"type,omitempty" azure:"ro"` }
DataStoreType - Data Store Type.
type DataStoreTypeList ¶
type DataStoreTypeList struct { // Link for the next set of data store types. NextLink *string `json:"nextLink,omitempty"` // List of DataStoreType. Value []*DataStoreType `json:"value,omitempty"` }
DataStoreTypeList - Data Store Type Collection.
type DataStoreTypeProperties ¶
type DataStoreTypeProperties struct { // REQUIRED; State of the data store type. State *State `json:"state,omitempty"` // Arm type for the manager resource to which the data source type is associated. This is optional. RepositoryType *string `json:"repositoryType,omitempty"` // Supported data services where it can be used as a sink. SupportedDataServicesAsSink []*string `json:"supportedDataServicesAsSink,omitempty"` // Supported data services where it can be used as a source. SupportedDataServicesAsSource []*string `json:"supportedDataServicesAsSource,omitempty"` }
DataStoreTypeProperties - Data Store Type properties.
func (DataStoreTypeProperties) MarshalJSON ¶
func (d DataStoreTypeProperties) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type DataStoreTypeProperties.
type DataStoreTypesClient ¶
type DataStoreTypesClient struct {
// contains filtered or unexported fields
}
DataStoreTypesClient contains the methods for the DataStoreTypes group. Don't use this type directly, use NewDataStoreTypesClient() instead.
func NewDataStoreTypesClient ¶
func NewDataStoreTypesClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*DataStoreTypesClient, error)
NewDataStoreTypesClient creates a new instance of DataStoreTypesClient with the specified values. subscriptionID - The Subscription Id credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*DataStoreTypesClient) Get ¶
func (client *DataStoreTypesClient) Get(ctx context.Context, dataStoreTypeName string, resourceGroupName string, dataManagerName string, options *DataStoreTypesClientGetOptions) (DataStoreTypesClientGetResponse, error)
Get - Gets the data store/repository type given its name. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataStoreTypeName - The data store/repository type name for which details are needed. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataStoreTypesClientGetOptions contains the optional parameters for the DataStoreTypesClient.Get method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataStoreTypes_Get-GET-example-182.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataStoreTypesClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } res, err := client.Get(ctx, "StorSimple8000Series", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } // TODO: use response item _ = res }
Output:
func (*DataStoreTypesClient) NewListByDataManagerPager ¶ added in v0.4.0
func (client *DataStoreTypesClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, options *DataStoreTypesClientListByDataManagerOptions) *runtime.Pager[DataStoreTypesClientListByDataManagerResponse]
NewListByDataManagerPager - Gets all the data store/repository types that the resource supports. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataStoreTypesClientListByDataManagerOptions contains the optional parameters for the DataStoreTypesClient.ListByDataManager method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataStoreTypes_ListByDataManager-GET-example-171.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataStoreTypesClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataManagerPager("ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type DataStoreTypesClientGetOptions ¶ added in v0.2.0
type DataStoreTypesClientGetOptions struct { }
DataStoreTypesClientGetOptions contains the optional parameters for the DataStoreTypesClient.Get method.
type DataStoreTypesClientGetResponse ¶ added in v0.2.0
type DataStoreTypesClientGetResponse struct {
DataStoreType
}
DataStoreTypesClientGetResponse contains the response from method DataStoreTypesClient.Get.
type DataStoreTypesClientListByDataManagerOptions ¶ added in v0.2.0
type DataStoreTypesClientListByDataManagerOptions struct { }
DataStoreTypesClientListByDataManagerOptions contains the optional parameters for the DataStoreTypesClient.ListByDataManager method.
type DataStoreTypesClientListByDataManagerResponse ¶ added in v0.2.0
type DataStoreTypesClientListByDataManagerResponse struct {
DataStoreTypeList
}
DataStoreTypesClientListByDataManagerResponse contains the response from method DataStoreTypesClient.ListByDataManager.
type DataStoresClient ¶
type DataStoresClient struct {
// contains filtered or unexported fields
}
DataStoresClient contains the methods for the DataStores group. Don't use this type directly, use NewDataStoresClient() instead.
func NewDataStoresClient ¶
func NewDataStoresClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*DataStoresClient, error)
NewDataStoresClient creates a new instance of DataStoresClient with the specified values. subscriptionID - The Subscription Id credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*DataStoresClient) BeginCreateOrUpdate ¶
func (client *DataStoresClient) BeginCreateOrUpdate(ctx context.Context, dataStoreName string, resourceGroupName string, dataManagerName string, dataStore DataStore, options *DataStoresClientBeginCreateOrUpdateOptions) (*runtime.Poller[DataStoresClientCreateOrUpdateResponse], error)
BeginCreateOrUpdate - Creates or updates the data store/repository in the data manager. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataStoreName - The data store/repository name to be created or updated. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only dataStore - The data store/repository object to be created or updated. options - DataStoresClientBeginCreateOrUpdateOptions contains the optional parameters for the DataStoresClient.BeginCreateOrUpdate method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataStores_CreateOrUpdate_DataSink-PUT-example-162.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataStoresClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginCreateOrUpdate(ctx, "TestAzureStorage1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", armhybriddatamanager.DataStore{ Properties: &armhybriddatamanager.DataStoreProperties{ CustomerSecrets: []*armhybriddatamanager.CustomerSecret{ { Algorithm: to.Ptr(armhybriddatamanager.SupportedAlgorithmRSA15), KeyIdentifier: to.Ptr("StorageAccountAccessKey"), KeyValue: to.Ptr("Of4H9eF03G8QuxvkZQEbFWv3YdN3U//WugzuqReQekbXXQyg+QSicVKrwSOOKVi1zWMYGbKg7d5/ES2gdz+O5ZEw89bvE4mJD/wQmkIsqhPnbN0gyVK6nZePXVUU1A+UzjLfvhSA6KyUQfzNAZ5/TLt6fo1JyQrKTtkvnkLFyfv1AqBZ+dw8JK3RZi/rEN8HD3R3qsBwUYfyEuGLGiujy2CGrr/1uPiUVMR6QuFWRsjm39eMSHa4maLg4tQ0IY/jIy8rMlx3KjF3CcCbPzAqEq5vXy37wkjZbus771te1gLSrzcpVKIMg4DrmgaoJ02jAu+izBjNgLXAFPSUneQ8yw==:ezMkh4PMhCnjJtYkpTaP0SdblP5VAeRe4glW2PgIzICHw3T8ZyGDoaTrCv4/m5wtcEhWdtxhta+j1MQWlK5MIA+hvf8QjIDIjQv696ov5y+pcFe/upd2ekGOei7FCwB2u7I8WnkAtIKTUkf6eDQBZXm26DjfG1Dlc+Mjjq+AerukEa6WpOyqrD7Qub26Pgmj4AsuBx19X1EAmTZacubkoiNagXM8V+IDanHOhLMvfgQ7rw8oZhWfofxi4m+eJqjOXXaqSyorNK8UEcqP6P9pDP8AN8ulXEx6rZy2B5Oi0vSV+wlRLbUuQslga4ItOGxctW/ZX8uWozt+5A3k4URt6A=="), }, { Algorithm: to.Ptr(armhybriddatamanager.SupportedAlgorithmRSA15), KeyIdentifier: to.Ptr("StorageAccountAccessKeyForQueue"), KeyValue: to.Ptr("Of4H9eF03G8QuxvkZQEbFWv3YdN3U//WugzuqReQekbXXQyg+QSicVKrwSOOKVi1zWMYGbKg7d5/ES2gdz+O5ZEw89bvE4mJD/wQmkIsqhPnbN0gyVK6nZePXVUU1A+UzjLfvhSA6KyUQfzNAZ5/TLt6fo1JyQrKTtkvnkLFyfv1AqBZ+dw8JK3RZi/rEN8HD3R3qsBwUYfyEuGLGiujy2CGrr/1uPiUVMR6QuFWRsjm39eMSHa4maLg4tQ0IY/jIy8rMlx3KjF3CcCbPzAqEq5vXy37wkjZbus771te1gLSrzcpVKIMg4DrmgaoJ02jAu+izBjNgLXAFPSUneQ8yw==:ezMkh4PMhCnjJtYkpTaP0SdblP5VAeRe4glW2PgIzICHw3T8ZyGDoaTrCv4/m5wtcEhWdtxhta+j1MQWlK5MIA+hvf8QjIDIjQv696ov5y+pcFe/upd2ekGOei7FCwB2u7I8WnkAtIKTUkf6eDQBZXm26DjfG1Dlc+Mjjq+AerukEa6WpOyqrD7Qub26Pgmj4AsuBx19X1EAmTZacubkoiNagXM8V+IDanHOhLMvfgQ7rw8oZhWfofxi4m+eJqjOXXaqSyorNK8UEcqP6P9pDP8AN8ulXEx6rZy2B5Oi0vSV+wlRLbUuQslga4ItOGxctW/ZX8uWozt+5A3k4URt6A=="), }}, DataStoreTypeID: to.Ptr("/subscriptions/6e0219f5-327a-4365-904f-05eed4227ad7/resourceGroups/ResourceGroupForSDKTest/providers/Microsoft.HybridData/dataManagers/TestAzureSDKOperations/dataStoreTypes/AzureStorageAccount"), ExtendedProperties: map[string]interface{}{ "extendedSaKey": nil, "extendedSaName": "/subscriptions/6e0219f5-327a-4365-904f-05eed4227ad7/resourceGroups/ResourceGroupForSDKTest/providers/Microsoft.Storage/storageAccounts/dmsdatasink", "storageAccountNameForQueue": "/subscriptions/6e0219f5-327a-4365-904f-05eed4227ad7/resourceGroups/ResourceGroupForSDKTest/providers/Microsoft.Storage/storageAccounts/dmsdatasink", }, RepositoryID: to.Ptr("/subscriptions/6e0219f5-327a-4365-904f-05eed4227ad7/resourceGroups/ResourceGroupForSDKTest/providers/Microsoft.Storage/storageAccounts/dmsdatasink"), State: to.Ptr(armhybriddatamanager.StateEnabled), }, }, nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } res, err := poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } // TODO: use response item _ = res }
Output:
func (*DataStoresClient) BeginDelete ¶
func (client *DataStoresClient) BeginDelete(ctx context.Context, dataStoreName string, resourceGroupName string, dataManagerName string, options *DataStoresClientBeginDeleteOptions) (*runtime.Poller[DataStoresClientDeleteResponse], error)
BeginDelete - This method deletes the given data store/repository. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataStoreName - The data store/repository name to be deleted. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataStoresClientBeginDeleteOptions contains the optional parameters for the DataStoresClient.BeginDelete method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataStores_Delete_DataSink-DELETE-example-161.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataStoresClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginDelete(ctx, "TestAzureStorage1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } _, err = poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } }
Output:
func (*DataStoresClient) Get ¶
func (client *DataStoresClient) Get(ctx context.Context, dataStoreName string, resourceGroupName string, dataManagerName string, options *DataStoresClientGetOptions) (DataStoresClientGetResponse, error)
Get - This method gets the data store/repository by name. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataStoreName - The data store/repository name queried. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataStoresClientGetOptions contains the optional parameters for the DataStoresClient.Get method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataStores_Get-GET-example-161.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataStoresClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } res, err := client.Get(ctx, "TestStorSimpleSource1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } // TODO: use response item _ = res }
Output:
func (*DataStoresClient) NewListByDataManagerPager ¶ added in v0.4.0
func (client *DataStoresClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, options *DataStoresClientListByDataManagerOptions) *runtime.Pager[DataStoresClientListByDataManagerResponse]
NewListByDataManagerPager - Gets all the data stores/repositories in the given resource. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - DataStoresClientListByDataManagerOptions contains the optional parameters for the DataStoresClient.ListByDataManager method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/DataStores_ListByDataManager-GET-example-151.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewDataStoresClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataManagerPager("ResourceGroupForSDKTest", "TestAzureSDKOperations", &armhybriddatamanager.DataStoresClientListByDataManagerOptions{Filter: nil}) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type DataStoresClientBeginCreateOrUpdateOptions ¶ added in v0.2.0
type DataStoresClientBeginCreateOrUpdateOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
DataStoresClientBeginCreateOrUpdateOptions contains the optional parameters for the DataStoresClient.BeginCreateOrUpdate method.
type DataStoresClientBeginDeleteOptions ¶ added in v0.2.0
type DataStoresClientBeginDeleteOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
DataStoresClientBeginDeleteOptions contains the optional parameters for the DataStoresClient.BeginDelete method.
type DataStoresClientCreateOrUpdateResponse ¶ added in v0.2.0
type DataStoresClientCreateOrUpdateResponse struct {
DataStore
}
DataStoresClientCreateOrUpdateResponse contains the response from method DataStoresClient.CreateOrUpdate.
type DataStoresClientDeleteResponse ¶ added in v0.2.0
type DataStoresClientDeleteResponse struct { }
DataStoresClientDeleteResponse contains the response from method DataStoresClient.Delete.
type DataStoresClientGetOptions ¶ added in v0.2.0
type DataStoresClientGetOptions struct { }
DataStoresClientGetOptions contains the optional parameters for the DataStoresClient.Get method.
type DataStoresClientGetResponse ¶ added in v0.2.0
type DataStoresClientGetResponse struct {
DataStore
}
DataStoresClientGetResponse contains the response from method DataStoresClient.Get.
type DataStoresClientListByDataManagerOptions ¶ added in v0.2.0
type DataStoresClientListByDataManagerOptions struct { // OData Filter options Filter *string }
DataStoresClientListByDataManagerOptions contains the optional parameters for the DataStoresClient.ListByDataManager method.
type DataStoresClientListByDataManagerResponse ¶ added in v0.2.0
type DataStoresClientListByDataManagerResponse struct {
DataStoreList
}
DataStoresClientListByDataManagerResponse contains the response from method DataStoresClient.ListByDataManager.
type DmsBaseObject ¶
type DmsBaseObject struct { // READ-ONLY; Id of the object. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; Name of the object. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; Type of the object. Type *string `json:"type,omitempty" azure:"ro"` }
DmsBaseObject - Base class for all objects under DataManager Service
type Error ¶
type Error struct { // REQUIRED; Error code that can be used to programmatically identify the error. Code *string `json:"code,omitempty"` // Describes the error in detail and provides debugging information. Message *string `json:"message,omitempty"` }
Error - Top level error for the job.
type ErrorDetails ¶
type ErrorDetails struct { // Error code. ErrorCode *int32 `json:"errorCode,omitempty"` // Error message. ErrorMessage *string `json:"errorMessage,omitempty"` // Contains the non localized exception message ExceptionMessage *string `json:"exceptionMessage,omitempty"` // Recommended action for the error. RecommendedAction *string `json:"recommendedAction,omitempty"` }
ErrorDetails - Error Details
type IsJobCancellable ¶
type IsJobCancellable string
IsJobCancellable - Describes whether the job is cancellable.
const ( IsJobCancellableNotCancellable IsJobCancellable = "NotCancellable" IsJobCancellableCancellable IsJobCancellable = "Cancellable" )
func PossibleIsJobCancellableValues ¶
func PossibleIsJobCancellableValues() []IsJobCancellable
PossibleIsJobCancellableValues returns the possible values for the IsJobCancellable const type.
type Job ¶
type Job struct { // REQUIRED; Job properties. Properties *JobProperties `json:"properties,omitempty"` // REQUIRED; Time at which the job was started in UTC ISO 8601 format. StartTime *time.Time `json:"startTime,omitempty"` // REQUIRED; Status of the job. Status *JobStatus `json:"status,omitempty"` // Time at which the job ended in UTC ISO 8601 format. EndTime *time.Time `json:"endTime,omitempty"` // Top level error for the job. Error *Error `json:"error,omitempty"` // READ-ONLY; Id of the object. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; Name of the object. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; Type of the object. Type *string `json:"type,omitempty" azure:"ro"` }
Job - Data service job.
func (Job) MarshalJSON ¶
MarshalJSON implements the json.Marshaller interface for type Job.
func (*Job) UnmarshalJSON ¶
UnmarshalJSON implements the json.Unmarshaller interface for type Job.
type JobDefinition ¶
type JobDefinition struct { // REQUIRED; JobDefinition properties. Properties *JobDefinitionProperties `json:"properties,omitempty"` // READ-ONLY; Id of the object. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; Name of the object. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; Type of the object. Type *string `json:"type,omitempty" azure:"ro"` }
JobDefinition - Job Definition.
type JobDefinitionFilter ¶
type JobDefinitionFilter struct { // REQUIRED; The state of the job definition. State *State `json:"state,omitempty"` // The data source associated with the job definition DataSource *string `json:"dataSource,omitempty"` // The last modified date time of the data source. LastModified *time.Time `json:"lastModified,omitempty"` }
JobDefinitionFilter - Contains the supported job definition filters.
func (*JobDefinitionFilter) UnmarshalJSON ¶
func (j *JobDefinitionFilter) UnmarshalJSON(data []byte) error
UnmarshalJSON implements the json.Unmarshaller interface for type JobDefinitionFilter.
type JobDefinitionList ¶
type JobDefinitionList struct { // Link for the next set of job definitions. NextLink *string `json:"nextLink,omitempty"` // List of job definitions. Value []*JobDefinition `json:"value,omitempty"` }
JobDefinitionList - Job Definition Collection.
type JobDefinitionProperties ¶
type JobDefinitionProperties struct { // REQUIRED; Data Sink Id associated to the job definition. DataSinkID *string `json:"dataSinkId,omitempty"` // REQUIRED; Data Source Id associated to the job definition. DataSourceID *string `json:"dataSourceId,omitempty"` // REQUIRED; State of the job definition. State *State `json:"state,omitempty"` // List of customer secrets containing a key identifier and key value. The key identifier is a way for the specific data source // to understand the key. Value contains customer secret encrypted by the // encryptionKeys. CustomerSecrets []*CustomerSecret `json:"customerSecrets,omitempty"` // A generic json used differently by each data service type. DataServiceInput interface{} `json:"dataServiceInput,omitempty"` // Last modified time of the job definition. LastModifiedTime *time.Time `json:"lastModifiedTime,omitempty"` // This is the preferred geo location for the job to run. RunLocation *RunLocation `json:"runLocation,omitempty"` // Schedule for running the job definition Schedules []*Schedule `json:"schedules,omitempty"` // Enum to detect if user confirmation is required. If not passed will default to NotRequired. UserConfirmation *UserConfirmation `json:"userConfirmation,omitempty"` }
JobDefinitionProperties - Job Definition
func (JobDefinitionProperties) MarshalJSON ¶
func (j JobDefinitionProperties) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type JobDefinitionProperties.
func (*JobDefinitionProperties) UnmarshalJSON ¶
func (j *JobDefinitionProperties) UnmarshalJSON(data []byte) error
UnmarshalJSON implements the json.Unmarshaller interface for type JobDefinitionProperties.
type JobDefinitionsClient ¶
type JobDefinitionsClient struct {
// contains filtered or unexported fields
}
JobDefinitionsClient contains the methods for the JobDefinitions group. Don't use this type directly, use NewJobDefinitionsClient() instead.
func NewJobDefinitionsClient ¶
func NewJobDefinitionsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*JobDefinitionsClient, error)
NewJobDefinitionsClient creates a new instance of JobDefinitionsClient with the specified values. subscriptionID - The Subscription Id credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*JobDefinitionsClient) BeginCreateOrUpdate ¶
func (client *JobDefinitionsClient) BeginCreateOrUpdate(ctx context.Context, dataServiceName string, jobDefinitionName string, resourceGroupName string, dataManagerName string, jobDefinition JobDefinition, options *JobDefinitionsClientBeginCreateOrUpdateOptions) (*runtime.Poller[JobDefinitionsClientCreateOrUpdateResponse], error)
BeginCreateOrUpdate - Creates or updates a job definition. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The data service type of the job definition. jobDefinitionName - The job definition name to be created or updated. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only jobDefinition - Job Definition object to be created or updated. options - JobDefinitionsClientBeginCreateOrUpdateOptions contains the optional parameters for the JobDefinitionsClient.BeginCreateOrUpdate method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/JobDefinitions_CreateOrUpdate-PUT-example-83.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobDefinitionsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginCreateOrUpdate(ctx, "DataTransformation", "jobdeffromtestcode1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", armhybriddatamanager.JobDefinition{ Properties: &armhybriddatamanager.JobDefinitionProperties{ DataServiceInput: map[string]interface{}{ "AzureStorageType": "Blob", "BackupChoice": "UseExistingLatest", "ContainerName": "containerfromtest", "DeviceName": "8600-SHG0997877L71FC", "FileNameFilter": "*", "IsDirectoryMode": false, "RootDirectories": []interface{}{ "\\", }, "VolumeNames": []interface{}{ "TestAutomation", }, }, DataSinkID: to.Ptr("/subscriptions/6e0219f5-327a-4365-904f-05eed4227ad7/resourceGroups/ResourceGroupForSDKTest/providers/Microsoft.HybridData/dataManagers/TestAzureSDKOperations/dataStores/TestAzureStorage1"), DataSourceID: to.Ptr("/subscriptions/6e0219f5-327a-4365-904f-05eed4227ad7/resourceGroups/ResourceGroupForSDKTest/providers/Microsoft.HybridData/dataManagers/TestAzureSDKOperations/dataStores/TestStorSimpleSource1"), RunLocation: to.Ptr(armhybriddatamanager.RunLocationWestus), State: to.Ptr(armhybriddatamanager.StateEnabled), UserConfirmation: to.Ptr(armhybriddatamanager.UserConfirmationRequired), }, }, nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } res, err := poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } // TODO: use response item _ = res }
Output:
func (*JobDefinitionsClient) BeginDelete ¶
func (client *JobDefinitionsClient) BeginDelete(ctx context.Context, dataServiceName string, jobDefinitionName string, resourceGroupName string, dataManagerName string, options *JobDefinitionsClientBeginDeleteOptions) (*runtime.Poller[JobDefinitionsClientDeleteResponse], error)
BeginDelete - This method deletes the given job definition. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The data service type of the job definition. jobDefinitionName - The job definition name to be deleted. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobDefinitionsClientBeginDeleteOptions contains the optional parameters for the JobDefinitionsClient.BeginDelete method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/JobDefinitions_Delete-DELETE-example-81.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobDefinitionsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginDelete(ctx, "DataTransformation", "jobdeffromtestcode1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } _, err = poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } }
Output:
func (*JobDefinitionsClient) BeginRun ¶
func (client *JobDefinitionsClient) BeginRun(ctx context.Context, dataServiceName string, jobDefinitionName string, resourceGroupName string, dataManagerName string, runParameters RunParameters, options *JobDefinitionsClientBeginRunOptions) (*runtime.Poller[JobDefinitionsClientRunResponse], error)
BeginRun - This method runs a job instance of the given job definition. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The data service type of the job definition. jobDefinitionName - Name of the job definition. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only runParameters - Run time parameters for the job definition. options - JobDefinitionsClientBeginRunOptions contains the optional parameters for the JobDefinitionsClient.BeginRun method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/JobDefinitions_Run-POST-example-132.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azcore/to" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobDefinitionsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginRun(ctx, "DataTransformation", "jobdeffromtestcode1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", armhybriddatamanager.RunParameters{ CustomerSecrets: []*armhybriddatamanager.CustomerSecret{}, DataServiceInput: map[string]interface{}{ "AzureStorageType": "Blob", "BackupChoice": "UseExistingLatest", "ContainerName": "containerfromtest", "DeviceName": "8600-SHG0997877L71FC", "FileNameFilter": "*", "IsDirectoryMode": false, "RootDirectories": []interface{}{ "\\", }, "VolumeNames": []interface{}{ "TestAutomation", }, }, UserConfirmation: to.Ptr(armhybriddatamanager.UserConfirmationNotRequired), }, nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } _, err = poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } }
Output:
func (*JobDefinitionsClient) Get ¶
func (client *JobDefinitionsClient) Get(ctx context.Context, dataServiceName string, jobDefinitionName string, resourceGroupName string, dataManagerName string, options *JobDefinitionsClientGetOptions) (JobDefinitionsClientGetResponse, error)
Get - This method gets job definition object by name. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The data service name of the job definition jobDefinitionName - The job definition name that is being queried. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobDefinitionsClientGetOptions contains the optional parameters for the JobDefinitionsClient.Get method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/JobDefinitions_Get-GET-example-81.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobDefinitionsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } res, err := client.Get(ctx, "DataTransformation", "jobdeffromtestcode1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } // TODO: use response item _ = res }
Output:
func (*JobDefinitionsClient) NewListByDataManagerPager ¶ added in v0.4.0
func (client *JobDefinitionsClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, options *JobDefinitionsClientListByDataManagerOptions) *runtime.Pager[JobDefinitionsClientListByDataManagerResponse]
NewListByDataManagerPager - This method gets all the job definitions of the given data manager resource. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobDefinitionsClientListByDataManagerOptions contains the optional parameters for the JobDefinitionsClient.ListByDataManager method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/JobDefinitions_ListByDataManager-GET-example-191.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobDefinitionsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataManagerPager("ResourceGroupForSDKTest", "TestAzureSDKOperations", &armhybriddatamanager.JobDefinitionsClientListByDataManagerOptions{Filter: nil}) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
func (*JobDefinitionsClient) NewListByDataServicePager ¶ added in v0.4.0
func (client *JobDefinitionsClient) NewListByDataServicePager(dataServiceName string, resourceGroupName string, dataManagerName string, options *JobDefinitionsClientListByDataServiceOptions) *runtime.Pager[JobDefinitionsClientListByDataServiceResponse]
NewListByDataServicePager - This method gets all the job definitions of the given data service name. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The data service type of interest. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobDefinitionsClientListByDataServiceOptions contains the optional parameters for the JobDefinitionsClient.ListByDataService method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/JobDefinitions_ListByDataService-GET-example-71.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobDefinitionsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataServicePager("DataTransformation", "ResourceGroupForSDKTest", "TestAzureSDKOperations", &armhybriddatamanager.JobDefinitionsClientListByDataServiceOptions{Filter: nil}) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type JobDefinitionsClientBeginCreateOrUpdateOptions ¶ added in v0.2.0
type JobDefinitionsClientBeginCreateOrUpdateOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
JobDefinitionsClientBeginCreateOrUpdateOptions contains the optional parameters for the JobDefinitionsClient.BeginCreateOrUpdate method.
type JobDefinitionsClientBeginDeleteOptions ¶ added in v0.2.0
type JobDefinitionsClientBeginDeleteOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
JobDefinitionsClientBeginDeleteOptions contains the optional parameters for the JobDefinitionsClient.BeginDelete method.
type JobDefinitionsClientBeginRunOptions ¶ added in v0.2.0
type JobDefinitionsClientBeginRunOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
JobDefinitionsClientBeginRunOptions contains the optional parameters for the JobDefinitionsClient.BeginRun method.
type JobDefinitionsClientCreateOrUpdateResponse ¶ added in v0.2.0
type JobDefinitionsClientCreateOrUpdateResponse struct {
JobDefinition
}
JobDefinitionsClientCreateOrUpdateResponse contains the response from method JobDefinitionsClient.CreateOrUpdate.
type JobDefinitionsClientDeleteResponse ¶ added in v0.2.0
type JobDefinitionsClientDeleteResponse struct { }
JobDefinitionsClientDeleteResponse contains the response from method JobDefinitionsClient.Delete.
type JobDefinitionsClientGetOptions ¶ added in v0.2.0
type JobDefinitionsClientGetOptions struct { }
JobDefinitionsClientGetOptions contains the optional parameters for the JobDefinitionsClient.Get method.
type JobDefinitionsClientGetResponse ¶ added in v0.2.0
type JobDefinitionsClientGetResponse struct {
JobDefinition
}
JobDefinitionsClientGetResponse contains the response from method JobDefinitionsClient.Get.
type JobDefinitionsClientListByDataManagerOptions ¶ added in v0.2.0
type JobDefinitionsClientListByDataManagerOptions struct { // OData Filter options Filter *string }
JobDefinitionsClientListByDataManagerOptions contains the optional parameters for the JobDefinitionsClient.ListByDataManager method.
type JobDefinitionsClientListByDataManagerResponse ¶ added in v0.2.0
type JobDefinitionsClientListByDataManagerResponse struct {
JobDefinitionList
}
JobDefinitionsClientListByDataManagerResponse contains the response from method JobDefinitionsClient.ListByDataManager.
type JobDefinitionsClientListByDataServiceOptions ¶ added in v0.2.0
type JobDefinitionsClientListByDataServiceOptions struct { // OData Filter options Filter *string }
JobDefinitionsClientListByDataServiceOptions contains the optional parameters for the JobDefinitionsClient.ListByDataService method.
type JobDefinitionsClientListByDataServiceResponse ¶ added in v0.2.0
type JobDefinitionsClientListByDataServiceResponse struct {
JobDefinitionList
}
JobDefinitionsClientListByDataServiceResponse contains the response from method JobDefinitionsClient.ListByDataService.
type JobDefinitionsClientRunResponse ¶ added in v0.2.0
type JobDefinitionsClientRunResponse struct { }
JobDefinitionsClientRunResponse contains the response from method JobDefinitionsClient.Run.
type JobDetails ¶
type JobDetails struct { // Error details for failure. This is optional. ErrorDetails []*ErrorDetails `json:"errorDetails,omitempty"` // Item Details Link to download files or see details ItemDetailsLink *string `json:"itemDetailsLink,omitempty"` // JobDefinition at the time of the run JobDefinition *JobDefinition `json:"jobDefinition,omitempty"` // List of stages that ran in the job JobStages []*JobStages `json:"jobStages,omitempty"` }
JobDetails - Job details.
func (JobDetails) MarshalJSON ¶
func (j JobDetails) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type JobDetails.
type JobFilter ¶
type JobFilter struct { // REQUIRED; The status of the job. Status *JobStatus `json:"status,omitempty"` // The start time of the job. StartTime *time.Time `json:"startTime,omitempty"` }
JobFilter - Contains the information about the filters for the job.
func (*JobFilter) UnmarshalJSON ¶
UnmarshalJSON implements the json.Unmarshaller interface for type JobFilter.
type JobList ¶
type JobList struct { // Link for the next set of jobs. NextLink *string `json:"nextLink,omitempty"` // List of jobs. Value []*Job `json:"value,omitempty"` }
JobList - Job Collection.
type JobProperties ¶
type JobProperties struct { // REQUIRED; Describes whether the job is cancellable. IsCancellable *IsJobCancellable `json:"isCancellable,omitempty"` // Number of bytes processed by the job as of now. BytesProcessed *int64 `json:"bytesProcessed,omitempty"` // Name of the data sink on which the job was triggered. DataSinkName *string `json:"dataSinkName,omitempty"` // Name of the data source on which the job was triggered. DataSourceName *string `json:"dataSourceName,omitempty"` // Details of a job run. This field will only be sent for expand details filter. Details *JobDetails `json:"details,omitempty"` // Number of items processed by the job as of now ItemsProcessed *int64 `json:"itemsProcessed,omitempty"` // Number of bytes to be processed by the job in total. TotalBytesToProcess *int64 `json:"totalBytesToProcess,omitempty"` // Number of items to be processed by the job in total TotalItemsToProcess *int64 `json:"totalItemsToProcess,omitempty"` }
JobProperties - Job Properties
type JobStages ¶
type JobStages struct { // REQUIRED; Status of the job stage. StageStatus *JobStatus `json:"stageStatus,omitempty"` // Error details for the stage. This is optional ErrorDetails []*ErrorDetails `json:"errorDetails,omitempty"` // Job Stage Details JobStageDetails interface{} `json:"jobStageDetails,omitempty"` // Name of the job stage. StageName *string `json:"stageName,omitempty"` }
JobStages - Job stages.
func (JobStages) MarshalJSON ¶
MarshalJSON implements the json.Marshaller interface for type JobStages.
type JobStatus ¶
type JobStatus string
JobStatus - Status of the job.
const ( JobStatusNone JobStatus = "None" JobStatusInProgress JobStatus = "InProgress" JobStatusSucceeded JobStatus = "Succeeded" JobStatusWaitingForAction JobStatus = "WaitingForAction" JobStatusFailed JobStatus = "Failed" JobStatusCancelled JobStatus = "Cancelled" JobStatusCancelling JobStatus = "Cancelling" JobStatusPartiallySucceeded JobStatus = "PartiallySucceeded" )
func PossibleJobStatusValues ¶
func PossibleJobStatusValues() []JobStatus
PossibleJobStatusValues returns the possible values for the JobStatus const type.
type JobsClient ¶
type JobsClient struct {
// contains filtered or unexported fields
}
JobsClient contains the methods for the Jobs group. Don't use this type directly, use NewJobsClient() instead.
func NewJobsClient ¶
func NewJobsClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*JobsClient, error)
NewJobsClient creates a new instance of JobsClient with the specified values. subscriptionID - The Subscription Id credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*JobsClient) BeginCancel ¶
func (client *JobsClient) BeginCancel(ctx context.Context, dataServiceName string, jobDefinitionName string, jobID string, resourceGroupName string, dataManagerName string, options *JobsClientBeginCancelOptions) (*runtime.Poller[JobsClientCancelResponse], error)
BeginCancel - Cancels the given job. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The name of the data service of the job definition. jobDefinitionName - The name of the job definition of the job. jobID - The job id of the job queried. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobsClientBeginCancelOptions contains the optional parameters for the JobsClient.BeginCancel method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/Jobs_Cancel-POST-example-111.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginCancel(ctx, "DataTransformation", "jobdeffromtestcode1", "6eca9b3d-5ffe-4b44-9607-1ba838371ff7", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } _, err = poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } }
Output:
func (*JobsClient) BeginResume ¶
func (client *JobsClient) BeginResume(ctx context.Context, dataServiceName string, jobDefinitionName string, jobID string, resourceGroupName string, dataManagerName string, options *JobsClientBeginResumeOptions) (*runtime.Poller[JobsClientResumeResponse], error)
BeginResume - Resumes the given job. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The name of the data service of the job definition. jobDefinitionName - The name of the job definition of the job. jobID - The job id of the job queried. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobsClientBeginResumeOptions contains the optional parameters for the JobsClient.BeginResume method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/Jobs_Resume-POST-example-121.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } poller, err := client.BeginResume(ctx, "DataTransformation", "jobdeffromtestcode1", "99ef93fe-36be-43e4-bebf-de6746730601", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } _, err = poller.PollUntilDone(ctx, nil) if err != nil { log.Fatalf("failed to pull the result: %v", err) } }
Output:
func (*JobsClient) Get ¶
func (client *JobsClient) Get(ctx context.Context, dataServiceName string, jobDefinitionName string, jobID string, resourceGroupName string, dataManagerName string, options *JobsClientGetOptions) (JobsClientGetResponse, error)
Get - This method gets a data manager job given the jobId. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The name of the data service of the job definition. jobDefinitionName - The name of the job definition of the job. jobID - The job id of the job queried. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobsClientGetOptions contains the optional parameters for the JobsClient.Get method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/Jobs_Get-GET-example-101.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } res, err := client.Get(ctx, "DataTransformation", "jobdeffromtestcode1", "99ef93fe-36be-43e4-bebf-de6746730601", "ResourceGroupForSDKTest", "TestAzureSDKOperations", &armhybriddatamanager.JobsClientGetOptions{Expand: nil}) if err != nil { log.Fatalf("failed to finish the request: %v", err) } // TODO: use response item _ = res }
Output:
func (*JobsClient) NewListByDataManagerPager ¶ added in v0.4.0
func (client *JobsClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, options *JobsClientListByDataManagerOptions) *runtime.Pager[JobsClientListByDataManagerResponse]
NewListByDataManagerPager - This method gets all the jobs at the data manager resource level. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobsClientListByDataManagerOptions contains the optional parameters for the JobsClient.ListByDataManager method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/Jobs_ListByDataManager-GET-example-201.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataManagerPager("ResourceGroupForSDKTest", "TestAzureSDKOperations", &armhybriddatamanager.JobsClientListByDataManagerOptions{Filter: nil}) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
func (*JobsClient) NewListByDataServicePager ¶ added in v0.4.0
func (client *JobsClient) NewListByDataServicePager(dataServiceName string, resourceGroupName string, dataManagerName string, options *JobsClientListByDataServiceOptions) *runtime.Pager[JobsClientListByDataServiceResponse]
NewListByDataServicePager - This method gets all the jobs of a data service type in a given resource. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The name of the data service of interest. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobsClientListByDataServiceOptions contains the optional parameters for the JobsClient.ListByDataService method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/Jobs_ListByDataService-GET-example-141.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataServicePager("DataTransformation", "ResourceGroupForSDKTest", "TestAzureSDKOperations", &armhybriddatamanager.JobsClientListByDataServiceOptions{Filter: nil}) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
func (*JobsClient) NewListByJobDefinitionPager ¶ added in v0.4.0
func (client *JobsClient) NewListByJobDefinitionPager(dataServiceName string, jobDefinitionName string, resourceGroupName string, dataManagerName string, options *JobsClientListByJobDefinitionOptions) *runtime.Pager[JobsClientListByJobDefinitionResponse]
NewListByJobDefinitionPager - This method gets all the jobs of a given job definition. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 dataServiceName - The name of the data service of the job definition. jobDefinitionName - The name of the job definition for which jobs are needed. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - JobsClientListByJobDefinitionOptions contains the optional parameters for the JobsClient.ListByJobDefinition method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/Jobs_ListByJobDefinition-GET-example-91.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewJobsClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByJobDefinitionPager("DataTransformation", "jobdeffromtestcode1", "ResourceGroupForSDKTest", "TestAzureSDKOperations", &armhybriddatamanager.JobsClientListByJobDefinitionOptions{Filter: nil}) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type JobsClientBeginCancelOptions ¶ added in v0.2.0
type JobsClientBeginCancelOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
JobsClientBeginCancelOptions contains the optional parameters for the JobsClient.BeginCancel method.
type JobsClientBeginResumeOptions ¶ added in v0.2.0
type JobsClientBeginResumeOptions struct { // Resumes the LRO from the provided token. ResumeToken string }
JobsClientBeginResumeOptions contains the optional parameters for the JobsClient.BeginResume method.
type JobsClientCancelResponse ¶ added in v0.2.0
type JobsClientCancelResponse struct { }
JobsClientCancelResponse contains the response from method JobsClient.Cancel.
type JobsClientGetOptions ¶ added in v0.2.0
type JobsClientGetOptions struct { // $expand is supported on details parameter for job, which provides details on the job stages. Expand *string }
JobsClientGetOptions contains the optional parameters for the JobsClient.Get method.
type JobsClientGetResponse ¶ added in v0.2.0
type JobsClientGetResponse struct {
Job
}
JobsClientGetResponse contains the response from method JobsClient.Get.
type JobsClientListByDataManagerOptions ¶ added in v0.2.0
type JobsClientListByDataManagerOptions struct { // OData Filter options Filter *string }
JobsClientListByDataManagerOptions contains the optional parameters for the JobsClient.ListByDataManager method.
type JobsClientListByDataManagerResponse ¶ added in v0.2.0
type JobsClientListByDataManagerResponse struct {
JobList
}
JobsClientListByDataManagerResponse contains the response from method JobsClient.ListByDataManager.
type JobsClientListByDataServiceOptions ¶ added in v0.2.0
type JobsClientListByDataServiceOptions struct { // OData Filter options Filter *string }
JobsClientListByDataServiceOptions contains the optional parameters for the JobsClient.ListByDataService method.
type JobsClientListByDataServiceResponse ¶ added in v0.2.0
type JobsClientListByDataServiceResponse struct {
JobList
}
JobsClientListByDataServiceResponse contains the response from method JobsClient.ListByDataService.
type JobsClientListByJobDefinitionOptions ¶ added in v0.2.0
type JobsClientListByJobDefinitionOptions struct { // OData Filter options Filter *string }
JobsClientListByJobDefinitionOptions contains the optional parameters for the JobsClient.ListByJobDefinition method.
type JobsClientListByJobDefinitionResponse ¶ added in v0.2.0
type JobsClientListByJobDefinitionResponse struct {
JobList
}
JobsClientListByJobDefinitionResponse contains the response from method JobsClient.ListByJobDefinition.
type JobsClientResumeResponse ¶ added in v0.2.0
type JobsClientResumeResponse struct { }
JobsClientResumeResponse contains the response from method JobsClient.Resume.
type Key ¶
type Key struct { // REQUIRED; The maximum byte size that can be encrypted by the key. For a key size larger than the size, break into chunks // and encrypt each chunk, append each encrypted chunk with : to mark the end of the chunk. EncryptionChunkSizeInBytes *int32 `json:"encryptionChunkSizeInBytes,omitempty"` // REQUIRED; Exponent of the encryption key. KeyExponent *string `json:"keyExponent,omitempty"` // REQUIRED; Modulus of the encryption key. KeyModulus *string `json:"keyModulus,omitempty"` }
Key - Encryption Key.
type OperationsClient ¶
type OperationsClient struct {
// contains filtered or unexported fields
}
OperationsClient contains the methods for the Operations group. Don't use this type directly, use NewOperationsClient() instead.
func NewOperationsClient ¶
func NewOperationsClient(credential azcore.TokenCredential, options *arm.ClientOptions) (*OperationsClient, error)
NewOperationsClient creates a new instance of OperationsClient with the specified values. credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*OperationsClient) NewListPager ¶ added in v0.4.0
func (client *OperationsClient) NewListPager(options *OperationsClientListOptions) *runtime.Pager[OperationsClientListResponse]
NewListPager - The list of operations for Microsoft.HybridData provider. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 options - OperationsClientListOptions contains the optional parameters for the OperationsClient.List method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/Operations_List-GET-example-11.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewOperationsClient(cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListPager(nil) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type OperationsClientListOptions ¶ added in v0.2.0
type OperationsClientListOptions struct { }
OperationsClientListOptions contains the optional parameters for the OperationsClient.List method.
type OperationsClientListResponse ¶ added in v0.2.0
type OperationsClientListResponse struct {
AvailableProviderOperations
}
OperationsClientListResponse contains the response from method OperationsClient.List.
type PublicKey ¶
type PublicKey struct { // REQUIRED; Public key property. Properties *PublicKeyProperties `json:"properties,omitempty"` // READ-ONLY; Id of the object. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; Name of the object. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; Type of the object. Type *string `json:"type,omitempty" azure:"ro"` }
PublicKey - Public key
type PublicKeyList ¶
type PublicKeyList struct { // Link for the next set of public keys. NextLink *string `json:"nextLink,omitempty"` // List of public keys. Value []*PublicKey `json:"value,omitempty"` }
PublicKeyList - PublicKey Collection
type PublicKeyProperties ¶
type PublicKeyProperties struct { // REQUIRED; Level one public key for encryption DataServiceLevel1Key *Key `json:"dataServiceLevel1Key,omitempty"` // REQUIRED; Level two public key for encryption DataServiceLevel2Key *Key `json:"dataServiceLevel2Key,omitempty"` }
PublicKeyProperties - PublicKey Properties
type PublicKeysClient ¶
type PublicKeysClient struct {
// contains filtered or unexported fields
}
PublicKeysClient contains the methods for the PublicKeys group. Don't use this type directly, use NewPublicKeysClient() instead.
func NewPublicKeysClient ¶
func NewPublicKeysClient(subscriptionID string, credential azcore.TokenCredential, options *arm.ClientOptions) (*PublicKeysClient, error)
NewPublicKeysClient creates a new instance of PublicKeysClient with the specified values. subscriptionID - The Subscription Id credential - used to authorize requests. Usually a credential from azidentity. options - pass nil to accept the default values.
func (*PublicKeysClient) Get ¶
func (client *PublicKeysClient) Get(ctx context.Context, publicKeyName string, resourceGroupName string, dataManagerName string, options *PublicKeysClientGetOptions) (PublicKeysClientGetResponse, error)
Get - This method gets the public keys. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 publicKeyName - Name of the public key. resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - PublicKeysClientGetOptions contains the optional parameters for the PublicKeysClient.Get method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/PublicKeys_Get-GET-example-222.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewPublicKeysClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } res, err := client.Get(ctx, "default", "ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) if err != nil { log.Fatalf("failed to finish the request: %v", err) } // TODO: use response item _ = res }
Output:
func (*PublicKeysClient) NewListByDataManagerPager ¶ added in v0.4.0
func (client *PublicKeysClient) NewListByDataManagerPager(resourceGroupName string, dataManagerName string, options *PublicKeysClientListByDataManagerOptions) *runtime.Pager[PublicKeysClientListByDataManagerResponse]
NewListByDataManagerPager - This method gets the list view of public keys, however it will only have one element. If the operation fails it returns an *azcore.ResponseError type. Generated from API version 2019-06-01 resourceGroupName - The Resource Group Name dataManagerName - The name of the DataManager Resource within the specified resource group. DataManager names must be between 3 and 24 characters in length and use any alphanumeric and underscore only options - PublicKeysClientListByDataManagerOptions contains the optional parameters for the PublicKeysClient.ListByDataManager method.
Example ¶
Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/hybriddatamanager/resource-manager/Microsoft.HybridData/stable/2019-06-01/examples/PublicKeys_ListByDataManager-GET-example-211.json
package main import ( "context" "log" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/hybriddatamanager/armhybriddatamanager" ) func main() { cred, err := azidentity.NewDefaultAzureCredential(nil) if err != nil { log.Fatalf("failed to obtain a credential: %v", err) } ctx := context.Background() client, err := armhybriddatamanager.NewPublicKeysClient("6e0219f5-327a-4365-904f-05eed4227ad7", cred, nil) if err != nil { log.Fatalf("failed to create client: %v", err) } pager := client.NewListByDataManagerPager("ResourceGroupForSDKTest", "TestAzureSDKOperations", nil) for pager.More() { nextResult, err := pager.NextPage(ctx) if err != nil { log.Fatalf("failed to advance page: %v", err) } for _, v := range nextResult.Value { // TODO: use page item _ = v } } }
Output:
type PublicKeysClientGetOptions ¶ added in v0.2.0
type PublicKeysClientGetOptions struct { }
PublicKeysClientGetOptions contains the optional parameters for the PublicKeysClient.Get method.
type PublicKeysClientGetResponse ¶ added in v0.2.0
type PublicKeysClientGetResponse struct {
PublicKey
}
PublicKeysClientGetResponse contains the response from method PublicKeysClient.Get.
type PublicKeysClientListByDataManagerOptions ¶ added in v0.2.0
type PublicKeysClientListByDataManagerOptions struct { }
PublicKeysClientListByDataManagerOptions contains the optional parameters for the PublicKeysClient.ListByDataManager method.
type PublicKeysClientListByDataManagerResponse ¶ added in v0.2.0
type PublicKeysClientListByDataManagerResponse struct {
PublicKeyList
}
PublicKeysClientListByDataManagerResponse contains the response from method PublicKeysClient.ListByDataManager.
type Resource ¶
type Resource struct { // REQUIRED; The location of the resource. This will be one of the supported and registered Azure Geo Regions (e.g. West US, // East US, Southeast Asia, etc.). The geo region of a resource cannot be changed once it // is created, but if an identical geo region is specified on update the request will succeed. Location *string `json:"location,omitempty"` // The sku type. SKU *SKU `json:"sku,omitempty"` // The list of key value pairs that describe the resource. These tags can be used in viewing and grouping this resource (across // resource groups). Tags map[string]*string `json:"tags,omitempty"` // READ-ONLY; The Resource Id. ID *string `json:"id,omitempty" azure:"ro"` // READ-ONLY; The Resource Name. Name *string `json:"name,omitempty" azure:"ro"` // READ-ONLY; The Resource type. Type *string `json:"type,omitempty" azure:"ro"` }
Resource - Model of the Resource.
func (Resource) MarshalJSON ¶
MarshalJSON implements the json.Marshaller interface for type Resource.
type RunLocation ¶
type RunLocation string
RunLocation - This is the preferred geo location for the job to run.
const ( RunLocationNone RunLocation = "none" RunLocationAustraliaeast RunLocation = "australiaeast" RunLocationAustraliasoutheast RunLocation = "australiasoutheast" RunLocationBrazilsouth RunLocation = "brazilsouth" RunLocationCanadacentral RunLocation = "canadacentral" RunLocationCanadaeast RunLocation = "canadaeast" RunLocationCentralindia RunLocation = "centralindia" RunLocationCentralus RunLocation = "centralus" RunLocationEastasia RunLocation = "eastasia" RunLocationEastus RunLocation = "eastus" RunLocationEastus2 RunLocation = "eastus2" RunLocationJapaneast RunLocation = "japaneast" RunLocationJapanwest RunLocation = "japanwest" RunLocationKoreacentral RunLocation = "koreacentral" RunLocationKoreasouth RunLocation = "koreasouth" RunLocationSoutheastasia RunLocation = "southeastasia" RunLocationSouthcentralus RunLocation = "southcentralus" RunLocationSouthindia RunLocation = "southindia" RunLocationNorthcentralus RunLocation = "northcentralus" RunLocationNortheurope RunLocation = "northeurope" RunLocationUksouth RunLocation = "uksouth" RunLocationUkwest RunLocation = "ukwest" RunLocationWestcentralus RunLocation = "westcentralus" RunLocationWesteurope RunLocation = "westeurope" RunLocationWestindia RunLocation = "westindia" RunLocationWestus RunLocation = "westus" RunLocationWestus2 RunLocation = "westus2" )
func PossibleRunLocationValues ¶
func PossibleRunLocationValues() []RunLocation
PossibleRunLocationValues returns the possible values for the RunLocation const type.
type RunParameters ¶
type RunParameters struct { // List of customer secrets containing a key identifier and key value. The key identifier is a way for the specific data source // to understand the key. Value contains customer secret encrypted by the // encryptionKeys. CustomerSecrets []*CustomerSecret `json:"customerSecrets,omitempty"` // A generic json used differently by each data service type. DataServiceInput interface{} `json:"dataServiceInput,omitempty"` // Enum to detect if user confirmation is required. If not passed will default to NotRequired. UserConfirmation *UserConfirmation `json:"userConfirmation,omitempty"` }
RunParameters - Run parameters for a job.
func (RunParameters) MarshalJSON ¶
func (r RunParameters) MarshalJSON() ([]byte, error)
MarshalJSON implements the json.Marshaller interface for type RunParameters.
type SKU ¶
type SKU struct { // The sku name. Required for data manager creation, optional for update. Name *string `json:"name,omitempty"` // The sku tier. This is based on the SKU name. Tier *string `json:"tier,omitempty"` }
SKU - The sku type.
type Schedule ¶
type Schedule struct { // Name of the schedule. Name *string `json:"name,omitempty"` // A list of repetition intervals in ISO 8601 format. PolicyList []*string `json:"policyList,omitempty"` }
Schedule for the job run.
func (Schedule) MarshalJSON ¶
MarshalJSON implements the json.Marshaller interface for type Schedule.
type State ¶
type State string
State - State of the data service.
func PossibleStateValues ¶
func PossibleStateValues() []State
PossibleStateValues returns the possible values for the State const type.
type SupportedAlgorithm ¶
type SupportedAlgorithm string
SupportedAlgorithm - The encryption algorithm used to encrypt data.
const ( SupportedAlgorithmNone SupportedAlgorithm = "None" SupportedAlgorithmRSA15 SupportedAlgorithm = "RSA1_5" SupportedAlgorithmRSAOAEP SupportedAlgorithm = "RSA_OAEP" SupportedAlgorithmPlainText SupportedAlgorithm = "PlainText" )
func PossibleSupportedAlgorithmValues ¶
func PossibleSupportedAlgorithmValues() []SupportedAlgorithm
PossibleSupportedAlgorithmValues returns the possible values for the SupportedAlgorithm const type.
type UserConfirmation ¶
type UserConfirmation string
UserConfirmation - Enum to detect if user confirmation is required. If not passed will default to NotRequired.
const ( UserConfirmationNotRequired UserConfirmation = "NotRequired" UserConfirmationRequired UserConfirmation = "Required" )
func PossibleUserConfirmationValues ¶
func PossibleUserConfirmationValues() []UserConfirmation
PossibleUserConfirmationValues returns the possible values for the UserConfirmation const type.
Source Files ¶
- build.go
- zz_generated_constants.go
- zz_generated_datamanagers_client.go
- zz_generated_dataservices_client.go
- zz_generated_datastores_client.go
- zz_generated_datastoretypes_client.go
- zz_generated_jobdefinitions_client.go
- zz_generated_jobs_client.go
- zz_generated_models.go
- zz_generated_models_serde.go
- zz_generated_operations_client.go
- zz_generated_publickeys_client.go
- zz_generated_response_types.go
- zz_generated_time_rfc3339.go