ingestion

Documentation

Index

• Constants
• func LookupReconcileTime() time.Duration
• type DruidIngestionReconciler
  • func NewDruidIngestionReconciler(mgr ctrl.Manager) *DruidIngestionReconciler
  • func (r *DruidIngestionReconciler) CreateOrUpdate(di *v1alpha1.DruidIngestion, svcName string, build builder.Builder, ...) (controllerutil.OperationResult, error)
  • func (r *DruidIngestionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DruidIngestionReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *DruidIngestionReconciler) UpdateCompaction(di *v1alpha1.DruidIngestion, svcName string, auth internalhttp.Auth) (bool, error)
  • func (r *DruidIngestionReconciler) UpdateRules(di *v1alpha1.DruidIngestion, svcName string, auth internalhttp.Auth) (bool, error)
• type TransformStatusFunc
• type VerbType

Constants

const (
	DruidIngestionControllerCreateSuccess      = "DruidIngestionControllerCreateSuccess"
	DruidIngestionControllerCreateFail         = "DruidIngestionControllerCreateFail"
	DruidIngestionControllerGetSuccess         = "DruidIngestionControllerGetSuccess"
	DruidIngestionControllerGetFail            = "DruidIngestionControllerGetFail"
	DruidIngestionControllerUpdateSuccess      = "DruidIngestionControllerUpdateSuccess"
	DruidIngestionControllerUpdateFail         = "DruidIngestionControllerUpdateFail"
	DruidIngestionControllerShutDownSuccess    = "DruidIngestionControllerShutDownSuccess"
	DruidIngestionControllerShutDownFail       = "DruidIngestionControllerShutDownFail"
	DruidIngestionControllerPatchStatusSuccess = "DruidIngestionControllerPatchStatusSuccess"
	DruidIngestionControllerPatchStatusFail    = "DruidIngestionControllerPatchStatusFail"
	DruidIngestionControllerFinalizer          = "druidingestion.datainfra.io/finalizer"
)

Functions

func LookupReconcileTime

func LookupReconcileTime() time.Duration

Types

type DruidIngestionReconciler

type DruidIngestionReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// reconcile time duration, defaults to 10s
	ReconcileWait time.Duration
	Recorder      record.EventRecorder
}

IngestionReconciler

func NewDruidIngestionReconciler

func NewDruidIngestionReconciler(mgr ctrl.Manager) *DruidIngestionReconciler

func (*DruidIngestionReconciler) CreateOrUpdate

func (r *DruidIngestionReconciler) CreateOrUpdate(
	di *v1alpha1.DruidIngestion,
	svcName string,
	build builder.Builder,
	auth internalhttp.Auth,
) (controllerutil.OperationResult, error)

func (*DruidIngestionReconciler) Reconcile

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

+kubebuilder:rbac:groups=druid.apache.org,resources=ingestions,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=druid.apache.org,resources=ingestion/status,verbs=get;update;patch

func (*DruidIngestionReconciler) SetupWithManager

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

func (*DruidIngestionReconciler) UpdateCompaction

func (r *DruidIngestionReconciler) UpdateCompaction(
	di *v1alpha1.DruidIngestion,
	svcName string,
	auth internalhttp.Auth,
) (bool, error)

UpdateCompaction updates the compaction settings for a Druid data source.

func (*DruidIngestionReconciler) UpdateRules

func (r *DruidIngestionReconciler) UpdateRules(
	di *v1alpha1.DruidIngestion,
	svcName string,
	auth internalhttp.Auth,
) (bool, error)

UpdateRules updates the rules for a Druid data source.

type TransformStatusFunc

type TransformStatusFunc func(obj client.Object) client.Object

type VerbType

type VerbType string

const (
	VerbPatched   VerbType = "Patched"
	VerbUnchanged VerbType = "Unchanged"
)