Documentation ¶
Index ¶
- func NewCassandraConfigFromDatastoreSpec(spec *v1alpha1.TemporalDatastoreSpec) *config.Cassandra
- func NewElasticsearchConfigFromDatastoreSpec(spec *v1alpha1.TemporalDatastoreSpec) (*esclient.Config, error)
- func NewSQLConfigFromDatastoreSpec(spec *v1alpha1.TemporalDatastoreSpec) *config.SQL
- type Manager
- func (m *Manager) RunAdvancedVisibilityStoreTasks(ctx context.Context, cluster *v1alpha1.TemporalCluster, ...) error
- 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
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 ¶
Manager handler persistence receonciliation.
func NewManager ¶
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.