37 lines
821 B
Go
37 lines
821 B
Go
package cluster
|
|
|
|
import (
|
|
"log/slog"
|
|
|
|
"github.com/libp2p/go-libp2p/core/network"
|
|
"github.com/multiformats/go-multiaddr"
|
|
)
|
|
|
|
// notify implements network.Notifiee for connection events.
|
|
type notify struct {
|
|
cluster *Cluster
|
|
}
|
|
|
|
func (n *notify) Connected(_ network.Network, conn network.Conn) {
|
|
remotePeer := conn.RemotePeer()
|
|
|
|
slog.Info(
|
|
"peer connected",
|
|
"peer_id", remotePeer.String(),
|
|
"remote_addr", conn.RemoteMultiaddr().String(),
|
|
)
|
|
}
|
|
|
|
func (n *notify) Disconnected(_ network.Network, conn network.Conn) {
|
|
remotePeer := conn.RemotePeer()
|
|
|
|
slog.Info(
|
|
"peer disconnected",
|
|
"peer_id", remotePeer.String(),
|
|
"remote_addr", conn.RemoteMultiaddr().String(),
|
|
)
|
|
}
|
|
|
|
func (n *notify) Listen(network.Network, multiaddr.Multiaddr) {}
|
|
func (n *notify) ListenClose(network.Network, multiaddr.Multiaddr) {}
|