chore: golines (#295)

Signed-off-by: Chris Gianelloni <[email protected]>

connmanager/outbound.go

@@ -25,7 +25,9 @@ import (
 	"go.opentelemetry.io/otel/attribute"
 )
 
-func (c *ConnectionManager) CreateOutboundConn(address string) (*ouroboros.Connection, error) {
+func (c *ConnectionManager) CreateOutboundConn(
+	address string,
+) (*ouroboros.Connection, error) {
 	t := otel.Tracer("")
 	if t != nil {
 		_, span := t.Start(context.TODO(), "create outbound connection")

node.go

@@ -104,7 +104,10 @@ func (n *Node) Run() error {
 			ConnManager: n.connManager,
 		},
 	)
-	n.eventBus.SubscribeFunc(peergov.OutboundConnectionEventType, n.handleOutboundConnEvent)
+	n.eventBus.SubscribeFunc(
+		peergov.OutboundConnectionEventType,
+		n.handleOutboundConnEvent,
+	)
 	if n.config.topologyConfig != nil {
 		n.peerGov.LoadTopologyConfig(n.config.topologyConfig)
 	}
@@ -231,7 +234,10 @@ func (n *Node) configureConnManager() error {
 		},
 	)
 	// Subscribe to connection closed events
-	n.eventBus.SubscribeFunc(connmanager.ConnectionClosedEventType, n.handleConnClosedEvent)
+	n.eventBus.SubscribeFunc(
+		connmanager.ConnectionClosedEventType,
+		n.handleConnClosedEvent,
+	)
 	// Start listeners
 	if err := n.connManager.Start(); err != nil {
 		return err
@@ -260,7 +266,11 @@ func (n *Node) handleOutboundConnEvent(evt event.Event) {
 	chainsyncClientConnId := n.chainsyncState.GetClientConnId()
 	if chainsyncClientConnId == nil {
 		if err := n.chainsyncClientStart(connId); err != nil {
-			n.config.logger.Error("failed to start chainsync client", "error", err)
+			n.config.logger.Error(
+				"failed to start chainsync client",
+				"error",
+				err,
+			)
 			return
 		}
 		n.chainsyncState.SetClientConnId(connId)

peergov/peergov.go

@@ -58,8 +58,14 @@ func NewPeerGovernor(cfg PeerGovernorConfig) *PeerGovernor {
 
 func (p *PeerGovernor) Start() error {
 	// Setup connmanager event listeners
-	p.config.EventBus.SubscribeFunc(connmanager.InboundConnectionEventType, p.handleInboundConnectionEvent)
-	p.config.EventBus.SubscribeFunc(connmanager.ConnectionClosedEventType, p.handleConnectionClosedEvent)
+	p.config.EventBus.SubscribeFunc(
+		connmanager.InboundConnectionEventType,
+		p.handleInboundConnectionEvent,
+	)
+	p.config.EventBus.SubscribeFunc(
+		connmanager.ConnectionClosedEventType,
+		p.handleConnectionClosedEvent,
+	)
 	// Start outbound connections
 	p.startOutboundConnections()
 	return nil