本文整理汇总了Golang中github.com/influx6/flux.FatalFailed函数的典型用法代码示例。如果您正苦于以下问题:Golang FatalFailed函数的具体用法?Golang FatalFailed怎么用?Golang FatalFailed使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了FatalFailed函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: TestQuero
func TestQuero(t *testing.T) {
db, err := sql.Open("mysql", "root:@tcp(localhost:3306)/test")
if err != nil {
flux.FatalFailed(t, "Creating sql connection: %+s", err)
}
defer db.Close()
prepareTable(t, db)
var ws sync.WaitGroup
ws.Add(1)
reader := flux.FileLoader()
qo := Quero(db)
reader.Bind(qo, true)
qo.React(func(r flux.Reactor, err error, d interface{}) {
ws.Done()
if err != nil {
flux.FatalFailed(t, "Failed in Building sql.Statement, Error Received: %+s", err)
}
log.Printf("Model data: %+q", d)
flux.LogPassed(t, "Successful created sql.Statement")
}, true)
reader.Send("./../../fixtures/models.dq")
defer qo.Close()
ws.Wait()
dropTables(t, db)
}
开发者ID:influx6,项目名称:dataquery,代码行数:35,代码来源:sql_test.go
示例2: TestTemplateDir
func TestTemplateDir(t *testing.T) {
dir := NewTemplateDir(&TemplateConfig{
Dir: "./fixtures",
Extension: ".tmpl",
})
dirs := []string{"base"}
asst, err := dir.Create("base.tmpl", dirs, nil)
if err != nil {
flux.FatalFailed(t, "Failed to load: %s", err.Error())
}
if len(asst.Funcs) < 1 {
flux.FatalFailed(t, "AssetTemplate Func map is empty")
}
buf := bytes.NewBuffer([]byte{})
do := &dataPack{
Name: "alex",
Title: "flabber",
}
err = asst.Tmpl.ExecuteTemplate(buf, "base", do)
if err != nil {
flux.FatalFailed(t, "Unable to exec templates: %+s", err)
}
flux.LogPassed(t, "Loaded Template succesfully")
}
开发者ID:influx6,项目名称:assets,代码行数:33,代码来源:assets_test.go
示例3: TestChunkParserCombo
func TestChunkParserCombo(t *testing.T) {
var ws sync.WaitGroup
ws.Add(1)
fs := ChunkFileScanAdaptor()
ps := ParseAdaptor(parser.DefaultInspectionFactory)
fs.Bind(ps, true)
fs.React(func(rs flux.Reactor, err error, data interface{}) {
ws.Done()
if err != nil {
flux.FatalFailed(t, "Error occured string: %v", err.Error())
}
if _, ok := data.(ds.Graphs); ok {
flux.FatalFailed(t, "Expected type ds.Graphs: %v", data)
}
flux.LogPassed(t, "Completed with parser Graph from ChunckFileScanner and Parser Combo")
}, true)
fs.Send("./../fixtures/dataset.dq")
ws.Wait()
fs.Close()
}
开发者ID:influx6,项目名称:dataquery,代码行数:28,代码来源:adapters_test.go
示例4: TestMarkFriday
func TestMarkFriday(t *testing.T) {
ws := new(sync.WaitGroup)
ws.Add(1)
mark := MarkFriday(MarkConfig{
SaveDir: "../fixtures/templates",
Ext: ".mdr",
})
mark.React((func(root flux.Reactor, err error, data interface{}) {
if err != nil {
flux.FatalFailed(t, "Error occured %+s", err)
}
if rf, ok := data.(*fs.FileWrite); ok {
flux.LogPassed(t, "Markdown Rendered: %+s -> %+s", rf.Data, rf)
} else {
flux.FatalFailed(t, "Failure in receiving Correct Response: %+s", data)
}
ws.Done()
}), true)
mark.Send("../fixtures/markdown/base.md")
ws.Wait()
mark.Close()
}
开发者ID:influx6,项目名称:reactors,代码行数:27,代码来源:builder_test.go
示例5: TestModelPassAndFailure
// TestModelPassAndFailure sets up a new map model and validates that the wrong data fails
func TestModelPassAndFailure(t *testing.T) {
mo := NewModels(map[string]interface{}{
"name": "",
"age": 0,
"date": time.Now(),
})
key, err := mo.Validate(map[string]interface{}{
"name": "alex ewetumo",
"age": 20,
"date": time.Now(),
})
if err != nil {
flux.FatalFailed(t, "Validation key failed: %s : %s", key, err.Error())
}
flux.LogPassed(t, "Validation passed!")
key, err = mo.Validate(map[string]interface{}{
"name": "alex ewetumo",
"age": 20,
"date": time.Duration(300) * time.Minute,
})
if err == nil {
flux.FatalFailed(t, "Validation key did not failed: %s", "date")
}
flux.LogPassed(t, "Validation failed as expected: %s : %s", key, err.Error())
}
开发者ID:influx6,项目名称:dataquery,代码行数:33,代码来源:models_test.go
示例6: TestMarkdownStream
func TestMarkdownStream(t *testing.T) {
ws := new(sync.WaitGroup)
ws.Add(2)
mark, err := MarkFridayStream(MarkStreamConfig{
InputDir: "../fixtures/markdown",
SaveDir: "../fixtures/templates",
Ext: ".html",
})
if err != nil {
flux.FatalFailed(t, "Failed to build list streamer", err)
}
mark.React((func(root flux.Reactor, err error, data interface{}) {
if err != nil {
flux.FatalFailed(t, "Error occured %+s", err)
}
ws.Done()
}), true)
mark.Send(true)
ws.Wait()
mark.Close()
}
开发者ID:influx6,项目名称:reactors,代码行数:25,代码来源:builder_test.go
示例7: TestMarkdown
func TestMarkdown(t *testing.T) {
ws := new(sync.WaitGroup)
ws.Add(1)
mark := BlackFriday()
mark.React((func(root flux.Reactor, err error, data interface{}) {
if err != nil {
flux.FatalFailed(t, "Error occured %+s", err)
}
if rf, ok := data.(*RenderFile); ok {
flux.LogPassed(t, "Markdown Rendered: %+s", rf.Data)
} else {
flux.FatalFailed(t, "Failure in receiving Correct Response: %+s", data)
}
ws.Done()
}), true)
mark.Send(&RenderFile{
Path: "./slug.md",
Data: []byte("# Slug Passive Aggressive -> SPA"),
})
ws.Wait()
mark.Close()
}
开发者ID:influx6,项目名称:reactors,代码行数:26,代码来源:builder_test.go
示例8: TestModelFileParser
func TestModelFileParser(t *testing.T) {
ps := NewParser(DefaultInspectionFactory)
fs, err := os.Open("./../fixtures/models.dq")
if err != nil {
flux.FatalFailed(t, "File.Error occured: %+s", err)
}
g, err := ps.Scan(fs)
if err != nil {
flux.FatalFailed(t, "Parser.Error occured: %+s", err)
}
itr, err := ds.CreateGraphTransversor(ds.DFPreOrderDirective(nil, nil))
if err != nil {
t.Fatal(err)
}
itr.Use(g.Get("user"))
for itr.Next() == nil {
node := itr.Node().(*ParseNode)
t.Logf("Node-Attr: %s %+s", node.Name(), node.Attr)
t.Logf("Node-Record: %s %+s", node.Name(), node.Records.Keys())
t.Logf("Node-Rules: %s %+s", node.Name(), node.Rules)
}
flux.LogPassed(t, "Successfully passed model query file properly")
}
开发者ID:influx6,项目名称:dataquery,代码行数:32,代码来源:parser_test.go
示例9: TestGoodFileParser
func TestGoodFileParser(t *testing.T) {
ps := NewParser(DefaultInspectionFactory)
fs, err := os.Open("./../fixtures/dataset.dq")
if err != nil {
flux.FatalFailed(t, "File.Error occured: %+s", err)
}
g, err := ps.Scan(fs)
if err != nil {
flux.FatalFailed(t, "Parser.Error: ", err)
}
flux.LogPassed(t, "Generated query graph successfully: %t", g != nil)
itr, err := ds.CreateGraphTransversor(ds.DFPreOrderDirective(nil, nil))
if err != nil {
flux.FatalFailed(t, "Transverso.Error occured: %+s", err)
}
itr.Use(g.Get("user"))
for itr.Next() == nil {
node := itr.Node().(*ParseNode)
t.Logf("Node-Attr: %s %+s", node.Name(), node.Attr)
t.Logf("Node-Record: %s %+s", node.Name(), node.Records.Keys())
t.Logf("Node-Rules: %s %+s", node.Name(), node.Rules)
}
flux.LogPassed(t, "Graph Iterator works properly")
}
开发者ID:influx6,项目名称:dataquery,代码行数:34,代码来源:parser_test.go
示例10: TestAssetMap
func TestAssetMap(t *testing.T) {
tree, err := AssetTree("./", []string{".go"}, nil)
if err != nil {
flux.FatalFailed(t, "Unable to create asset map: %s", err.Error())
}
if len(tree) <= 0 {
flux.FatalFailed(t, "expected one key atleast: %s")
}
flux.LogPassed(t, "Succesfully created asset map tree")
}
开发者ID:influx6,项目名称:assets,代码行数:13,代码来源:assets_test.go
示例11: TestVirtualDir
func TestVirtualDir(t *testing.T) {
if _, err := RootDirectory.GetDir("/"); err != nil {
flux.FatalFailed(t, "Unable to located asset dir in dirCollection")
}
if _, err := RootDirectory.GetDir("/fixtures"); err != nil {
flux.FatalFailed(t, "Unable to located /fixtures dir in dirCollection")
}
to, err := RootDirectory.GetDir("/fixtures/base")
if err != nil {
flux.FatalFailed(t, "Unable to located fixtures/base directory: %s", err)
}
al, err := to.GetFile("basic.tmpl")
if err != nil {
flux.FatalFailed(t, "Unable to located /fixtures/base/basic.tmpl file: %s", err)
}
if data, err := al.Data(); err != nil {
flux.FatalFailed(t, "failed to load /fixtures/base/basic.tmpl contents: %s", err)
} else if len(data) != 364 {
flux.FatalFailed(t, "incorrect assets/tests/lock.md content, expected length %d got %d", 364, len(data))
}
if _, err := RootDirectory.GetFile("/fixtures/base/basic.tmpl"); err != nil {
flux.FatalFailed(t, "Unable to get File /fixtures/base/basic.tmpl file: %s", err)
}
tom, _ := RootDirectory.GetDir("/fixtures")
if _, err := tom.GetFile("/base/basic.tmpl"); err != nil {
flux.FatalFailed(t, "Unable to get File /base/basic.tmpl file: %s", err)
}
}
开发者ID:influx6,项目名称:assets,代码行数:35,代码来源:prod_test.go
示例12: expect
func expect(t *testing.T, v, m interface{}) {
if v != m {
flux.FatalFailed(t, "Value %+v and %+v are not a match", v, m)
return
}
flux.LogPassed(t, "Value %+v and %+v are a match", v, m)
}
开发者ID:influx6,项目名称:relay,代码行数:7,代码来源:utils.go
示例13: TestChunkScannerWithSinglePack
func TestChunkScannerWithSinglePack(t *testing.T) {
var ws sync.WaitGroup
ws.Add(1)
fs := ChunkFileScanAdaptor()
fs.React(func(rs flux.Reactor, err error, data interface{}) {
ws.Done()
if err != nil {
flux.FatalFailed(t, "Error occured string: %v", err.Error())
}
if _, ok := data.(string); !ok {
t.Fatalf("Expected type string: %v", data)
}
flux.LogPassed(t, "Completed with scanning on SinglePack file")
}, true)
fs.Send("./../fixtures/dataset.dq")
ws.Wait()
fs.Close()
}
开发者ID:influx6,项目名称:dataquery,代码行数:25,代码来源:adapters_test.go
示例14: TestBadFileParser
func TestBadFileParser(t *testing.T) {
ps := NewParser(DefaultInspectionFactory)
fs, err := os.Open("./../fixtures/config.dq")
if err != nil {
flux.FatalFailed(t, "File.Error occured: %+s", err)
}
_, err = ps.Scan(fs)
if err == nil {
flux.FatalFailed(t, "Parser is supposed to error out about bad file")
}
flux.LogPassed(t, "Bad file failed properly: %+s", err)
}
开发者ID:influx6,项目名称:dataquery,代码行数:17,代码来源:parser_test.go
示例15: dropTables
func dropTables(t *testing.T, db *sql.DB) {
_, err := db.Exec("DROP TABLE IF EXISTS test.users")
if err != nil {
flux.FatalFailed(t, "Failed sql drop test.users table: %+s", err)
}
flux.LogPassed(t, "Successfully exectuable DROP table to sql db: %+s", "test.users")
_, err = db.Exec("DROP TABLE IF EXISTS test.photos")
if err != nil {
flux.FatalFailed(t, "Failed sql drop test.photos table: %+s", err)
}
flux.LogPassed(t, "Successfully exectuable DROP table to sql db: %+s", "test.photos")
}
开发者ID:influx6,项目名称:dataquery,代码行数:17,代码来源:sql_test.go
示例16: TestModels
func TestModels(t *testing.T) {
ps := NewParser(DefaultInspectionFactory)
fs, err := os.Open("./../fixtures/models.dq")
if err != nil {
flux.FatalFailed(t, "File.Error occured: %+s", err)
}
g, err := ps.Scan(fs)
if err != nil {
flux.FatalFailed(t, "Parser is supposed to not error out about model file: %+s", err)
}
flux.LogPassed(t, "Generated query graph successfully: %t", g != nil)
}
开发者ID:influx6,项目名称:dataquery,代码行数:17,代码来源:parser_test.go
示例17: TestChunkScanning
func TestChunkScanning(t *testing.T) {
fs, err := os.Open("./../fixtures/config.dq")
if err != nil {
flux.FatalFailed(t, "File.Error occured: %+s", err)
}
err = ScanChunks(NewScanner(fs), func(cu string) {
// t.Logf("Chunks: %s", cu)
})
if err != nil {
flux.FatalFailed(t, "ChunkScanning.Error occured: %+s", err)
}
flux.LogPassed(t, "ChunkScanning finished successfully!")
}
开发者ID:influx6,项目名称:dataquery,代码行数:17,代码来源:parser_test.go
示例18: TestDebugVirtualFile
func TestDebugVirtualFile(t *testing.T) {
vf := NewVFile("./", "assets/vim.md", "vim.md", 5, true, true, func(v *VFile) ([]byte, error) {
return readFile(v)
})
if vf.Size() > 5 {
flux.FatalFailed(t, "Incorrect size value,expected %d got %d", 5, vf.Size())
}
if data, err := vf.Data(); err != nil {
flux.FatalFailed(t, "Error occured retrieving content: %s", err)
} else {
if string(data) != "#Vim\n" {
flux.FatalFailed(t, "Error in file content expected %s got %s", "#Vim", data)
}
}
flux.LogPassed(t, "Successfully read contents of virtual file")
}
开发者ID:influx6,项目名称:assets,代码行数:19,代码来源:vfiles_test.go
示例19: TestCompressedVirtualFile
func TestCompressedVirtualFile(t *testing.T) {
vf := NewVFile("./", "assets/bucklock.txt", "buklock.txt", 30, true, true, func(v *VFile) ([]byte, error) {
return readData(v, []byte("\x1f\x8b\x08\x00\x00\x09\x6e\x88\x00\xff\x52\x0e\xcb\xcc\xe5\x02\x04\x00\x00\xff\xff\xec\xfe\xa5\xd9\x05\x00\x00\x00"))
})
if vf.Size() < 30 {
flux.FatalFailed(t, "Incorrect size value,expected %d got %d", 30, vf.Size())
}
if data, err := vf.Data(); err != nil {
flux.FatalFailed(t, "Error occured retrieving content: %s", err)
} else {
if string(data) != "#Vim\n" {
flux.FatalFailed(t, "Error in file content expected %s got %s", "shop", data)
}
}
flux.LogPassed(t, "Successfully read contents of virtual file")
}
开发者ID:influx6,项目名称:assets,代码行数:19,代码来源:vfiles_test.go
示例20: TestPlainVirtualFile
func TestPlainVirtualFile(t *testing.T) {
vf := NewVFile("./", "assets/bucklock.txt", "buklock.txt", 5, true, true, func(v *VFile) ([]byte, error) {
return []byte("shop"), nil
})
if vf.Size() > 5 {
flux.FatalFailed(t, "Incorrect size value,expected %d got %d", 5, vf.Size())
}
if data, err := vf.Data(); err != nil {
flux.FatalFailed(t, "Error occured retrieving content: %s", err)
} else {
if string(data) != "shop" {
flux.FatalFailed(t, "Error in file content expected %s got %s", "shop", data)
}
}
flux.LogPassed(t, "Successfully read contents of virtual file")
}
开发者ID:influx6,项目名称:assets,代码行数:19,代码来源:vfiles_test.go
注:本文中的github.com/influx6/flux.FatalFailed函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论