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, serverName spec.ServerName, ...) ([]*PusherDevice, error)

Functions

func NotifyUserCountsAsync

func NotifyUserCountsAsync(ctx context.Context, pgClient pushgateway.Client, localpart string, serverName spec.ServerName, db storage.UserDatabase) error

NotifyUserCountsAsync sends notifications to a local user's notification destinations. UserDatabase 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, serverName spec.ServerName, tweaks map[string]interface{}, db storage.UserDatabase) ([]*PusherDevice, error)

GetPushDevices pushes to the configured devices of a local user.