bus

Documentation

Index

• func Publish(ev *Event)
• func Subscribe(topic string, queue string, h Handler) error
• func SubscribeWithExpire(topic string, queue string, expire time.Duration, h Handler) error
• func Unsubscribe(topic string, queue string)
• type Event
  • func NewEvent(flag string, topic string, data interface{}, params interface{}) *Event
• type Handler
• type Subscriber

Functions

func Publish

func Publish(ev *Event)

Publish 发布事件

func Subscribe

func Subscribe(topic string, queue string, h Handler) error

Subscribe 订阅事件

func SubscribeWithExpire

func SubscribeWithExpire(topic string, queue string, expire time.Duration, h Handler) error

func Unsubscribe

func Unsubscribe(topic string, queue string)

Unsubscribe 取消订阅

Types

type Event

type Event struct {
	Flag    string      `json:"flag,omitempty"`
	Topic   string      `json:"topic,omitempty"`
	Message interface{} `json:"message,omitempty"`
	Params  interface{} `json:"params,omitempty"`
	Queue   string      `json:"queue,omitempty"`
	// contains filtered or unexported fields
}

Event is given to a subscription handler for processing

func NewEvent

func NewEvent(flag string, topic string, data interface{}, params interface{}) *Event

type Handler

type Handler func(*Event) error

Handler is used to process messages via a subscription of a topic. The handler is passed a publication interface which contains the message and optional Ack method to acknowledge receipt of the message.

type Subscriber

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

Subscriber 订阅者