controllersdk

package

v0.0.5 Latest Latest Go to latest Published: Mar 16, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/denniskniep/provider-springclouddataflow

Links

Open Source Insights

Documentation ¶

Index ¶

func AssertAreEqual[C any](t *testing.T, actual interface{}, expected interface{})
func Create[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], ...) (managed.ExternalCreation, error)
func Delete[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], ...) error
func MapToCompare[C any](obj interface{}) (*C, error)
func Observe[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], ...) (managed.ExternalObservation, error)
func Setup[R resource.Managed](groupVersionKind schema.GroupVersionKind, newInstance R, mgr ctrl.Manager, ...) error
func SkipIfIsShort(t *testing.T)
func TestCreateAndAssert[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P) *O
func TestDelete[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P)
func TestUpdate[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P)
func TestUpdateAndAssert[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P)
func Update[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], ...) (managed.ExternalUpdate, error)
type Connector
- func (c *Connector[R]) Connect(ctx context.Context, mg resource.Managed) (managed.ExternalClient, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AssertAreEqual ¶

func AssertAreEqual[C any](t *testing.T, actual interface{}, expected interface{})

func Create ¶

func Create[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], mg resource.Managed) (managed.ExternalCreation, error)

func Delete ¶

func Delete[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], mg resource.Managed) error

func MapToCompare ¶

func MapToCompare[C any](obj interface{}) (*C, error)

func Observe ¶

func Observe[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], mg resource.Managed) (managed.ExternalObservation, error)

func Setup ¶

func Setup[R resource.Managed](groupVersionKind schema.GroupVersionKind, newInstance R, mgr ctrl.Manager, o controller.Options, newExternalClientFn func(conn *Connector[R], creds []byte) (managed.ExternalClient, error)) error

Setup adds a controller that reconciles managed resources.

func SkipIfIsShort ¶

func SkipIfIsShort(t *testing.T)

func TestCreateAndAssert ¶

func TestCreateAndAssert[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P) *O

func TestDelete ¶

func TestDelete[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P)

func TestUpdate ¶

func TestUpdate[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P)

func TestUpdateAndAssert ¶

func TestUpdateAndAssert[R resource.Managed, P any, O any, C any](t *testing.T, srv clients.Service[R, P, O, C], param *P)

func Update ¶

func Update[R resource.Managed, P any, O any, C any](ctx context.Context, logger logging.Logger, srv clients.Service[R, P, O, C], mg resource.Managed) (managed.ExternalUpdate, error)

Types ¶

type Connector ¶

type Connector[R resource.Managed] struct {
	Kube                client.Client
	Usage               resource.Tracker
	Logger              logging.Logger
	NewExternalClientFn func(conn *Connector[R], creds []byte) (managed.ExternalClient, error)
}

A connector is expected to produce an ExternalClient when its Connect method is called.

func (*Connector[R]) Connect ¶

func (c *Connector[R]) Connect(ctx context.Context, mg resource.Managed) (managed.ExternalClient, error)

Source Files ¶

View all Source files

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