hevent

Documentation

Index

• type HEvent
• type HEventBus
  • func HEventSrv() *HEventBus
  • func (h *HEventBus) Push(topic string, data interface{})
  • func (h *HEventBus) Sub(topic string, ch HEventData)
• type HEventData
• type HEventDataArray
• type HEventRepo

Types

type HEvent

type HEvent struct {
	Data  interface{}
	Topic string
}

type HEventBus

type HEventBus struct {
	// contains filtered or unexported fields
}

func HEventSrv

func HEventSrv() *HEventBus

func (*HEventBus) Push

func (h *HEventBus) Push(topic string, data interface{})

func (*HEventBus) Sub

func (h *HEventBus) Sub(topic string, ch HEventData)

type HEventData

type HEventData chan HEvent

type HEventDataArray

type HEventDataArray []HEventData //一个topic 可以有多个消费者

type HEventRepo

type HEventRepo interface {
	Sub(topic string, ch HEventData)
	Push(topic string, data interface{})
}