deployment

Documentation

Index

• Constants
• type ARMDiagnosticsClient
  • func (dc *ARMDiagnosticsClient) Expose(ctx context.Context, options clients.ExposeOptions) (failed chan error, stop chan struct{}, signals chan os.Signal, err error)
  • func (dc *ARMDiagnosticsClient) GetPublicEndpoint(ctx context.Context, options clients.EndpointOptions) (*string, error)
  • func (dc *ARMDiagnosticsClient) Logs(ctx context.Context, options clients.LogsOptions) ([]clients.LogStream, error)
• type ResourceDeploymentClient
  • func (dc *ResourceDeploymentClient) Deploy(ctx context.Context, options clients.DeploymentOptions) (clients.DeploymentResult, error)
  • func (dc *ResourceDeploymentClient) GetProviderConfigs(options clients.DeploymentOptions) sdkclients.ProviderConfig

Constants

const (
	NestedModuleType string = "Microsoft.Resources/deployments"

	// OperationPollInterval is the interval used for polling of deployment operations for progress.
	OperationPollInterval time.Duration = time.Second * 5
)

Types

type ARMDiagnosticsClient

type ARMDiagnosticsClient struct {
	K8sTypedClient    *k8s.Clientset
	RestConfig        *rest.Config
	K8sRuntimeClient  client.Client
	ApplicationClient generated.GenericResourcesClient
	ContainerClient   generated.GenericResourcesClient
	EnvironmentClient generated.GenericResourcesClient
	GatewayClient     generated.GenericResourcesClient
}

func (*ARMDiagnosticsClient) Expose

func (dc *ARMDiagnosticsClient) Expose(ctx context.Context, options clients.ExposeOptions) (failed chan error, stop chan struct{}, signals chan os.Signal, err error)

Expose function finds a running replica of the container, prints the replica name, sets up a signal notification, creates channels for errors, readiness and stopping, and runs a portforwarding process.

func (*ARMDiagnosticsClient) GetPublicEndpoint

func (dc *ARMDiagnosticsClient) GetPublicEndpoint(ctx context.Context, options clients.EndpointOptions) (*string, error)

GetPublicEndpoint checks if the resource type is Applications.Core/gateways, then attempts to get the URL from the response properties, and returns the URL as a string or an error if the URL is not found.

func (*ARMDiagnosticsClient) Logs

func (dc *ARMDiagnosticsClient) Logs(ctx context.Context, options clients.LogsOptions) ([]clients.LogStream, error)

Logs() retrieves the running replicas of the container, and creates log streams for the replicas. If an error occurs, it will close all the created streams before returning the error.

type ResourceDeploymentClient

type ResourceDeploymentClient struct {
	RadiusResourceGroup string
	Client              *sdkclients.ResourceDeploymentsClient
	OperationsClient    *sdkclients.ResourceDeploymentOperationsClient
	Tags                map[string]*string
}

func (*ResourceDeploymentClient) Deploy

func (dc *ResourceDeploymentClient) Deploy(ctx context.Context, options clients.DeploymentOptions) (clients.DeploymentResult, error)

Deploy starts a deployment, monitors its progress, and returns the deployment summary when it is complete, or an error if one occurs.

func (*ResourceDeploymentClient) GetProviderConfigs

func (dc *ResourceDeploymentClient) GetProviderConfigs(options clients.DeploymentOptions) sdkclients.ProviderConfig

GetProviderConfigs() creates a default provider config and then updates it with any provider scopes passed in the DeploymentOptions.