mirror of
https://github.com/flavioribeiro/donut.git
synced 2025-10-05 15:06:51 +08:00
wrapping properly errors
This commit is contained in:
@@ -32,12 +32,12 @@ func NewDonutEngineController(p DonutEngineParams) *DonutEngineController {
|
|||||||
func (c *DonutEngineController) EngineFor(req *entities.RequestParams) (DonutEngine, error) {
|
func (c *DonutEngineController) EngineFor(req *entities.RequestParams) (DonutEngine, error) {
|
||||||
prober := c.selectProberFor(req)
|
prober := c.selectProberFor(req)
|
||||||
if prober == nil {
|
if prober == nil {
|
||||||
return nil, fmt.Errorf("request %v: not fulfilled error %v", req, entities.ErrMissingProber)
|
return nil, fmt.Errorf("request %v: not fulfilled error %w", req, entities.ErrMissingProber)
|
||||||
}
|
}
|
||||||
|
|
||||||
streamer := c.selectStreamerFor(req)
|
streamer := c.selectStreamerFor(req)
|
||||||
if prober == nil {
|
if prober == nil {
|
||||||
return nil, fmt.Errorf("request %v: not fulfilled error %v", req, entities.ErrMissingStreamer)
|
return nil, fmt.Errorf("request %v: not fulfilled error %w", req, entities.ErrMissingStreamer)
|
||||||
}
|
}
|
||||||
|
|
||||||
return &donutEngine{
|
return &donutEngine{
|
||||||
|
Reference in New Issue
Block a user