From 2a756282a4997081a73544a9af6dc59571f0c466 Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Fri, 18 Sep 2020 22:57:52 +0300 Subject: human readable time info about streams --- pkg/server/hook/proxy.go | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'pkg/server/hook') 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 == "" { -- cgit v1.2.3-70-g09d2