diff options
author | KatolaZ <katolaz@freaknet.org> | 2017-07-15 01:26:39 +0100 |
---|---|---|
committer | KatolaZ <katolaz@freaknet.org> | 2017-07-15 01:26:39 +0100 |
commit | 726b399e4747032a3d052339cd62c57ae5b6767c (patch) | |
tree | aac8350e83bb13e9628dd287ca3aae97ecafcb32 /sandpit/test_parse_message.go | |
parent | ed637037b75cb5dfe1b49e776956fa6ab3632b68 (diff) |
pipeline from spool to worker is done -- added examples
Diffstat (limited to 'sandpit/test_parse_message.go')
-rw-r--r-- | sandpit/test_parse_message.go | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/sandpit/test_parse_message.go b/sandpit/test_parse_message.go new file mode 100644 index 0000000..f60f03c --- /dev/null +++ b/sandpit/test_parse_message.go @@ -0,0 +1,44 @@ +package main + +import( + "fmt" + "github.com/go-yaml/yaml" + "io/ioutil" + "log" + "os" +) + + +var orig_msg= ` +--- +m_id: 123456 +m_repo: master +m_branch: test_branch +m_oldrev: a1b2c3d4e5f6 +m_newrev: 9a8b7c6d5e4f +... + +` + + +func main(){ + + var msg *SCORSHmsg + msg = new(SCORSHmsg) + + + fname := "spool/test_2" + + data, err := ioutil.ReadFile(fname) + if err != nil { + log.Printf("Unable to open file: %s\n", fname) + os.Exit(1) + } + err = yaml.Unmarshal([]byte(data), msg) + if err != nil{ + log.Printf("Error parsing message: %s", err) + } + + fmt.Printf("%s\n", msg) + +} |