producers

Documentation

Index

• type JetStreamPublisher
• type SyncAPI
  • func NewSyncAPI(db storage.Database, js JetStreamPublisher, clientDataTopic string, ...) *SyncAPI
  • func (p *SyncAPI) GetAndSendNotificationData(ctx context.Context, userID, roomID string) error
  • func (p *SyncAPI) SendAccountData(userID string, roomID string, dataType string) error

Types

type JetStreamPublisher

type JetStreamPublisher interface {
	PublishMsg(*nats.Msg, ...nats.PubOpt) (*nats.PubAck, error)
}

type SyncAPI

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

SyncAPI produces messages for the Sync API server to consume.

func NewSyncAPI

func NewSyncAPI(db storage.Database, js JetStreamPublisher, clientDataTopic string, notificationDataTopic string) *SyncAPI

func (*SyncAPI) GetAndSendNotificationData

func (p *SyncAPI) GetAndSendNotificationData(ctx context.Context, userID, roomID string) error

GetAndSendNotificationData reads the database and sends data about unread notifications to the Sync API server.

func (*SyncAPI) SendAccountData

func (p *SyncAPI) SendAccountData(userID string, roomID string, dataType string) error

SendAccountData sends account data to the Sync API server.