reporter

Documentation

Index

• type ErrorReporter
• type ImportErrorReporter
  • func NewImportErrorReporter(kafkaProducer KafkaProducer, serviceName string) (ImportErrorReporter, error)
  • func (c ImportErrorReporter) Notify(id string, errContext string, err error) error
• type KafkaProducer

Types

type ErrorReporter

type ErrorReporter interface {
	Notify(id string, errContext string, err error) error
}

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