centrifugomessenger

package

v1.1.39 Latest Latest Go to latest Published: Feb 5, 2026 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func GetConnectionToken(secret string) func(http.ResponseWriter, *http.Request)

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

func New(endpoint string, enableTLS bool) *CentrifugoMessenger

func (c *CentrifugoMessenger) SendMessage(
	ctx context.Context,
	message *Message,
	recipients []string,
) error

type Message struct {
	Body any      `json:"body"`
	ID   pulid.ID `json:"id"`
	Type string   `json:"type"`
}

type TokenResponse struct {
	Token string `json:"token"`
}

Path	Synopsis
apiproto