faultinjection

Documentation

Index

• type FaultInjectionDataStoreFactory
  • func NewFaultInjectionDatastoreFactory(fiConfig *config.FaultInjection, baseFactory persistence.DataStoreFactory) *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)

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)