group

Documentation

Overview

Note(Arun): There are a lot of methods that should return wrapped errors.

Index

• type GroupState
  • func NewGroupState() *GroupState
  • func (i *GroupState) Read(ctx context.Context, cr *v1alpha1.Group, client client.Client) error
• type ReconcileGroup
  • func (r *ReconcileGroup) Reconcile(ctx context.Context, request reconcile.Request) (result ctrl.Result, err error)
  • func (r *ReconcileGroup) SetupWithManager(mgr ctrl.Manager) error
• type TracingReconciler
  • func NewTracingReconciler(teardown bool, logger logr.Logger) *TracingReconciler
  • func (i *TracingReconciler) Reconcile(groupState *GroupState, cr *v1alpha1.Group) common.DesiredState
• type TracingState
  • func NewTracingState() *TracingState
  • func (i *TracingState) JaegerClickHouseURL() (*url.URL, error)
  • func (i *TracingState) JaegerClickHouseUsername() (string, error)
  • func (i *TracingState) Read(ctx context.Context, cr *v1alpha1.Group, client client.Client) error

Types

type GroupState

type GroupState struct {
	Tracing TracingState
	Tenant  *v1alpha1.Tenant
}

func NewGroupState

func NewGroupState() *GroupState

func (*GroupState) Read

func (i *GroupState) Read(ctx context.Context, cr *v1alpha1.Group, client client.Client) error

type ReconcileGroup

type ReconcileGroup struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	Client       client.Client
	Scheme       *runtime.Scheme
	Transport    *http.Transport
	Recorder     record.EventRecorder
	Log          logr.Logger
	StatusPoller *polling.StatusPoller
}

ReconcileGroup reconciles a Group object.

func (*ReconcileGroup) Reconcile

func (r *ReconcileGroup) Reconcile(
	ctx context.Context,
	request reconcile.Request,
) (result ctrl.Result, err error)

Reconcile , The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

func (*ReconcileGroup) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type TracingReconciler

type TracingReconciler struct {
	Teardown bool
	Log      logr.Logger
}

func NewTracingReconciler

func NewTracingReconciler(teardown bool, logger logr.Logger) *TracingReconciler

func (*TracingReconciler) Reconcile

func (i *TracingReconciler) Reconcile(groupState *GroupState, cr *v1alpha1.Group) common.DesiredState

type TracingState

type TracingState struct {
	JaegerClickHouseCredentials *v1.Secret
	JaegerClickHouseQuotas      *v1.ConfigMap
	JaegerService               *v1.Service
	JaegerPluginConfig          *v1.Secret
	JaegerPluginSchemas         *v1.ConfigMap
	// Read the Deployment that the Jaeger operator manages
	JaegerDeployment     *appsv1.Deployment
	JaegerCR             *jaegerOperator.Jaeger
	JaegerServiceMonitor *monitoring.ServiceMonitor
	OtelService          *v1.Service
	OtelServiceAccount   *v1.ServiceAccount
	OtelPluginConfig     *v1.Secret
	OtelDeployment       *appsv1.Deployment
	OtelServiceMonitor   *monitoring.ServiceMonitor
}

func NewTracingState

func NewTracingState() *TracingState

func (*TracingState) JaegerClickHouseURL

func (i *TracingState) JaegerClickHouseURL() (*url.URL, error)

Get the Clickhouse user and password for the Jaeger clickhouse plugin.

func (*TracingState) JaegerClickHouseUsername

func (i *TracingState) JaegerClickHouseUsername() (string, error)

func (*TracingState) Read

func (i *TracingState) Read(ctx context.Context, cr *v1alpha1.Group, client client.Client) error