stargate

Documentation

Index

• Constants
• Variables
• func CreateStargateConfigMap(namespace, cassandraYaml, stargateCqlYaml string, ...) *corev1.ConfigMap
• func CreateVectorConfigMap(namespace, vectorToml string, dc cassdcapi.CassandraDatacenter) *corev1.ConfigMap
• func DeploymentName(dc *cassdcapi.CassandraDatacenter, rack *cassdcapi.Rack) string
• func FilterConfig(config map[string]interface{}, retainedSettings []string) map[string]interface{}
• func GeneratedConfigMapName(clusterName, dcName string) string
• func MergeYamlString(userConfigMap string, generatedConfigMap string) string
• func NewDeployments(stargate *api.Stargate, dc *cassdcapi.CassandraDatacenter, logger logr.Logger) map[string]appsv1.Deployment
• func NewService(stargate *api.Stargate, dc *cassdcapi.CassandraDatacenter) *corev1.Service
• func NewStargate(stargateKey types.NamespacedName, kc *api.K8ssandraCluster, ...) *stargateapi.Stargate
• func ReconcileAuthKeyspace(managementApi cassandra.ManagementApiFacade, replication map[string]int, ...) error
• func ReconcileAuthTable(managementApi cassandra.ManagementApiFacade, logger logr.Logger) error
• func ResourceName(dc *cassdcapi.CassandraDatacenter) string
• func ServiceName(dc *cassdcapi.CassandraDatacenter) string
• func VectorAgentConfigMapName(clusterName, dcName string) string
• type ClusterVersion

Constants

const (
	AuthKeyspace = "data_endpoint_auth"
	AuthTable    = "token"
)

const (
	DefaultImageRepository = "stargateio"
	DefaultImageName3      = "stargate-3_11"
	DefaultImageName4      = "stargate-4_0"
	DefaultImageNameDse68  = "stargate-dse-68"
	DefaultVersion         = "1.0.77"
)

const (
	MetricsPort         = 8084
	VectorContainerName = "stargate-vector-agent"
)

const CqlConfigName = "stargate-cql.yaml"

Variables

var CassandraYamlRetainedSettings = []string{"server_encryption_options"}

var CqlYamlRetainedSettings = []string{
	"rpc_keepalive",
	"native_transport_max_frame_size_in_mb",
	"native_transport_max_concurrent_connections",
	"native_transport_max_concurrent_connections_per_ip",
	"native_transport_flush_in_batches_legacy",
	"native_transport_allow_older_protocols",
	"native_transport_max_concurrent_requests_in_bytes_per_ip",
	"native_transport_max_concurrent_requests_in_bytes",
	"native_transport_idle_timeout_in_ms",
	"client_encryption_options",
}

Functions

func CreateStargateConfigMap

func CreateStargateConfigMap(namespace, cassandraYaml, stargateCqlYaml string, dc cassdcapi.CassandraDatacenter) *corev1.ConfigMap

func CreateVectorConfigMap

func CreateVectorConfigMap(namespace, vectorToml string, dc cassdcapi.CassandraDatacenter) *corev1.ConfigMap

func DeploymentName

func DeploymentName(dc *cassdcapi.CassandraDatacenter, rack *cassdcapi.Rack) string

func FilterConfig

func FilterConfig(config map[string]interface{}, retainedSettings []string) map[string]interface{}

func GeneratedConfigMapName

func GeneratedConfigMapName(clusterName, dcName string) string

func MergeYamlString

func MergeYamlString(userConfigMap string, generatedConfigMap string) string

func NewDeployments

func NewDeployments(stargate *api.Stargate, dc *cassdcapi.CassandraDatacenter, logger logr.Logger) map[string]appsv1.Deployment

NewDeployments compute the Deployments to create for the given Stargate and CassandraDatacenter resources.

func NewService

func NewService(stargate *api.Stargate, dc *cassdcapi.CassandraDatacenter) *corev1.Service

NewService creates a Service object for the given Stargate and CassandraDatacenter resources.

func NewStargate

func NewStargate(
	stargateKey types.NamespacedName,
	kc *api.K8ssandraCluster,
	stargateTemplate *stargateapi.StargateDatacenterTemplate,
	actualDc *cassdcapi.CassandraDatacenter,
	dcTemplate api.CassandraDatacenterTemplate,
	logger logr.Logger,
) *stargateapi.Stargate

func ReconcileAuthKeyspace

func ReconcileAuthKeyspace(managementApi cassandra.ManagementApiFacade, replication map[string]int, logger logr.Logger) error

ReconcileAuthKeyspace ensures that the Stargate auth schema exists, has the appropriate replication, and contains the appropriate tables.

func ReconcileAuthTable

func ReconcileAuthTable(managementApi cassandra.ManagementApiFacade, logger logr.Logger) error

ReconcileAuthTable ensures that the Stargate auth schema contains the appropriate tables. Note that we don't do much here and currently, we only check if the token table exists, without checking if the table definition matches the expected one. If the auth schema becomes more complex in the future, we'd need to find a more robust solution, maybe à la Reaper.

func ResourceName

func ResourceName(dc *cassdcapi.CassandraDatacenter) string

func ServiceName

func ServiceName(dc *cassdcapi.CassandraDatacenter) string

func VectorAgentConfigMapName

func VectorAgentConfigMapName(clusterName, dcName string) string

VectorAgentConfigMapName generates a ConfigMap name based on the K8s sanitized cluster name and datacenter name.

Types

type ClusterVersion

type ClusterVersion string

const (
	ClusterVersion3  ClusterVersion = "3.11"
	ClusterVersion4  ClusterVersion = "4.0"
	ClusterVersion68 ClusterVersion = "6.8"
)