hevent

package

v1.0.0 Latest Latest Go to latest Published: Jan 5, 2022 License: Apache-2.0 Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type HEvent struct {
	Data  interface{}
	Topic string
}

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

func HEventSrv() *HEventBus

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

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

type HEventData chan HEvent

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

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