testutil

Documentation

Index

• Constants
• func AfterTestSuite()
• func BeforeTestSuite()
• func CreateSchema(name string)
• func CreateSimulacronCluster(dc1Length int, dc2Length int)
• func EnsureCcmCluster(setupHandler func(), queries ...string)
• func EnsureSimulacronCluster()
• func GetSession() *gocql.Session
• func PanicIfError(err error)
• func StartSimulacron()
• func StopSimulacron()
• func TestLogger() log.Logger
• type ClusterQueryLogReport
  • func GetQueryLogs(dcIndex int) ClusterQueryLogReport
• type DataCenterQueryLogReport
• type Frame
• type Message
• type NodeQueryLogReport
• type QueryLog
• type QueryMatches
  • func CountLogMatches(nodeLogs []NodeQueryLogReport, query string) QueryMatches

Constants

const SimulacronStartIp = "127.0.0.101"

Functions

func AfterTestSuite

func AfterTestSuite()

func BeforeTestSuite

func BeforeTestSuite()

func CreateSchema

func CreateSchema(name string)

func CreateSimulacronCluster

func CreateSimulacronCluster(dc1Length int, dc2Length int)

func EnsureCcmCluster

func EnsureCcmCluster(setupHandler func(), queries ...string)

func EnsureSimulacronCluster

func EnsureSimulacronCluster()

func GetSession

func GetSession() *gocql.Session

Gets the shared session for this suite

func PanicIfError

func PanicIfError(err error)

func StartSimulacron

func StartSimulacron()

func StopSimulacron

func StopSimulacron()

func TestLogger

func TestLogger() log.Logger

Types

type ClusterQueryLogReport

type ClusterQueryLogReport struct {
	Id          int64                      `json:"id"`
	DataCenters []DataCenterQueryLogReport `json:"data_centers"`
}

func GetQueryLogs

func GetQueryLogs(dcIndex int) ClusterQueryLogReport

type DataCenterQueryLogReport

type DataCenterQueryLogReport struct {
	Id    int64                `json:"id"`
	Nodes []NodeQueryLogReport `json:"nodes"`
}

type Frame

type Frame struct {
	ProtocolVersion int     `json:"protocol_version"`
	Message         Message `json:"message"`
}

type Message

type Message struct {
	Type  string `json:"type"`
	Query string `json:"query"`
}

type NodeQueryLogReport

type NodeQueryLogReport struct {
	Id      int64      `json:"id"`
	Queries []QueryLog `json:"queries"`
}

type QueryLog

type QueryLog struct {
	Connection string `json:"connection"`
	Frame      Frame  `json:"frame"`
}

type QueryMatches

type QueryMatches struct {
	Prepare int
	Execute int
}

func CountLogMatches

func CountLogMatches(nodeLogs []NodeQueryLogReport, query string) QueryMatches