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

v1

v1.9.9

May 20, 2025

v1.9.8

May 20, 2025

v1.9.7

May 20, 2025

v1.9.6

May 20, 2025

v1.9.5

May 20, 2025

v1.9.4

May 20, 2025

v1.9.3

May 20, 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 string) terraform.CallbackFn

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

+ func (ac *APICallbacks) Update(name string) 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 string) terraform.CallbackFn

+ Destroy func(name string) terraform.CallbackFn

+ Update func(name string) 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 ESSOptions struct

+ TLSConfig *tls.Config

+ TLSSecretName *string

+ 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

+ ESSOptions *ESSOptions

+ OperationTrackerStore *OperationTrackerStore

+ PollJitter time.Duration

+ Provider *config.Provider

+ SecretStoreConfigGVK *schema.GroupVersionKind

+ 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/v2