arm

Documentation

Index

• Constants
• func ClassifyCloudError(err *genericarmclient.CloudError) (core.CloudErrorDetails, error)
• func ClearPollerResumeToken(obj genruntime.MetaObject)
• func ConvertToARMResourceImpl(ctx context.Context, metaObject genruntime.ARMMetaObject, ...) (genruntime.ARMResource, error)
• func GetPollerResumeToken(obj genruntime.MetaObject) (string, string, bool)
• func NoAction(_ context.Context) (ctrl.Result, error)
• func SetPollerResumeToken(obj genruntime.MetaObject, id string, token string)
• type ARMClientCache
  • func NewARMClientCache(credentialProvider identity.CredentialProvider, kubeClient kubeclient.Client, ...) *ARMClientCache
  • func (c *ARMClientCache) GetConnection(ctx context.Context, obj genruntime.ARMMetaObject) (Connection, error)
• type ARMConnectionFactory
• type AzureDeploymentReconciler
  • func NewAzureDeploymentReconciler(armConnectionFactory ARMConnectionFactory, kubeClient kubeclient.Client, ...) *AzureDeploymentReconciler
  • func (r *AzureDeploymentReconciler) Claim(ctx context.Context, log logr.Logger, eventRecorder record.EventRecorder, ...) error
  • func (r *AzureDeploymentReconciler) CreateOrUpdate(ctx context.Context, log logr.Logger, eventRecorder record.EventRecorder, ...) (ctrl.Result, error)
  • func (r *AzureDeploymentReconciler) Delete(ctx context.Context, log logr.Logger, eventRecorder record.EventRecorder, ...) (ctrl.Result, error)
  • func (r *AzureDeploymentReconciler) UpdateStatus(ctx context.Context, log logr.Logger, eventRecorder record.EventRecorder, ...) error
• type Connection
• type CreateOrUpdateAction
• type CreateOrUpdateActionFunc
• type CreateOrUpdateSuccessMode
• type DeleteAction
• type DeleteActionFunc

Constants

const (
	PollerResumeTokenAnnotation = "serviceoperator.azure.com/poller-resume-token"
	PollerResumeIDAnnotation    = "serviceoperator.azure.com/poller-resume-id"
)

const (
	CreateOrUpdateActionNoAction        = CreateOrUpdateAction("NoAction")
	CreateOrUpdateActionBeginCreation   = CreateOrUpdateAction("BeginCreateOrUpdate")
	CreateOrUpdateActionMonitorCreation = CreateOrUpdateAction("MonitorCreateOrUpdate")
)

const (
	DeleteActionBeginDelete   = DeleteAction("BeginDelete")
	DeleteActionMonitorDelete = DeleteAction("MonitorDelete")
)

const (
	WatchResource  = CreateOrUpdateSuccessMode("watch")
	ManageResource = CreateOrUpdateSuccessMode("manage")
)

Functions

func ClassifyCloudError

func ClassifyCloudError(err *genericarmclient.CloudError) (core.CloudErrorDetails, error)

func ClearPollerResumeToken

func ClearPollerResumeToken(obj genruntime.MetaObject)

ClearPollerResumeToken clears the poller resume token and ID annotations

func ConvertToARMResourceImpl

func ConvertToARMResourceImpl(
	ctx context.Context,
	metaObject genruntime.ARMMetaObject,
	scheme *runtime.Scheme,
	resolver *resolver.Resolver,
	subscriptionID string) (genruntime.ARMResource, error)

ConvertToARMResourceImpl factored out of AzureDeploymentReconciler.ConvertResourceToARMResource to allow for testing

func GetPollerResumeToken

func GetPollerResumeToken(obj genruntime.MetaObject) (string, string, bool)

GetPollerResumeToken returns a poller ID and the poller token

func NoAction

func NoAction(_ context.Context) (ctrl.Result, error)

func SetPollerResumeToken

func SetPollerResumeToken(obj genruntime.MetaObject, id string, token string)

Types

type ARMClientCache

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

ARMClientCache is a cache for armClients to hold multiple credential clients and global credential client.

func NewARMClientCache

func NewARMClientCache(
	credentialProvider identity.CredentialProvider,
	kubeClient kubeclient.Client,
	configuration cloud.Configuration,
	httpClient *http.Client,
	armMetrics *metrics.ARMClientMetrics) *ARMClientCache

func (*ARMClientCache) GetConnection

func (c *ARMClientCache) GetConnection(ctx context.Context, obj genruntime.ARMMetaObject) (Connection, error)

GetConnection finds and returns connection details to be used for a given resource

type ARMConnectionFactory

type ARMConnectionFactory func(context.Context, genruntime.ARMMetaObject) (Connection, error)

type AzureDeploymentReconciler

type AzureDeploymentReconciler struct {
	reconcilers.ARMOwnedResourceReconcilerCommon
	ARMConnectionFactory ARMConnectionFactory
	KubeClient           kubeclient.Client
	ResourceResolver     *resolver.Resolver
	PositiveConditions   *conditions.PositiveConditionBuilder
	Config               config.Values
	Extension            genruntime.ResourceExtension
}

func NewAzureDeploymentReconciler

func NewAzureDeploymentReconciler(
	armConnectionFactory ARMConnectionFactory,
	kubeClient kubeclient.Client,
	resourceResolver *resolver.Resolver,
	positiveConditions *conditions.PositiveConditionBuilder,
	cfg config.Values,
	extension genruntime.ResourceExtension) *AzureDeploymentReconciler

func (*AzureDeploymentReconciler) Claim

func (r *AzureDeploymentReconciler) Claim(
	ctx context.Context,
	log logr.Logger,
	eventRecorder record.EventRecorder,
	obj genruntime.MetaObject,
) error

func (*AzureDeploymentReconciler) CreateOrUpdate

func (r *AzureDeploymentReconciler) CreateOrUpdate(
	ctx context.Context,
	log logr.Logger,
	eventRecorder record.EventRecorder,
	obj genruntime.MetaObject,
) (ctrl.Result, error)

func (*AzureDeploymentReconciler) Delete

func (r *AzureDeploymentReconciler) Delete(
	ctx context.Context,
	log logr.Logger,
	eventRecorder record.EventRecorder,
	obj genruntime.MetaObject,
) (ctrl.Result, error)

func (*AzureDeploymentReconciler) UpdateStatus

func (r *AzureDeploymentReconciler) UpdateStatus(
	ctx context.Context,
	log logr.Logger,
	eventRecorder record.EventRecorder,
	obj genruntime.MetaObject,
) error

type Connection

type Connection interface {
	Client() *genericarmclient.GenericClient
	CredentialFrom() types.NamespacedName
	SubscriptionID() string
}

type CreateOrUpdateAction

type CreateOrUpdateAction string

type CreateOrUpdateActionFunc

type CreateOrUpdateActionFunc = func(ctx context.Context) (ctrl.Result, error)

type CreateOrUpdateSuccessMode

type CreateOrUpdateSuccessMode string

type DeleteAction

type DeleteAction string

type DeleteActionFunc

type DeleteActionFunc = func(ctx context.Context) (ctrl.Result, error)