persistence

Documentation

Index

• func NewSQLconfigFromDatastoreSpec(spec *v1alpha1.TemporalDatastoreSpec) *config.SQL
• type Manager
  • func NewManager(c client.Client, schemaFilePath string) *Manager
  • func (m *Manager) RunDefaultStoreUpdateTask(ctx context.Context, cluster *v1alpha1.TemporalCluster, ...) error
  • func (m *Manager) RunStoreSetupTask(ctx context.Context, cluster *v1alpha1.TemporalCluster, ...) error
  • func (m *Manager) RunVisibilityStoreUpdateTask(ctx context.Context, cluster *v1alpha1.TemporalCluster, ...) error
• type Schema

Functions

func NewSQLconfigFromDatastoreSpec

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) RunDefaultStoreUpdateTask

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

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

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"
)