util

Documentation

Index

• func NotifyUserCountsAsync(ctx context.Context, pgClient pushgateway.Client, localpart string, ...) error
• 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.

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.