mirror of
https://github.com/weaveworks/scope.git
synced 2026-03-03 02:00:43 +00:00
type connEncoder can be function-scoped
This commit is contained in:
@@ -53,6 +53,11 @@ func (p *TCPPublisher) Publish(msg report.Report) {
|
||||
}
|
||||
|
||||
func (p *TCPPublisher) loop(incoming <-chan net.Conn) {
|
||||
type connEncoder struct {
|
||||
net.Conn
|
||||
*gob.Encoder
|
||||
}
|
||||
|
||||
activeConns := map[string]connEncoder{} // host: connEncoder
|
||||
|
||||
for {
|
||||
@@ -94,11 +99,6 @@ func (p *TCPPublisher) loop(incoming <-chan net.Conn) {
|
||||
}
|
||||
}
|
||||
|
||||
type connEncoder struct {
|
||||
net.Conn
|
||||
*gob.Encoder
|
||||
}
|
||||
|
||||
func fwd(ln net.Listener) chan net.Conn {
|
||||
c := make(chan net.Conn)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user