stargate

Documentation

Index

• Constants
• func CreateStargateConfigMap(namespace, configYaml, clusterName, dcName string) *corev1.ConfigMap
• func DeploymentName(dc *cassdcapi.CassandraDatacenter, rack *cassdcapi.Rack) string
• func FilterYamlConfig(config map[string]interface{}) map[string]interface{}
• func GeneratedConfigMapName(clusterName, dcName string) string
• func MergeConfigMaps(userConfigMap string, generatedConfigMap string) string
• func NewDeployments(stargate *api.Stargate, dc *cassdcapi.CassandraDatacenter) map[string]appsv1.Deployment
• func NewService(stargate *api.Stargate, dc *cassdcapi.CassandraDatacenter) *corev1.Service
• 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
• type ClusterVersion

Constants

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

const (
	DefaultImageRepository = "stargateio"
	DefaultImageName3      = "stargate-3_11"
	DefaultImageName4      = "stargate-4_0"
	DefaultVersion         = "1.0.45"
)

Functions

func CreateStargateConfigMap

func CreateStargateConfigMap(namespace, configYaml, clusterName, dcName string) *corev1.ConfigMap

func DeploymentName

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

func FilterYamlConfig

func FilterYamlConfig(config map[string]interface{}) map[string]interface{}

func GeneratedConfigMapName

func GeneratedConfigMapName(clusterName, dcName string) string

func MergeConfigMaps

func MergeConfigMaps(userConfigMap string, generatedConfigMap string) string

func NewDeployments

func NewDeployments(stargate *api.Stargate, dc *cassdcapi.CassandraDatacenter) 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 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

Types

type ClusterVersion

type ClusterVersion string

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