testsupport

Documentation

Index

• Constants
• func CreateDatabase(config db.Config)
• func GetDBConfig() db.Config
• func RemoveDatabase(config db.Config)
• func WaitOrReady(startTimeout time.Duration, monitor ifrit.Process) error
• type BadReader
  • func (r *BadReader) Close() error
  • func (r *BadReader) Read(buffer []byte) (int, error)
• type CertWriter
  • func NewCertWriter(certPath string) (*CertWriter, error)
  • func (c *CertWriter) WriteAndSign(commonName, caName string) (string, string, error)
  • func (c *CertWriter) WriteCA(caName string) (string, error)
• type ParallelRunner
  • func (p *ParallelRunner) RunOnChannel(queue chan interface{}, workFunc func(item interface{}))
  • func (p *ParallelRunner) RunOnSlice(items []interface{}, workFunc func(item interface{}))
  • func (p *ParallelRunner) RunOnSliceStrings(someStrings []string, workFunc func(aString string))

Constants

const DefaultDBTimeout = 5

const RSABits = 1024

Functions

func CreateDatabase

func CreateDatabase(config db.Config)

func GetDBConfig

func GetDBConfig() db.Config

func RemoveDatabase

func RemoveDatabase(config db.Config)

func WaitOrReady

func WaitOrReady(startTimeout time.Duration, monitor ifrit.Process) error

Types

type BadReader

type BadReader struct {
	Error error
}

func (*BadReader) Close

func (r *BadReader) Close() error

func (*BadReader) Read

func (r *BadReader) Read(buffer []byte) (int, error)

type CertWriter

type CertWriter struct {
	CertPath string
	// contains filtered or unexported fields
}

func NewCertWriter

func NewCertWriter(certPath string) (*CertWriter, error)

func (*CertWriter) WriteAndSign

func (c *CertWriter) WriteAndSign(commonName, caName string) (string, string, error)

func (*CertWriter) WriteCA

func (c *CertWriter) WriteCA(caName string) (string, error)

type ParallelRunner

type ParallelRunner struct {
	NumWorkers int
}

func (*ParallelRunner) RunOnChannel

func (p *ParallelRunner) RunOnChannel(queue chan interface{}, workFunc func(item interface{}))

func (*ParallelRunner) RunOnSlice

func (p *ParallelRunner) RunOnSlice(items []interface{}, workFunc func(item interface{}))

func (*ParallelRunner) RunOnSliceStrings

func (p *ParallelRunner) RunOnSliceStrings(someStrings []string, workFunc func(aString string))