util

Documentation

Index

• func NotifyUserCountsAsync(ctx context.Context, pgClient pushgateway.Client, localpart string, ...) error
• func StartPhoneHomeCollector(startTime time.Time, cfg *config.Dendrite, statsDB storage.Statistics)
• type PusherDevice
  • func GetPushDevices(ctx context.Context, localpart string, tweaks map[string]interface{}, ...) ([]*PusherDevice, error)

Functions

func NotifyUserCountsAsync

func NotifyUserCountsAsync(ctx context.Context, pgClient pushgateway.Client, localpart string, db storage.Database) error

NotifyUserCountsAsync sends notifications to a local user's notification destinations. Database lookups run synchronously, but a single goroutine is started when talking to the Push gateways. There is no way to know when the background goroutine has finished.

func StartPhoneHomeCollector

func StartPhoneHomeCollector(startTime time.Time, cfg *config.Dendrite, statsDB storage.Statistics)

Types

type PusherDevice

type PusherDevice struct {
	Device pushgateway.Device
	Pusher *api.Pusher
	URL    string
	Format string
}

func GetPushDevices

func GetPushDevices(ctx context.Context, localpart string, tweaks map[string]interface{}, db storage.Database) ([]*PusherDevice, error)

GetPushDevices pushes to the configured devices of a local user.