helpers

Documentation

Index

• Constants
• func DefaultTestLogger() log.Logger
• func DockerClient(t TestingT) *dockerClient.Client
• func Eventually(timeout time.Duration, f func() bool) bool
• func GetBlockHeight(getMetrics func() (map[string]interface{}, error)) (value int, err error)
• func GetMetricsForPort(httpPort int) func() (map[string]interface{}, error)
• func InitSwarmEnvironment(t *testing.T, ctx context.Context)
• func LocalIP() string
• func LogSwarmServices(t *testing.T, ctx context.Context)
• func NodeAddresses() []string
• func PrintLog(log Log, w io.Writer)
• func RequireEventually(t TestingT, duration time.Duration, f func(t TestingT))
• func SkipUnlessSwarmIsEnabled(t *testing.T)
• func WithContext(f func(ctx context.Context))
• func WithContextAndShutdown(f func(ctx context.Context) govnr.ShutdownWaiter)
• type HttpServer
  • func CreateHttpServer(path string, port int, ...) HttpServer
• type Log
  • func ReadAllServicesLog(ctx context.Context) (Log, error)
  • func ReadServiceLog(ctx context.Context, cli *client.Client, service swarm.Service) (Log, error)
• type LogLine
• type TestingT

Constants

const DOCKER_API_VERSION = "1.40"

Functions

func DefaultTestLogger

func DefaultTestLogger() log.Logger

func DockerClient

func DockerClient(t TestingT) *dockerClient.Client

func Eventually

func Eventually(timeout time.Duration, f func() bool) bool

func GetBlockHeight

func GetBlockHeight(getMetrics func() (map[string]interface{}, error)) (value int, err error)

func GetMetricsForPort

func GetMetricsForPort(httpPort int) func() (map[string]interface{}, error)

func InitSwarmEnvironment

func InitSwarmEnvironment(t *testing.T, ctx context.Context)

func LocalIP

func LocalIP() string

func LogSwarmServices

func LogSwarmServices(t *testing.T, ctx context.Context)

func NodeAddresses

func NodeAddresses() []string

func PrintLog

func PrintLog(log Log, w io.Writer)

func RequireEventually

func RequireEventually(t TestingT, duration time.Duration, f func(t TestingT))

* run the test func with a testing.T -like reporter func will run eventuallyIterations times at most, but will not start later than the specified duration expects the test func to succeed at least once, at which point this function returns immediately, Otherwise, the parent test will fail with the details of the last func failure.

func SkipUnlessSwarmIsEnabled

func SkipUnlessSwarmIsEnabled(t *testing.T)

func WithContext

func WithContext(f func(ctx context.Context))

func WithContextAndShutdown

func WithContextAndShutdown(f func(ctx context.Context) govnr.ShutdownWaiter)

Types

type HttpServer

type HttpServer interface {
	Start()
	Shutdown()
	Url() string
	Port() int
}

func CreateHttpServer

func CreateHttpServer(path string, port int, f func(writer http.ResponseWriter, request *http.Request)) HttpServer

type Log

type Log = <-chan *LogLine

func ReadAllServicesLog

func ReadAllServicesLog(ctx context.Context) (Log, error)

func ReadServiceLog

func ReadServiceLog(ctx context.Context, cli *client.Client, service swarm.Service) (Log, error)

type LogLine

type LogLine struct {
	Prefix  string
	IsError bool
	Text    string
}

type TestingT

type TestingT interface {
	require.TestingT
}