Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

flow

package module

Go to main page

Versions in this module

v0

v0.3.0

Jul 3, 2017

Changes in this version

+ type Flow struct

+ func NewFlow() *Flow

+ func (p *Flow) Choice() *Choice

+ func (p *Flow) From(url string, params ...interface{}) *Flow

+ func (p *Flow) GetBody() interface{}

+ func (p *Flow) GetHeader() HeaderMap

+ func (p *Flow) SetBody(b interface{}) *Flow

+ func (p *Flow) SetHeader(k, v string) *Flow

+ func (p *Flow) To(url string, params ...interface{}) *Flow

v0.2.3

Jun 30, 2017

v0.2.2

Jun 5, 2017

v0.2.1

Jun 5, 2017

Changes in this version

+ func RegisterConnector(name string, ...)

+ type Choice struct

+ func NewChoice(p IPipe) *Choice

+ func (c *Choice) Otherwise() *Choice

+ func (c *Choice) To(url string, params ...interface{}) *Choice

+ func (c *Choice) When(e HeaderFnc) *Choice

+ type ExchangeMessage struct

+ func NewExchangeMessage() *ExchangeMessage

+ func (e *ExchangeMessage) BindJSON(v interface{}) error

+ func (e *ExchangeMessage) BindXML(v interface{}) error

+ func (e *ExchangeMessage) ClearHeader()

+ func (e *ExchangeMessage) DelHeader(k string)

+ func (e *ExchangeMessage) GetBody() interface{}

+ func (e *ExchangeMessage) GetHeader(k string) string

+ func (e *ExchangeMessage) GetHeaderMap() HeaderMap

+ func (e *ExchangeMessage) SetBody(b interface{})

+ func (e *ExchangeMessage) SetHeader(k, v string)

+ func (e *ExchangeMessage) WriteJSON(v interface{}) error

+ func (e *ExchangeMessage) WriteXML(v interface{}) error

+ type HeaderFnc func(IPipe) (interface{}, IPipe)

+ func (h HeaderFnc) Exist() HeaderFnc

+ func (h HeaderFnc) IsEqualTo(s string) HeaderFnc

+ func Header(s string) HeaderFnc

+ type HeaderMap map[string]string

+ func (h HeaderMap) Add(key, value string)

+ func (h HeaderMap) Del(key string)

+ func (h HeaderMap) Get(key string) string

+ func (h HeaderMap) ListKeys() []string

+ type IPipe interface

+ Body func() interface{}

+ Choice func() *Choice

+ From func(string, ...interface{}) IPipe

+ GetBody func() interface{}

+ GetFails func() []error

+ GetHeader func() HeaderMap

+ Header func() HeaderMap

+ Processor func(PipeProcessor) IPipe

+ SetBody func(interface{}) IPipe

+ SetHeader func(string, string) IPipe

+ To func(string, ...interface{}) IPipe

+ Transform func(Transform, string, Transform, template.FuncMap) IPipe

+ func NewPipe() IPipe

+ type Message chan interface

+ type Pipe struct

+ func (p *Pipe) Body() interface{}

+ func (p *Pipe) Choice() *Choice

+ func (p *Pipe) From(url string, params ...interface{}) IPipe

+ func (p *Pipe) GetBody() interface{}

+ func (p *Pipe) GetFails() []error

+ func (p *Pipe) GetHeader() HeaderMap

+ func (p *Pipe) Header() HeaderMap

+ func (p *Pipe) Processor(proc PipeProcessor) IPipe

+ func (p *Pipe) SetBody(b interface{}) IPipe

+ func (p *Pipe) SetHeader(k, v string) IPipe

+ func (p *Pipe) To(url string, params ...interface{}) IPipe

+ func (p *Pipe) Transform(from Transform, mode string, to Transform, fncs template.FuncMap) IPipe

+ type PipeProcessor func(*ExchangeMessage, Message, func())

+ type Stack []interface

+ func (s *Stack) Clear()

+ func (s *Stack) Pop() interface{}

+ func (s *Stack) Push(ext interface{})

+ func (s Stack) Top() interface{}

+ type Transform string

+ func (original Transform) TransformFromJSON(from, to Transform, fncMap template.FuncMap) (string, error)

+ func (original Transform) TransformFromXML(from, to Transform, fncMap template.FuncMap) (string, error)

+ type URI struct

+ func (u URI) GetHost() string

+ func (u URI) GetOption(k string) string

+ func (u URI) GetProtocol() string

+ func (u URI) GetRaw() string