persistence

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCassandraConfigFromDatastoreSpec added in v0.1.0

func NewCassandraConfigFromDatastoreSpec(spec *v1alpha1.TemporalDatastoreSpec) *config.Cassandra

NewCassandraConfigFromDatastoreSpec creates a new instance of a temporal cassandra config from the provided TemporalDatastoreSpec.

func NewElasticsearchConfigFromDatastoreSpec added in v0.1.0

func NewElasticsearchConfigFromDatastoreSpec(spec *v1alpha1.TemporalDatastoreSpec) (*esclient.Config, error)

NewElasticsearchConfigFromDatastoreSpec creates a new instance of a temporal elasticsearch client config from the provided TemporalDatastoreSpec.

func NewSQLConfigFromDatastoreSpec added in v0.1.0

func NewSQLConfigFromDatastoreSpec(spec *v1alpha1.TemporalDatastoreSpec) *config.SQL

NewSQLconfigFromDatastoreSpec creates a new instance of a temporal SQL config from the provided TemporalDatastoreSpec.

Types

type Manager

type Manager struct {
	client.Client

	SchemaFilePath string
}

Manager handler persistence receonciliation.

func NewManager

func NewManager(c client.Client, schemaFilePath string) *Manager

NewManager creates a new instance of the persistence manager.

func (*Manager) RunAdvancedVisibilityStoreTasks added in v0.1.0

func (m *Manager) RunAdvancedVisibilityStoreTasks(ctx context.Context, cluster *v1alpha1.TemporalCluster, store *v1alpha1.TemporalDatastoreSpec, templateVersion semver.Version) error

RunAdvancedVisibilityStoreTasks creates the index setting for the temporal index and the index itself.

func (*Manager) RunDefaultStoreUpdateTask added in v0.0.2

func (m *Manager) RunDefaultStoreUpdateTask(ctx context.Context, cluster *v1alpha1.TemporalCluster, store *v1alpha1.TemporalDatastoreSpec, version semver.Version) error

RunDefaultStoreUpdateTask runs the update schema task on the provided cluster's default store.

func (*Manager) RunStoreSetupTask added in v0.0.2

func (m *Manager) RunStoreSetupTask(ctx context.Context, cluster *v1alpha1.TemporalCluster, store *v1alpha1.TemporalDatastoreSpec) error

RunStoreSetupTask runs the setup schema task on the provided cluster's store.

func (*Manager) RunVisibilityStoreUpdateTask added in v0.0.2

func (m *Manager) RunVisibilityStoreUpdateTask(ctx context.Context, cluster *v1alpha1.TemporalCluster, store *v1alpha1.TemporalDatastoreSpec, version semver.Version) error

RunVisibilityStoreUpdateTask runs the update schema task on the provided cluster's visibility store.

type Schema

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL