controller

package
v0.0.17 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 6, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDamengParams 

func NewDamengParams(cr *v1alpha1.Tpcc) string

func NewEsrallyCleanupJobs 

func NewEsrallyCleanupJobs(cr *v1alpha1.Esrally) []*batchv1.Job

func NewEsrallyJobs 

func NewEsrallyJobs(cr *v1alpha1.Esrally) []*batchv1.Job

func NewEsrallyPrepareJobs 

func NewEsrallyPrepareJobs(cr *v1alpha1.Esrally) []*batchv1.Job

func NewEsrallyRunJobs 

func NewEsrallyRunJobs(cr *v1alpha1.Esrally) []*batchv1.Job

func NewFioJobs 

func NewFioJobs(cr *v1alpha1.Fio) []*batchv1.Job

func NewFioRunJobs 

func NewFioRunJobs(cr *v1alpha1.Fio) []*batchv1.Job

func NewMssqlParams 

func NewMssqlParams(cr *v1alpha1.Tpcc) string

func NewOceanBaseOracleTenantParams 

func NewOceanBaseOracleTenantParams(cr *v1alpha1.Tpcc) string

func NewPgbenchCleanupJobs 

func NewPgbenchCleanupJobs(cr *v1alpha1.Pgbench) []*batchv1.Job

func NewPgbenchJobs 

func NewPgbenchJobs(cr *v1alpha1.Pgbench) []*batchv1.Job

func NewPgbenchPrepareJobs 

func NewPgbenchPrepareJobs(cr *v1alpha1.Pgbench) []*batchv1.Job

func NewPgbenchRunJobs 

func NewPgbenchRunJobs(cr *v1alpha1.Pgbench) []*batchv1.Job

func NewRedisBenchJobs 

func NewRedisBenchJobs(cr *v1alpha1.RedisBench) []*batchv1.Job

func NewRedisBenchRunJobs 

func NewRedisBenchRunJobs(cr *v1alpha1.RedisBench) []*batchv1.Job

func NewSysbenchCleanupJobs 

func NewSysbenchCleanupJobs(cr *v1alpha1.Sysbench) []*batchv1.Job

func NewSysbenchJobs 

func NewSysbenchJobs(cr *v1alpha1.Sysbench) []*batchv1.Job

func NewSysbenchPrepareJobs 

func NewSysbenchPrepareJobs(cr *v1alpha1.Sysbench) []*batchv1.Job

func NewSysbenchRunJobs 

func NewSysbenchRunJobs(cr *v1alpha1.Sysbench) []*batchv1.Job

func NewTidbParams 

func NewTidbParams(cr *v1alpha1.Tpcc) string

func NewTpccCleanupJobs 

func NewTpccCleanupJobs(cr *v1alpha1.Tpcc) []*batchv1.Job

func NewTpccGaussdbParams 

func NewTpccGaussdbParams(cr *v1alpha1.Tpcc) string

func NewTpccJobs 

func NewTpccJobs(cr *v1alpha1.Tpcc) []*batchv1.Job

func NewTpccKingbaseParams added in v0.0.16 

func NewTpccKingbaseParams(cr *v1alpha1.Tpcc) string

func NewTpccMysqlParams 

func NewTpccMysqlParams(cr *v1alpha1.Tpcc) string

func NewTpccPostgresParams 

func NewTpccPostgresParams(cr *v1alpha1.Tpcc) string

func NewTpccPrepareJobs 

func NewTpccPrepareJobs(cr *v1alpha1.Tpcc) []*batchv1.Job

func NewTpccRunJobs 

func NewTpccRunJobs(cr *v1alpha1.Tpcc) []*batchv1.Job

func NewTpccVastbaseParams added in v0.0.16 

func NewTpccVastbaseParams(cr *v1alpha1.Tpcc) string

func NewTpccWorkLoadParams 

func NewTpccWorkLoadParams(cr *v1alpha1.Tpcc) string

func NewTpcdsCleanupJobs 

func NewTpcdsCleanupJobs(cr v1alpha1.Tpcds) []*batchv1.Job

func NewTpcdsJobs 

func NewTpcdsJobs(cr v1alpha1.Tpcds) []*batchv1.Job

func NewTpcdsPrepareJobs 

func NewTpcdsPrepareJobs(cr v1alpha1.Tpcds) []*batchv1.Job

func NewTpcdsRunJobs 

func NewTpcdsRunJobs(cr v1alpha1.Tpcds) []*batchv1.Job

func NewTpchAllJobs 

func NewTpchAllJobs(cr *v1alpha1.Tpch) []*batchv1.Job

func NewTpchCleanupJobs 

func NewTpchCleanupJobs(cr *v1alpha1.Tpch) []*batchv1.Job

func NewTpchJobs 

func NewTpchJobs(cr *v1alpha1.Tpch) []*batchv1.Job

func NewTpchPrepareJobs 

func NewTpchPrepareJobs(cr *v1alpha1.Tpch) []*batchv1.Job

func NewTpchRunJobs 

func NewTpchRunJobs(cr *v1alpha1.Tpch) []*batchv1.Job

func NewYcsbCleanupJobs 

func NewYcsbCleanupJobs(cr *v1alpha1.Ycsb) []*batchv1.Job

func NewYcsbJobs 

func NewYcsbJobs(cr *v1alpha1.Ycsb) []*batchv1.Job

func NewYcsbMinioParams 

func NewYcsbMinioParams(cr *v1alpha1.Ycsb) string

func NewYcsbMongodbParams 

func NewYcsbMongodbParams(cr *v1alpha1.Ycsb) string

func NewYcsbMysqlParams 

func NewYcsbMysqlParams(cr *v1alpha1.Ycsb) string

func NewYcsbPostgresParams 

func NewYcsbPostgresParams(cr *v1alpha1.Ycsb) string

func NewYcsbPrepareJobs 

func NewYcsbPrepareJobs(cr *v1alpha1.Ycsb) []*batchv1.Job

func NewYcsbRedisParams 

func NewYcsbRedisParams(cr *v1alpha1.Ycsb) string

func NewYcsbRunJobs 

func NewYcsbRunJobs(cr *v1alpha1.Ycsb) []*batchv1.Job

func NewYcsbWorkloadParams 

func NewYcsbWorkloadParams(cr *v1alpha1.Ycsb) string

func ParseEsrally 

func ParseEsrally(msg string) string

func ParsePgbench 

func ParsePgbench(msg string) string

func ParseRedisBench 

func ParseRedisBench(msg string) string

func ParseSysBench 

func ParseSysBench(msg string) string

func ParseTPCC 

func ParseTPCC(msg string) string

func ParseTpch 

func ParseTpch(msg string) string

func ParseYcsb 

func ParseYcsb(msg string) string

func PgbenchInitContainers added in v0.0.16 

func PgbenchInitContainers(cr *v1alpha1.Pgbench) *corev1.Container

PgbenchInitContainers returns the init containers for pgbench

func TpccInitContainers 

func TpccInitContainers(cr *v1alpha1.Tpcc) *corev1.Container

TpccInitContainers returns the init containers for tpcc tpcc will fail if database not exists, so we need to create database first

func TpcdsInitContainers 

func TpcdsInitContainers(cr *v1alpha1.Tpcds) *corev1.Container

func YcsbInitContainers 

func YcsbInitContainers(cr *v1alpha1.Ycsb) *corev1.Container

Types

type EsrallyReconciler 

type EsrallyReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

EsrallyReconciler reconciles an Esrally object.

func (*EsrallyReconciler) Reconcile 

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

func (*EsrallyReconciler) SetupWithManager 

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

type FioReconciler 

type FioReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

FioReconciler reconciles a Fio object

func (*FioReconciler) Reconcile 

func (r *FioReconciler) 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 Fio 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.15.0/pkg/reconcile

func (*FioReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type PgbenchReconciler 

type PgbenchReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

PgbenchReconciler reconciles a Pgbench object

func (*PgbenchReconciler) Reconcile 

func (r *PgbenchReconciler) 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 Pgbench 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.15.0/pkg/reconcile

func (*PgbenchReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type RedisbenchReconciler 

type RedisbenchReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

RedisbenchReconciler reconciles a Redisbench object

func (*RedisbenchReconciler) Reconcile 

func (r *RedisbenchReconciler) 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 Redisbench 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.15.0/pkg/reconcile

func (*RedisbenchReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type SysbenchReconciler 

type SysbenchReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

SysbenchReconciler reconciles a Sysbench object

func (*SysbenchReconciler) Reconcile 

func (r *SysbenchReconciler) 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 Sysbench 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.1controllerutil.RequeueDuration.0/pkg/reconcile

func (*SysbenchReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type TpccReconciler 

type TpccReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

TpccReconciler reconciles a Tpcc object

func (*TpccReconciler) Reconcile 

func (r *TpccReconciler) 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 Tpcc 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.15.0/pkg/reconcile

func (*TpccReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type TpcdsReconciler 

type TpcdsReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

TpcdsReconciler reconciles a Tpcds object

func (*TpcdsReconciler) Reconcile 

func (r *TpcdsReconciler) 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 Tpcds 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.15.0/pkg/reconcile

func (*TpcdsReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type TpchReconciler 

type TpchReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

TpchReconciler reconciles a Tpch object

func (*TpchReconciler) Reconcile 

func (r *TpchReconciler) 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 Tpch 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.15.0/pkg/reconcile

func (*TpchReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type YcsbReconciler 

type YcsbReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RestConfig *rest.Config
}

YcsbReconciler reconciles a Ycsb object

func (*YcsbReconciler) Reconcile 

func (r *YcsbReconciler) 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 Ycsb 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.15.0/pkg/reconcile

func (*YcsbReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.