strategies

Jan 17, 2023

Changes in this version

+ type RandomStrategy struct

+ func NewRandomStrategy(dur time.Duration) *RandomStrategy

+ func (r *RandomStrategy) ActionsCh() *types.Channel[*Action]

+ func (r *RandomStrategy) EndCurIteration(*Context)

+ func (r *RandomStrategy) Finalize(*Context)

+ func (r *RandomStrategy) NextIteration(*Context)

+ func (r *RandomStrategy) Start() error

+ func (r *RandomStrategy) Step(e *types.Event, ctx *Context)

+ func (r *RandomStrategy) Stop() error

Nov 29, 2022

Changes in this version

type Context

+ ActionSequence *types.List[*Action]

Nov 3, 2022

Changes in this version

type DummyStrategy

+ Actions *types.Channel[*Action]

+ func (d *DummyStrategy) ActionsCh() *types.Channel[*Action]

type Strategy

+ ActionsCh func() *types.Channel[*Action]

Oct 5, 2022

Changes in this version

type Action

+ func DeliverMany(messages []*types.Message) Action

Sep 21, 2022

Changes in this version

type Context

+ func (c *Context) Abort()

+ func (c *Context) AbortCh() <-chan struct{}

type Strategy

+ func NewStrategyWithProperty(strategy Strategy, prop *sm.StateMachine) Strategy

+ type StrategyWithProperty struct

+ Property *sm.StateMachine

+ func (s *StrategyWithProperty) EndCurIteration(ctx *Context)

+ func (s *StrategyWithProperty) Finalize(ctx *Context)

+ func (s *StrategyWithProperty) NextIteration(ctx *Context)

+ func (s *StrategyWithProperty) Step(e *types.Event, ctx *Context) Action

Aug 29, 2022

Changes in this version

type DummyStrategy

+ func (f *DummyStrategy) EndCurIteration(*Context)

type FilteredStrategy

+ func (f *FilteredStrategy) EndCurIteration(*Context)

+ type Monitor interface

+ Finalize func(*Context)

+ NextIteration func(*Context)

+ Step func(*types.Event, *Context)

+ type StateMachineMonitor struct

type Strategy

+ func NewStrategyWithMonitor(strat Strategy, monit Monitor) Strategy

+ EndCurIteration func(*Context)

+ type StrategyWithMonitor struct

+ func (s *StrategyWithMonitor) Finalize(c *Context)

+ func (s *StrategyWithMonitor) NextIteration(c *Context)

+ func (s *StrategyWithMonitor) Step(e *types.Event, c *Context) Action

Jun 13, 2022

Changes in this version

type Action

+ func ActionSequence(actions ...Action) Action

type Context

+ Logger *log.Logger

type DummyStrategy

+ func (d *DummyStrategy) Finalize(*Context)

type FilteredStrategy

+ func (f *FilteredStrategy) Finalize(*Context)

type Strategy

+ Finalize func(*Context)

+ type StrategyConfig struct

+ FinalizeFunc func(*Context)

+ IterationTimeout time.Duration

+ Iterations int

+ SetupFunc func(*Context)

+ StepFunc func(*types.Event, *Context)

May 12, 2022

Changes in this version

+ type Action struct

+ Do func(*Context, *dispatcher.Dispatcher) error

+ Name string

+ func DeliverMessage(m *types.Message) Action

+ func DoNothing() Action

type Context

+ Messages *types.Map[types.MessageID, *types.Message]

+ func (c *Context) CurIteration() int

+ func (c *Context) NextIteration()

type Driver

+ func NewStrategyDriver(config *config.Config, mp types.MessageParser, strategy Strategy) *Driver

type DummyStrategy

+ func (d *DummyStrategy) NextIteration()

+ type FilteredStrategy struct

+ func NewFilteredStrategy(filter Filter, strategy Strategy, logger *log.Logger) *FilteredStrategy

+ func (f *FilteredStrategy) NextIteration()

+ func (f *FilteredStrategy) Start() error

+ func (f *FilteredStrategy) Step(e *types.Event, c *Context) Action

+ func (f *FilteredStrategy) Stop() error

type Strategy

+ NextIteration func()

Apr 16, 2022

Changes in this version

+ type Context struct

+ EventDAG *types.EventDAG

+ MessagePool *types.MessageStore

+ PendingMessages *types.MessageStore

+ Replicas *types.ReplicaStore

+ Vars *types.VarSet

+ type DefaultFilter struct

+ func NewDefaultFilter(ctx *context.RootContext) *DefaultFilter

+ func (d *DefaultFilter) Step(e *types.Event) []*types.Message

+ type DummyStrategy struct

+ func NewDummyStrategy(ctx *context.RootContext) *DummyStrategy

+ func (d *DummyStrategy) Start() error

+ func (d *DummyStrategy) Step(event *types.Event, _ []*types.Message) []*types.Message

+ func (d *DummyStrategy) Stop() error

+ type Filter interface

+ Step func(*types.Event) []*types.Message

+ type StrategyChain struct

+ func NewStrategyChain(ctx *context.RootContext, strategies ...Strategy) *StrategyChain

+ func (c *StrategyChain) AddStrategy(s Strategy)

+ func (c *StrategyChain) Start() error

+ func (c *StrategyChain) Step(e *types.Event, in []*types.Message) []*types.Message

+ func (c *StrategyChain) Stop() error

+ type TimeoutStrategy struct

+ func NewTimeoutStrategy(ctx *context.RootContext) *TimeoutStrategy

+ func (t *TimeoutStrategy) Step(e *types.Event, in []*types.Message) []*types.Message

Feb 11, 2022

Changes in this version

+ var ErrNoStrategy = errors.New("strategy does not exist")

+ type Driver struct

+ func GetStrategy(ctx *context.RootContext, s string) (*Driver, error)

+ func NewDriver(ctx *context.RootContext, strategy Strategy) *Driver

+ func (d *Driver) Start() error

+ func (d *Driver) Stop() error

+ func (srv *Driver) Name() string

+ func (srv *Driver) SetupRouter(router *gin.RouterGroup)

+ type Strategy interface

+ Step func(*types.Event) []*types.Message