deployers

package

v0.1.0-alpha.24 Latest Latest Go to latest Published: Apr 12, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/GreptimeTeam/greptimedb-operator

Documentation ¶

Index ¶

Constants
func UpdateStatus(ctx context.Context, input *v1alpha1.GreptimeDBCluster, kc client.Client, ...) error
func WithEtcdMaintenanceBuilder(builder EtcdMaintenanceBuilder) func(*MetaDeployer)
type CommonBuilder
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
type EtcdMaintenanceBuilder
type FrontendDeployer
- func NewFrontendDeployer(mgr ctrl.Manager) *FrontendDeployer
type MetaDeployer
- func NewMetaDeployer(mgr ctrl.Manager, opts ...MetaDeployerOption) *MetaDeployer
type MetaDeployerOption

Constants ¶

View Source

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

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL