workers

Documentation

Index

• func SetupTransactionWorkers(appserviceDB storage.Database, ...) error

Functions

func SetupTransactionWorkers

func SetupTransactionWorkers(
	appserviceDB storage.Database,
	workerStates []types.ApplicationServiceWorkerState,
) error

SetupTransactionWorkers spawns a separate goroutine for each application service. Each of these "workers" handle taking all events intended for their app service, batch them up into a single transaction (up to a max transaction size), then send that off to the AS's /transactions/{txnID} endpoint. It also handles exponentially backing off in case the AS isn't currently available.