Versions in this module Expand all Collapse all v0 v0.8.1 May 31, 2022 v0.8.0 May 31, 2022 Changes in this version + type Auth struct + func NewAuth(url string) (*Auth, error) + func (auth *Auth) SessionID(r *http.Request) string + func (auth *Auth) UserID(r *http.Request) (string, error) v0.7.1 May 30, 2022 v0.7.0 May 30, 2022 Changes in this version + const SYSSessionSubscribed + const SYSSessionUnsubscribed + type App struct + func New(config *core.Config) *App + func (app *App) Close() + func (app *App) Listen() error + type Client struct + Client pulsar.Client + func (c *Client) Close() + func (c *Client) Send(event *ClientEvent) error + type ClientEvent struct + Data any + Metadata any + Name string + Topic *topic.TopicName + UserID string + type ClientOptions struct + Name string + Topic string + URL string + type Sender struct + func (d *Sender) Close() + type SenderOptions struct + ID string + Topic string + type SubEvent struct + Filter topic.TopicFilter + SessionId string + type Subscription struct
Go to main page