harness

package

v0.0.0-...-ff7342e Latest Latest Go to latest Published: Sep 24, 2017 License: GPL-3.0, GPL-3.0-only Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

src.goshawkdb.io/tests

Documentation ¶

Index ¶

type ConfigKey
- func (ck ConfigKey) LoadFromEnv(env TestEnv) (bool, []byte, error)
type Connection
- func (conn *Connection) AwaitRootVersionChange(guidBuf []byte, expectedPtrs int) ([]client.RefCap, error)
- func (conn *Connection) SetRootToNZeroObjs(n int) ([]byte, error)
type TestEnv
- func GetTestEnv() TestEnv
- func (te TestEnv) Clone() TestEnv
- func (te TestEnv) EnsureEnv(key ConfigKey, value string) string
type TestHelper
type TestHelperTxnResult
- func (self TestHelperTxnResult) Error() string
type TestInterface
type TestTAdaptor

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ConfigKey ¶

type ConfigKey string

const (
	GoshawkDB      ConfigKey = "GOSHAWKDB_BINARY"
	ClusterConfig  ConfigKey = "GOSHAWKDB_CLUSTER_CONFIG"
	ClusterHosts   ConfigKey = "GOSHAWKDB_CLUSTER_HOSTS"
	ClusterCert    ConfigKey = "GOSHAWKDB_CLUSTER_CERT"
	ClusterKeyPair ConfigKey = "GOSHAWKDB_CLUSTER_KEYPAIR"
	ClientKeyPair  ConfigKey = "GOSHAWKDB_CLIENT_KEYPAIR"
	RootName       ConfigKey = "GOSHAWKDB_ROOT_NAME"
	GoPath         ConfigKey = "GOPATH"
)

func (ConfigKey) LoadFromEnv ¶

func (ck ConfigKey) LoadFromEnv(env TestEnv) (bool, []byte, error)

type Connection ¶

type Connection struct {
	*TestHelper
	log.Logger
	*client.Connection
	// contains filtered or unexported fields
}

func (*Connection) AwaitRootVersionChange ¶

func (conn *Connection) AwaitRootVersionChange(guidBuf []byte, expectedPtrs int) ([]client.RefCap, error)

func (*Connection) SetRootToNZeroObjs ¶

func (conn *Connection) SetRootToNZeroObjs(n int) ([]byte, error)

type TestEnv ¶

type TestEnv map[ConfigKey]string

func GetTestEnv ¶

func GetTestEnv() TestEnv

func (TestEnv) Clone ¶

func (te TestEnv) Clone() TestEnv

func (TestEnv) EnsureEnv ¶

func (te TestEnv) EnsureEnv(key ConfigKey, value string) string

type TestHelper ¶

type TestHelper struct {
	TestInterface

	ClusterHosts  []string
	ClusterCert   []byte
	ClientKeyPair []byte
	RootName      string
	Rng           *rand.Rand
	// contains filtered or unexported fields
}

func NewHelper ¶

func NewHelper(t TestInterface) *TestHelper

func NewMainHelper ¶

func NewMainHelper() *TestHelper

func NewTestHelper ¶

func NewTestHelper(t *testing.T) *TestHelper

func (*TestHelper) CreateConnections ¶

func (th *TestHelper) CreateConnections(num int) []*Connection

func (*TestHelper) InParallel ¶

func (th *TestHelper) InParallel(n int, fun func(int, *Connection) error) (*sync.WaitGroup, chan error)

func (*TestHelper) MaybeFatal ¶

func (th *TestHelper) MaybeFatal(err error) error

func (*TestHelper) Shutdown ¶

func (th *TestHelper) Shutdown()

type TestHelperTxnResult ¶

type TestHelperTxnResult uint8

const Abort TestHelperTxnResult = iota

func (TestHelperTxnResult) Error ¶

func (self TestHelperTxnResult) Error() string

type TestInterface ¶

type TestInterface interface {
	log.Logger
	Fatal(keyvals ...interface{})
}

type TestTAdaptor ¶

type TestTAdaptor struct {
	log.Logger
	*testing.T
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
interpreter
config
topology

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL