controller

Feb 1, 2024

Changes in this version

type AsyncTracker

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

+ func (a *AsyncTracker) HasFrameworkTFState() bool

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

+ 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 Options

+ StartWebhooks bool

+ 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

Nov 16, 2023

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) GetTfID() string

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

+ func (a *AsyncTracker) HasState() bool

+ func (a *AsyncTracker) IsDeleted() bool

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

+ 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 NoForkAsyncConnector struct

+ func NewNoForkAsyncConnector(kube client.Client, ots *OperationTrackerStore, sf terraform.SetupFn, ...) *NoForkAsyncConnector

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

+ type NoForkAsyncOption func(connector *NoForkAsyncConnector)

+ func WithNoForkAsyncCallbackProvider(ac CallbackProvider) NoForkAsyncOption

+ func WithNoForkAsyncConnectorEventHandler(e *handler.EventHandler) NoForkAsyncOption

+ func WithNoForkAsyncLogger(l logging.Logger) NoForkAsyncOption

+ func WithNoForkAsyncManagementPolicies(isManagementPoliciesEnabled bool) NoForkAsyncOption

+ func WithNoForkAsyncMetricRecorder(r *metrics.MetricRecorder) NoForkAsyncOption

+ type NoForkConnector struct

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

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

+ type NoForkFinalizer struct

+ OperationStore TrackerCleaner

+ func NewNoForkFinalizer(tc TrackerCleaner, af xpresource.Finalizer) *NoForkFinalizer

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

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

+ type NoForkOption func(connector *NoForkConnector)

+ func WithNoForkLogger(l logging.Logger) NoForkOption

+ func WithNoForkManagementPolicies(isManagementPoliciesEnabled bool) NoForkOption

+ func WithNoForkMetricRecorder(r *metrics.MetricRecorder) NoForkOption

+ 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

+ 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, diag.Diagnostics)

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

+ type Store interface

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

+ 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)