human readable time info about streams

1 files changed, 4 insertions, 0 deletions

diff --git a/pkg/server/hook/proxy.go b/pkg/server/hook/proxy.go
index 7da4c4a..ca8e3c8 100644
--- a/pkg/server/hook/proxy.go
+++ b/pkg/server/hook/proxy.go
@@ -24,6 +24,7 @@ type proxy struct {
 	addr string
 	auth string
 	c    chan bool
+	env  env.Env
 }
 
 func (p *proxy) Send(rq, wq queue.Q) error {
@@ -42,6 +43,8 @@ func (p *proxy) Send(rq, wq queue.Q) error {
 		return nil
 	}
 
+	p.env.Push("info", "-> " + p.addr)
+
 	return queue.Copy(rq, wq)
 }
 
@@ -74,6 +77,7 @@ func (h *proxyHook) Open(env env.Env) (interface{}, error) {
 		addr: addr,
 		auth: h.auth,
 		c:    make(chan bool),
+		env:  env,
 	}
 
 	if p.auth == "" {