tests

Documentation

Index

• Constants
• func DurationBetween() func(t *testing.T, expected time.Duration, skew float64)
• func NewArangoClusterSynchronization(name string) *api.ArangoClusterSynchronization
• func NewArangoDeployment(name string) *api.ArangoDeployment
• func NewCustomRequestHandler(t *testing.T, method string, path string, ...) http.HandlerFunc
• func NewEmptyInspector(t *testing.T) inspectorInterface.Inspector
• func NewInspector(t *testing.T, c kclient.Client) inspectorInterface.Inspector
• func NewSimpleHandler(t *testing.T, method string, path string, ...) http.HandlerFunc
• func RefreshArangoClusterSynchronization(t *testing.T, client kclient.Client, acs *api.ArangoClusterSynchronization) *api.ArangoClusterSynchronization
• func WithLogScanner(t *testing.T, name string, in func(t *testing.T, s LogScanner))
• type AsyncHandler
  • func NewAsyncHandler(t *testing.T, s Server, method string, path string, retCode int, ...) AsyncHandler
• type LogScanner
• type Server
  • func NewServer(t *testing.T) Server

Constants

const FakeNamespace = "fake"

Functions

func DurationBetween

func DurationBetween() func(t *testing.T, expected time.Duration, skew float64)

func NewArangoClusterSynchronization

func NewArangoClusterSynchronization(name string) *api.ArangoClusterSynchronization

func NewArangoDeployment

func NewArangoDeployment(name string) *api.ArangoDeployment

func NewCustomRequestHandler

func NewCustomRequestHandler(t *testing.T, method string, path string, reqVerify func(t *testing.T, r *http.Request), respHeaders func(t *testing.T) map[string]string, resp func(t *testing.T) (int, interface{})) http.HandlerFunc

func NewEmptyInspector

func NewEmptyInspector(t *testing.T) inspectorInterface.Inspector

func NewInspector

func NewInspector(t *testing.T, c kclient.Client) inspectorInterface.Inspector

func NewSimpleHandler

func NewSimpleHandler(t *testing.T, method string, path string, resp func(t *testing.T) (int, interface{})) http.HandlerFunc

func RefreshArangoClusterSynchronization

func RefreshArangoClusterSynchronization(t *testing.T, client kclient.Client, acs *api.ArangoClusterSynchronization) *api.ArangoClusterSynchronization

func WithLogScanner

func WithLogScanner(t *testing.T, name string, in func(t *testing.T, s LogScanner))

Types

type AsyncHandler

type AsyncHandler interface {
	ID() string

	Start()
	InProgress()
	Missing()
	Done()
}

func NewAsyncHandler

func NewAsyncHandler(t *testing.T, s Server, method string, path string, retCode int, ret interface{}) AsyncHandler

type LogScanner

type LogScanner interface {
	Factory() logging.Factory

	Get(timeout time.Duration) (string, bool)
	GetData(t *testing.T, timeout time.Duration, obj interface{}) bool
}

type Server

type Server interface {
	NewConnection() driver.Connection
	NewClient() driver.Client

	Handle(f http.HandlerFunc)
	Addr() string
	Stop()
}

func NewServer

func NewServer(t *testing.T) Server