sql

Documentation

Index

• type Finalizer
  • func NewSqlFinalizer(client client.Client, wf WrappedFinalizer, opts ...SqlOpt) Finalizer
• type Reconciler
  • func NewSqlReconciler(client client.Client, cr *condition.Ready, wr WrappedReconciler, f Finalizer, ...) Reconciler
• type Resource
• type SqlFinalizer
  • func (tf *SqlFinalizer) AddFinalizer(ctx context.Context) error
  • func (tf *SqlFinalizer) Finalize(ctx context.Context, resource Resource) (ctrl.Result, error)
• type SqlOpt
  • func WithLogSql(logSql bool) SqlOpt
  • func WithRequeueInterval(interval time.Duration) SqlOpt
  • func WithRequeueMaxOffset(offset time.Duration) SqlOpt
• type SqlOptions
• type SqlReconciler
  • func (r *SqlReconciler) Reconcile(ctx context.Context, resource Resource) (ctrl.Result, error)
• type WrappedFinalizer
• type WrappedReconciler

Types

type Finalizer

type Finalizer interface {
	AddFinalizer(context.Context) error
	Finalize(context.Context, Resource) (ctrl.Result, error)
}

func NewSqlFinalizer

func NewSqlFinalizer(client client.Client, wf WrappedFinalizer, opts ...SqlOpt) Finalizer

type Reconciler

type Reconciler interface {
	Reconcile(ctx context.Context, resource Resource) (ctrl.Result, error)
}

func NewSqlReconciler

func NewSqlReconciler(client client.Client, cr *condition.Ready, wr WrappedReconciler, f Finalizer,
	opts ...SqlOpt) Reconciler

type Resource

type Resource interface {
	v1.Object
	MariaDBRef() *mariadbv1alpha1.MariaDBRef
	IsBeingDeleted() bool
	RequeueInterval() *metav1.Duration
	RetryInterval() *metav1.Duration
	CleanupPolicy() *mariadbv1alpha1.CleanupPolicy
}

type SqlFinalizer

type SqlFinalizer struct {
	Client      client.Client
	RefResolver *refresolver.RefResolver

	WrappedFinalizer WrappedFinalizer

	SqlOptions
}

func (*SqlFinalizer) AddFinalizer

func (tf *SqlFinalizer) AddFinalizer(ctx context.Context) error

func (*SqlFinalizer) Finalize

func (tf *SqlFinalizer) Finalize(ctx context.Context, resource Resource) (ctrl.Result, error)

type SqlOpt

type SqlOpt func(*SqlOptions)

func WithLogSql

func WithLogSql(logSql bool) SqlOpt

func WithRequeueInterval

func WithRequeueInterval(interval time.Duration) SqlOpt

func WithRequeueMaxOffset

func WithRequeueMaxOffset(offset time.Duration) SqlOpt

type SqlOptions

type SqlOptions struct {
	RequeueInterval  time.Duration
	RequeueMaxOffset time.Duration
	LogSql           bool
}

type SqlReconciler

type SqlReconciler struct {
	Client         client.Client
	RefResolver    *refresolver.RefResolver
	ConditionReady *condition.Ready

	WrappedReconciler WrappedReconciler
	Finalizer         Finalizer

	SqlOptions
}

func (*SqlReconciler) Reconcile

func (r *SqlReconciler) Reconcile(ctx context.Context, resource Resource) (ctrl.Result, error)

type WrappedFinalizer

type WrappedFinalizer interface {
	AddFinalizer(context.Context) error
	RemoveFinalizer(context.Context) error
	ContainsFinalizer() bool
	Reconcile(context.Context, *sqlClient.Client) error
}

type WrappedReconciler

type WrappedReconciler interface {
	Reconcile(context.Context, *sqlClient.Client) error
	PatchStatus(context.Context, condition.Patcher) error
}