@@ -71,16 +71,16 @@ type discoveryMessage struct {
7171func (msg discoveryMessage ) String () string {
7272 s := fmt .Sprintf ("type: %s" , msg .EventType )
7373 if msg .Message != "" {
74- s = fmt .Sprintf ("% s, message: %s" , s , msg .Message )
74+ s = fmt .Sprintf (tr ( "%[1] s, message: %[2]s" ) , s , msg .Message )
7575 }
7676 if msg .ProtocolVersion != 0 {
77- s = fmt .Sprintf ("% s, protocol version: %d" , s , msg .ProtocolVersion )
77+ s = fmt .Sprintf (tr ( "%[1] s, protocol version: %[2]d" ) , s , msg .ProtocolVersion )
7878 }
7979 if len (msg .Ports ) > 0 {
80- s = fmt .Sprintf ("% s, ports: %s" , s , msg .Ports )
80+ s = fmt .Sprintf (tr ( "%[1] s, ports: %[2]s" ) , s , msg .Ports )
8181 }
8282 if msg .Port != nil {
83- s = fmt .Sprintf ("% s, port: %s" , s , msg .Port )
83+ s = fmt .Sprintf (tr ( "%[1] s, port: %[2]s" ) , s , msg .Port )
8484 }
8585 return s
8686}
@@ -225,7 +225,7 @@ func (disc *PluggableDiscovery) waitMessage(timeout time.Duration) (*discoveryMe
225225 }
226226 return msg , nil
227227 case <- time .After (timeout ):
228- return nil , fmt .Errorf ("timeout waiting for message from %s" , disc .id )
228+ return nil , fmt .Errorf (tr ( "timeout waiting for message from %s" ) , disc .id )
229229 }
230230}
231231
@@ -294,7 +294,7 @@ func (disc *PluggableDiscovery) Run() (err error) {
294294 return err
295295 }
296296 if msg , err := disc .waitMessage (time .Second * 10 ); err != nil {
297- return fmt .Errorf ("calling HELLO : %w " , err )
297+ return fmt .Errorf (tr ( "calling %[1]s : %[2]w" ), "HELLO " , err )
298298 } else if msg .EventType != "hello" {
299299 return errors .Errorf (tr ("communication out of sync, expected 'hello', received '%s'" ), msg .EventType )
300300 } else if msg .Message != "OK" || msg .Error {
@@ -315,7 +315,7 @@ func (disc *PluggableDiscovery) Start() error {
315315 return err
316316 }
317317 if msg , err := disc .waitMessage (time .Second * 10 ); err != nil {
318- return fmt .Errorf ("calling START : %w " , err )
318+ return fmt .Errorf (tr ( "calling %[1]s : %[2]w" ), "START " , err )
319319 } else if msg .EventType != "start" {
320320 return errors .Errorf (tr ("communication out of sync, expected 'start', received '%s'" ), msg .EventType )
321321 } else if msg .Message != "OK" || msg .Error {
@@ -335,7 +335,7 @@ func (disc *PluggableDiscovery) Stop() error {
335335 return err
336336 }
337337 if msg , err := disc .waitMessage (time .Second * 10 ); err != nil {
338- return fmt .Errorf ("calling STOP : %w " , err )
338+ return fmt .Errorf (tr ( "calling %[1]s : %[2]w" ), "STOP " , err )
339339 } else if msg .EventType != "stop" {
340340 return errors .Errorf (tr ("communication out of sync, expected 'stop', received '%s'" ), msg .EventType )
341341 } else if msg .Message != "OK" || msg .Error {
@@ -358,7 +358,7 @@ func (disc *PluggableDiscovery) Quit() error {
358358 return err
359359 }
360360 if msg , err := disc .waitMessage (time .Second * 10 ); err != nil {
361- return fmt .Errorf ("calling QUIT : %w " , err )
361+ return fmt .Errorf (tr ( "calling %[1]s : %[2]w" ), "QUIT " , err )
362362 } else if msg .EventType != "quit" {
363363 return errors .Errorf (tr ("communication out of sync, expected 'quit', received '%s'" ), msg .EventType )
364364 } else if msg .Message != "OK" || msg .Error {
@@ -381,7 +381,7 @@ func (disc *PluggableDiscovery) List() ([]*Port, error) {
381381 return nil , err
382382 }
383383 if msg , err := disc .waitMessage (time .Second * 10 ); err != nil {
384- return nil , fmt .Errorf ("calling LIST : %w " , err )
384+ return nil , fmt .Errorf (tr ( "calling %[1]s : %[2]w" ), "LIST " , err )
385385 } else if msg .EventType != "list" {
386386 return nil , errors .Errorf (tr ("communication out of sync, expected 'list', received '%s'" ), msg .EventType )
387387 } else if msg .Error {
@@ -404,7 +404,7 @@ func (disc *PluggableDiscovery) StartSync(size int) (<-chan *Event, error) {
404404 }
405405
406406 if msg , err := disc .waitMessage (time .Second * 10 ); err != nil {
407- return nil , fmt .Errorf ("calling START_SYNC : %w " , err )
407+ return nil , fmt .Errorf (tr ( "calling %[1]s : %[2]w" ), "START_SYNC " , err )
408408 } else if msg .EventType != "start_sync" {
409409 return nil , errors .Errorf (tr ("communication out of sync, expected 'start_sync', received '%s'" ), msg .EventType )
410410 } else if msg .Message != "OK" || msg .Error {
0 commit comments