utils

Documentation

Index

• Constants
• Variables
• func NewCustom(t *testing.T, states am.Struct) *am.Machine
• func NewCustomRpcWorker(t *testing.T, states am.Struct) *am.Machine
• func NewNoRels(t *testing.T, initialState am.S) *am.Machine
• func NewNoRelsRpcWorker(t *testing.T, initialState am.S) *am.Machine
• func NewRels(t *testing.T, initialState am.S) *am.Machine
• func NewRelsNodeWorker(t *testing.T, initialState am.S) *am.Machine
• func NewRelsRpcWorker(t *testing.T, initialState am.S) *am.Machine
• func RandListener(host string) net.Listener
• func RandPort(min, max int) string

Constants

const EnvAmTestRunner = "AM_TEST_RUNNER"

Variables

var (
	RelsNodeWorkerStruct = am.StructMerge(ssnode.WorkerStruct, ss.States)
	RelsNodeWorkerStates = am.SAdd(ss.Names, ssnode.WorkerStates.Names())
)

var (
	ConnInit sync.Mutex
)

Functions

func NewCustom

func NewCustom(t *testing.T, states am.Struct) *am.Machine

NewCustom creates a new machine with custom states.

func NewCustomRpcWorker

func NewCustomRpcWorker(t *testing.T, states am.Struct) *am.Machine

NewCustomRpcWorker creates a new worker with custom states.

func NewNoRels

func NewNoRels(t *testing.T, initialState am.S) *am.Machine

NewNoRels creates a new machine without relations between states.

func NewNoRelsRpcWorker

func NewNoRelsRpcWorker(t *testing.T, initialState am.S) *am.Machine

NewNoRelsRpcWorker creates a new RPC worker without relations between states.

func NewRels

func NewRels(t *testing.T, initialState am.S) *am.Machine

NewRels creates a new machine with basic relations between ABCD states.

func NewRelsNodeWorker

func NewRelsNodeWorker(t *testing.T, initialState am.S) *am.Machine

NewRelsNodeWorker creates a new Node worker machine with basic relations between ABCD states.

func NewRelsRpcWorker

func NewRelsRpcWorker(t *testing.T, initialState am.S) *am.Machine

NewRelsRpcWorker creates a new RPC worker machine with basic relations between ABCD states.

func RandListener

func RandListener(host string) net.Listener

RandListener creates a new listener on an open port between 40000 and 50000. It allows to avoid conflicts with other tests, using predefined addresses, unlike using port 0.

func RandPort

func RandPort(min, max int) string