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
- 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
Constants ¶
const ( OpensearchApiTlsCondition = "OpensearchApiTls" OpensearchApiTlsPhase = "Generate transport TLS" )
const ( OpensearchTransportTlsCondition = "OpensearchTransportTls" OpensearchTransportTlsPhase = "Generate transport TLS" )
Variables ¶
This section is empty.
Functions ¶
func GetNodeName ¶
Types ¶
type CompareResource ¶
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
type OpensearchReconciler ¶
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
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)