| 61 | } |
| 62 | |
| 63 | type ArchiveMessageHandler struct { |
| 64 | fd net.Conn |
| 65 | uploader *WalUploader |
| 66 | } |
| 67 | |
| 68 | func (h *ArchiveMessageHandler) Handle(ctx context.Context, messageBody []byte) error { |
| 69 | walFileName := string(messageBody) |
nothing calls this directly
no outgoing calls
no test coverage detected