Documentation ¶
Index ¶
- type FaultInjectionDataStoreFactory
- func (d *FaultInjectionDataStoreFactory) Close()
- func (d *FaultInjectionDataStoreFactory) NewClusterMetadataStore() (persistence.ClusterMetadataStore, error)
- func (d *FaultInjectionDataStoreFactory) NewExecutionStore() (persistence.ExecutionStore, error)
- func (d *FaultInjectionDataStoreFactory) NewMetadataStore() (persistence.MetadataStore, error)
- func (d *FaultInjectionDataStoreFactory) NewNexusEndpointStore() (persistence.NexusEndpointStore, error)
- func (d *FaultInjectionDataStoreFactory) NewQueue(queueType persistence.QueueType) (persistence.Queue, error)
- func (d *FaultInjectionDataStoreFactory) NewQueueV2() (persistence.QueueV2, error)
- func (d *FaultInjectionDataStoreFactory) NewShardStore() (persistence.ShardStore, error)
- func (d *FaultInjectionDataStoreFactory) NewTaskStore() (persistence.TaskStore, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FaultInjectionDataStoreFactory ¶
type FaultInjectionDataStoreFactory struct {
// contains filtered or unexported fields
}
func NewFaultInjectionDatastoreFactory ¶
func NewFaultInjectionDatastoreFactory( fiConfig *config.FaultInjection, baseFactory persistence.DataStoreFactory, ) *FaultInjectionDataStoreFactory
func (*FaultInjectionDataStoreFactory) Close ¶
func (d *FaultInjectionDataStoreFactory) Close()
func (*FaultInjectionDataStoreFactory) NewClusterMetadataStore ¶
func (d *FaultInjectionDataStoreFactory) NewClusterMetadataStore() (persistence.ClusterMetadataStore, error)
func (*FaultInjectionDataStoreFactory) NewExecutionStore ¶
func (d *FaultInjectionDataStoreFactory) NewExecutionStore() (persistence.ExecutionStore, error)
func (*FaultInjectionDataStoreFactory) NewMetadataStore ¶
func (d *FaultInjectionDataStoreFactory) NewMetadataStore() (persistence.MetadataStore, error)
func (*FaultInjectionDataStoreFactory) NewNexusEndpointStore ¶
func (d *FaultInjectionDataStoreFactory) NewNexusEndpointStore() (persistence.NexusEndpointStore, error)
func (*FaultInjectionDataStoreFactory) NewQueue ¶
func (d *FaultInjectionDataStoreFactory) NewQueue(queueType persistence.QueueType) (persistence.Queue, error)
func (*FaultInjectionDataStoreFactory) NewQueueV2 ¶
func (d *FaultInjectionDataStoreFactory) NewQueueV2() (persistence.QueueV2, error)
func (*FaultInjectionDataStoreFactory) NewShardStore ¶
func (d *FaultInjectionDataStoreFactory) NewShardStore() (persistence.ShardStore, error)
func (*FaultInjectionDataStoreFactory) NewTaskStore ¶
func (d *FaultInjectionDataStoreFactory) NewTaskStore() (persistence.TaskStore, error)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.