push

Documentation

Index

• func CreatePublisher() pubsub.Publisher
• func CreateSubscriber() pubsub.Subscriber
• func SendPush(body types.M, where types.M, auth *rest.Auth, onPushStatusSaved func(string)) error
• type Consumer
  • func (c *Consumer) On(channel string, listener pubsub.HandlerType)
  • func (c *Consumer) Subscribe(channel string)
  • func (c *Consumer) Unsubscribe(channel string)
• type Publisher
  • func (p *Publisher) Publish(channel string, message string)

Functions

func CreatePublisher

func CreatePublisher() pubsub.Publisher

CreatePublisher ...

func CreateSubscriber

func CreateSubscriber() pubsub.Subscriber

CreateSubscriber ...

func SendPush

func SendPush(body types.M, where types.M, auth *rest.Auth, onPushStatusSaved func(string)) error

SendPush 发送推送消息

Types

type Consumer

type Consumer struct {
	pubsub.EventEmitter
	// contains filtered or unexported fields
}

Consumer ...

func (*Consumer) On

func (c *Consumer) On(channel string, listener pubsub.HandlerType)

On ...

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(channel string)

Subscribe ...

func (*Consumer) Unsubscribe

func (c *Consumer) Unsubscribe(channel string)

Unsubscribe ...

type Publisher

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

Publisher ...

func (*Publisher) Publish

func (p *Publisher) Publish(channel string, message string)

Publish ...