From c54555759832d422b0a3521fc93f6425e8d35331 Mon Sep 17 00:00:00 2001 From: karitra Date: Thu, 25 Jan 2018 15:19:50 +0300 Subject: [PATCH] test: QueryMetrics, WriteMessage stubs --- isolate/d_test.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/isolate/d_test.go b/isolate/d_test.go index 66a15e5..4f7ce0f 100644 --- a/isolate/d_test.go +++ b/isolate/d_test.go @@ -36,6 +36,10 @@ func (t *testDownstream) Write(ctx context.Context, code uint64, data []byte) er return nil } +func (t *testDownstream) WriteMessage(ctx context.Context, num uint64, packedPayload []byte) error { + return nil +} + func (t *testDownstream) Error(ctx context.Context, code uint64, errorcode [2]int, msg string) error { t.ch <- testDownstreamItem{code, []interface{}{errorcode, msg}} return nil @@ -72,6 +76,10 @@ func (b *testBox) Close() error { return nil } +func (b *testBox) QueryMetrics(uuids []string) (response []MarkedWorkerMetrics) { + return +} + type testProcess struct { ctx context.Context killed chan struct{}