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
  • func (b *SchemaJobBuilder) Enabled() bool
  • 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
  • func (b *SchemaScriptsConfigmapBuilder) Enabled() bool
  • func (b *SchemaScriptsConfigmapBuilder) GetStoreCreateTemplate(spec *v1beta1.DatastoreSpec) (string, error)
  • func (b *SchemaScriptsConfigmapBuilder) GetStoreSetupTemplate(spec *v1beta1.DatastoreSpec) (string, error)
  • func (b *SchemaScriptsConfigmapBuilder) GetStoreUpdateTemplate(spec *v1beta1.DatastoreSpec, targetSchema Schema) (string, error)
  • func (b *SchemaScriptsConfigmapBuilder) Update(object client.Object) error

Constants

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

	CreateDefaultDatabaseScript             = "create-default-database.sh"
	SetupDefaultSchemaScript                = "setup-default-schema.sh"
	UpdateDefaultSchemaScript               = "update-default-schema.sh"
	CreateVisibilityDatabaseScript          = "create-visibility-database.sh"
	SetupVisibilitySchemaScript             = "setup-visibility-schema.sh"
	UpdateVisibilitySchemaScript            = "update-visibility-schema.sh"
	CreateSecondaryVisibilityDatabaseScript = "create-secondary-visibility-database.sh"
	SetupSecondaryVisibilitySchemaScript    = "setup-secondary-visibility-schema.sh"
	UpdateSecondaryVisibilitySchemaScript   = "update-secondary-visibility-schema.sh"
	CreateAdvancedVisibilityDatabaseScript  = "create-advanced-visibility-database.sh"
	SetupAdvancedVisibilitySchemaScript     = "setup-advanced-visibility-schema.sh"
	UpdateAdvancedVisibilitySchemaScript    = "update-advanced-visibility-schema.sh"
)

const ServiceNameSuffix = "schema-setup"

ServiceNameSuffix is used as suffix in resource names for persistence setup jobs in place of a ServiceName.

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

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

func (*SchemaJobBuilder) Enabled

func (b *SchemaJobBuilder) Enabled() bool

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

func (*SchemaScriptsConfigmapBuilder) Enabled

func (b *SchemaScriptsConfigmapBuilder) Enabled() bool

func (*SchemaScriptsConfigmapBuilder) GetStoreCreateTemplate

func (b *SchemaScriptsConfigmapBuilder) GetStoreCreateTemplate(spec *v1beta1.DatastoreSpec) (string, error)

func (*SchemaScriptsConfigmapBuilder) GetStoreSetupTemplate

func (b *SchemaScriptsConfigmapBuilder) GetStoreSetupTemplate(spec *v1beta1.DatastoreSpec) (string, error)

func (*SchemaScriptsConfigmapBuilder) GetStoreUpdateTemplate

func (b *SchemaScriptsConfigmapBuilder) GetStoreUpdateTemplate(spec *v1beta1.DatastoreSpec, targetSchema Schema) (string, error)

func (*SchemaScriptsConfigmapBuilder) Update

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