deployers

Documentation

Index

• Constants
• Variables
• func UpdateStatus(ctx context.Context, input *v1alpha1.GreptimeDBCluster, kc client.Client, ...) error
• func WithCheckEtcdService(enableCheckEtcdService bool) func(*MetaDeployer)
• func WithEtcdMaintenanceBuilder(builder EtcdMaintenanceBuilder) func(*MetaDeployer)
• type CommonDeployer
  • func NewFromManager(mgr ctrl.Manager) *CommonDeployer
  • func (c *CommonDeployer) GenerateConfigMap(cluster *v1alpha1.GreptimeDBCluster, componentKind v1alpha1.ComponentKind) (*corev1.ConfigMap, error)
  • func (c *CommonDeployer) GetCluster(crdObject client.Object) (*v1alpha1.GreptimeDBCluster, error)
  • func (c *CommonDeployer) ResourceName(clusterName string, componentKind v1alpha1.ComponentKind) string
• 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) Render(crdObject client.Object) ([]client.Object, error)
• 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) Render(crdObject client.Object) ([]client.Object, error)
• 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) PreSyncHooks() []deployer.Hook
  • func (d *MetaDeployer) Render(crdObject client.Object) ([]client.Object, error)
• type MetaDeployerOption

Constants

const (
	GreptimeComponentName = "app.greptime.io/component"
)

Variables

var (
	DefaultMetricPortName = "metrics"
	DefaultMetricPath     = "/metrics"
	DefaultScapeInterval  = "30s"

	DefaultConfigPath = "/etc/greptimedb"
)

Functions

func UpdateStatus

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

func WithCheckEtcdService

func WithCheckEtcdService(enableCheckEtcdService bool) func(*MetaDeployer)

func WithEtcdMaintenanceBuilder

func WithEtcdMaintenanceBuilder(builder EtcdMaintenanceBuilder) func(*MetaDeployer)

Types

type CommonDeployer

type CommonDeployer struct {
	client.Client
	Scheme *runtime.Scheme

	deployer.DefaultDeployer
}

CommonDeployer is the common deployer for all components of GreptimeDBCluster.

func NewFromManager

func NewFromManager(mgr ctrl.Manager) *CommonDeployer

func (*CommonDeployer) GenerateConfigMap

func (c *CommonDeployer) GenerateConfigMap(cluster *v1alpha1.GreptimeDBCluster, componentKind v1alpha1.ComponentKind) (*corev1.ConfigMap, error)

func (*CommonDeployer) GetCluster

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

func (*CommonDeployer) ResourceName

func (c *CommonDeployer) ResourceName(clusterName string, componentKind v1alpha1.ComponentKind) string

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) Render

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

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) Render

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

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) PreSyncHooks

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

func (*MetaDeployer) Render

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

type MetaDeployerOption

type MetaDeployerOption func(*MetaDeployer)