refresh

package

v0.1.0 Latest Latest Go to latest Published: May 21, 2023 License: MIT Imports: 6 Imported by: 0

Details

Package refresh reads config refresh notification from AMQP.

This section is empty.

This section is empty.

This section is empty.

type Refresh struct {
	C chan string // Channel C delivers applications names found in events.
	// contains filtered or unexported fields
}

Refresh holds data for worker that reads events from amqp and delivers applications found in channel `Refresh.C`.

func New(amqpURL, consumerTag string, applications []string, debug bool, engine amqpEngine) *Refresh

New spawns a Refresh worker that reads events from amqp and delivers applications found in channel `Refresh.C`.

func (r *Refresh) Close()

Close interrupts the refresh goroutine to release resources.