Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Consumer ¶
type Consumer interface {
Consume()
// contains filtered or unexported methods
}
Consumer interface
func NewConsumer ¶
func NewConsumer(d database.Db, m monitoring.MetricsI) Consumer
NewConsumer - creates new message queue consumer
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(m monitoring.MetricsI) Producer
NewProducer - create new message queue producer
Source Files
Click to show internal directories.
Click to hide internal directories.