Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controller

package

Go to main page

Versions in this module

v2

v2.2.1

Dec 8, 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.2.0-5

Feb 17, 2026

v2.2.0-4

Feb 13, 2026

v2.2.0-3

Feb 10, 2026

v2.2.0-2

Jan 20, 2026

v2.2.0-1

Dec 8, 2025

v2.0.2

Oct 7, 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/jwefers/upjet