Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Consumer ¶
type Consumer interface {
Consume()
Status(*config.AppConfig, monitoring.MetricsI) error
// contains filtered or unexported methods
}
Consumer interface
type Producer ¶
type Producer interface {
Send(context.Context, *registryv1.Cluster) error
}
Producer interface
func NewFakeProducer ¶
func NewFakeProducer(m monitoring.MetricsI) Producer
NewFakeProducer creates a fake producer
func NewProducer ¶
func NewProducer(appConfig *config.AppConfig, m monitoring.MetricsI) Producer
NewProducer - create new message queue producer
Source Files
Click to show internal directories.
Click to hide internal directories.