persistence

Documentation

Index

• Constants
• func GetDatastoresEnvironmentVariables(datastores []*v1beta1.DatastoreSpec) []corev1.EnvVar
• func GetDatastoresVolumeMounts(datastores []*v1beta1.DatastoreSpec) []corev1.VolumeMount
• func GetDatastoresVolumes(datastores []*v1beta1.DatastoreSpec) []corev1.Volume
• type Schema
• type SchemaJobBuilder
  • func NewSchemaJobBuilder(instance *v1beta1.TemporalCluster, scheme *runtime.Scheme, name string, ...) *SchemaJobBuilder
  • func (b *SchemaJobBuilder) Build() (client.Object, error)
  • func (b *SchemaJobBuilder) Update(object client.Object) error
• type SchemaScriptsConfigmapBuilder
  • func NewSchemaScriptsConfigmapBuilder(instance *v1beta1.TemporalCluster, scheme *runtime.Scheme) *SchemaScriptsConfigmapBuilder
  • func (b *SchemaScriptsConfigmapBuilder) Build() (client.Object, error)
  • func (b *SchemaScriptsConfigmapBuilder) Update(object client.Object) error

Constants

const (
	CreateCassandraTemplate      = "create-cassandra.sh"
	CreateDatabaseTemplate       = "create-database.sh"
	CreateDatabaseTemplate_V1_18 = "create-database-1-8.sh"
	SetupSchemaTemplate          = "setup-schema.sh"
	UpdateSchemaTemplate         = "update-schema.sh"
	SetupAdvancedVisibility      = "setup-advanced-visibility.sh"
	UpdateAdvancedVisibility     = "update-advanced-visibility.sh"
)

Functions

func GetDatastoresEnvironmentVariables

func GetDatastoresEnvironmentVariables(datastores []*v1beta1.DatastoreSpec) []corev1.EnvVar

GetDatastoresEnvironmentVariables returns needed env vars for the provided datastores list.

func GetDatastoresVolumeMounts

func GetDatastoresVolumeMounts(datastores []*v1beta1.DatastoreSpec) []corev1.VolumeMount

GetDatastoresVolumeMounts returns needed volume mounts for the provided datastores list.

func GetDatastoresVolumes

func GetDatastoresVolumes(datastores []*v1beta1.DatastoreSpec) []corev1.Volume

GetDatastoresVolumes returns needed volume for the provided datastores list.

Types

type Schema

type Schema string

const (
	DefaultSchema    Schema = "default"
	VisibilitySchema Schema = "visibility"
)

type SchemaJobBuilder

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

func NewSchemaJobBuilder

func NewSchemaJobBuilder(instance *v1beta1.TemporalCluster, scheme *runtime.Scheme, name string, command []string) *SchemaJobBuilder

func (*SchemaJobBuilder) Build

func (b *SchemaJobBuilder) Build() (client.Object, error)

func (*SchemaJobBuilder) Update

func (b *SchemaJobBuilder) Update(object client.Object) error

type SchemaScriptsConfigmapBuilder

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

func NewSchemaScriptsConfigmapBuilder

func NewSchemaScriptsConfigmapBuilder(instance *v1beta1.TemporalCluster, scheme *runtime.Scheme) *SchemaScriptsConfigmapBuilder

func (*SchemaScriptsConfigmapBuilder) Build

func (b *SchemaScriptsConfigmapBuilder) Build() (client.Object, error)

func (*SchemaScriptsConfigmapBuilder) Update

func (b *SchemaScriptsConfigmapBuilder) Update(object client.Object) error