lookoutingester

Documentation

Index

• Constants
• func Run(config *configuration.LookoutIngesterConfiguration)

Constants

const (
	MigrateDatabase string = "migrateDatabase"
)

Functions

func Run

func Run(config *configuration.LookoutIngesterConfiguration)

Run will create a pipeline that will take Armada event messages from Pulsar and update the Lookout database accordingly. This pipeline will run until a SIGTERM is received