echo

package module

v0.0.7 Latest Latest Go to latest Published: Nov 13, 2021 License: MIT Imports: 7 Imported by: 1

Details

echo is a golang runtime message tool It's currently support message pub/sub

go get github.com/johnhaha/echo

echo.Pub(CHANNEL,CONTENT)

echo.PubJson(CHANNEL,JSON)

echo.Sub(CONTEXT,CHANNEL,HANDLER)

This section is empty.

This section is empty.

func Pub(channel string, val string) error

pub string data to channel

func PubJson(channel string, val interface{}) error

pub json encoded data

func Sub(ctx context.Context, channel string, consumer func(*SubCtx))

sub to some channel and take action

type SubCtx struct {
	Data string
}

func (c *SubCtx) Parser(data interface{}) error

type Suber struct {
	SubMap map[string]func(*SubCtx)
}

func NewSuber() *Suber

func (s *Suber) Add(channel string, consumer func(*SubCtx))

func (s *Suber) Sub(ctx context.Context)