Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNoStrategy = errors.New("strategy does not exist")
)
Functions ¶
This section is empty.
Types ¶
type Context ¶ added in v0.1.1
type Context struct {
MessagePool *types.MessageStore
// Replicas reference to the replica store
Replicas *types.ReplicaStore
// EventDAG is the directed acyclic graph all prior events
EventDAG *types.EventDAG
// Vars is a generic key value store to facilate maintaining auxilliary information
// during the execution of a testcase
Vars *types.VarSet
PendingMessages *types.MessageStore
}
type DefaultFilter ¶ added in v0.1.1
type DefaultFilter struct {
// contains filtered or unexported fields
}
func NewDefaultFilter ¶ added in v0.1.1
func NewDefaultFilter(ctx *context.RootContext) *DefaultFilter
type Driver ¶
type Driver struct {
*types.BaseService
// contains filtered or unexported fields
}
func GetStrategy ¶
func GetStrategy(ctx *context.RootContext, s string) (*Driver, error)
func (*Driver) SetupRouter ¶
func (srv *Driver) SetupRouter(router *gin.RouterGroup)
SetupRouter for setting up the dashboard routes implements DashboardRouter
type DummyStrategy ¶ added in v0.1.1
type DummyStrategy struct {
*types.BaseService
// contains filtered or unexported fields
}
func NewDummyStrategy ¶ added in v0.1.1
func NewDummyStrategy(ctx *context.RootContext) *DummyStrategy
func (*DummyStrategy) Start ¶ added in v0.1.1
func (d *DummyStrategy) Start() error
func (*DummyStrategy) Stop ¶ added in v0.1.1
func (d *DummyStrategy) Stop() error
type StrategyChain ¶ added in v0.1.1
type StrategyChain struct {
*types.BaseService
// contains filtered or unexported fields
}
func NewStrategyChain ¶ added in v0.1.1
func NewStrategyChain(ctx *context.RootContext, strategies ...Strategy) *StrategyChain
func (*StrategyChain) AddStrategy ¶ added in v0.1.1
func (c *StrategyChain) AddStrategy(s Strategy)
func (*StrategyChain) Start ¶ added in v0.1.1
func (c *StrategyChain) Start() error
func (*StrategyChain) Stop ¶ added in v0.1.1
func (c *StrategyChain) Stop() error
type TimeoutStrategy ¶ added in v0.1.1
type TimeoutStrategy struct {
*types.BaseService
// contains filtered or unexported fields
}
func NewTimeoutStrategy ¶ added in v0.1.1
func NewTimeoutStrategy(ctx *context.RootContext) *TimeoutStrategy
Click to show internal directories.
Click to hide internal directories.