pipeline

Documentation

Index

• type Channel
• type Func
• type Message
• type Pipeline
  • func New() Pipeline

Types

type Channel

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

Channel is a container of pipeline processing functions

type Func

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

Func is the pipeline processing function

type Message

type Message = message.Message

Message is the alias of `message.Message`

type Pipeline

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

Pipeline is used as interceptor for inbound and outbound messages

func New

func New() Pipeline

New creates a pipeline