goevent

README

go-event 基于 chan

观察者模式 事件中心
扩展开发，定义消息通道大小

//使用方法
package main

import (
	goevent "github.com/gif-gif/go.io/go-event"
	golog "github.com/gif-gif/go.io/go-log"
	"github.com/gif-gif/go.io/goio"
	"time"
)

func main() {
	goio.Init()
	event := goevent.New()
	event.Subscribe("test", func(msg goevent.Message) {
		golog.WithTag("goevent").Info(msg)
	})
	event.Publish("test", "test")
	time.Sleep(time.Duration(1) * time.Second)
}

Documentation

Index

• func Publish(topic string, data interface{})
• func Subscribe(topic string, fn SubscribeFunc)
• type GoEvent
  • func Default() *GoEvent
  • func New(channelSize ...int) *GoEvent
  • func (ev *GoEvent) Publish(topic string, data interface{}, async ...bool)
  • func (ev *GoEvent) Subscribe(topic string, fn SubscribeFunc, async ...bool)
  • func (ev *GoEvent) UnSubscribe(topic string)
  • func (ev *GoEvent) UnSubscribeDefault()
• type Message
• type MessageChan
• type SubscribeFunc

Functions

func Publish

func Publish(topic string, data interface{})

func Subscribe

func Subscribe(topic string, fn SubscribeFunc)

Types

type GoEvent

type GoEvent struct {
	DefaultTopic string
	// contains filtered or unexported fields
}

支持同步和异步执行(发送和接收)

默认是同步执行

func Default

func Default() *GoEvent

func New

func New(channelSize ...int) *GoEvent

func (*GoEvent) Publish

func (ev *GoEvent) Publish(topic string, data interface{}, async ...bool)

发布 执行当前topic 对应的所有订阅者, async=true 则异步执行(并发执行无序)，否则同步执行保证channel发送顺序

func (*GoEvent) Subscribe

func (ev *GoEvent) Subscribe(topic string, fn SubscribeFunc, async ...bool)

订阅：一个topic可以对应多个处理器，（topic->handler 的关系是1:n）,一次添加一个订阅者

func (*GoEvent) UnSubscribe

func (ev *GoEvent) UnSubscribe(topic string)

取消订阅(topic 对应的所有订阅者)

func (*GoEvent) UnSubscribeDefault

func (ev *GoEvent) UnSubscribeDefault()

type Message

type Message struct {
	Topic string
	Data  interface{}
}

type MessageChan

type MessageChan chan Message

type SubscribeFunc

type SubscribeFunc func(msg Message)