controllers

Documentation

Index

• Constants
• func GetNodeName(clusterName, groupName string, index int) string
• type CompareResource
• type OpensearchApiTlsReconciler
  • func (r *OpensearchApiTlsReconciler) Configure(ctx context.Context, req ctrl.Request, resource client.Object) (meta any, err error)
  • func (r *OpensearchApiTlsReconciler) Create(ctx context.Context, resource client.Object, data map[string]interface{}, ...) (res ctrl.Result, err error)
  • func (r *OpensearchApiTlsReconciler) Delete(ctx context.Context, resource client.Object, data map[string]interface{}, ...) (err error)
  • func (r *OpensearchApiTlsReconciler) Diff(resource client.Object, data map[string]interface{}, meta interface{}) (diff controller.Diff, err error)
  • func (r *OpensearchApiTlsReconciler) OnError(ctx context.Context, resource client.Object, data map[string]any, meta any, ...)
  • func (r *OpensearchApiTlsReconciler) OnSuccess(ctx context.Context, resource client.Object, data map[string]any, meta any, ...) (err error)
  • func (r *OpensearchApiTlsReconciler) Read(ctx context.Context, resource client.Object, data map[string]any, meta any) (res ctrl.Result, err error)
  • func (r *OpensearchApiTlsReconciler) Update(ctx context.Context, resource client.Object, data map[string]interface{}, ...) (res ctrl.Result, err error)
• type OpensearchReconciler
  • func (r *OpensearchReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OpensearchReconciler) SetupWithManager(mgr ctrl.Manager) error
• type OpensearchTransportTlsReconciler
  • func (r *OpensearchTransportTlsReconciler) Configure(ctx context.Context, req ctrl.Request, resource client.Object) (meta any, err error)
  • func (r *OpensearchTransportTlsReconciler) Create(ctx context.Context, resource client.Object, data map[string]interface{}, ...) (res ctrl.Result, err error)
  • func (r *OpensearchTransportTlsReconciler) Delete(ctx context.Context, resource client.Object, data map[string]interface{}, ...) (err error)
  • func (r *OpensearchTransportTlsReconciler) Diff(resource client.Object, data map[string]interface{}, meta interface{}) (diff controller.Diff, err error)
  • func (r *OpensearchTransportTlsReconciler) OnError(ctx context.Context, resource client.Object, data map[string]any, meta any, ...)
  • func (r *OpensearchTransportTlsReconciler) OnSuccess(ctx context.Context, resource client.Object, data map[string]any, meta any, ...) (err error)
  • func (r *OpensearchTransportTlsReconciler) Read(ctx context.Context, resource client.Object, data map[string]any, meta any) (res ctrl.Result, err error)
  • func (r *OpensearchTransportTlsReconciler) Update(ctx context.Context, resource client.Object, data map[string]interface{}, ...) (res ctrl.Result, err error)
• type Reconciler
  • func (r *Reconciler) SetLogger(log *logrus.Entry)
  • func (r *Reconciler) SetReconsiler(reconciler controller.Reconciler)
  • func (r *Reconciler) SetRecorder(recorder record.EventRecorder)

Constants

const (
	OpensearchApiTlsCondition = "OpensearchApiTls"
	OpensearchApiTlsPhase     = "Generate transport TLS"
)

const (
	OpensearchTransportTlsCondition = "OpensearchTransportTls"
	OpensearchTransportTlsPhase     = "Generate transport TLS"
)

Functions

func GetNodeName

func GetNodeName(clusterName, groupName string, index int) string

Types

type CompareResource

type CompareResource struct {
	Current  client.Object
	Expected client.Object
	Diff     *controller.Diff
}

type OpensearchApiTlsReconciler

type OpensearchApiTlsReconciler struct {
	Reconciler
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*OpensearchApiTlsReconciler) Configure

func (r *OpensearchApiTlsReconciler) Configure(ctx context.Context, req ctrl.Request, resource client.Object) (meta any, err error)

Configure permit to init condition

func (*OpensearchApiTlsReconciler) Create

func (r *OpensearchApiTlsReconciler) Create(ctx context.Context, resource client.Object, data map[string]interface{}, meta interface{}) (res ctrl.Result, err error)

Create save secret with new API certificate

func (*OpensearchApiTlsReconciler) Delete

func (r *OpensearchApiTlsReconciler) Delete(ctx context.Context, resource client.Object, data map[string]interface{}, meta interface{}) (err error)

Delete permit to delete TLS secret We add parent link, so k8s auto delete children

func (*OpensearchApiTlsReconciler) Diff

func (r *OpensearchApiTlsReconciler) Diff(resource client.Object, data map[string]interface{}, meta interface{}) (diff controller.Diff, err error)

Diff permit to check if TLS secret is up to date

func (*OpensearchApiTlsReconciler) OnError

func (r *OpensearchApiTlsReconciler) OnError(ctx context.Context, resource client.Object, data map[string]any, meta any, err error)

OnError permit to set status condition on the right state and record error

func (*OpensearchApiTlsReconciler) OnSuccess

func (r *OpensearchApiTlsReconciler) OnSuccess(ctx context.Context, resource client.Object, data map[string]any, meta any, diff controller.Diff) (err error)

OnSuccess permit to set status condition on the right state is everithink is good

func (*OpensearchApiTlsReconciler) Read

func (r *OpensearchApiTlsReconciler) Read(ctx context.Context, resource client.Object, data map[string]any, meta any) (res ctrl.Result, err error)

Read existing Api TLS

func (*OpensearchApiTlsReconciler) Update

func (r *OpensearchApiTlsReconciler) Update(ctx context.Context, resource client.Object, data map[string]interface{}, meta interface{}) (res ctrl.Result, err error)

Update permit to update TLS secret

type OpensearchReconciler

type OpensearchReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

OpensearchReconciler reconciles a Opensearch object

func (*OpensearchReconciler) Reconcile

func (r *OpensearchReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Opensearch object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.2/pkg/reconcile

func (*OpensearchReconciler) SetupWithManager

func (r *OpensearchReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type OpensearchTransportTlsReconciler

type OpensearchTransportTlsReconciler struct {
	Reconciler
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func (*OpensearchTransportTlsReconciler) Configure

func (r *OpensearchTransportTlsReconciler) Configure(ctx context.Context, req ctrl.Request, resource client.Object) (meta any, err error)

Configure permit to init condition

func (*OpensearchTransportTlsReconciler) Create

func (r *OpensearchTransportTlsReconciler) Create(ctx context.Context, resource client.Object, data map[string]interface{}, meta interface{}) (res ctrl.Result, err error)

Create generate new TLS authorities

func (*OpensearchTransportTlsReconciler) Delete

func (r *OpensearchTransportTlsReconciler) Delete(ctx context.Context, resource client.Object, data map[string]interface{}, meta interface{}) (err error)

Delete permit to delete TLS secret We add parent link, so k8s auto delete children

func (*OpensearchTransportTlsReconciler) Diff

func (r *OpensearchTransportTlsReconciler) Diff(resource client.Object, data map[string]interface{}, meta interface{}) (diff controller.Diff, err error)

Diff permit to check if TLS secret is up to date

func (*OpensearchTransportTlsReconciler) OnError

func (r *OpensearchTransportTlsReconciler) OnError(ctx context.Context, resource client.Object, data map[string]any, meta any, err error)

OnError permit to set status condition on the right state and record error

func (*OpensearchTransportTlsReconciler) OnSuccess

func (r *OpensearchTransportTlsReconciler) OnSuccess(ctx context.Context, resource client.Object, data map[string]any, meta any, diff controller.Diff) (err error)

OnSuccess permit to set status condition on the right state is everithink is good

func (*OpensearchTransportTlsReconciler) Read

func (r *OpensearchTransportTlsReconciler) Read(ctx context.Context, resource client.Object, data map[string]any, meta any) (res ctrl.Result, err error)

Read existing transport TLS

func (*OpensearchTransportTlsReconciler) Update

func (r *OpensearchTransportTlsReconciler) Update(ctx context.Context, resource client.Object, data map[string]interface{}, meta interface{}) (res ctrl.Result, err error)

Update permit to update TLS secret

type Reconciler

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

func (*Reconciler) SetLogger

func (r *Reconciler) SetLogger(log *logrus.Entry)

func (*Reconciler) SetReconsiler

func (r *Reconciler) SetReconsiler(reconciler controller.Reconciler)

func (*Reconciler) SetRecorder

func (r *Reconciler) SetRecorder(recorder record.EventRecorder)