utils

Documentation

Index

• Variables
• func ReleaseIfTimeout(t testing.TB, duration time.Duration, fnc func(t testing.TB))
• func SocketIOServer(receivers WSReceivers, port int32)
• type ConditionalWaitGroup
  • func (wg *ConditionalWaitGroup) AddIf(delta int, condition bool)
  • func (wg *ConditionalWaitGroup) DoneIf(condition bool)
  • func (wg *ConditionalWaitGroup) WaitIf(condition bool)
• type Volatile
  • func NewOneTimeVolatile(value interface{}) Volatile
  • func NewVolatile(value interface{}) Volatile
• type WSReceiver
• type WSReceivers

Variables

var TimeoutPrecision = 50 * time.Millisecond

Functions

func ReleaseIfTimeout

func ReleaseIfTimeout(t testing.TB, duration time.Duration, fnc func(t testing.TB))

TODO: Use gomega library

func SocketIOServer

func SocketIOServer(receivers WSReceivers, port int32)

Types

type ConditionalWaitGroup

type ConditionalWaitGroup struct {
	sync.WaitGroup
}

func (*ConditionalWaitGroup) AddIf

func (wg *ConditionalWaitGroup) AddIf(delta int, condition bool)

func (*ConditionalWaitGroup) DoneIf

func (wg *ConditionalWaitGroup) DoneIf(condition bool)

func (*ConditionalWaitGroup) WaitIf

func (wg *ConditionalWaitGroup) WaitIf(condition bool)

type Volatile

type Volatile interface {
	Get() interface{}
	Set(interface{}) error
}

func NewOneTimeVolatile

func NewOneTimeVolatile(value interface{}) Volatile

func NewVolatile

func NewVolatile(value interface{}) Volatile

type WSReceiver

type WSReceiver func(*gosocketio.Channel, interface{})

type WSReceivers

type WSReceivers map[string]WSReceiver