Versions in this module Expand all Collapse all v0 v0.5.0 Jan 17, 2021 Changes in this version + type Channel interface + Process func(s *session.Session, msg *message.Message) error + PushBack func(h Func) + PushFront func(h Func) + type Func func(s *session.Session, msg *message.Message) error + type Message = message.Message + type Pipeline interface + Inbound func() Channel + Outbound func() Channel + func New() Pipeline