(m *Message)
| 1527 | } |
| 1528 | |
| 1529 | func (c *Client) send(m *Message) { |
| 1530 | defer func() { |
| 1531 | if err := recover(); err != nil { |
| 1532 | c.logger.Debug("recovered", |
| 1533 | slog.String("Topic", "Zebra"), |
| 1534 | slog.Any("Error", err), |
| 1535 | ) |
| 1536 | } |
| 1537 | }() |
| 1538 | c.logger.Debug("send command to zebra", |
| 1539 | slog.String("Topic", "Zebra"), |
| 1540 | slog.Any("Header", m.Header), |
| 1541 | slog.Any("Body", m.Body)) |
| 1542 | c.outgoing <- m |
| 1543 | } |
| 1544 | |
| 1545 | func (c *Client) sendCommand(command APIType, vrfID uint32, body Body) { |
| 1546 | m := &Message{ |