refresh

package

v0.0.2 Latest Latest Go to latest Published: Nov 8, 2022 License: MIT Imports: 6 Imported by: 0

Details

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.