directbase

type Adapter interface {
	// Delete removes the GCP object.
	// This can be called without calling Find.
	// It returns (true, nil) if the object was deleted,
	// and (false, nil) if the object was not found but should be presumed deleted.
	// In an error, the state is not fully determined - a delete might be in progress.
	Delete(ctx context.Context, op *DeleteOperation) (deleted bool, err error)

	// Find must be called as the first operation (unless we are deleting).
	// It returns whether the corresponding GCP object was found.
	Find(ctx context.Context) (found bool, err error)

	// Create creates a new GCP object.
	// This should only be called when Find has previously returned false.
	// The implementation should write the updated status into `u`.
	Create(ctx context.Context, op *CreateOperation) error

	// Update updates an existing GCP object.
	// This should only be called when Find has previously returned true.
	// The implementation should write the updated status into `u`.
	Update(ctx context.Context, op *UpdateOperation) error

	// Export fetches the cloud provider's representation of the object
	// as an unstructured.Unstructured.
	// Assumes Find has previously returned true.
	Export(ctx context.Context) (*unstructured.Unstructured, error)
}

type AdapterForObjectOperation struct {
	Reader client.Reader
	Object *unstructured.Unstructured
}

type CreateOperation struct {
	// contains filtered or unexported fields
}

type DeleteOperation struct {
	// contains filtered or unexported fields
}

type Deps struct {
	Defaulters      []k8s.Defaulter
	JitterGenerator jitter.Generator

	// There are Dependencies for Adapters in particular (not the reconcilers)
	IAMAdapterDeps *IAMAdapterDeps

	SkipNameValidation bool
}

type DirectReconciler struct {
	lifecyclehandler.LifecycleHandler
	client.Client
	metrics.ReconcilerMetrics

	SkipNameValidation bool
	// contains filtered or unexported fields
}

type IAMAdapterDeps struct {
	ControllerDeps *controller.Deps
	KubeClient     client.Client
}

type IAMModel interface {
	IAMAdapterForObject(ctx context.Context, reader client.Reader, u *unstructured.Unstructured, deps *IAMAdapterDeps) (Adapter, error)
}

type Model interface {
	// AdapterForObject builds an operation object for reconciling the object u.
	// If there are references, AdapterForObject should dereference them before returning (using reader)
	AdapterForObject(ctx context.Context, op *AdapterForObjectOperation) (Adapter, error)

	// AdapterForURL builds an operation object for exporting the object u.
	AdapterForURL(ctx context.Context, url string) (Adapter, error)
}

type Operation interface {
	// Writes the status and ready condition to the object's status subresource.
	// We split out the readyCondition so that we will not write it from the reconcile loop if we wrote it here.
	UpdateStatus(ctx context.Context, typedStatus any, readyCondition *v1alpha1.Condition) error

	// RequestRequeue requests a requeue of the operation, by returning Requeue = true from the reconcile loop.
	RequestRequeue()

	// SetLastModifiedCookie sets the last-changed-cookie annotation on the object.
	SetLastModifiedCookie(ctx context.Context, desired, actual proto.Message) error

	// CompareLastModifiedCookie compares the last-changed-cookie annotation on the object with the hashes of the desired and actual state.
	CompareLastModifiedCookie(desired, actual proto.Message) (bool, error)
}

type SensitiveFieldModel interface {
	// AdapterForObject builds an operation object for reconciling the object u.
	// If there are references, AdapterForObject should dereference them before returning (using reader)
	AdapterForObject(ctx context.Context, op *AdapterForObjectOperation) (Adapter, error)

	// AdapterForURL builds an operation object for exporting the object u.
	AdapterForURL(ctx context.Context, url string) (Adapter, error)

	MapSecretToResources(ctx context.Context, reader client.Reader, secret corev1.Secret) ([]reconcile.Request, error)
}

type UpdateOperation struct {
	// contains filtered or unexported fields
}