From 8423ccf89093ea3af9d079b33036b6657f930b6e Mon Sep 17 00:00:00 2001 From: Drew Bailey <2614075+drewbailey@users.noreply.github.com> Date: Fri, 1 Nov 2019 14:54:25 -0400 Subject: [PATCH] allow more time for streaming message remove unused struct --- api/agent.go | 4 ---- command/agent/monitor/monitor_test.go | 2 +- 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/api/agent.go b/api/agent.go index fdd5ff891..2ec8ff233 100644 --- a/api/agent.go +++ b/api/agent.go @@ -237,10 +237,6 @@ func (a *Agent) Health() (*AgentHealthResponse, error) { return nil, fmt.Errorf("unable to unmarshal response with status %d: %v", resp.StatusCode, err) } -type MonitorFrame struct { - Data []byte `json:",omitempty"` -} - // Monitor returns a channel which will receive streaming logs from the agent // Providing a non-nil stopCh can be used to close the connection and stop log streaming func (a *Agent) Monitor(stopCh <-chan struct{}, q *QueryOptions) (<-chan *StreamFrame, <-chan error) { diff --git a/command/agent/monitor/monitor_test.go b/command/agent/monitor/monitor_test.go index be7deae2c..92a8563cc 100644 --- a/command/agent/monitor/monitor_test.go +++ b/command/agent/monitor/monitor_test.go @@ -82,7 +82,7 @@ TEST: select { case <-passed: break TEST - case <-time.After(1 * time.Second): + case <-time.After(2 * time.Second): require.Fail(t, "expected to see warn dropped messages") } }