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 ARMClientFactory
• type AzureDeploymentReconciler
  • func NewAzureDeploymentReconciler(armClientFactory ARMClientFactory, kubeClient kubeclient.Client, ...) *AzureDeploymentReconciler
  • func (r *AzureDeploymentReconciler) Reconcile(ctx context.Context, log logr.Logger, eventRecorder record.EventRecorder, ...) (ctrl.Result, error)
• type CreateOrUpdateAction
• type CreateOrUpdateActionFunc
• type DeleteAction
• type DeleteActionFunc

Constants

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

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

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

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 ARMClientFactory

type ARMClientFactory func(genruntime.ARMMetaObject) *genericarmclient.GenericClient

type AzureDeploymentReconciler

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

func NewAzureDeploymentReconciler

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

func (*AzureDeploymentReconciler) Reconcile

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

type CreateOrUpdateAction

type CreateOrUpdateAction string

type CreateOrUpdateActionFunc

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

type DeleteAction

type DeleteAction string

type DeleteActionFunc

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