integrationruntime

package
v0.20240222.1121651 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2024 License: MPL-2.0 Imports: 13 Imported by: 0

README

github.com/hashicorp/go-azure-sdk/resource-manager/synapse/2021-06-01/integrationruntime Documentation

The integrationruntime SDK allows for interaction with the Azure Resource Manager Service synapse (API Version 2021-06-01).

This readme covers example usages, but further information on using this SDK can be found in the project root.

Import Path

import "github.com/hashicorp/go-azure-sdk/resource-manager/synapse/2021-06-01/integrationruntime"

Client Initialization

client := integrationruntime.NewIntegrationRuntimeClientWithBaseURI("https://management.azure.com")
client.Client.Authorizer = authorizer

Example Usage: IntegrationRuntimeClient.AuthKeysList

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

read, err := client.AuthKeysList(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.AuthKeysRegenerate

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

payload := integrationruntime.IntegrationRuntimeRegenerateKeyParameters{
	// ...
}


read, err := client.AuthKeysRegenerate(ctx, id, payload)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.ConnectionInfosGet

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

read, err := client.ConnectionInfosGet(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.Create

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

payload := integrationruntime.IntegrationRuntimeResource{
	// ...
}


if err := client.CreateThenPoll(ctx, id, payload, integrationruntime.DefaultCreateOperationOptions()); err != nil {
	// handle the error
}

Example Usage: IntegrationRuntimeClient.CredentialsSync

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

read, err := client.CredentialsSync(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.Delete

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

if err := client.DeleteThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: IntegrationRuntimeClient.DisableInteractiveQuery

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

if err := client.DisableInteractiveQueryThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: IntegrationRuntimeClient.EnableInteractiveQuery

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

if err := client.EnableInteractiveQueryThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: IntegrationRuntimeClient.Get

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

read, err := client.Get(ctx, id, integrationruntime.DefaultGetOperationOptions())
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.ListByWorkspace

ctx := context.TODO()
id := integrationruntime.NewWorkspaceID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue")

// alternatively `client.ListByWorkspace(ctx, id)` can be used to do batched pagination
items, err := client.ListByWorkspaceComplete(ctx, id)
if err != nil {
	// handle the error
}
for _, item := range items {
	// do something
}

Example Usage: IntegrationRuntimeClient.MonitoringDataList

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

read, err := client.MonitoringDataList(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.NodeIPAddressGet

ctx := context.TODO()
id := integrationruntime.NewNodeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue", "nodeValue")

read, err := client.NodeIPAddressGet(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.NodesDelete

ctx := context.TODO()
id := integrationruntime.NewNodeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue", "nodeValue")

read, err := client.NodesDelete(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.NodesGet

ctx := context.TODO()
id := integrationruntime.NewNodeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue", "nodeValue")

read, err := client.NodesGet(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.NodesUpdate

ctx := context.TODO()
id := integrationruntime.NewNodeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue", "nodeValue")

payload := integrationruntime.UpdateIntegrationRuntimeNodeRequest{
	// ...
}


read, err := client.NodesUpdate(ctx, id, payload)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.ObjectMetadataList

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

payload := integrationruntime.GetSsisObjectMetadataRequest{
	// ...
}


read, err := client.ObjectMetadataList(ctx, id, payload)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.ObjectMetadataRefresh

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

if err := client.ObjectMetadataRefreshThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: IntegrationRuntimeClient.Start

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

if err := client.StartThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: IntegrationRuntimeClient.StatusGet

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

read, err := client.StatusGet(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.Stop

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

if err := client.StopThenPoll(ctx, id); err != nil {
	// handle the error
}

Example Usage: IntegrationRuntimeClient.Update

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

payload := integrationruntime.UpdateIntegrationRuntimeRequest{
	// ...
}


read, err := client.Update(ctx, id, payload)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Example Usage: IntegrationRuntimeClient.Upgrade

ctx := context.TODO()
id := integrationruntime.NewIntegrationRuntimeID("12345678-1234-9876-4563-123456789012", "example-resource-group", "workspaceValue", "integrationRuntimeValue")

read, err := client.Upgrade(ctx, id)
if err != nil {
	// handle the error
}
if model := read.Model; model != nil {
	// do something with the model/response object
}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PossibleValuesForDataFlowComputeType 

func PossibleValuesForDataFlowComputeType() []string

func PossibleValuesForIntegrationRuntimeAuthKeyName 

func PossibleValuesForIntegrationRuntimeAuthKeyName() []string

func PossibleValuesForIntegrationRuntimeAutoUpdate 

func PossibleValuesForIntegrationRuntimeAutoUpdate() []string

func PossibleValuesForIntegrationRuntimeEdition 

func PossibleValuesForIntegrationRuntimeEdition() []string

func PossibleValuesForIntegrationRuntimeEntityReferenceType 

func PossibleValuesForIntegrationRuntimeEntityReferenceType() []string

func PossibleValuesForIntegrationRuntimeInternalChannelEncryptionMode 

func PossibleValuesForIntegrationRuntimeInternalChannelEncryptionMode() []string

func PossibleValuesForIntegrationRuntimeLicenseType 

func PossibleValuesForIntegrationRuntimeLicenseType() []string

func PossibleValuesForIntegrationRuntimeSsisCatalogPricingTier 

func PossibleValuesForIntegrationRuntimeSsisCatalogPricingTier() []string

func PossibleValuesForIntegrationRuntimeState 

func PossibleValuesForIntegrationRuntimeState() []string

func PossibleValuesForIntegrationRuntimeType 

func PossibleValuesForIntegrationRuntimeType() []string

func PossibleValuesForIntegrationRuntimeUpdateResult 

func PossibleValuesForIntegrationRuntimeUpdateResult() []string

func PossibleValuesForManagedIntegrationRuntimeNodeStatus 

func PossibleValuesForManagedIntegrationRuntimeNodeStatus() []string

func PossibleValuesForSelfHostedIntegrationRuntimeNodeStatus 

func PossibleValuesForSelfHostedIntegrationRuntimeNodeStatus() []string

func PossibleValuesForSsisObjectMetadataType 

func PossibleValuesForSsisObjectMetadataType() []string

func ValidateIntegrationRuntimeID 

func ValidateIntegrationRuntimeID(input interface{}, key string) (warnings []string, errors []error)

ValidateIntegrationRuntimeID checks that 'input' can be parsed as a Integration Runtime ID

func ValidateNodeID 

func ValidateNodeID(input interface{}, key string) (warnings []string, errors []error)

ValidateNodeID checks that 'input' can be parsed as a Node ID

func ValidateWorkspaceID 

func ValidateWorkspaceID(input interface{}, key string) (warnings []string, errors []error)

ValidateWorkspaceID checks that 'input' can be parsed as a Workspace ID

Types

type AuthKeysListOperationResponse 

type AuthKeysListOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeAuthKeys
}

type AuthKeysRegenerateOperationResponse 

type AuthKeysRegenerateOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeAuthKeys
}

type ConnectionInfosGetOperationResponse 

type ConnectionInfosGetOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeConnectionInfo
}

type CreateOperationOptions 

type CreateOperationOptions struct {
	IfMatch *string
}

func DefaultCreateOperationOptions 

func DefaultCreateOperationOptions() CreateOperationOptions

func (CreateOperationOptions) ToHeaders 

func (o CreateOperationOptions) ToHeaders() *client.Headers

func (CreateOperationOptions) ToOData 

func (o CreateOperationOptions) ToOData() *odata.Query

func (CreateOperationOptions) ToQuery 

func (o CreateOperationOptions) ToQuery() *client.QueryParams

type CreateOperationResponse 

type CreateOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeResource
}

type CredentialsSyncOperationResponse 

type CredentialsSyncOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
}

type CustomSetupBase 

type CustomSetupBase interface {
}

type DataFlowComputeType 

type DataFlowComputeType string
const (
	DataFlowComputeTypeComputeOptimized DataFlowComputeType = "ComputeOptimized"
	DataFlowComputeTypeGeneral          DataFlowComputeType = "General"
	DataFlowComputeTypeMemoryOptimized  DataFlowComputeType = "MemoryOptimized"
)

func (*DataFlowComputeType) UnmarshalJSON 

func (s *DataFlowComputeType) UnmarshalJSON(bytes []byte) error

type DeleteOperationResponse 

type DeleteOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
}

type DisableInteractiveQueryOperationResponse 

type DisableInteractiveQueryOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
}

type EnableInteractiveQueryOperationResponse 

type EnableInteractiveQueryOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
}

type EntityReference 

type EntityReference struct {
	ReferenceName *string                                `json:"referenceName,omitempty"`
	Type          *IntegrationRuntimeEntityReferenceType `json:"type,omitempty"`
}

type GetOperationOptions 

type GetOperationOptions struct {
	IfNoneMatch *string
}

func DefaultGetOperationOptions 

func DefaultGetOperationOptions() GetOperationOptions

func (GetOperationOptions) ToHeaders 

func (o GetOperationOptions) ToHeaders() *client.Headers

func (GetOperationOptions) ToOData 

func (o GetOperationOptions) ToOData() *odata.Query

func (GetOperationOptions) ToQuery 

func (o GetOperationOptions) ToQuery() *client.QueryParams

type GetOperationResponse 

type GetOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeResource
}

type GetSsisObjectMetadataRequest 

type GetSsisObjectMetadataRequest struct {
	MetadataPath *string `json:"metadataPath,omitempty"`
}

type IntegrationRuntime 

type IntegrationRuntime interface {
}

type IntegrationRuntimeAuthKeyName 

type IntegrationRuntimeAuthKeyName string
const (
	IntegrationRuntimeAuthKeyNameAuthKeyOne IntegrationRuntimeAuthKeyName = "authKey1"
	IntegrationRuntimeAuthKeyNameAuthKeyTwo IntegrationRuntimeAuthKeyName = "authKey2"
)

func (*IntegrationRuntimeAuthKeyName) UnmarshalJSON 

func (s *IntegrationRuntimeAuthKeyName) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeAuthKeys 

type IntegrationRuntimeAuthKeys struct {
	AuthKey1 *string `json:"authKey1,omitempty"`
	AuthKey2 *string `json:"authKey2,omitempty"`
}

type IntegrationRuntimeAutoUpdate 

type IntegrationRuntimeAutoUpdate string
const (
	IntegrationRuntimeAutoUpdateOff IntegrationRuntimeAutoUpdate = "Off"
	IntegrationRuntimeAutoUpdateOn  IntegrationRuntimeAutoUpdate = "On"
)

func (*IntegrationRuntimeAutoUpdate) UnmarshalJSON 

func (s *IntegrationRuntimeAutoUpdate) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeClient 

type IntegrationRuntimeClient struct {
	Client *resourcemanager.Client
}

func NewIntegrationRuntimeClientWithBaseURI 

func NewIntegrationRuntimeClientWithBaseURI(sdkApi sdkEnv.Api) (*IntegrationRuntimeClient, error)

func (IntegrationRuntimeClient) AuthKeysList 

func (c IntegrationRuntimeClient) AuthKeysList(ctx context.Context, id IntegrationRuntimeId) (result AuthKeysListOperationResponse, err error)

AuthKeysList ...

func (IntegrationRuntimeClient) AuthKeysRegenerate 

func (c IntegrationRuntimeClient) AuthKeysRegenerate(ctx context.Context, id IntegrationRuntimeId, input IntegrationRuntimeRegenerateKeyParameters) (result AuthKeysRegenerateOperationResponse, err error)

AuthKeysRegenerate ...

func (IntegrationRuntimeClient) ConnectionInfosGet 

func (c IntegrationRuntimeClient) ConnectionInfosGet(ctx context.Context, id IntegrationRuntimeId) (result ConnectionInfosGetOperationResponse, err error)

ConnectionInfosGet ...

func (IntegrationRuntimeClient) Create 

func (c IntegrationRuntimeClient) Create(ctx context.Context, id IntegrationRuntimeId, input IntegrationRuntimeResource, options CreateOperationOptions) (result CreateOperationResponse, err error)

Create ...

func (IntegrationRuntimeClient) CreateThenPoll 

func (c IntegrationRuntimeClient) CreateThenPoll(ctx context.Context, id IntegrationRuntimeId, input IntegrationRuntimeResource, options CreateOperationOptions) error

CreateThenPoll performs Create then polls until it's completed

func (IntegrationRuntimeClient) CredentialsSync 

func (c IntegrationRuntimeClient) CredentialsSync(ctx context.Context, id IntegrationRuntimeId) (result CredentialsSyncOperationResponse, err error)

CredentialsSync ...

func (IntegrationRuntimeClient) Delete 

func (c IntegrationRuntimeClient) Delete(ctx context.Context, id IntegrationRuntimeId) (result DeleteOperationResponse, err error)

Delete ...

func (IntegrationRuntimeClient) DeleteThenPoll 

func (c IntegrationRuntimeClient) DeleteThenPoll(ctx context.Context, id IntegrationRuntimeId) error

DeleteThenPoll performs Delete then polls until it's completed

func (IntegrationRuntimeClient) DisableInteractiveQuery 

func (c IntegrationRuntimeClient) DisableInteractiveQuery(ctx context.Context, id IntegrationRuntimeId) (result DisableInteractiveQueryOperationResponse, err error)

DisableInteractiveQuery ...

func (IntegrationRuntimeClient) DisableInteractiveQueryThenPoll 

func (c IntegrationRuntimeClient) DisableInteractiveQueryThenPoll(ctx context.Context, id IntegrationRuntimeId) error

DisableInteractiveQueryThenPoll performs DisableInteractiveQuery then polls until it's completed

func (IntegrationRuntimeClient) EnableInteractiveQuery 

func (c IntegrationRuntimeClient) EnableInteractiveQuery(ctx context.Context, id IntegrationRuntimeId) (result EnableInteractiveQueryOperationResponse, err error)

EnableInteractiveQuery ...

func (IntegrationRuntimeClient) EnableInteractiveQueryThenPoll 

func (c IntegrationRuntimeClient) EnableInteractiveQueryThenPoll(ctx context.Context, id IntegrationRuntimeId) error

EnableInteractiveQueryThenPoll performs EnableInteractiveQuery then polls until it's completed

func (IntegrationRuntimeClient) Get 

func (c IntegrationRuntimeClient) Get(ctx context.Context, id IntegrationRuntimeId, options GetOperationOptions) (result GetOperationResponse, err error)

Get ...

func (IntegrationRuntimeClient) ListByWorkspace 

func (c IntegrationRuntimeClient) ListByWorkspace(ctx context.Context, id WorkspaceId) (result ListByWorkspaceOperationResponse, err error)

ListByWorkspace ...

func (IntegrationRuntimeClient) ListByWorkspaceComplete 

func (c IntegrationRuntimeClient) ListByWorkspaceComplete(ctx context.Context, id WorkspaceId) (ListByWorkspaceCompleteResult, error)

ListByWorkspaceComplete retrieves all the results into a single object

func (IntegrationRuntimeClient) ListByWorkspaceCompleteMatchingPredicate 

func (c IntegrationRuntimeClient) ListByWorkspaceCompleteMatchingPredicate(ctx context.Context, id WorkspaceId, predicate IntegrationRuntimeResourceOperationPredicate) (result ListByWorkspaceCompleteResult, err error)

ListByWorkspaceCompleteMatchingPredicate retrieves all the results and then applies the predicate

func (IntegrationRuntimeClient) MonitoringDataList 

func (c IntegrationRuntimeClient) MonitoringDataList(ctx context.Context, id IntegrationRuntimeId) (result MonitoringDataListOperationResponse, err error)

MonitoringDataList ...

func (IntegrationRuntimeClient) NodeIPAddressGet 

func (c IntegrationRuntimeClient) NodeIPAddressGet(ctx context.Context, id NodeId) (result NodeIPAddressGetOperationResponse, err error)

NodeIPAddressGet ...

func (IntegrationRuntimeClient) NodesDelete 

func (c IntegrationRuntimeClient) NodesDelete(ctx context.Context, id NodeId) (result NodesDeleteOperationResponse, err error)

NodesDelete ...

func (IntegrationRuntimeClient) NodesGet 

func (c IntegrationRuntimeClient) NodesGet(ctx context.Context, id NodeId) (result NodesGetOperationResponse, err error)

NodesGet ...

func (IntegrationRuntimeClient) NodesUpdate 

func (c IntegrationRuntimeClient) NodesUpdate(ctx context.Context, id NodeId, input UpdateIntegrationRuntimeNodeRequest) (result NodesUpdateOperationResponse, err error)

NodesUpdate ...

func (IntegrationRuntimeClient) ObjectMetadataList 

func (c IntegrationRuntimeClient) ObjectMetadataList(ctx context.Context, id IntegrationRuntimeId, input GetSsisObjectMetadataRequest) (result ObjectMetadataListOperationResponse, err error)

ObjectMetadataList ...

func (IntegrationRuntimeClient) ObjectMetadataRefresh 

func (c IntegrationRuntimeClient) ObjectMetadataRefresh(ctx context.Context, id IntegrationRuntimeId) (result ObjectMetadataRefreshOperationResponse, err error)

ObjectMetadataRefresh ...

func (IntegrationRuntimeClient) ObjectMetadataRefreshThenPoll 

func (c IntegrationRuntimeClient) ObjectMetadataRefreshThenPoll(ctx context.Context, id IntegrationRuntimeId) error

ObjectMetadataRefreshThenPoll performs ObjectMetadataRefresh then polls until it's completed

func (IntegrationRuntimeClient) Start 

func (c IntegrationRuntimeClient) Start(ctx context.Context, id IntegrationRuntimeId) (result StartOperationResponse, err error)

Start ...

func (IntegrationRuntimeClient) StartThenPoll 

func (c IntegrationRuntimeClient) StartThenPoll(ctx context.Context, id IntegrationRuntimeId) error

StartThenPoll performs Start then polls until it's completed

func (IntegrationRuntimeClient) StatusGet 

func (c IntegrationRuntimeClient) StatusGet(ctx context.Context, id IntegrationRuntimeId) (result StatusGetOperationResponse, err error)

StatusGet ...

func (IntegrationRuntimeClient) Stop 

func (c IntegrationRuntimeClient) Stop(ctx context.Context, id IntegrationRuntimeId) (result StopOperationResponse, err error)

Stop ...

func (IntegrationRuntimeClient) StopThenPoll 

func (c IntegrationRuntimeClient) StopThenPoll(ctx context.Context, id IntegrationRuntimeId) error

StopThenPoll performs Stop then polls until it's completed

func (IntegrationRuntimeClient) Update 

func (c IntegrationRuntimeClient) Update(ctx context.Context, id IntegrationRuntimeId, input UpdateIntegrationRuntimeRequest) (result UpdateOperationResponse, err error)

Update ...

func (IntegrationRuntimeClient) Upgrade 

func (c IntegrationRuntimeClient) Upgrade(ctx context.Context, id IntegrationRuntimeId) (result UpgradeOperationResponse, err error)

Upgrade ...

type IntegrationRuntimeComputeProperties 

type IntegrationRuntimeComputeProperties struct {
	DataFlowProperties           *IntegrationRuntimeDataFlowProperties `json:"dataFlowProperties,omitempty"`
	Location                     *string                               `json:"location,omitempty"`
	MaxParallelExecutionsPerNode *int64                                `json:"maxParallelExecutionsPerNode,omitempty"`
	NodeSize                     *string                               `json:"nodeSize,omitempty"`
	NumberOfNodes                *int64                                `json:"numberOfNodes,omitempty"`
	VNetProperties               *IntegrationRuntimeVNetProperties     `json:"vNetProperties,omitempty"`
}

type IntegrationRuntimeConnectionInfo 

type IntegrationRuntimeConnectionInfo struct {
	HostServiceUri         *string `json:"hostServiceUri,omitempty"`
	IdentityCertThumbprint *string `json:"identityCertThumbprint,omitempty"`
	IsIdentityCertExprired *bool   `json:"isIdentityCertExprired,omitempty"`
	PublicKey              *string `json:"publicKey,omitempty"`
	ServiceToken           *string `json:"serviceToken,omitempty"`
	Version                *string `json:"version,omitempty"`
}

type IntegrationRuntimeCustomSetupScriptProperties 

type IntegrationRuntimeCustomSetupScriptProperties struct {
	BlobContainerUri *string       `json:"blobContainerUri,omitempty"`
	SasToken         *SecureString `json:"sasToken,omitempty"`
}

type IntegrationRuntimeCustomerVirtualNetwork 

type IntegrationRuntimeCustomerVirtualNetwork struct {
	SubnetId *string `json:"subnetId,omitempty"`
}

type IntegrationRuntimeDataFlowProperties 

type IntegrationRuntimeDataFlowProperties struct {
	ComputeType *DataFlowComputeType `json:"computeType,omitempty"`
	CoreCount   *int64               `json:"coreCount,omitempty"`
	TimeToLive  *int64               `json:"timeToLive,omitempty"`
}

type IntegrationRuntimeDataProxyProperties 

type IntegrationRuntimeDataProxyProperties struct {
	ConnectVia           *EntityReference `json:"connectVia,omitempty"`
	Path                 *string          `json:"path,omitempty"`
	StagingLinkedService *EntityReference `json:"stagingLinkedService,omitempty"`
}

type IntegrationRuntimeEdition 

type IntegrationRuntimeEdition string
const (
	IntegrationRuntimeEditionEnterprise IntegrationRuntimeEdition = "Enterprise"
	IntegrationRuntimeEditionStandard   IntegrationRuntimeEdition = "Standard"
)

func (*IntegrationRuntimeEdition) UnmarshalJSON 

func (s *IntegrationRuntimeEdition) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeEntityReferenceType 

type IntegrationRuntimeEntityReferenceType string
const (
	IntegrationRuntimeEntityReferenceTypeIntegrationRuntimeReference IntegrationRuntimeEntityReferenceType = "IntegrationRuntimeReference"
	IntegrationRuntimeEntityReferenceTypeLinkedServiceReference      IntegrationRuntimeEntityReferenceType = "LinkedServiceReference"
)

func (*IntegrationRuntimeEntityReferenceType) UnmarshalJSON 

func (s *IntegrationRuntimeEntityReferenceType) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeId 

type IntegrationRuntimeId struct {
	SubscriptionId         string
	ResourceGroupName      string
	WorkspaceName          string
	IntegrationRuntimeName string
}

IntegrationRuntimeId is a struct representing the Resource ID for a Integration Runtime

func NewIntegrationRuntimeID 

func NewIntegrationRuntimeID(subscriptionId string, resourceGroupName string, workspaceName string, integrationRuntimeName string) IntegrationRuntimeId

NewIntegrationRuntimeID returns a new IntegrationRuntimeId struct

func ParseIntegrationRuntimeID 

func ParseIntegrationRuntimeID(input string) (*IntegrationRuntimeId, error)

ParseIntegrationRuntimeID parses 'input' into a IntegrationRuntimeId

func ParseIntegrationRuntimeIDInsensitively 

func ParseIntegrationRuntimeIDInsensitively(input string) (*IntegrationRuntimeId, error)

ParseIntegrationRuntimeIDInsensitively parses 'input' case-insensitively into a IntegrationRuntimeId note: this method should only be used for API response data and not user input

func (*IntegrationRuntimeId) FromParseResult 

func (id *IntegrationRuntimeId) FromParseResult(input resourceids.ParseResult) error

func (IntegrationRuntimeId) ID 

func (id IntegrationRuntimeId) ID() string

ID returns the formatted Integration Runtime ID

func (IntegrationRuntimeId) Segments 

func (id IntegrationRuntimeId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Integration Runtime ID

func (IntegrationRuntimeId) String 

func (id IntegrationRuntimeId) String() string

String returns a human-readable description of this Integration Runtime ID

type IntegrationRuntimeInternalChannelEncryptionMode 

type IntegrationRuntimeInternalChannelEncryptionMode string
const (
	IntegrationRuntimeInternalChannelEncryptionModeNotEncrypted IntegrationRuntimeInternalChannelEncryptionMode = "NotEncrypted"
	IntegrationRuntimeInternalChannelEncryptionModeNotSet       IntegrationRuntimeInternalChannelEncryptionMode = "NotSet"
	IntegrationRuntimeInternalChannelEncryptionModeSslEncrypted IntegrationRuntimeInternalChannelEncryptionMode = "SslEncrypted"
)

func (*IntegrationRuntimeInternalChannelEncryptionMode) UnmarshalJSON 

func (s *IntegrationRuntimeInternalChannelEncryptionMode) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeLicenseType 

type IntegrationRuntimeLicenseType string
const (
	IntegrationRuntimeLicenseTypeBasePrice       IntegrationRuntimeLicenseType = "BasePrice"
	IntegrationRuntimeLicenseTypeLicenseIncluded IntegrationRuntimeLicenseType = "LicenseIncluded"
)

func (*IntegrationRuntimeLicenseType) UnmarshalJSON 

func (s *IntegrationRuntimeLicenseType) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeMonitoringData 

type IntegrationRuntimeMonitoringData struct {
	Name  *string                                 `json:"name,omitempty"`
	Nodes *[]IntegrationRuntimeNodeMonitoringData `json:"nodes,omitempty"`
}

type IntegrationRuntimeNodeIPAddress 

type IntegrationRuntimeNodeIPAddress struct {
	IPAddress *string `json:"ipAddress,omitempty"`
}

type IntegrationRuntimeNodeMonitoringData 

type IntegrationRuntimeNodeMonitoringData struct {
	AvailableMemoryInMB   *int64   `json:"availableMemoryInMB,omitempty"`
	ConcurrentJobsLimit   *int64   `json:"concurrentJobsLimit,omitempty"`
	ConcurrentJobsRunning *int64   `json:"concurrentJobsRunning,omitempty"`
	CpuUtilization        *int64   `json:"cpuUtilization,omitempty"`
	MaxConcurrentJobs     *int64   `json:"maxConcurrentJobs,omitempty"`
	NodeName              *string  `json:"nodeName,omitempty"`
	ReceivedBytes         *float64 `json:"receivedBytes,omitempty"`
	SentBytes             *float64 `json:"sentBytes,omitempty"`
}

type IntegrationRuntimeRegenerateKeyParameters 

type IntegrationRuntimeRegenerateKeyParameters struct {
	KeyName *IntegrationRuntimeAuthKeyName `json:"keyName,omitempty"`
}

type IntegrationRuntimeResource 

type IntegrationRuntimeResource struct {
	Etag       *string            `json:"etag,omitempty"`
	Id         *string            `json:"id,omitempty"`
	Name       *string            `json:"name,omitempty"`
	Properties IntegrationRuntime `json:"properties"`
	Type       *string            `json:"type,omitempty"`
}

func (*IntegrationRuntimeResource) UnmarshalJSON 

func (s *IntegrationRuntimeResource) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeResourceOperationPredicate 

type IntegrationRuntimeResourceOperationPredicate struct {
	Etag *string
	Id   *string
	Name *string
	Type *string
}

func (IntegrationRuntimeResourceOperationPredicate) Matches 

func (p IntegrationRuntimeResourceOperationPredicate) Matches(input IntegrationRuntimeResource) bool

type IntegrationRuntimeSsisCatalogInfo 

type IntegrationRuntimeSsisCatalogInfo struct {
	CatalogAdminPassword  *SecureString                             `json:"catalogAdminPassword,omitempty"`
	CatalogAdminUserName  *string                                   `json:"catalogAdminUserName,omitempty"`
	CatalogPricingTier    *IntegrationRuntimeSsisCatalogPricingTier `json:"catalogPricingTier,omitempty"`
	CatalogServerEndpoint *string                                   `json:"catalogServerEndpoint,omitempty"`
}

type IntegrationRuntimeSsisCatalogPricingTier 

type IntegrationRuntimeSsisCatalogPricingTier string
const (
	IntegrationRuntimeSsisCatalogPricingTierBasic     IntegrationRuntimeSsisCatalogPricingTier = "Basic"
	IntegrationRuntimeSsisCatalogPricingTierPremium   IntegrationRuntimeSsisCatalogPricingTier = "Premium"
	IntegrationRuntimeSsisCatalogPricingTierPremiumRS IntegrationRuntimeSsisCatalogPricingTier = "PremiumRS"
	IntegrationRuntimeSsisCatalogPricingTierStandard  IntegrationRuntimeSsisCatalogPricingTier = "Standard"
)

func (*IntegrationRuntimeSsisCatalogPricingTier) UnmarshalJSON 

func (s *IntegrationRuntimeSsisCatalogPricingTier) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeSsisProperties 

type IntegrationRuntimeSsisProperties struct {
	CatalogInfo                  *IntegrationRuntimeSsisCatalogInfo             `json:"catalogInfo,omitempty"`
	CustomSetupScriptProperties  *IntegrationRuntimeCustomSetupScriptProperties `json:"customSetupScriptProperties,omitempty"`
	DataProxyProperties          *IntegrationRuntimeDataProxyProperties         `json:"dataProxyProperties,omitempty"`
	Edition                      *IntegrationRuntimeEdition                     `json:"edition,omitempty"`
	ExpressCustomSetupProperties *[]CustomSetupBase                             `json:"expressCustomSetupProperties,omitempty"`
	LicenseType                  *IntegrationRuntimeLicenseType                 `json:"licenseType,omitempty"`
}

func (*IntegrationRuntimeSsisProperties) UnmarshalJSON 

func (s *IntegrationRuntimeSsisProperties) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeState 

type IntegrationRuntimeState string
const (
	IntegrationRuntimeStateAccessDenied     IntegrationRuntimeState = "AccessDenied"
	IntegrationRuntimeStateInitial          IntegrationRuntimeState = "Initial"
	IntegrationRuntimeStateLimited          IntegrationRuntimeState = "Limited"
	IntegrationRuntimeStateNeedRegistration IntegrationRuntimeState = "NeedRegistration"
	IntegrationRuntimeStateOffline          IntegrationRuntimeState = "Offline"
	IntegrationRuntimeStateOnline           IntegrationRuntimeState = "Online"
	IntegrationRuntimeStateStarted          IntegrationRuntimeState = "Started"
	IntegrationRuntimeStateStarting         IntegrationRuntimeState = "Starting"
	IntegrationRuntimeStateStopped          IntegrationRuntimeState = "Stopped"
	IntegrationRuntimeStateStopping         IntegrationRuntimeState = "Stopping"
)

func (*IntegrationRuntimeState) UnmarshalJSON 

func (s *IntegrationRuntimeState) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeStatus 

type IntegrationRuntimeStatus interface {
}

type IntegrationRuntimeStatusResponse 

type IntegrationRuntimeStatusResponse struct {
	Name       *string                  `json:"name,omitempty"`
	Properties IntegrationRuntimeStatus `json:"properties"`
}

func (*IntegrationRuntimeStatusResponse) UnmarshalJSON 

func (s *IntegrationRuntimeStatusResponse) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeType 

type IntegrationRuntimeType string
const (
	IntegrationRuntimeTypeManaged    IntegrationRuntimeType = "Managed"
	IntegrationRuntimeTypeSelfHosted IntegrationRuntimeType = "SelfHosted"
)

func (*IntegrationRuntimeType) UnmarshalJSON 

func (s *IntegrationRuntimeType) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeUpdateResult 

type IntegrationRuntimeUpdateResult string
const (
	IntegrationRuntimeUpdateResultFail    IntegrationRuntimeUpdateResult = "Fail"
	IntegrationRuntimeUpdateResultNone    IntegrationRuntimeUpdateResult = "None"
	IntegrationRuntimeUpdateResultSucceed IntegrationRuntimeUpdateResult = "Succeed"
)

func (*IntegrationRuntimeUpdateResult) UnmarshalJSON 

func (s *IntegrationRuntimeUpdateResult) UnmarshalJSON(bytes []byte) error

type IntegrationRuntimeVNetProperties 

type IntegrationRuntimeVNetProperties struct {
	PublicIPs *[]string `json:"publicIPs,omitempty"`
	Subnet    *string   `json:"subnet,omitempty"`
	SubnetId  *string   `json:"subnetId,omitempty"`
	VNetId    *string   `json:"vNetId,omitempty"`
}

type LinkedIntegrationRuntime 

type LinkedIntegrationRuntime struct {
	CreateTime          *string `json:"createTime,omitempty"`
	DataFactoryLocation *string `json:"dataFactoryLocation,omitempty"`
	DataFactoryName     *string `json:"dataFactoryName,omitempty"`
	Name                *string `json:"name,omitempty"`
	SubscriptionId      *string `json:"subscriptionId,omitempty"`
}

func (*LinkedIntegrationRuntime) GetCreateTimeAsTime 

func (o *LinkedIntegrationRuntime) GetCreateTimeAsTime() (*time.Time, error)

func (*LinkedIntegrationRuntime) SetCreateTimeAsTime 

func (o *LinkedIntegrationRuntime) SetCreateTimeAsTime(input time.Time)

type LinkedIntegrationRuntimeKeyAuthorization 

type LinkedIntegrationRuntimeKeyAuthorization struct {
	Key SecureString `json:"key"`
}

func (LinkedIntegrationRuntimeKeyAuthorization) MarshalJSON 

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

type LinkedIntegrationRuntimeRbacAuthorization 

type LinkedIntegrationRuntimeRbacAuthorization struct {
	ResourceId string `json:"resourceId"`
}

func (LinkedIntegrationRuntimeRbacAuthorization) MarshalJSON 

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

type LinkedIntegrationRuntimeType 

type LinkedIntegrationRuntimeType interface {
}

type ListByWorkspaceCompleteResult 

type ListByWorkspaceCompleteResult struct {
	LatestHttpResponse *http.Response
	Items              []IntegrationRuntimeResource
}

type ListByWorkspaceOperationResponse 

type ListByWorkspaceOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *[]IntegrationRuntimeResource
}

type ManagedIntegrationRuntime 

type ManagedIntegrationRuntime struct {
	ManagedVirtualNetwork *ManagedIntegrationRuntimeManagedVirtualNetworkReference `json:"managedVirtualNetwork,omitempty"`
	ProvisioningState     *IntegrationRuntimeState                                 `json:"provisioningState,omitempty"`
	TypeProperties        ManagedIntegrationRuntimeTypeProperties                  `json:"typeProperties"`

	// Fields inherited from IntegrationRuntime
	Description *string `json:"description,omitempty"`
}

func (ManagedIntegrationRuntime) MarshalJSON 

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

type ManagedIntegrationRuntimeError 

type ManagedIntegrationRuntimeError struct {
	Code       *string   `json:"code,omitempty"`
	Message    *string   `json:"message,omitempty"`
	Parameters *[]string `json:"parameters,omitempty"`
	Time       *string   `json:"time,omitempty"`
}

func (*ManagedIntegrationRuntimeError) GetTimeAsTime 

func (o *ManagedIntegrationRuntimeError) GetTimeAsTime() (*time.Time, error)

func (*ManagedIntegrationRuntimeError) SetTimeAsTime 

func (o *ManagedIntegrationRuntimeError) SetTimeAsTime(input time.Time)

type ManagedIntegrationRuntimeManagedVirtualNetworkReference 

type ManagedIntegrationRuntimeManagedVirtualNetworkReference struct {
	Id            *string `json:"id,omitempty"`
	ReferenceName *string `json:"referenceName,omitempty"`
	Type          *string `json:"type,omitempty"`
}

type ManagedIntegrationRuntimeNode 

type ManagedIntegrationRuntimeNode struct {
	Errors *[]ManagedIntegrationRuntimeError    `json:"errors,omitempty"`
	NodeId *string                              `json:"nodeId,omitempty"`
	Status *ManagedIntegrationRuntimeNodeStatus `json:"status,omitempty"`
}

type ManagedIntegrationRuntimeNodeStatus 

type ManagedIntegrationRuntimeNodeStatus string
const (
	ManagedIntegrationRuntimeNodeStatusAvailable   ManagedIntegrationRuntimeNodeStatus = "Available"
	ManagedIntegrationRuntimeNodeStatusRecycling   ManagedIntegrationRuntimeNodeStatus = "Recycling"
	ManagedIntegrationRuntimeNodeStatusStarting    ManagedIntegrationRuntimeNodeStatus = "Starting"
	ManagedIntegrationRuntimeNodeStatusUnavailable ManagedIntegrationRuntimeNodeStatus = "Unavailable"
)

func (*ManagedIntegrationRuntimeNodeStatus) UnmarshalJSON 

func (s *ManagedIntegrationRuntimeNodeStatus) UnmarshalJSON(bytes []byte) error

type ManagedIntegrationRuntimeOperationResult 

type ManagedIntegrationRuntimeOperationResult struct {
	ActivityId *string   `json:"activityId,omitempty"`
	ErrorCode  *string   `json:"errorCode,omitempty"`
	Parameters *[]string `json:"parameters,omitempty"`
	Result     *string   `json:"result,omitempty"`
	StartTime  *string   `json:"startTime,omitempty"`
	Type       *string   `json:"type,omitempty"`
}

func (*ManagedIntegrationRuntimeOperationResult) GetStartTimeAsTime 

func (o *ManagedIntegrationRuntimeOperationResult) GetStartTimeAsTime() (*time.Time, error)

func (*ManagedIntegrationRuntimeOperationResult) SetStartTimeAsTime 

func (o *ManagedIntegrationRuntimeOperationResult) SetStartTimeAsTime(input time.Time)

type ManagedIntegrationRuntimeStatus 

type ManagedIntegrationRuntimeStatus struct {
	TypeProperties ManagedIntegrationRuntimeStatusTypeProperties `json:"typeProperties"`

	// Fields inherited from IntegrationRuntimeStatus
	DataFactoryName *string                  `json:"dataFactoryName,omitempty"`
	State           *IntegrationRuntimeState `json:"state,omitempty"`
}

func (ManagedIntegrationRuntimeStatus) MarshalJSON 

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

type ManagedIntegrationRuntimeStatusTypeProperties 

type ManagedIntegrationRuntimeStatusTypeProperties struct {
	CreateTime    *string                                   `json:"createTime,omitempty"`
	LastOperation *ManagedIntegrationRuntimeOperationResult `json:"lastOperation,omitempty"`
	Nodes         *[]ManagedIntegrationRuntimeNode          `json:"nodes,omitempty"`
	OtherErrors   *[]ManagedIntegrationRuntimeError         `json:"otherErrors,omitempty"`
}

func (*ManagedIntegrationRuntimeStatusTypeProperties) GetCreateTimeAsTime 

func (o *ManagedIntegrationRuntimeStatusTypeProperties) GetCreateTimeAsTime() (*time.Time, error)

func (*ManagedIntegrationRuntimeStatusTypeProperties) SetCreateTimeAsTime 

func (o *ManagedIntegrationRuntimeStatusTypeProperties) SetCreateTimeAsTime(input time.Time)

type ManagedIntegrationRuntimeTypeProperties 

type ManagedIntegrationRuntimeTypeProperties struct {
	ComputeProperties      *IntegrationRuntimeComputeProperties      `json:"computeProperties,omitempty"`
	CustomerVirtualNetwork *IntegrationRuntimeCustomerVirtualNetwork `json:"customerVirtualNetwork,omitempty"`
	SsisProperties         *IntegrationRuntimeSsisProperties         `json:"ssisProperties,omitempty"`
}

type MonitoringDataListOperationResponse 

type MonitoringDataListOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeMonitoringData
}

type NodeIPAddressGetOperationResponse 

type NodeIPAddressGetOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeNodeIPAddress
}

type NodeId 

type NodeId struct {
	SubscriptionId         string
	ResourceGroupName      string
	WorkspaceName          string
	IntegrationRuntimeName string
	NodeName               string
}

NodeId is a struct representing the Resource ID for a Node

func NewNodeID 

func NewNodeID(subscriptionId string, resourceGroupName string, workspaceName string, integrationRuntimeName string, nodeName string) NodeId

NewNodeID returns a new NodeId struct

func ParseNodeID 

func ParseNodeID(input string) (*NodeId, error)

ParseNodeID parses 'input' into a NodeId

func ParseNodeIDInsensitively 

func ParseNodeIDInsensitively(input string) (*NodeId, error)

ParseNodeIDInsensitively parses 'input' case-insensitively into a NodeId note: this method should only be used for API response data and not user input

func (*NodeId) FromParseResult 

func (id *NodeId) FromParseResult(input resourceids.ParseResult) error

func (NodeId) ID 

func (id NodeId) ID() string

ID returns the formatted Node ID

func (NodeId) Segments 

func (id NodeId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Node ID

func (NodeId) String 

func (id NodeId) String() string

String returns a human-readable description of this Node ID

type NodesDeleteOperationResponse 

type NodesDeleteOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
}

type NodesGetOperationResponse 

type NodesGetOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *SelfHostedIntegrationRuntimeNode
}

type NodesUpdateOperationResponse 

type NodesUpdateOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *SelfHostedIntegrationRuntimeNode
}

type ObjectMetadataListOperationResponse 

type ObjectMetadataListOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *SsisObjectMetadataListResponse
}

type ObjectMetadataRefreshOperationResponse 

type ObjectMetadataRefreshOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *SsisObjectMetadataStatusResponse
}

type RawCustomSetupBaseImpl 

type RawCustomSetupBaseImpl struct {
	Type   string
	Values map[string]interface{}
}

RawCustomSetupBaseImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawIntegrationRuntimeImpl 

type RawIntegrationRuntimeImpl struct {
	Type   string
	Values map[string]interface{}
}

RawIntegrationRuntimeImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawIntegrationRuntimeStatusImpl 

type RawIntegrationRuntimeStatusImpl struct {
	Type   string
	Values map[string]interface{}
}

RawIntegrationRuntimeStatusImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawLinkedIntegrationRuntimeTypeImpl 

type RawLinkedIntegrationRuntimeTypeImpl struct {
	Type   string
	Values map[string]interface{}
}

RawLinkedIntegrationRuntimeTypeImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawSecretBaseImpl 

type RawSecretBaseImpl struct {
	Type   string
	Values map[string]interface{}
}

RawSecretBaseImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type RawSsisObjectMetadataImpl 

type RawSsisObjectMetadataImpl struct {
	Type   string
	Values map[string]interface{}
}

RawSsisObjectMetadataImpl is returned when the Discriminated Value doesn't match any of the defined types NOTE: this should only be used when a type isn't defined for this type of Object (as a workaround) and is used only for Deserialization (e.g. this cannot be used as a Request Payload).

type SecretBase 

type SecretBase interface {
}

type SecureString 

type SecureString struct {
	Value string `json:"value"`
}

func (SecureString) MarshalJSON 

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

type SelfHostedIntegrationRuntime 

type SelfHostedIntegrationRuntime struct {
	TypeProperties *SelfHostedIntegrationRuntimeTypeProperties `json:"typeProperties,omitempty"`

	// Fields inherited from IntegrationRuntime
	Description *string `json:"description,omitempty"`
}

func (SelfHostedIntegrationRuntime) MarshalJSON 

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

type SelfHostedIntegrationRuntimeNode 

type SelfHostedIntegrationRuntimeNode struct {
	Capabilities        *map[string]string                      `json:"capabilities,omitempty"`
	ConcurrentJobsLimit *int64                                  `json:"concurrentJobsLimit,omitempty"`
	ExpiryTime          *string                                 `json:"expiryTime,omitempty"`
	HostServiceUri      *string                                 `json:"hostServiceUri,omitempty"`
	IsActiveDispatcher  *bool                                   `json:"isActiveDispatcher,omitempty"`
	LastConnectTime     *string                                 `json:"lastConnectTime,omitempty"`
	LastEndUpdateTime   *string                                 `json:"lastEndUpdateTime,omitempty"`
	LastStartTime       *string                                 `json:"lastStartTime,omitempty"`
	LastStartUpdateTime *string                                 `json:"lastStartUpdateTime,omitempty"`
	LastStopTime        *string                                 `json:"lastStopTime,omitempty"`
	LastUpdateResult    *IntegrationRuntimeUpdateResult         `json:"lastUpdateResult,omitempty"`
	MachineName         *string                                 `json:"machineName,omitempty"`
	MaxConcurrentJobs   *int64                                  `json:"maxConcurrentJobs,omitempty"`
	NodeName            *string                                 `json:"nodeName,omitempty"`
	RegisterTime        *string                                 `json:"registerTime,omitempty"`
	Status              *SelfHostedIntegrationRuntimeNodeStatus `json:"status,omitempty"`
	Version             *string                                 `json:"version,omitempty"`
	VersionStatus       *string                                 `json:"versionStatus,omitempty"`
}

func (*SelfHostedIntegrationRuntimeNode) GetExpiryTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) GetExpiryTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeNode) GetLastConnectTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) GetLastConnectTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeNode) GetLastEndUpdateTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) GetLastEndUpdateTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeNode) GetLastStartTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) GetLastStartTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeNode) GetLastStartUpdateTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) GetLastStartUpdateTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeNode) GetLastStopTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) GetLastStopTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeNode) GetRegisterTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) GetRegisterTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeNode) SetExpiryTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) SetExpiryTimeAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeNode) SetLastConnectTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) SetLastConnectTimeAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeNode) SetLastEndUpdateTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) SetLastEndUpdateTimeAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeNode) SetLastStartTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) SetLastStartTimeAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeNode) SetLastStartUpdateTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) SetLastStartUpdateTimeAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeNode) SetLastStopTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) SetLastStopTimeAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeNode) SetRegisterTimeAsTime 

func (o *SelfHostedIntegrationRuntimeNode) SetRegisterTimeAsTime(input time.Time)

type SelfHostedIntegrationRuntimeNodeStatus 

type SelfHostedIntegrationRuntimeNodeStatus string
const (
	SelfHostedIntegrationRuntimeNodeStatusInitializeFailed SelfHostedIntegrationRuntimeNodeStatus = "InitializeFailed"
	SelfHostedIntegrationRuntimeNodeStatusInitializing     SelfHostedIntegrationRuntimeNodeStatus = "Initializing"
	SelfHostedIntegrationRuntimeNodeStatusLimited          SelfHostedIntegrationRuntimeNodeStatus = "Limited"
	SelfHostedIntegrationRuntimeNodeStatusNeedRegistration SelfHostedIntegrationRuntimeNodeStatus = "NeedRegistration"
	SelfHostedIntegrationRuntimeNodeStatusOffline          SelfHostedIntegrationRuntimeNodeStatus = "Offline"
	SelfHostedIntegrationRuntimeNodeStatusOnline           SelfHostedIntegrationRuntimeNodeStatus = "Online"
	SelfHostedIntegrationRuntimeNodeStatusUpgrading        SelfHostedIntegrationRuntimeNodeStatus = "Upgrading"
)

func (*SelfHostedIntegrationRuntimeNodeStatus) UnmarshalJSON 

func (s *SelfHostedIntegrationRuntimeNodeStatus) UnmarshalJSON(bytes []byte) error

type SelfHostedIntegrationRuntimeStatus 

type SelfHostedIntegrationRuntimeStatus struct {
	TypeProperties SelfHostedIntegrationRuntimeStatusTypeProperties `json:"typeProperties"`

	// Fields inherited from IntegrationRuntimeStatus
	DataFactoryName *string                  `json:"dataFactoryName,omitempty"`
	State           *IntegrationRuntimeState `json:"state,omitempty"`
}

func (SelfHostedIntegrationRuntimeStatus) MarshalJSON 

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

type SelfHostedIntegrationRuntimeStatusTypeProperties 

type SelfHostedIntegrationRuntimeStatusTypeProperties struct {
	AutoUpdate                             *IntegrationRuntimeAutoUpdate                    `json:"autoUpdate,omitempty"`
	AutoUpdateETA                          *string                                          `json:"autoUpdateETA,omitempty"`
	Capabilities                           *map[string]string                               `json:"capabilities,omitempty"`
	CreateTime                             *string                                          `json:"createTime,omitempty"`
	InternalChannelEncryption              *IntegrationRuntimeInternalChannelEncryptionMode `json:"internalChannelEncryption,omitempty"`
	LatestVersion                          *string                                          `json:"latestVersion,omitempty"`
	Links                                  *[]LinkedIntegrationRuntime                      `json:"links,omitempty"`
	LocalTimeZoneOffset                    *string                                          `json:"localTimeZoneOffset,omitempty"`
	NodeCommunicationChannelEncryptionMode *string                                          `json:"nodeCommunicationChannelEncryptionMode,omitempty"`
	Nodes                                  *[]SelfHostedIntegrationRuntimeNode              `json:"nodes,omitempty"`
	PushedVersion                          *string                                          `json:"pushedVersion,omitempty"`
	ScheduledUpdateDate                    *string                                          `json:"scheduledUpdateDate,omitempty"`
	ServiceUrls                            *[]string                                        `json:"serviceUrls,omitempty"`
	TaskQueueId                            *string                                          `json:"taskQueueId,omitempty"`
	UpdateDelayOffset                      *string                                          `json:"updateDelayOffset,omitempty"`
	Version                                *string                                          `json:"version,omitempty"`
	VersionStatus                          *string                                          `json:"versionStatus,omitempty"`
}

func (*SelfHostedIntegrationRuntimeStatusTypeProperties) GetAutoUpdateETAAsTime 

func (o *SelfHostedIntegrationRuntimeStatusTypeProperties) GetAutoUpdateETAAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeStatusTypeProperties) GetCreateTimeAsTime 

func (o *SelfHostedIntegrationRuntimeStatusTypeProperties) GetCreateTimeAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeStatusTypeProperties) GetScheduledUpdateDateAsTime 

func (o *SelfHostedIntegrationRuntimeStatusTypeProperties) GetScheduledUpdateDateAsTime() (*time.Time, error)

func (*SelfHostedIntegrationRuntimeStatusTypeProperties) SetAutoUpdateETAAsTime 

func (o *SelfHostedIntegrationRuntimeStatusTypeProperties) SetAutoUpdateETAAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeStatusTypeProperties) SetCreateTimeAsTime 

func (o *SelfHostedIntegrationRuntimeStatusTypeProperties) SetCreateTimeAsTime(input time.Time)

func (*SelfHostedIntegrationRuntimeStatusTypeProperties) SetScheduledUpdateDateAsTime 

func (o *SelfHostedIntegrationRuntimeStatusTypeProperties) SetScheduledUpdateDateAsTime(input time.Time)

type SelfHostedIntegrationRuntimeTypeProperties 

type SelfHostedIntegrationRuntimeTypeProperties struct {
	LinkedInfo LinkedIntegrationRuntimeType `json:"linkedInfo"`
}

func (*SelfHostedIntegrationRuntimeTypeProperties) UnmarshalJSON 

func (s *SelfHostedIntegrationRuntimeTypeProperties) UnmarshalJSON(bytes []byte) error

type SsisEnvironment 

type SsisEnvironment struct {
	FolderId  *int64          `json:"folderId,omitempty"`
	Variables *[]SsisVariable `json:"variables,omitempty"`

	// Fields inherited from SsisObjectMetadata
	Description *string `json:"description,omitempty"`
	Id          *int64  `json:"id,omitempty"`
	Name        *string `json:"name,omitempty"`
}

func (SsisEnvironment) MarshalJSON 

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

type SsisEnvironmentReference 

type SsisEnvironmentReference struct {
	EnvironmentFolderName *string `json:"environmentFolderName,omitempty"`
	EnvironmentName       *string `json:"environmentName,omitempty"`
	Id                    *int64  `json:"id,omitempty"`
	ReferenceType         *string `json:"referenceType,omitempty"`
}

type SsisFolder 

type SsisFolder struct {

	// Fields inherited from SsisObjectMetadata
	Description *string `json:"description,omitempty"`
	Id          *int64  `json:"id,omitempty"`
	Name        *string `json:"name,omitempty"`
}

func (SsisFolder) MarshalJSON 

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

type SsisObjectMetadata 

type SsisObjectMetadata interface {
}

type SsisObjectMetadataListResponse 

type SsisObjectMetadataListResponse struct {
	NextLink *string               `json:"nextLink,omitempty"`
	Value    *[]SsisObjectMetadata `json:"value,omitempty"`
}

func (*SsisObjectMetadataListResponse) UnmarshalJSON 

func (s *SsisObjectMetadataListResponse) UnmarshalJSON(bytes []byte) error

type SsisObjectMetadataStatusResponse 

type SsisObjectMetadataStatusResponse struct {
	Error      *string `json:"error,omitempty"`
	Name       *string `json:"name,omitempty"`
	Properties *string `json:"properties,omitempty"`
	Status     *string `json:"status,omitempty"`
}

type SsisObjectMetadataType 

type SsisObjectMetadataType string
const (
	SsisObjectMetadataTypeEnvironment SsisObjectMetadataType = "Environment"
	SsisObjectMetadataTypeFolder      SsisObjectMetadataType = "Folder"
	SsisObjectMetadataTypePackage     SsisObjectMetadataType = "Package"
	SsisObjectMetadataTypeProject     SsisObjectMetadataType = "Project"
)

func (*SsisObjectMetadataType) UnmarshalJSON 

func (s *SsisObjectMetadataType) UnmarshalJSON(bytes []byte) error

type SsisPackage 

type SsisPackage struct {
	FolderId       *int64           `json:"folderId,omitempty"`
	Parameters     *[]SsisParameter `json:"parameters,omitempty"`
	ProjectId      *int64           `json:"projectId,omitempty"`
	ProjectVersion *int64           `json:"projectVersion,omitempty"`

	// Fields inherited from SsisObjectMetadata
	Description *string `json:"description,omitempty"`
	Id          *int64  `json:"id,omitempty"`
	Name        *string `json:"name,omitempty"`
}

func (SsisPackage) MarshalJSON 

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

type SsisParameter 

type SsisParameter struct {
	DataType              *string `json:"dataType,omitempty"`
	DefaultValue          *string `json:"defaultValue,omitempty"`
	Description           *string `json:"description,omitempty"`
	DesignDefaultValue    *string `json:"designDefaultValue,omitempty"`
	Id                    *int64  `json:"id,omitempty"`
	Name                  *string `json:"name,omitempty"`
	Required              *bool   `json:"required,omitempty"`
	Sensitive             *bool   `json:"sensitive,omitempty"`
	SensitiveDefaultValue *string `json:"sensitiveDefaultValue,omitempty"`
	ValueSet              *bool   `json:"valueSet,omitempty"`
	ValueType             *string `json:"valueType,omitempty"`
	Variable              *string `json:"variable,omitempty"`
}

type SsisProject 

type SsisProject struct {
	EnvironmentRefs *[]SsisEnvironmentReference `json:"environmentRefs,omitempty"`
	FolderId        *int64                      `json:"folderId,omitempty"`
	Parameters      *[]SsisParameter            `json:"parameters,omitempty"`
	Version         *int64                      `json:"version,omitempty"`

	// Fields inherited from SsisObjectMetadata
	Description *string `json:"description,omitempty"`
	Id          *int64  `json:"id,omitempty"`
	Name        *string `json:"name,omitempty"`
}

func (SsisProject) MarshalJSON 

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

type SsisVariable 

type SsisVariable struct {
	DataType       *string `json:"dataType,omitempty"`
	Description    *string `json:"description,omitempty"`
	Id             *int64  `json:"id,omitempty"`
	Name           *string `json:"name,omitempty"`
	Sensitive      *bool   `json:"sensitive,omitempty"`
	SensitiveValue *string `json:"sensitiveValue,omitempty"`
	Value          *string `json:"value,omitempty"`
}

type StartOperationResponse 

type StartOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeStatusResponse
}

type StatusGetOperationResponse 

type StatusGetOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeStatusResponse
}

type StopOperationResponse 

type StopOperationResponse struct {
	Poller       pollers.Poller
	HttpResponse *http.Response
	OData        *odata.OData
}

type UpdateIntegrationRuntimeNodeRequest 

type UpdateIntegrationRuntimeNodeRequest struct {
	ConcurrentJobsLimit *int64 `json:"concurrentJobsLimit,omitempty"`
}

type UpdateIntegrationRuntimeRequest 

type UpdateIntegrationRuntimeRequest struct {
	AutoUpdate        *IntegrationRuntimeAutoUpdate `json:"autoUpdate,omitempty"`
	UpdateDelayOffset *string                       `json:"updateDelayOffset,omitempty"`
}

type UpdateOperationResponse 

type UpdateOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
	Model        *IntegrationRuntimeResource
}

type UpgradeOperationResponse 

type UpgradeOperationResponse struct {
	HttpResponse *http.Response
	OData        *odata.OData
}

type WorkspaceId 

type WorkspaceId struct {
	SubscriptionId    string
	ResourceGroupName string
	WorkspaceName     string
}

WorkspaceId is a struct representing the Resource ID for a Workspace

func NewWorkspaceID 

func NewWorkspaceID(subscriptionId string, resourceGroupName string, workspaceName string) WorkspaceId

NewWorkspaceID returns a new WorkspaceId struct

func ParseWorkspaceID 

func ParseWorkspaceID(input string) (*WorkspaceId, error)

ParseWorkspaceID parses 'input' into a WorkspaceId

func ParseWorkspaceIDInsensitively 

func ParseWorkspaceIDInsensitively(input string) (*WorkspaceId, error)

ParseWorkspaceIDInsensitively parses 'input' case-insensitively into a WorkspaceId note: this method should only be used for API response data and not user input

func (*WorkspaceId) FromParseResult 

func (id *WorkspaceId) FromParseResult(input resourceids.ParseResult) error

func (WorkspaceId) ID 

func (id WorkspaceId) ID() string

ID returns the formatted Workspace ID

func (WorkspaceId) Segments 

func (id WorkspaceId) Segments() []resourceids.Segment

Segments returns a slice of Resource ID Segments which comprise this Workspace ID

func (WorkspaceId) String 

func (id WorkspaceId) String() string

String returns a human-readable description of this Workspace ID

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.