transaction

Mar 17, 2022

Changes in this version

type ExternalObservation

+ Message string

Feb 16, 2022

Changes in this version

type ReconcilerOption

+ func WithHandler(h Handler) ReconcilerOption

Feb 16, 2022

Changes in this version

+ func ControllerName(kind string) string

+ type ConnectionDetails map[string][]byte

+ type ExternalClient interface

+ Close func()

+ Create func(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ Delete func(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ Observe func(ctx context.Context, tr tresource.Transaction) (ExternalObservation, error)

+ type ExternalClientFns struct

+ CloseFn func()

+ CreateFn func(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ DeleteFn func(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ ObserveFn func(ctx context.Context, tr tresource.Transaction) (ExternalObservation, error)

+ func (e ExternalClientFns) Close()

+ func (e ExternalClientFns) Create(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ func (e ExternalClientFns) Delete(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ func (e ExternalClientFns) Observe(ctx context.Context, tr tresource.Transaction) (ExternalObservation, error)

+ type ExternalConnecter interface

+ Connect func(ctx context.Context, tr tresource.Transaction, deviceName string) (ExternalClient, error)

+ type ExternalConnectorFn func(ctx context.Context, tr tresource.Transaction, deviceName string) (ExternalClient, error)

+ func (ec ExternalConnectorFn) Connect(ctx context.Context, tr tresource.Transaction, deviceName string) (ExternalClient, error)

+ type ExternalObservation struct

+ Exhausted bool

+ Exists bool

+ GvkResourceList []*systemv1alpha1.Gvk

+ Pending bool

+ Ready bool

+ Success bool

+ type Handler interface

+ GetResources func(ctx context.Context, tr tresource.Transaction) (map[string]map[string]map[string]interface{}, error)

+ type HandlerFn struct

+ GetResourcesFn func(ctx context.Context, tr tresource.Transaction) (map[string]map[string]map[string]interface{}, error)

+ func (e HandlerFn) GetResources(ctx context.Context, tr tresource.Transaction) (map[string]map[string]map[string]interface{}, error)

+ type NopClient struct

+ func (c *NopClient) Close()

+ func (c *NopClient) Create(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ func (c *NopClient) Delete(ctx context.Context, tr tresource.Transaction, gvkList []string) error

+ func (c *NopClient) Observe(ctx context.Context, tr tresource.Transaction) (ExternalObservation, error)

+ type NopConnecter struct

+ func (c *NopConnecter) Connect(_ context.Context, _ tresource.Transaction, _ string) (ExternalClient, error)

+ type NopHandler struct

+ func (e *NopHandler) GetResources(ctx context.Context, tr tresource.Transaction) (map[string]map[string]map[string]interface{}, error)

+ type Reconciler struct

+ func NewReconciler(m manager.Manager, of resource.ManagedKind, o ...ReconcilerOption) *Reconciler

+ func (r *Reconciler) Reconcile(_ context.Context, req reconcile.Request) (reconcile.Result, error)

+ type ReconcilerOption func(*Reconciler)

+ func WithExternalConnecter(c ExternalConnecter) ReconcilerOption

+ func WithFinalizer(f tresource.Finalizer) ReconcilerOption

+ func WithLogger(l logging.Logger) ReconcilerOption

+ func WithPollInterval(after time.Duration) ReconcilerOption

+ func WithRecorder(er event.Recorder) ReconcilerOption

+ func WithTimeout(duration time.Duration) ReconcilerOption