coordinator

Documentation

Index

• func NewCoordinatorLogging(scheme *runtime.Scheme, instance *trinov1alpha1.TrinoCluster, ...) *common.LoggingRecociler
• type ConfigMapReconciler
  • func NewConfigMap(scheme *runtime.Scheme, instance *trinov1alpha1.TrinoCluster, ...) *ConfigMapReconciler
  • func (c *ConfigMapReconciler) Build(_ context.Context) (client.Object, error)
  • func (c *ConfigMapReconciler) ConfigurationOverride(resource client.Object)
• type DeploymentReconciler
  • func NewDeployment(scheme *runtime.Scheme, instance *trinov1alpha1.TrinoCluster, ...) *DeploymentReconciler
  • func (d *DeploymentReconciler) Build(_ context.Context) (client.Object, error)
  • func (d *DeploymentReconciler) CommandOverride(resource client.Object)
  • func (d *DeploymentReconciler) EnvOverride(resource client.Object)
  • func (d *DeploymentReconciler) GetConditions() *[]metav1.Condition
  • func (d *DeploymentReconciler) LogOverride(resource client.Object)
• type IngressReconciler
  • func NewIngress(scheme *runtime.Scheme, instance *trinov1alpha1.TrinoCluster, ...) *IngressReconciler
  • func (i *IngressReconciler) Build(_ context.Context) (client.Object, error)
• type LogDataBuilder
  • func (c *LogDataBuilder) MakeContainerLogData() map[string]string
• type Role
  • func NewRoleCoordinator(scheme *runtime.Scheme, instance *trinov1alpha1.TrinoCluster, ...) *Role
  • func (r *Role) MergeLabels() map[string]string
  • func (r *Role) ReconcileRole(ctx context.Context) (ctrl.Result, error)
  • func (r *Role) RoleName() common.Role
• type RoleGroup
  • func NewRoleGroupReconciler(scheme *runtime.Scheme, instance *trinov1alpha1.TrinoCluster, ...) *RoleGroup
  • func (m *RoleGroup) MergeGroupConfigSpec() any
  • func (m *RoleGroup) MergeLabels(mergedCfg any) map[string]string
  • func (m *RoleGroup) RegisterResource()
• type ServiceReconciler
  • func NewService(scheme *runtime.Scheme, instance *trinov1alpha1.TrinoCluster, ...) *ServiceReconciler
  • func (s *ServiceReconciler) Build(_ context.Context) (client.Object, error)

Functions

func NewCoordinatorLogging

func NewCoordinatorLogging(
	scheme *runtime.Scheme,
	instance *trinov1alpha1.TrinoCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg any,
	logDataBuilder common.RoleLoggingDataBuilder,
	role common.Role,
) *common.LoggingRecociler

Types

type ConfigMapReconciler

type ConfigMapReconciler struct {
	common.ConfigurationStyleReconciler[*trinov1alpha1.TrinoCluster, *trinov1alpha1.RoleGroupSpec]
}

func NewConfigMap

func NewConfigMap(
	scheme *runtime.Scheme,
	instance *trinov1alpha1.TrinoCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *trinov1alpha1.RoleGroupSpec,
) *ConfigMapReconciler

NewConfigMap new a ConfigMapReconcile

func (*ConfigMapReconciler) Build

func (c *ConfigMapReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

func (*ConfigMapReconciler) ConfigurationOverride

func (c *ConfigMapReconciler) ConfigurationOverride(resource client.Object)

ConfigurationOverride implement the ConfigurationOverride interface

type DeploymentReconciler

type DeploymentReconciler struct {
	common.WorkloadStyleReconciler[*trinov1alpha1.TrinoCluster, *trinov1alpha1.RoleGroupSpec]
}

func NewDeployment

func NewDeployment(
	scheme *runtime.Scheme,
	instance *trinov1alpha1.TrinoCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *trinov1alpha1.RoleGroupSpec,
	replicates int32,
) *DeploymentReconciler

NewDeployment new a DeploymentReconcile

func (*DeploymentReconciler) Build

func (d *DeploymentReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

func (*DeploymentReconciler) CommandOverride

func (d *DeploymentReconciler) CommandOverride(resource client.Object)

CommandOverride implement the WorkloadOverride interface

func (*DeploymentReconciler) EnvOverride

func (d *DeploymentReconciler) EnvOverride(resource client.Object)

EnvOverride implement the WorkloadOverride interface

func (*DeploymentReconciler) GetConditions

func (d *DeploymentReconciler) GetConditions() *[]metav1.Condition

GetConditions implement the ConditionGetter interface

func (*DeploymentReconciler) LogOverride

func (d *DeploymentReconciler) LogOverride(resource client.Object)

LogOverride implement the WorkloadOverride interface

type IngressReconciler

type IngressReconciler struct {
	common.GeneralResourceStyleReconciler[*trinov1alpha1.TrinoCluster, *trinov1alpha1.RoleGroupSpec]
}

func NewIngress

func NewIngress(
	scheme *runtime.Scheme,
	instance *trinov1alpha1.TrinoCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *trinov1alpha1.RoleGroupSpec,
) *IngressReconciler

func (*IngressReconciler) Build

func (i *IngressReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

type LogDataBuilder

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

func (*LogDataBuilder) MakeContainerLogData

func (c *LogDataBuilder) MakeContainerLogData() map[string]string

MakeContainerLogData MakeContainerLog4jData implement RoleLoggingDataBuilder

type Role

type Role struct {
	common.BaseRoleReconciler[*trinov1alpha1.TrinoCluster]
}

func NewRoleCoordinator

func NewRoleCoordinator(
	scheme *runtime.Scheme,
	instance *trinov1alpha1.TrinoCluster,
	client client.Client,
	log logr.Logger) *Role

NewRoleCoordinator NewRoleMaster new roleMaster

func (*Role) MergeLabels

func (r *Role) MergeLabels() map[string]string

func (*Role) ReconcileRole

func (r *Role) ReconcileRole(ctx context.Context) (ctrl.Result, error)

func (*Role) RoleName

func (r *Role) RoleName() common.Role

type RoleGroup

type RoleGroup struct {
	common.BaseRoleGroupReconciler[*trinov1alpha1.TrinoCluster]
}

RoleGroup master role group reconcile

func NewRoleGroupReconciler

func NewRoleGroupReconciler(
	scheme *runtime.Scheme,
	instance *trinov1alpha1.TrinoCluster,
	client client.Client,
	groupName string,
	roleLabels map[string]string,
	log logr.Logger) *RoleGroup

func (*RoleGroup) MergeGroupConfigSpec

func (m *RoleGroup) MergeGroupConfigSpec() any

func (*RoleGroup) MergeLabels

func (m *RoleGroup) MergeLabels(mergedCfg any) map[string]string

func (*RoleGroup) RegisterResource

func (m *RoleGroup) RegisterResource()

type ServiceReconciler

type ServiceReconciler struct {
	common.GeneralResourceStyleReconciler[*trinov1alpha1.TrinoCluster, *trinov1alpha1.RoleGroupSpec]
}

func NewService

func NewService(
	scheme *runtime.Scheme,
	instance *trinov1alpha1.TrinoCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *trinov1alpha1.RoleGroupSpec,

) *ServiceReconciler

NewService new a ServiceReconcile

func (*ServiceReconciler) Build

func (s *ServiceReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface