Versions in this module Expand all Collapse all v0 v0.12.1 Oct 8, 2019 v0.12.0 Sep 29, 2019 Changes in this version + type Module struct + func Init(auth *auth.Module) *Module + func (m *Module) IsEnabled() bool + func (m *Module) Publish(project, token, subject string, data interface{}) (int, error) + func (m *Module) QueueSubscribe(project, token, clientID, subject, queue string, cb model.PubsubCallback) (int, error) + func (m *Module) SetConfig(pubsub *config.Pubsub) error + func (m *Module) Subscribe(project, token, clientID, subject string, cb model.PubsubCallback) (int, error) + func (m *Module) Unsubscribe(clientID, subject string) (int, error) + func (m *Module) UnsubscribeAll(clientID string) (int, error)
Go to main page