gatekeeper

package
v0.3.12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 16, 2019 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApiServer

type ApiServer struct {
	// contains filtered or unexported fields
}

func NewApiServer

func NewApiServer(repo *Repository) *ApiServer

func (*ApiServer) ServeHTTP

func (s *ApiServer) ServeHTTP(resp http.ResponseWriter, req *http.Request)

func (*ApiServer) Start

func (s *ApiServer) Start()

func (*ApiServer) Stop

func (s *ApiServer) Stop()

type ChaosMonkey

type ChaosMonkey struct {
	// contains filtered or unexported fields
}

func NewChaosMonkey

func NewChaosMonkey(namespace string, kube dynamic.Interface, duration string, stopCh <-chan struct{}) *ChaosMonkey

func (*ChaosMonkey) Close

func (c *ChaosMonkey) Close()

func (*ChaosMonkey) Start

func (c *ChaosMonkey) Start() error

type Repository

type Repository struct {
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository(casePath string, operatorAddr string, sourceDB *sql.DB, targetDB *sql.DB, clusterClient clusterclient.ClusterInterface) *Repository

type TestCase

type TestCase struct {
	TestCaseConfig
	// contains filtered or unexported fields
}

func NewTestCase

func NewTestCase(c TestCaseConfig, version string, operatorAddr string, sourceDB *sql.DB, targetDB *sql.DB) *TestCase

func (*TestCase) Delete

func (tc *TestCase) Delete()

func (*TestCase) Prepare

func (tc *TestCase) Prepare()

func (*TestCase) Start

func (tc *TestCase) Start(bootstrap bool)

type TestCaseConfig

type TestCaseConfig struct {
	Name                       string `json:"name"  yaml:"name"`
	Desc                       string `json:"desc"  yaml:"desc"`
	mysql_test.GeneratorConfig `json:",inline"  yaml:",inline"`
}

type Version

type Version struct {
	Name         string
	RunningCases []string
	// contains filtered or unexported fields
}

func (*Version) Delete

func (v *Version) Delete()

func (*Version) Reconcile

func (v *Version) Reconcile(configs []TestCaseConfig, operatorAddr string, sourceDB *sql.DB, targetDB *sql.DB, bootstrap bool)

Jump to

Keyboard shortcuts

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