Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrorReporter ¶
ErrorReporter is the interface that wraps the Notify method. ID and errContent are required parameters. If neither is provided or there is any error while attempting to report the event then an error is returned which the caller can handle as they see fit.
type ImportErrorReporter ¶
type ImportErrorReporter struct {
// contains filtered or unexported fields
}
ImportErrorReporter a reporter for sending error reports to the import-reporter
func NewImportErrorReporter ¶
func NewImportErrorReporter(kafkaProducer KafkaProducer, serviceName string) (ImportErrorReporter, error)
NewImportErrorReporter create a new ImportErrorReporter to send error reports to the import-reporter
func (ImportErrorReporter) Notify ¶
func (c ImportErrorReporter) Notify(id string, errContext string, err error) error
Notify send an error report to the import-reporter ID and errContent are required parameters. If neither is provided or there is any error while attempting to report the event then an error is returned which the caller can handle as they see fit.
type KafkaProducer ¶
type KafkaProducer interface {
Channels() *kafka.ProducerChannels
}
KafkaProducer interface of the dp-kafka kafka.Producer
Source Files
Directories