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)
  • func (nc *Client) ListEHNamespaceByResourceGroup(ctx context.Context, resourceGroupName string) (eventhub.EHNamespaceListResultPage, error)
  • func (nc *Client) ListResourceGroup(ctx context.Context, filter string, top *int32) (resources.GroupListResultPage, 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.

func (*Client) ListEHNamespaceByResourceGroup

func (nc *Client) ListEHNamespaceByResourceGroup(ctx context.Context, resourceGroupName string) (eventhub.EHNamespaceListResultPage, error)

func (*Client) ListResourceGroup

func (nc *Client) ListResourceGroup(ctx context.Context, filter string, top *int32) (resources.GroupListResultPage, 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)
	ListResourceGroup(ctx context.Context, filter string, top *int32) (resources.GroupListResultPage, error)
	ListEHNamespaceByResourceGroup(ctx context.Context, resourceGroupName string) (eventhub.EHNamespaceListResultPage, 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