controller

package

Go to main page

Versions in this module

v2

v2.3.0

Jun 22, 2026

Changes in this version

type AsyncTracker

+ func (a *AsyncTracker) GetFrameworkIdentity() *tfprotov6.ResourceIdentityData

+ func (a *AsyncTracker) ResetReconstructedFrameworkTFState()

+ func (a *AsyncTracker) ResetReconstructedTfState()

+ func (a *AsyncTracker) SetFrameworkIdentity(id *tfprotov6.ResourceIdentityData)

+ func (a *AsyncTracker) SetReconstructedFrameworkTFState(state *tfprotov6.DynamicValue)

+ func (a *AsyncTracker) SetReconstructedTfState(state *tfsdk.InstanceState)

v2.2.0

Nov 5, 2025

v2.1.0

Oct 16, 2025

Changes in this version

+ var BlockNestingModeList = rschema.ListNestedBlock{}.GetNestingMode()

+ var BlockNestingModeSet = rschema.SetNestedBlock{}.GetNestingMode()

+ var BlockNestingModeSingle = rschema.SingleNestedBlock{}.GetNestingMode()

+ var NestingModeList = rschema.ListNestedAttribute{}.GetNestingMode()

+ var NestingModeMap = rschema.MapNestedAttribute{}.GetNestingMode()

+ var NestingModeSet = rschema.SetNestedAttribute{}.GetNestingMode()

+ var NestingModeSingle = rschema.SingleNestedAttribute{}.GetNestingMode()

+ type BlockNestingMode uint8

v2.1.0-rc.0

Oct 16, 2025

v2.0.0

Aug 4, 2025

Changes in this version

+ var Base64DecodeFunc = function.New(&function.Spec{ ... })

+ var Base64EncodeFunc = function.New(&function.Spec{ ... })

+ type APICallbacks struct

+ func NewAPICallbacks(m ctrl.Manager, of xpresource.ManagedKind, opts ...APICallbacksOption) *APICallbacks

+ func (ac *APICallbacks) Create(name types.NamespacedName) terraform.CallbackFn

+ func (ac *APICallbacks) Destroy(name types.NamespacedName) terraform.CallbackFn

+ func (ac *APICallbacks) Update(name types.NamespacedName) terraform.CallbackFn

+ type APICallbacksOption func(callbacks *APICallbacks)

+ func WithEventHandler(e *handler.EventHandler) APICallbacksOption

+ func WithStatusUpdates(enabled bool) APICallbacksOption

+ type APISecretClient struct

+ func (a *APISecretClient) GetSecretData(ctx context.Context, ref *xpv1.SecretReference) (map[string][]byte, error)

+ func (a *APISecretClient) GetSecretValue(ctx context.Context, sel xpv1.SecretKeySelector) ([]byte, error)

+ type AsyncTracker struct

+ LastOperation *terraform.Operation

+ func NewAsyncTracker(opts ...AsyncTrackerOption) *AsyncTracker

+ func (a *AsyncTracker) GetFrameworkTFState() *tfprotov5.DynamicValue

+ func (a *AsyncTracker) GetTfID() string

+ func (a *AsyncTracker) GetTfState() *tfsdk.InstanceState

+ func (a *AsyncTracker) HasFrameworkTFState() bool

+ func (a *AsyncTracker) HasState() bool

+ func (a *AsyncTracker) IsDeleted() bool

+ func (a *AsyncTracker) SetDeleted(deleted bool)

+ func (a *AsyncTracker) SetFrameworkTFState(state *tfprotov5.DynamicValue)

+ func (a *AsyncTracker) SetTfState(state *tfsdk.InstanceState)

+ type AsyncTrackerOption func(manager *AsyncTracker)

+ func WithAsyncTrackerLogger(l logging.Logger) AsyncTrackerOption

+ type CallbackFn func(error, context.Context) error

+ type CallbackProvider interface

+ Create func(name types.NamespacedName) terraform.CallbackFn

+ Destroy func(name types.NamespacedName) terraform.CallbackFn

+ Update func(name types.NamespacedName) terraform.CallbackFn

+ type Connector struct

+ func NewConnector(kube client.Client, ws Store, sf terraform.SetupFn, cfg *config.Resource, ...) *Connector

+ func (c *Connector) Connect(ctx context.Context, mg xpresource.Managed) (managed.ExternalClient, error)

+ type OperationTrackerFinalizer struct

+ OperationStore TrackerCleaner

+ func NewOperationTrackerFinalizer(tc TrackerCleaner, af xpresource.Finalizer) *OperationTrackerFinalizer

+ func (nf *OperationTrackerFinalizer) AddFinalizer(ctx context.Context, obj xpresource.Object) error

+ func (nf *OperationTrackerFinalizer) RemoveFinalizer(ctx context.Context, obj xpresource.Object) error

+ type OperationTrackerStore struct

+ func NewOperationStore(l logging.Logger) *OperationTrackerStore

+ func (ops *OperationTrackerStore) RemoveTracker(obj xpresource.Object) error

+ func (ops *OperationTrackerStore) Tracker(tr resource.Terraformed) *AsyncTracker

+ type Option func(*Connector)

+ func WithCallbackProvider(ac CallbackProvider) Option

+ func WithConnectorEventHandler(e *handler.EventHandler) Option

+ func WithLogger(l logging.Logger) Option

+ type Options struct

+ OperationTrackerStore *OperationTrackerStore

+ PollJitter time.Duration

+ Provider *config.Provider

+ SetupFn terraform.SetupFn

+ StartWebhooks bool

+ WorkspaceStore *terraform.WorkspaceStore

+ type ProviderSharer interface

+ UseProvider func(inuse terraform.InUse, attachmentConfig string)

+ type Resource interface

+ Apply func(ctx context.Context, s *tf.InstanceState, d *tf.InstanceDiff, meta interface{}) (*tf.InstanceState, tfdiag.Diagnostics)

+ RefreshWithoutUpgrade func(ctx context.Context, s *tf.InstanceState, meta interface{}) (*tf.InstanceState, tfdiag.Diagnostics)

+ type Store interface

+ Workspace func(ctx context.Context, c resource.SecretClient, tr resource.Terraformed, ...) (*terraform.Workspace, error)

+ type TerraformPluginFrameworkAsyncConnector struct

+ func NewTerraformPluginFrameworkAsyncConnector(kube client.Client, ots *OperationTrackerStore, sf terraform.SetupFn, ...) *TerraformPluginFrameworkAsyncConnector

+ func (c *TerraformPluginFrameworkAsyncConnector) Connect(ctx context.Context, mg xpresource.Managed) (managed.ExternalClient, error)

+ type TerraformPluginFrameworkAsyncOption func(connector *TerraformPluginFrameworkAsyncConnector)

+ func WithTerraformPluginFrameworkAsyncCallbackProvider(ac CallbackProvider) TerraformPluginFrameworkAsyncOption

+ func WithTerraformPluginFrameworkAsyncConnectorEventHandler(e *handler.EventHandler) TerraformPluginFrameworkAsyncOption

+ func WithTerraformPluginFrameworkAsyncLogger(l logging.Logger) TerraformPluginFrameworkAsyncOption

+ func WithTerraformPluginFrameworkAsyncManagementPolicies(isManagementPoliciesEnabled bool) TerraformPluginFrameworkAsyncOption

+ func WithTerraformPluginFrameworkAsyncMetricRecorder(r *metrics.MetricRecorder) TerraformPluginFrameworkAsyncOption

+ type TerraformPluginFrameworkConnector struct

+ func NewTerraformPluginFrameworkConnector(kube client.Client, sf terraform.SetupFn, cfg *config.Resource, ...) *TerraformPluginFrameworkConnector

+ func (c *TerraformPluginFrameworkConnector) Connect(ctx context.Context, mg xpresource.Managed) (managed.ExternalClient, error)

+ type TerraformPluginFrameworkConnectorOption func(connector *TerraformPluginFrameworkConnector)

+ func WithTerraformPluginFrameworkLogger(l logging.Logger) TerraformPluginFrameworkConnectorOption

+ func WithTerraformPluginFrameworkManagementPolicies(isManagementPoliciesEnabled bool) TerraformPluginFrameworkConnectorOption

+ func WithTerraformPluginFrameworkMetricRecorder(r *metrics.MetricRecorder) TerraformPluginFrameworkConnectorOption

+ type TerraformPluginSDKAsyncConnector struct

+ func NewTerraformPluginSDKAsyncConnector(kube client.Client, ots *OperationTrackerStore, sf terraform.SetupFn, ...) *TerraformPluginSDKAsyncConnector

+ func (c *TerraformPluginSDKAsyncConnector) Connect(ctx context.Context, mg xpresource.Managed) (managed.ExternalClient, error)

+ type TerraformPluginSDKAsyncOption func(connector *TerraformPluginSDKAsyncConnector)

+ func WithTerraformPluginSDKAsyncCallbackProvider(ac CallbackProvider) TerraformPluginSDKAsyncOption

+ func WithTerraformPluginSDKAsyncConnectorEventHandler(e *handler.EventHandler) TerraformPluginSDKAsyncOption

+ func WithTerraformPluginSDKAsyncLogger(l logging.Logger) TerraformPluginSDKAsyncOption

+ func WithTerraformPluginSDKAsyncManagementPolicies(isManagementPoliciesEnabled bool) TerraformPluginSDKAsyncOption

+ func WithTerraformPluginSDKAsyncMetricRecorder(r *metrics.MetricRecorder) TerraformPluginSDKAsyncOption

+ type TerraformPluginSDKConnector struct

+ func NewTerraformPluginSDKConnector(kube client.Client, sf terraform.SetupFn, cfg *config.Resource, ...) *TerraformPluginSDKConnector

+ func (c *TerraformPluginSDKConnector) Connect(ctx context.Context, mg xpresource.Managed) (managed.ExternalClient, error)

+ type TerraformPluginSDKOption func(connector *TerraformPluginSDKConnector)

+ func WithTerraformPluginSDKLogger(l logging.Logger) TerraformPluginSDKOption

+ func WithTerraformPluginSDKManagementPolicies(isManagementPoliciesEnabled bool) TerraformPluginSDKOption

+ func WithTerraformPluginSDKMetricRecorder(r *metrics.MetricRecorder) TerraformPluginSDKOption

+ type TrackerCleaner interface

+ RemoveTracker func(obj xpresource.Object) error

+ type Workspace interface

+ Apply func(context.Context) (terraform.ApplyResult, error)

+ ApplyAsync func(terraform.CallbackFn) error

+ Destroy func(context.Context) error

+ DestroyAsync func(terraform.CallbackFn) error

+ Import func(context.Context, resource.Terraformed) (terraform.ImportResult, error)

+ Plan func(context.Context) (terraform.PlanResult, error)

+ Refresh func(context.Context) (terraform.RefreshResult, error)

Other modules containing this package

github.com/crossplane/upjet

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL