kafka

Documentation

Index

• type ErrorNotifierKafka
  • func New(ctx context.Context, log log.Log, serviceName string, topic string, ...) *ErrorNotifierKafka
  • func (e *ErrorNotifierKafka) Send4XX(ctx context.Context, errorCode string, err error, stackTrace string, ...) error
  • func (e *ErrorNotifierKafka) Send5XX(ctx context.Context, errorCode string, err error, stackTrace string, ...) error

Types

type ErrorNotifierKafka

type ErrorNotifierKafka struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, log log.Log, serviceName string, topic string, producer *kafka.Producer) *ErrorNotifierKafka

func (*ErrorNotifierKafka) Send4XX

func (e *ErrorNotifierKafka) Send4XX(ctx context.Context, errorCode string, err error, stackTrace string, errorData interface{}) error

func (*ErrorNotifierKafka) Send5XX

func (e *ErrorNotifierKafka) Send5XX(ctx context.Context, errorCode string, err error, stackTrace string, errorData interface{}) error