testlib

package

Go to main page

Versions in this module

v0

v0.1.4

Jan 25, 2022

Changes in this version

type Action

+ func RestartReplica(replicaFunc ReplicaFunc) Action

+ func StartReplica(replicaFunc ReplicaFunc) Action

+ func StopReplica(replicaFunc ReplicaFunc) Action

type Condition

+ func Once(c Condition) Condition

+ type ReplicaFunc func(*types.Event, *Context) (types.ReplicaID, bool)

+ func EventReplica() ReplicaFunc

+ func MessageFrom() ReplicaFunc

+ func MessageTo() ReplicaFunc

v0.1.3

Jan 18, 2022

Changes in this version

type Condition

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

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

v0.1.2

Jan 17, 2022

v0.1.1

Jan 16, 2022

Changes in this version

type Condition

+ func IsEventOf(replica types.ReplicaID) Condition

type Context

+ func (c *Context) Log(keyvals map[string]string)

v0.1.0

Jan 12, 2022

Changes in this version

+ const FailStateLabel

+ const StartStateLabel

+ const SuccessStateLabel

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

+ func DeliverMessage() Action

+ func DropMessage() Action

+ func RecordMessageAs(label string) Action

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

+ func IsEventType(t string) Condition

+ func IsMessageFrom(from types.ReplicaID) Condition

+ func IsMessageReceive() Condition

+ func IsMessageSend() Condition

+ func IsMessageTo(to types.ReplicaID) Condition

+ func IsMessageType(t string) 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

+ MessagePool *types.MessageStore

+ Replicas *types.ReplicaStore

+ TimeoutDriver *TimeoutDriver

+ Vars *VarSet

+ func NewContext(c *context.RootContext, testcase *TestCase) *Context

+ func (c *Context) Abort()

+ func (c *Context) EndTestCase()

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

+ func (c *Context) Logger() *log.Logger

+ func (c *Context) NewMessage(cur *types.Message, data []byte) *types.Message

+ type CountWrapper struct

+ CounterFunc func(*types.Event, *Context) (*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) Incr() Action

+ 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 Counter struct

+ func NewCounter() *Counter

+ func (c *Counter) Incr()

+ func (c *Counter) SetValue(v int)

+ func (c *Counter) Value() int

+ type HandlerCascade struct

+ DefaultHandler HandlerFunc

+ Handlers []HandlerFunc

+ func NewHandlerCascade(opts ...HandlerCascadeOption) *HandlerCascade

+ func (c *HandlerCascade) AddHandler(h HandlerFunc)

+ func (c *HandlerCascade) HandleEvent(e *types.Event, ctx *Context) []*types.Message

+ type HandlerCascadeOption func(*HandlerCascade)

+ func WithDefault(d HandlerFunc) HandlerCascadeOption

+ type HandlerFunc func(*types.Event, *Context) ([]*types.Message, bool)

+ func NewStateMachineHandler(stateMachine *StateMachine) HandlerFunc

+ type IfThenHandler struct

+ func If(cond Condition) *IfThenHandler

+ func (i *IfThenHandler) Then(action Action, rest ...Action) HandlerFunc

+ type ReportStore struct

+ func NewReportStore() *ReportStore

+ func (r *ReportStore) NewEvent(testcase string)

+ func (r *ReportStore) NewMessage(testcase string)

+ func (r *ReportStore) String() string

+ type SetWrapper struct

+ SetFunc func(*types.Event, *Context) (*types.MessageStore, 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

+ func (s *SetWrapper) DeliverAll() Action

+ func (s *SetWrapper) Store() Action

+ 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) Transition(to string)

+ type StateMachineBuilder struct

+ func (s StateMachineBuilder) MarkSuccess() StateMachineBuilder

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

+ type TestCase struct

+ Cascade *HandlerCascade

+ Logger *log.Logger

+ Name string

+ StateMachine *StateMachine

+ Timeout time.Duration

+ func NewTestCase(name string, timeout time.Duration, sm *StateMachine, cascade *HandlerCascade) *TestCase

+ func (t *TestCase) Abort()

+ func (t *TestCase) End()

+ func (t *TestCase) SetupFunc(setupFunc func(*Context) error)

+ type TestingServer struct

+ ReportStore *ReportStore

+ func NewTestingServer(config *config.Config, messageParser types.MessageParser, ...) (*TestingServer, error)

+ func (srv *TestingServer) Done() chan string

+ func (srv *TestingServer) Name() string

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

+ func (srv *TestingServer) Start()

+ func (srv *TestingServer) Stop()

+ type TimeoutDriver struct

+ func NewTimeoutDriver(store *types.TimeoutStore) *TimeoutDriver

+ func (t *TimeoutDriver) NewEvent(e *types.Event)

+ func (t *TimeoutDriver) ToDispatch() []*types.ReplicaTimeout

+ type VarSet struct

+ func NewVarSet() *VarSet

+ func (v *VarSet) Exists(label string) bool

+ func (v *VarSet) Get(label string) (interface{}, bool)

+ func (v *VarSet) GetBool(label string) (bool, bool)

+ func (v *VarSet) GetCounter(label string) (*Counter, bool)

+ func (v *VarSet) GetInt(label string) (int, bool)

+ func (v *VarSet) GetMessageSet(label string) (*types.MessageStore, bool)

+ func (v *VarSet) GetString(label string) (string, bool)

+ func (v *VarSet) NewMessageSet(label string)

+ func (v *VarSet) Set(label string, value interface{})

+ func (v *VarSet) SetCounter(label string)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL