errorinjectors

Documentation

Index

• Variables
• func NewConfigStoreManager(wrapped persistence.ConfigStoreManager, errorRate float64, logger log.Logger) persistence.ConfigStoreManager
• func NewDomainManager(wrapped persistence.DomainManager, errorRate float64, logger log.Logger) persistence.DomainManager
• func NewExecutionManager(wrapped persistence.ExecutionManager, errorRate float64, logger log.Logger) persistence.ExecutionManager
• func NewHistoryManager(wrapped persistence.HistoryManager, errorRate float64, logger log.Logger) persistence.HistoryManager
• func NewQueueManager(wrapped persistence.QueueManager, errorRate float64, logger log.Logger) persistence.QueueManager
• func NewShardManager(wrapped persistence.ShardManager, errorRate float64, logger log.Logger) persistence.ShardManager
• func NewTaskManager(wrapped persistence.TaskManager, errorRate float64, logger log.Logger) persistence.TaskManager
• func NewVisibilityManager(wrapped persistence.VisibilityManager, errorRate float64, logger log.Logger) persistence.VisibilityManager

Variables

var (
	// ErrFakeTimeout is a fake persistence timeout error.
	ErrFakeTimeout = &persistence.TimeoutError{Msg: "Fake Persistence Timeout Error."}
)

Functions

func NewConfigStoreManager

func NewConfigStoreManager(
	wrapped persistence.ConfigStoreManager,
	errorRate float64,
	logger log.Logger,
) persistence.ConfigStoreManager

NewConfigStoreManager creates a new instance of ConfigStoreManager with error injection.

func NewDomainManager

func NewDomainManager(
	wrapped persistence.DomainManager,
	errorRate float64,
	logger log.Logger,
) persistence.DomainManager

NewDomainManager creates a new instance of DomainManager with error injection.

func NewExecutionManager

func NewExecutionManager(
	wrapped persistence.ExecutionManager,
	errorRate float64,
	logger log.Logger,
) persistence.ExecutionManager

NewExecutionManager creates a new instance of ExecutionManager with error injection.

func NewHistoryManager

func NewHistoryManager(
	wrapped persistence.HistoryManager,
	errorRate float64,
	logger log.Logger,
) persistence.HistoryManager

NewHistoryManager creates a new instance of HistoryManager with error injection.

func NewQueueManager

func NewQueueManager(
	wrapped persistence.QueueManager,
	errorRate float64,
	logger log.Logger,
) persistence.QueueManager

NewQueueManager creates a new instance of QueueManager with error injection.

func NewShardManager

func NewShardManager(
	wrapped persistence.ShardManager,
	errorRate float64,
	logger log.Logger,
) persistence.ShardManager

NewShardManager creates a new instance of ShardManager with error injection.

func NewTaskManager

func NewTaskManager(
	wrapped persistence.TaskManager,
	errorRate float64,
	logger log.Logger,
) persistence.TaskManager

NewTaskManager creates a new instance of TaskManager with error injection.

func NewVisibilityManager

func NewVisibilityManager(
	wrapped persistence.VisibilityManager,
	errorRate float64,
	logger log.Logger,
) persistence.VisibilityManager

NewVisibilityManager creates a new instance of VisibilityManager with error injection.