unnamedwatches

Documentation

Index

• Variables
• type WResource
  • func (wr *WResource) Init(mgr ctrl.Manager, options *pc.Options)
  • func (wr *WResource) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (wr *WResource) ReconcileResource(ctx context.Context) error
• type WatchMutationWebhookConfiguration
  • func (w *WatchMutationWebhookConfiguration) Create(event event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchMutationWebhookConfiguration) Delete(event event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchMutationWebhookConfiguration) Generic(event event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchMutationWebhookConfiguration) GetName() string
  • func (w *WatchMutationWebhookConfiguration) GetType() client.Object
  • func (w *WatchMutationWebhookConfiguration) Reconcile(ctx context.Context) error
  • func (w *WatchMutationWebhookConfiguration) Update(event event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)
• type WatchSecret
  • func (w *WatchSecret) Create(event event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchSecret) Delete(event event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchSecret) Generic(event event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchSecret) GetName() string
  • func (w *WatchSecret) GetType() client.Object
  • func (w *WatchSecret) Reconcile(ctx context.Context) error
  • func (w *WatchSecret) Update(event event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)
• type WatchValidatingWebhookConfiguration
  • func (w *WatchValidatingWebhookConfiguration) Create(event event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchValidatingWebhookConfiguration) Delete(event event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchValidatingWebhookConfiguration) Generic(event event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)
  • func (w *WatchValidatingWebhookConfiguration) GetName() string
  • func (w *WatchValidatingWebhookConfiguration) GetType() client.Object
  • func (w *WatchValidatingWebhookConfiguration) Reconcile(ctx context.Context) error
  • func (w *WatchValidatingWebhookConfiguration) Update(event event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)

Variables

var (
	WatchSecretWebhookName                    = "doris-operator-webhook-secret-watch"
	WatchValidatingWebhookConfigurationName   = "doris-operator-validate-webhook-watch"
	WatchMutatingWebhookConfigurationName     = "doris-operator-mutate-webhook-watch"
	DefaultMutatingWebhookConfigurationName   = "doris-operator-mutate-webhook"
	DefaultValidatingWebhookConfigurationName = "doris-operator-validate-webhook"
)

var (
	OperatorPodSelector       = "control-plane=doris-operator"
	OperatorPodTimeAnnotation = "doris-operator/update-time"
)

Types

type WResource

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

define the need resource for unnamedwatches

func (*WResource) Init

func (wr *WResource) Init(mgr ctrl.Manager, options *pc.Options)

func (*WResource) Reconcile

func (wr *WResource) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

webhook need watch resources for running.

func (*WResource) ReconcileResource

func (wr *WResource) ReconcileResource(ctx context.Context) error

reconciles the resources about certificates.

type WatchMutationWebhookConfiguration

type WatchMutationWebhookConfiguration struct {
	Name                             string
	MutationWebhookConfigurationName string
	SecretNamespaceName              types.NamespacedName
	Type                             client.Object
	// contains filtered or unexported fields
}

func (*WatchMutationWebhookConfiguration) Create

func (w *WatchMutationWebhookConfiguration) Create(event event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchMutationWebhookConfiguration) Delete

func (w *WatchMutationWebhookConfiguration) Delete(event event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchMutationWebhookConfiguration) Generic

func (w *WatchMutationWebhookConfiguration) Generic(event event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchMutationWebhookConfiguration) GetName

func (w *WatchMutationWebhookConfiguration) GetName() string

return the watch resource name.

func (*WatchMutationWebhookConfiguration) GetType

func (w *WatchMutationWebhookConfiguration) GetType() client.Object

func (*WatchMutationWebhookConfiguration) Reconcile

func (w *WatchMutationWebhookConfiguration) Reconcile(ctx context.Context) error

func (*WatchMutationWebhookConfiguration) Update

func (w *WatchMutationWebhookConfiguration) Update(event event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)

type WatchSecret

type WatchSecret struct {

	//the watch controller name.
	Name                               string
	NamespaceName                      types.NamespacedName
	Type                               client.Object
	WebhookService                     string
	MutatingWebhookConfigurationName   string
	ValidatingWebhookConfigurationName string
	// contains filtered or unexported fields
}

define secret should be watched by operator.

func (*WatchSecret) Create

func (w *WatchSecret) Create(event event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchSecret) Delete

func (w *WatchSecret) Delete(event event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchSecret) Generic

func (w *WatchSecret) Generic(event event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchSecret) GetName

func (w *WatchSecret) GetName() string

return the watch resource name.

func (*WatchSecret) GetType

func (w *WatchSecret) GetType() client.Object

func (*WatchSecret) Reconcile

func (w *WatchSecret) Reconcile(ctx context.Context) error

func (*WatchSecret) Update

func (w *WatchSecret) Update(event event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)

type WatchValidatingWebhookConfiguration

type WatchValidatingWebhookConfiguration struct {

	//the watch controller name.
	Name                               string
	ValidatingWebhookConfigurationName string
	SecretNamespaceName                types.NamespacedName
	Type                               client.Object
	// contains filtered or unexported fields
}

func (*WatchValidatingWebhookConfiguration) Create

func (w *WatchValidatingWebhookConfiguration) Create(event event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchValidatingWebhookConfiguration) Delete

func (w *WatchValidatingWebhookConfiguration) Delete(event event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchValidatingWebhookConfiguration) Generic

func (w *WatchValidatingWebhookConfiguration) Generic(event event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)

func (*WatchValidatingWebhookConfiguration) GetName

func (w *WatchValidatingWebhookConfiguration) GetName() string

return the watch resource name.

func (*WatchValidatingWebhookConfiguration) GetType

func (w *WatchValidatingWebhookConfiguration) GetType() client.Object

func (*WatchValidatingWebhookConfiguration) Reconcile

func (w *WatchValidatingWebhookConfiguration) Reconcile(ctx context.Context) error

func (*WatchValidatingWebhookConfiguration) Update

func (w *WatchValidatingWebhookConfiguration) Update(event event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)