mirror of
https://github.com/openziti/ziti.git
synced 2026-10-13 23:59:53 +00:00
go fmt ./...
This commit is contained in:
@@ -23,8 +23,8 @@ import (
|
||||
)
|
||||
|
||||
type closeHandler struct {
|
||||
r *network.Router
|
||||
network *network.Network
|
||||
r *network.Router
|
||||
network *network.Network
|
||||
}
|
||||
|
||||
func newCloseHandler(r *network.Router, network *network.Network) *closeHandler {
|
||||
@@ -48,4 +48,4 @@ func newXctrlCloseHandler(done chan struct{}) channel2.CloseHandler {
|
||||
func (h *xctrlCloseHandler) HandleClose(ch channel2.Channel) {
|
||||
pfxlog.ContextLogger(ch.Label()).Info("closing Xctrl instances")
|
||||
close(h.done)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -57,8 +57,8 @@ func (h *inspectHandler) HandleReceive(request *channel2.Message, ch channel2.Ch
|
||||
h.respond(ch, request, response)
|
||||
}
|
||||
|
||||
func (h *inspectHandler) respondWithError(ch channel2.Channel, request *channel2.Message, errs...string) {
|
||||
response := &ctrl_pb.InspectResponse{Success: false, Errors: errs }
|
||||
func (h *inspectHandler) respondWithError(ch channel2.Channel, request *channel2.Message, errs ...string) {
|
||||
response := &ctrl_pb.InspectResponse{Success: false, Errors: errs}
|
||||
h.respond(ch, request, response)
|
||||
}
|
||||
|
||||
|
||||
@@ -44,4 +44,4 @@ func (h *metricsHandler) HandleReceive(msg *channel2.Message, ch channel2.Channe
|
||||
} else {
|
||||
pfxlog.ContextLogger(ch.Label()).Errorf("unexpected error (%s)", err)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user