worker

Documentation

Index

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

Functions

func GC

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

func Merge

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

func Periodic

func Periodic(
	ctx context.Context,
	ping *health.Ping,
	interval time.Duration,
	warm bool,
	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.

func System

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