Support attaching to containers in forward backend

Signed-off-by: Ben Firshman <ben@firshman.co.uk>
This commit is contained in:
Ben Firshman 2014-06-06 18:28:34 -07:00
parent 2d6548b962
commit 41f3776cf8
1 changed files with 9 additions and 4 deletions

View File

@ -46,10 +46,15 @@ type forwarder struct {
} }
func (f *forwarder) attach(ctx *beam.Message) error { func (f *forwarder) attach(ctx *beam.Message) error {
ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: f.Server}) if ctx.Args[0] == "" {
for { ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: f.Server})
time.Sleep(1 * time.Second) for {
(&beam.Object{ctx.Ret}).Log("forward: heartbeat") time.Sleep(1 * time.Second)
(&beam.Object{ctx.Ret}).Log("forward: heartbeat")
}
} else {
c := f.newContainer(ctx.Args[0])
ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: c})
} }
return nil return nil
} }