allow more time for streaming message

remove unused struct

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) {

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")
 		}
 	}