worker

Documentation

Index

• func Periodic(ctx context.Context, ping *health.Ping, interval time.Duration, ...) func() error
• func SaveBuffers(ctx context.Context, interval time.Duration)
• func SiteCacheUpdate(ctx context.Context, interval time.Duration)

Functions

func Periodic

func Periodic(
	ctx context.Context,
	ping *health.Ping,
	interval time.Duration,
	work func(context.Context, time.Duration)) func() error

func SaveBuffers

func SaveBuffers(ctx context.Context, interval time.Duration)

SaveBuffers persists collected Entry Buffers to the timeseries storage.

func SiteCacheUpdate

func SiteCacheUpdate(ctx context.Context, interval time.Duration)

SiteCacheUpdate updates cache of active sites.