内置普通节点

  	p := ograph.NewPipeline()

	e := ograph.NewElement("cmd").UseFactory(ogimpl.CMD).
		Params("Cmd", []string{"go", "version"})

    // register and run the node which exec go version
	p.Register(e).Run(context.TODO(), nil)
  

  	state := ograph.NewState()
	state.Set("time", time.Now())

	p := ograph.NewPipeline()

	e := ograph.NewElement("req").UseFactory(ogimpl.HttpReq).
		Params("Method", "POST").
		Params("Url", "http://localhost:8080/ping").
		// Render body as:
		// Send-Time: 2024-08-03 10:10:20.0873372 +0800 CST m=+0.002574001
		Params("BodyTpl", `Send-Time: {{GetState "time"}}`)

	p.Register(e).Run(context.Background(), state)
  

  	p := ograph.NewPipeline()

	a := ograph.NewElement("Assert").Apply(ogimpl.AssertOp("i==1"))

	p.Register(a)

	s := ograph.NewState()
	s.Set("i", 1) // if set with other value, the assertion fails, then the pipeline will also fail

	p.Run(context.TODO(), s)