util

Documentation

Index

• type YWTestContext
  • func NewYugawareTestContext(ctx context.Context, logger logr.Logger, hostname string, dialTimeout int, ...) *YWTestContext
  • func (c *YWTestContext) CleanupUniverse(universeName string)
  • func (c *YWTestContext) CreateUniverseIfNotExists(universeName, provider, instanceType string, withTLS bool, regions ...string) *models.UniverseResp
  • func (c *YWTestContext) CreateYSQLDatabase(universe string, database string)
  • func (c *YWTestContext) CreateYugatoolContext(universeName string) *YugatoolTestContext
  • func (c *YWTestContext) DropYSQLDatabase(universe string, database string)
  • func (c *YWTestContext) DumpYugawareLogs()
  • func (c *YWTestContext) GetMasterAddresses(universeName string) []*common.HostPortPB
  • func (c *YWTestContext) GetUniverse(universeName string) *models.UniverseResp
  • func (c *YWTestContext) RunYugawareCommand(args ...string) ([]byte, error)
  • func (c *YWTestContext) YCQLConnection(universeName string) *gocql.Session
  • func (c *YWTestContext) YSQLConnection(universeName string, database string) *sql.DB
• type YugatoolTestContext
  • func NewYugatoolTestContext(logger logr.Logger, universe *models.UniverseResp, ...) *YugatoolTestContext
  • func (c *YugatoolTestContext) RunYugatoolCommand(args ...string) (*bytes.Buffer, error)
  • func (c *YugatoolTestContext) YSQLConnection() *sql.DB

Types

type YWTestContext

type YWTestContext struct {
	*client.YugawareClient

	Hostname             string
	DialTimeout          int
	SkipHostVerification bool
	CACert               string
	ClientCert           string
	ClientKey            string
	APIToken             string
	Fs                   vfs.Filesystem
}

func NewYugawareTestContext

func NewYugawareTestContext(ctx context.Context, logger logr.Logger, hostname string, dialTimeout int, skipHostVerification bool, cacert, clientCert, clientKey, apiToken string) *YWTestContext

func (*YWTestContext) CleanupUniverse

func (c *YWTestContext) CleanupUniverse(universeName string)

func (*YWTestContext) CreateUniverseIfNotExists

func (c *YWTestContext) CreateUniverseIfNotExists(universeName, provider, instanceType string, withTLS bool, regions ...string) *models.UniverseResp

func (*YWTestContext) CreateYSQLDatabase

func (c *YWTestContext) CreateYSQLDatabase(universe string, database string)

func (*YWTestContext) CreateYugatoolContext

func (c *YWTestContext) CreateYugatoolContext(universeName string) *YugatoolTestContext

func (*YWTestContext) DropYSQLDatabase

func (c *YWTestContext) DropYSQLDatabase(universe string, database string)

func (*YWTestContext) DumpYugawareLogs

func (c *YWTestContext) DumpYugawareLogs()

func (*YWTestContext) GetMasterAddresses

func (c *YWTestContext) GetMasterAddresses(universeName string) []*common.HostPortPB

func (*YWTestContext) GetUniverse

func (c *YWTestContext) GetUniverse(universeName string) *models.UniverseResp

func (*YWTestContext) RunYugawareCommand

func (c *YWTestContext) RunYugawareCommand(args ...string) ([]byte, error)

func (*YWTestContext) YCQLConnection

func (c *YWTestContext) YCQLConnection(universeName string) *gocql.Session

func (*YWTestContext) YSQLConnection

func (c *YWTestContext) YSQLConnection(universeName string, database string) *sql.DB

type YugatoolTestContext

type YugatoolTestContext struct {
	*client.YBClient

	Output               string
	DialTimeout          int64
	MasterAddresses      []*common.HostPortPB
	CACert               string
	ClientCert           string
	ClientKey            string
	SkipHostVerification bool

	UniverseInfo *models.UniverseResp

	Fs vfs.Filesystem
}

func NewYugatoolTestContext

func NewYugatoolTestContext(logger logr.Logger, universe *models.UniverseResp, masters []*common.HostPortPB, dialTimeout int64, cacert, clientCert, clientKey []byte, skipHostVerification bool) *YugatoolTestContext

func (*YugatoolTestContext) RunYugatoolCommand

func (c *YugatoolTestContext) RunYugatoolCommand(args ...string) (*bytes.Buffer, error)

func (*YugatoolTestContext) YSQLConnection

func (c *YugatoolTestContext) YSQLConnection() *sql.DB