event

package

v1.0.0 Latest Latest Go to latest Published: Apr 28, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var (
	// TODO: implement distrbuted broker
	Broker broker = newMemoryBroker()
)

func Init(addr string) error

func Publish(topic string, ev interface{}) error

func Query(topic string, request, response interface{}) error

func Unsubscribe(s *Subscriber) error

type Request struct {
	Topic string
	Reply string
	Body  []byte
}

type Response struct {
	Body  []byte
	Error string
}

type Subscriber struct {
	ID    string
	Topic string
	Chan  chan []byte
	Exit  chan bool

	sync.RWMutex
	Queue [][]byte
}

func Subscribe(topic string) (*Subscriber, error)

func (s *Subscriber) Close() error

func (s *Subscriber) Next(ctx context.Context, ev interface{}) error