azure

Documentation

Index

• Constants
• type Client
  • func NewAzureClient(namespaceClient eventhub.NamespacesClient, ...) *Client
  • func (nc *Client) CreateNamespace(ctx context.Context, azureCfg *Config, groupName, namespace string, tags Tags) (*eventhub.EHNamespace, error)
  • func (nc *Client) CreateResourceGroup(ctx context.Context, config *Config, name string, tags Tags) (resources.Group, error)
  • func (nc *Client) DeleteResourceGroup(ctx context.Context, tags Tags) (resources.GroupsDeleteFuture, error)
  • func (nc *Client) GetEventhubAccessKeys(ctx context.Context, resourceGroupName string, namespaceName string, ...) (result eventhub.AccessKeys, err error)
  • func (nc *Client) GetResourceGroup(ctx context.Context, tags Tags) (resources.Group, error)
• type Config
  • func GetConfig(clientID, clientSecret, tenantID, subscriptionID, location string) (*Config, error)
  • func GetConfigFromHAPCredentialsAndProvisioningParams(credentials hyperscaler.Credentials, ...) (*Config, error)
  • func NewDefaultConfig() *Config
  • func (c *Config) Environment() (*azure.Environment, error)
  • func (c *Config) GetLocation() string
• type HyperscalerProvider
  • func NewAzureProvider() HyperscalerProvider
• type Interface
• type ResourceGroupDoesNotExistError
  • func NewResourceGroupDoesNotExist(errorMessage string) ResourceGroupDoesNotExistError
  • func (e ResourceGroupDoesNotExistError) Error() string
• type Tags

Constants

const (
	FutureOperationSucceeded string = "Succeeded"
	FutureOperationDeleting  string = "Deleting"
)

const (
	// Azure tags used to identify the Kyma runtime
	TagSubAccountID = "SubAccountID"
	TagInstanceID   = "InstanceID"
	TagOperationID  = "OperationID"
)

Types

type Client

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

func NewAzureClient

func NewAzureClient(namespaceClient eventhub.NamespacesClient, resourcegroupClient resources.GroupsClient, logger logrus.FieldLogger) *Client

func (*Client) CreateNamespace

func (nc *Client) CreateNamespace(ctx context.Context, azureCfg *Config, groupName, namespace string, tags Tags) (*eventhub.EHNamespace, error)

func (*Client) CreateResourceGroup

func (nc *Client) CreateResourceGroup(ctx context.Context, config *Config, name string, tags Tags) (resources.Group, error)

func (*Client) DeleteResourceGroup

func (nc *Client) DeleteResourceGroup(ctx context.Context, tags Tags) (resources.GroupsDeleteFuture, error)

func (*Client) GetEventhubAccessKeys

func (nc *Client) GetEventhubAccessKeys(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string) (result eventhub.AccessKeys, err error)

func (*Client) GetResourceGroup

func (nc *Client) GetResourceGroup(ctx context.Context, tags Tags) (resources.Group, error)

GetResourceGroup gets the resource group by tags. If more than one resource group is found, it is treated as an error.

type Config

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

func GetConfig

func GetConfig(clientID, clientSecret, tenantID, subscriptionID, location string) (*Config, error)

func GetConfigFromHAPCredentialsAndProvisioningParams

func GetConfigFromHAPCredentialsAndProvisioningParams(credentials hyperscaler.Credentials, parameters internal.ProvisioningParameters) (*Config, error)

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) Environment

func (c *Config) Environment() (*azure.Environment, error)

func (*Config) GetLocation

func (c *Config) GetLocation() string

type HyperscalerProvider

type HyperscalerProvider interface {
	GetClient(config *Config, logger logrus.FieldLogger) (Interface, error)
}

func NewAzureProvider

func NewAzureProvider() HyperscalerProvider

type Interface

type Interface interface {
	GetEventhubAccessKeys(ctx context.Context, resourceGroupName string, namespaceName string, authorizationRuleName string) (result eventhub.AccessKeys, err error)
	CreateResourceGroup(ctx context.Context, config *Config, name string, tags Tags) (resources.Group, error)
	CreateNamespace(ctx context.Context, azureCfg *Config, groupName, namespace string, tags Tags) (*eventhub.EHNamespace, error)
	GetResourceGroup(ctx context.Context, tags Tags) (resources.Group, error)
	DeleteResourceGroup(ctx context.Context, tags Tags) (resources.GroupsDeleteFuture, error)
}

type ResourceGroupDoesNotExistError

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

func NewResourceGroupDoesNotExist

func NewResourceGroupDoesNotExist(errorMessage string) ResourceGroupDoesNotExistError

func (ResourceGroupDoesNotExistError) Error

func (e ResourceGroupDoesNotExistError) Error() string

type Tags

type Tags map[string]*string

Tags type represents Azure tags acceptable by the Azure client