producers

Documentation

Index

• type SyncAPIProducer
  • func (p *SyncAPIProducer) SendData(userID string, roomID string, dataType string, ...) error

Types

type SyncAPIProducer

type SyncAPIProducer struct {
	Topic     string
	JetStream nats.JetStreamContext
}

SyncAPIProducer produces events for the sync API server to consume

func (*SyncAPIProducer) SendData

func (p *SyncAPIProducer) SendData(userID string, roomID string, dataType string, readMarker *eventutil.ReadMarkerJSON) error

SendData sends account data to the sync API server