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 ¶
InitializeApi starts background goroutines for REST API processes. Use context cancellation to stop them.
func InitializeStats ¶
InitializeStats starts background goroutines for the statuser process. Use context cancellation to stop it.
func InitializeWorker ¶
InitializeWorker starts background goroutines for worker processes. Use context cancellation to stop them.
Types ¶
This section is empty.