nano: Index | Files

package pipeline

import ""


Package Files


type Channel Uses

type Channel interface {
    PushFront(h Func)
    PushBack(h Func)
    Process(s *session.Session, msg *message.Message) error

type Func Uses

type Func func(s *session.Session, msg *message.Message) error

type Message Uses

type Message = message.Message

Message is the alias of `message.Message`

type Pipeline Uses

type Pipeline interface {
    Outbound() Channel
    Inbound() Channel

func New Uses

func New() Pipeline

Package pipeline imports 3 packages (graph) and is imported by 7 packages. Updated 2019-07-08. Refresh now. Tools for package owners.