persistence

package

v0.0.1 Latest Latest Go to latest Published: May 26, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

type Manager struct {
	client.Client

	SchemaFilePath string
}

Manager handler persistence receonciliation.

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

NewManager creates a new instance of the persistence manager.

func (m *Manager) RunDefaultStoreSchemaTasks(ctx context.Context, cluster *v1alpha1.TemporalCluster) error

RunDefaultStoreSchemaTasks runs the setup and update default schema tasks on the provided cluster's default store.

func (m *Manager) RunVisibilityStoreSchemaTasks(ctx context.Context, cluster *v1alpha1.TemporalCluster) error

RunVisibilityStoreSchemaTasks runs the setup and update visibility schema tasks on the provided cluster's visibility store.

type Schema string

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