common

package
v0.0.0-...-40be03b Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HbaseKey          = "hbase-site.xml"
	LogKey            = "log4j.properties"
	SSLClientFileName = "ssl-client.xml"
	SSLServerFileName = "ssl-server.xml"
)
View Source 
const (
	ZookeeperHostsKey      = "ZOOKEEPER_HOSTS"
	ZookeeperClientPortKey = "ZOOKEEPER_CLIENT_PORT"
	ZookeeperChrootKey     = "ZOOKEEPER_CHROOT"
	ZookeeperKey           = "zookeeper"
)

Variables

View Source 
var (
	HBaseConfigDir      = path.Join(constants.KubedoopConfigDir)
	HDFSConfigDir       = path.Join(constants.KubedoopConfigDir)
	HBaseMountConfigDir = path.Join(constants.KubedoopConfigDirMount, "hbase")
	HDFSMountConfigDir  = path.Join(constants.KubedoopConfigDirMount, "hdfs")

	HHbaseConfigVolumeName = "hbase-config"
	HbaseLogVolumeName     = "log"
)

Functions

func GetRoleLoggingConfig 

func GetRoleLoggingConfig(
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
	role string,
) *commonsv1alpha1.LoggingConfigSpec

func NewStatefulSetReconciler 

func NewStatefulSetReconciler(
	client *client.Client,
	clusterConfig *hbasev1alph1.ClusterConfigSpec,
	roleGroupInfo reconciler.RoleGroupInfo,
	ports []corev1.ContainerPort,
	image *util.Image,
	stopped bool,
	replicas *int32,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
) (*reconciler.StatefulSet, error)

Types

type AffinityBuilder 

type AffinityBuilder struct {
	PodAffinity []PodAffinity
}

func NewAffinityBuilder 

func NewAffinityBuilder(
	podAffinity ...PodAffinity,
) *AffinityBuilder

func (*AffinityBuilder) AddPodAffinity 

func (a *AffinityBuilder) AddPodAffinity(podAffinity PodAffinity) *AffinityBuilder

func (*AffinityBuilder) Build 

func (a *AffinityBuilder) Build() *corev1.Affinity

type AffinityStrange 

type AffinityStrange = string
const (
	AffinityRequired  AffinityStrange = "required"
	AffinityPreferred AffinityStrange = "preferred"
)

type ConfigMapBuilder 

type ConfigMapBuilder struct {
	builder.ConfigMapBuilder

	LoggingConfig       *commonsv1alpha1.LoggingConfigSpec
	VectorConfigMapName string

	ClusterName   string
	RoleName      string
	RolegroupName string
	// contains filtered or unexported fields
}

func NewConfigMapBuilder 

func NewConfigMapBuilder(
	client *client.Client,
	name string,
	loggingConfig *commonsv1alpha1.LoggingConfigSpec,
	vectorConfigMapName string,
	krb5SecretClass string,
	tlsSecretClass string,
	options ...builder.Option,
) *ConfigMapBuilder

func (*ConfigMapBuilder) AddHbaseENVSh 

func (b *ConfigMapBuilder) AddHbaseENVSh() error

func (*ConfigMapBuilder) AddHbaseSite 

func (b *ConfigMapBuilder) AddHbaseSite(znode *ZnodeConfiguration) error

func (*ConfigMapBuilder) AddLog4jProperties 

func (b *ConfigMapBuilder) AddLog4jProperties() error

func (*ConfigMapBuilder) AddSSLClientXML 

func (b *ConfigMapBuilder) AddSSLClientXML() error

func (*ConfigMapBuilder) AddSSLServerXML 

func (b *ConfigMapBuilder) AddSSLServerXML() error

func (*ConfigMapBuilder) AddVectorConfig 

func (b *ConfigMapBuilder) AddVectorConfig(ctx context.Context) error

type ConfigMapReconciler 

type ConfigMapReconciler[T reconciler.AnySpec] struct {
	reconciler.ResourceReconciler[*ConfigMapBuilder]
	ClusterConfig *hbasev1alph1.ClusterConfigSpec
}

func NewConfigMapReconciler 

func NewConfigMapReconciler[T reconciler.AnySpec](
	client *client.Client,
	clusterConfig *hbasev1alph1.ClusterConfigSpec,
	loggingConfig *commonsv1alpha1.LoggingConfigSpec,
	options reconciler.RoleGroupInfo,
) *ConfigMapReconciler[T]

func (*ConfigMapReconciler[T]) GetZKZnodeConfig 

func (r *ConfigMapReconciler[T]) GetZKZnodeConfig(ctx context.Context) (*ZnodeConfiguration, error)

func (*ConfigMapReconciler[T]) Reconcile 

func (r *ConfigMapReconciler[T]) Reconcile(ctx context.Context) (ctrl.Result, error)

type NodeAffinity 

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

func (*NodeAffinity) Weight 

func (n *NodeAffinity) Weight(weight int32) *NodeAffinity

type PodAffinity 

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

func NewPodAffinity 

func NewPodAffinity(labels map[string]string, affinityRequired, anti bool) *PodAffinity

func (*PodAffinity) Weight 

func (p *PodAffinity) Weight(weight int32) *PodAffinity

type StatefulSetBuilder 

type StatefulSetBuilder struct {
	builder.StatefulSet
	Ports         []corev1.ContainerPort
	ClusterConfig *hbasev1alph1.ClusterConfigSpec
	RoleName      string
	ClusterName   string
	// contains filtered or unexported fields
}

func NewStatefulSetBuilder 

func NewStatefulSetBuilder(
	client *client.Client,
	name string,
	clusterConfig *hbasev1alph1.ClusterConfigSpec,
	replicas *int32,
	ports []corev1.ContainerPort,
	image *util.Image,
	krb5SecretClass string,
	tlsSecretClass string,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
	options ...builder.Option,
) *StatefulSetBuilder

func (*StatefulSetBuilder) Build 

func (b *StatefulSetBuilder) Build(ctx context.Context) (ctrlclient.Object, error)

func (*StatefulSetBuilder) GetDefaultAffinityBuilder 

func (b *StatefulSetBuilder) GetDefaultAffinityBuilder() *AffinityBuilder

func (*StatefulSetBuilder) GetLivenessProbe 

func (b *StatefulSetBuilder) GetLivenessProbe() *corev1.Probe

func (*StatefulSetBuilder) GetMainContainerCommanArgs 

func (b *StatefulSetBuilder) GetMainContainerCommanArgs() []string

func (*StatefulSetBuilder) GetReadinessProbe 

func (b *StatefulSetBuilder) GetReadinessProbe() *corev1.Probe

func (*StatefulSetBuilder) GetStartupProbe 

func (b *StatefulSetBuilder) GetStartupProbe() *corev1.Probe

type StatefulSetReconciler 

type StatefulSetReconciler struct {
	reconciler.StatefulSet
	ClusterConfig *hbasev1alph1.ClusterConfigSpec
}

type ZnodeConfiguration 

type ZnodeConfiguration struct {
	ConfigMap *corev1.ConfigMap
}

func (*ZnodeConfiguration) AddData 

func (c *ZnodeConfiguration) AddData(zookeeper string) error

zookeeper example: simple-zk-server-primary-0.simple-zk-server-primary.default.svc.cluster.local:2181/znode-0f8ba74a-7fb1-4d0a-81a5-7259a56defda

func (*ZnodeConfiguration) GetChroot 

func (c *ZnodeConfiguration) GetChroot() (string, error)

func (*ZnodeConfiguration) GetClientPort 

func (c *ZnodeConfiguration) GetClientPort() (string, error)

func (*ZnodeConfiguration) GetQuorum 

func (c *ZnodeConfiguration) GetQuorum() (string, error)

func (*ZnodeConfiguration) GetZookeeper 

func (c *ZnodeConfiguration) GetZookeeper() (string, error)

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.