Documentation
¶
Index ¶
- func FailingPolicy(runenv *runtime.RunEnv, initCtx *run.InitContext) error
- func FailingTimeout(runenv *runtime.RunEnv, initCtx *run.InitContext) error
- func FourToOne(runenv *runtime.RunEnv, initCtx *run.InitContext) error
- func OneOnOne(runenv *runtime.RunEnv, initCtx *run.InitContext) error
- type RabbitTestParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FailingPolicy ¶
func FailingPolicy(runenv *runtime.RunEnv, initCtx *run.InitContext) error
A test with composed with 2 instances, aimed to fail (routing policy will block connection to rabbit broker)
func FailingTimeout ¶
func FailingTimeout(runenv *runtime.RunEnv, initCtx *run.InitContext) error
A test with composed with 2 instances, aimed to fail (no messages will be sent by the producer)
Types ¶
type RabbitTestParams ¶
type RabbitTestParams struct {
MessagesByNode int
RoutingPolicy network.RoutingPolicyType
}
Click to show internal directories.
Click to hide internal directories.