deployers

Documentation

Index

• Constants
• func UpdateStatus(ctx context.Context, input *v1alpha1.GreptimeDBCluster, kc client.Client, ...) error
• func WithEtcdMaintenanceBuilder(builder EtcdMaintenanceBuilder) func(*MetaDeployer)
• type CommonBuilder
  • func (c *CommonBuilder) GenerateConfigMap() (*corev1.ConfigMap, error)
  • func (c *CommonBuilder) GeneratePodMonitor() (*monitoringv1.PodMonitor, error)
  • func (c *CommonBuilder) GeneratePodTemplateSpec(template *v1alpha1.PodTemplateSpec) *corev1.PodTemplateSpec
  • func (c *CommonBuilder) MountConfigDir(template *corev1.PodTemplateSpec)
• type CommonDeployer
  • func NewFromManager(mgr ctrl.Manager) *CommonDeployer
  • func (c *CommonDeployer) GetCluster(crdObject client.Object) (*v1alpha1.GreptimeDBCluster, error)
  • func (c *CommonDeployer) NewCommonBuilder(crdObject client.Object, componentKind v1alpha1.ComponentKind) *CommonBuilder
• type DatanodeDeployer
  • func NewDatanodeDeployer(mgr ctrl.Manager) *DatanodeDeployer
  • func (d *DatanodeDeployer) CheckAndUpdateStatus(ctx context.Context, crdObject client.Object) (bool, error)
  • func (d *DatanodeDeployer) CleanUp(ctx context.Context, crdObject client.Object) error
  • func (d *DatanodeDeployer) Generate(crdObject client.Object) ([]client.Object, error)
  • func (d *DatanodeDeployer) NewBuilder(crdObject client.Object) deployer.Builder
• type EtcdMaintenanceBuilder
• type FrontendDeployer
  • func NewFrontendDeployer(mgr ctrl.Manager) *FrontendDeployer
  • func (d *FrontendDeployer) CheckAndUpdateStatus(ctx context.Context, crdObject client.Object) (bool, error)
  • func (d *FrontendDeployer) Generate(crdObject client.Object) ([]client.Object, error)
  • func (d *FrontendDeployer) NewBuilder(crdObject client.Object) deployer.Builder
• type MetaDeployer
  • func NewMetaDeployer(mgr ctrl.Manager, opts ...MetaDeployerOption) *MetaDeployer
  • func (d *MetaDeployer) CheckAndUpdateStatus(ctx context.Context, highLevelObject client.Object) (bool, error)
  • func (d *MetaDeployer) Generate(crdObject client.Object) ([]client.Object, error)
  • func (d *MetaDeployer) NewBuilder(crdObject client.Object) deployer.Builder
  • func (d *MetaDeployer) PreSyncHooks() []deployer.Hook
• type MetaDeployerOption

Constants

const (
	TLSCrtSecretKey = "tls.crt"
	TLSKeySecretKey = "tls.key"
)

Functions

func UpdateStatus

func UpdateStatus(ctx context.Context, input *v1alpha1.GreptimeDBCluster, kc client.Client, opts ...client.UpdateOption) error

func WithEtcdMaintenanceBuilder

func WithEtcdMaintenanceBuilder(builder EtcdMaintenanceBuilder) func(*MetaDeployer)

Types

type CommonBuilder

type CommonBuilder struct {
	Cluster       *v1alpha1.GreptimeDBCluster
	ComponentKind v1alpha1.ComponentKind

	*deployer.DefaultBuilder
}

func (*CommonBuilder) GenerateConfigMap

func (c *CommonBuilder) GenerateConfigMap() (*corev1.ConfigMap, error)

func (*CommonBuilder) GeneratePodMonitor

func (c *CommonBuilder) GeneratePodMonitor() (*monitoringv1.PodMonitor, error)

func (*CommonBuilder) GeneratePodTemplateSpec

func (c *CommonBuilder) GeneratePodTemplateSpec(template *v1alpha1.PodTemplateSpec) *corev1.PodTemplateSpec

func (*CommonBuilder) MountConfigDir

func (c *CommonBuilder) MountConfigDir(template *corev1.PodTemplateSpec)

MountConfigDir mounts the configmap to the main container as '/etc/greptimedb/config.toml'.

type CommonDeployer

type CommonDeployer struct {
	Scheme *runtime.Scheme

	client.Client
	deployer.DefaultDeployer
}

CommonDeployer is the common deployer for all components of GreptimeDBCluster.

func NewFromManager

func NewFromManager(mgr ctrl.Manager) *CommonDeployer

NewFromManager creates a new CommonDeployer from controller manager.

func (*CommonDeployer) GetCluster

func (c *CommonDeployer) GetCluster(crdObject client.Object) (*v1alpha1.GreptimeDBCluster, error)

func (*CommonDeployer) NewCommonBuilder

func (c *CommonDeployer) NewCommonBuilder(crdObject client.Object, componentKind v1alpha1.ComponentKind) *CommonBuilder

type DatanodeDeployer

type DatanodeDeployer struct {
	*CommonDeployer
}

DatanodeDeployer is the deployer for datanode.

func NewDatanodeDeployer

func NewDatanodeDeployer(mgr ctrl.Manager) *DatanodeDeployer

func (*DatanodeDeployer) CheckAndUpdateStatus

func (d *DatanodeDeployer) CheckAndUpdateStatus(ctx context.Context, crdObject client.Object) (bool, error)

func (*DatanodeDeployer) CleanUp

func (d *DatanodeDeployer) CleanUp(ctx context.Context, crdObject client.Object) error

func (*DatanodeDeployer) Generate

func (d *DatanodeDeployer) Generate(crdObject client.Object) ([]client.Object, error)

func (*DatanodeDeployer) NewBuilder

func (d *DatanodeDeployer) NewBuilder(crdObject client.Object) deployer.Builder

type EtcdMaintenanceBuilder

type EtcdMaintenanceBuilder func(etcdEndpoints []string) (clientv3.Maintenance, error)

type FrontendDeployer

type FrontendDeployer struct {
	*CommonDeployer
}

func NewFrontendDeployer

func NewFrontendDeployer(mgr ctrl.Manager) *FrontendDeployer

func (*FrontendDeployer) CheckAndUpdateStatus

func (d *FrontendDeployer) CheckAndUpdateStatus(ctx context.Context, crdObject client.Object) (bool, error)

func (*FrontendDeployer) Generate

func (d *FrontendDeployer) Generate(crdObject client.Object) ([]client.Object, error)

func (*FrontendDeployer) NewBuilder

func (d *FrontendDeployer) NewBuilder(crdObject client.Object) deployer.Builder

type MetaDeployer

type MetaDeployer struct {
	*CommonDeployer
	// contains filtered or unexported fields
}

func NewMetaDeployer

func NewMetaDeployer(mgr ctrl.Manager, opts ...MetaDeployerOption) *MetaDeployer

func (*MetaDeployer) CheckAndUpdateStatus

func (d *MetaDeployer) CheckAndUpdateStatus(ctx context.Context, highLevelObject client.Object) (bool, error)

func (*MetaDeployer) Generate

func (d *MetaDeployer) Generate(crdObject client.Object) ([]client.Object, error)

func (*MetaDeployer) NewBuilder

func (d *MetaDeployer) NewBuilder(crdObject client.Object) deployer.Builder

func (*MetaDeployer) PreSyncHooks

func (d *MetaDeployer) PreSyncHooks() []deployer.Hook

type MetaDeployerOption

type MetaDeployerOption func(*MetaDeployer)