background

package
v0.0.0-...-4263410 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 11, 2024 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Overview

Background jobs responsible for queueing batch operations (availability checks) or other operations (cleanups etc).

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EnqueueAvailabilityStatusRequest

func EnqueueAvailabilityStatusRequest(ctx context.Context, asm *kafka.AvailabilityStatusMessage) error

EnqueueAvailabilityStatusRequest prepares a status request check to be sent in the next batch to the platform kafka. Messages can be delayed up to several seconds until sent. The function can block if the enqueueing channel is full.

func InitializeApi

func InitializeApi(ctx context.Context)

InitializeApi starts background goroutines for REST API processes. Use context cancellation to stop them.

func InitializeStats

func InitializeStats(ctx context.Context)

InitializeStats starts background goroutines for the statuser process. Use context cancellation to stop it.

func InitializeWorker

func InitializeWorker(ctx context.Context)

InitializeWorker starts background goroutines for worker processes. Use context cancellation to stop them.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL