gatekeeper

Documentation

Index

• type ApiServer
  • func NewApiServer(repo *Repository) *ApiServer
  • func (s *ApiServer) ServeHTTP(resp http.ResponseWriter, req *http.Request)
  • func (s *ApiServer) Start()
  • func (s *ApiServer) Stop()
• type ChaosMonkey
  • func NewChaosMonkey(namespace string, kube dynamic.Interface, duration string, ...) *ChaosMonkey
  • func (c *ChaosMonkey) Close()
  • func (c *ChaosMonkey) Start() error
• type Repository
  • func NewRepository(casePath string, operatorAddr string, sourceDB *sql.DB, targetDB *sql.DB, ...) *Repository
• type TestCase
  • func NewTestCase(c TestCaseConfig, version string, operatorAddr string, sourceDB *sql.DB, ...) *TestCase
  • func (tc *TestCase) Delete()
  • func (tc *TestCase) Prepare()
  • func (tc *TestCase) Start(bootstrap bool)
• type TestCaseConfig
• type Version
  • func (v *Version) Delete()
  • func (v *Version) Reconcile(configs []TestCaseConfig, operatorAddr string, sourceDB *sql.DB, ...)

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)