sm

Oct 5, 2022

Changes in this version

type Condition

+ func IsMessageBetween(one, two types.ReplicaID) Condition

Sep 26, 2022

Changes in this version

+ type Action func(*types.Event, *Context)

type Condition

+ func ConditionWithAction(cond Condition, action Action) Condition

type CountWrapper

+ func (c *CountWrapper) Incr() Action

type SetWrapper

+ func (s *SetWrapper) Add() Action

Sep 21, 2022

Changes in this version

+ const FailStateLabel

+ const StartStateLabel

+ const SuccessStateLabel

+ type Condition func(e *types.Event, c *Context) bool

+ func IsEventOf(replica types.ReplicaID) Condition

+ func IsEventOfF(replicaFunc func(*types.Event, *Context) (types.ReplicaID, bool)) Condition

+ func IsEventType(t string) Condition

+ func IsMessageFrom(from types.ReplicaID) Condition

+ func IsMessageFromF(replicaF func(*types.Event, *Context) (types.ReplicaID, bool)) Condition

+ func IsMessageReceive() Condition

+ func IsMessageSend() Condition

+ func IsMessageTo(to types.ReplicaID) Condition

+ func IsMessageToF(replicaF func(*types.Event, *Context) (types.ReplicaID, bool)) Condition

+ func IsMessageType(t string) Condition

+ func OnceCondition(c Condition) Condition

+ func (c Condition) And(other Condition) Condition

+ func (c Condition) Not() Condition

+ func (c Condition) Or(other Condition) Condition

+ type Context struct

+ EventDAG *types.EventDAG

+ Logger *log.Logger

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

+ ReplicaStore *types.ReplicaStore

+ Vars *types.VarSet

+ func NewContext(ctx *context.RootContext, logger *log.Logger) *Context

+ func (c *Context) GetMessage(e *types.Event) (*types.Message, bool)

+ type CountWrapper struct

+ CounterFunc func(*types.Event, *Context) (*types.Counter, bool)

+ func Count(label string) *CountWrapper

+ func CountF(labelFunc func(*types.Event, *Context) (string, bool)) *CountWrapper

+ func CountTo(label string) *CountWrapper

+ func (c *CountWrapper) Eq(val int) Condition

+ func (c *CountWrapper) EqF(val func(*types.Event, *Context) (int, bool)) Condition

+ func (c *CountWrapper) Geq(val int) Condition

+ func (c *CountWrapper) GeqF(val func(*types.Event, *Context) (int, bool)) Condition

+ func (c *CountWrapper) Gt(val int) Condition

+ func (c *CountWrapper) GtF(val func(*types.Event, *Context) (int, bool)) Condition

+ func (c *CountWrapper) Leq(val int) Condition

+ func (c *CountWrapper) LeqF(val func(*types.Event, *Context) (int, bool)) Condition

+ func (c *CountWrapper) Lt(val int) Condition

+ func (c *CountWrapper) LtF(valF func(*types.Event, *Context) (int, bool)) Condition

+ type SetWrapper struct

+ SetFunc func(*types.Event, *Context) (*types.Map[types.MessageID, *types.Message], bool)

+ func Set(label string) *SetWrapper

+ func SetF(labelFunc func(*types.Event, *Context) (string, bool)) *SetWrapper

+ func (s *SetWrapper) Contains() Condition

+ func (s *SetWrapper) Count() *CountWrapper

+ type State struct

+ Label string

+ Success bool

+ Transitions map[string]Condition

+ func (s *State) Eq(other *State) bool

+ func (s *State) Is(l string) bool

+ func (s *State) MarshalJSON() ([]byte, error)

+ type StateMachine struct

+ func NewStateMachine() *StateMachine

+ func (s *StateMachine) Builder() StateMachineBuilder

+ func (s *StateMachine) CurState() *State

+ func (s *StateMachine) InState(state string) Condition

+ func (s *StateMachine) InSuccessState() bool

+ func (s *StateMachine) Reset()

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

+ func (s *StateMachine) Transition(to string)

+ type StateMachineBuilder struct

+ func (s StateMachineBuilder) MarkSuccess() StateMachineBuilder

+ func (s StateMachineBuilder) On(cond Condition, stateLabel string) StateMachineBuilder