pubsub

Documentation

Index

• func Init()
• func Publish(tag string, data map[string]interface{})
• func PublishTopic(topic string, tag string, data map[string]interface{})
• func SendEvent(appId string, uid string, event string, v interface{})
• func SendTagEvent(tag string, appId string, uid string, event string, v interface{})
• type MessageCallback
• type PubSub
  • func NewPubSub(proj string, topic string, subscription string) *PubSub
  • func (p *PubSub) Publish(data interface{}) (string, error)
  • func (p *PubSub) PullMessage(callback MessageCallback, timeout time.Duration) error

Functions

func Init

func Init()

func Publish

func Publish(tag string, data map[string]interface{})

func PublishTopic

func PublishTopic(topic string, tag string, data map[string]interface{})

func SendEvent

func SendEvent(appId string, uid string, event string, v interface{})

func SendTagEvent

func SendTagEvent(tag string, appId string, uid string, event string, v interface{})

SendTagEvent the first param tag is used for filter events in a pubsub topic for a specific subscription

Types

type MessageCallback

type MessageCallback func(msg *pubsub.Message) error

type PubSub

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

func NewPubSub

func NewPubSub(proj string, topic string, subscription string) *PubSub

func (*PubSub) Publish

func (p *PubSub) Publish(data interface{}) (string, error)

Publish a message to the topic Notice: this function is synchronous, so it will block until the message is published the caller should call this function in a goroutine

func (*PubSub) PullMessage

func (p *PubSub) PullMessage(callback MessageCallback, timeout time.Duration) error

PullMessage will pull a message from the topic using synchronous method, so it will block until a message is pulled if callback function returns error, the message will not be consumed and will be pulled again callback 业务完成以后， 返回nil， 否则返回错误 一旦返回错误，在一段时间之内，消息会继续被重新推送 如果超过时间，还没有成功， 则消息会进入死信队列