mock

Documentation

Index

• Variables
• func GetKakfkaConfig() config.AccessPoint
• func GetMockDBClient() *rdb.DBClient
• func InitMockDB() error

Variables

var (
	MockDB       *sql.DB
	MockDBClient *rdb.DBClient
)

var LocalUnitTestKafka = config.AccessPoint{
	Source: "kafka://localhost:9092/?" +
		"topics=my-event-test-topic" +
		"&numpartition=2&numreplica=1&autocommitsecond=1" +
		"initial=oldest&version=1.1.1",
}

var LocalUnitTestMySQLConfig = config.AccessPoint{
	Source: "mysql://root:root@tcp(127.0.0.1:3306)/testdb?charset=utf8&parseTime=True&loc=Local",
	Options: map[string]interface{}{
		"sqllevel":    "info",
		"maxopenconn": 100,
		"maxidleconn": 100,
	},
}

Functions

func GetKakfkaConfig

func GetKakfkaConfig() config.AccessPoint

func GetMockDBClient

func GetMockDBClient() *rdb.DBClient

func InitMockDB

func InitMockDB() error

InitMockDB initialize the test database