nano: github.com/lonng/nano/pipeline Index | Files

package pipeline

import "github.com/lonng/nano/pipeline"

Index

Package Files

pipeline.go

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.