diff options
| author | Paul Buetow <paul@buetow.org> | 2021-10-31 17:23:34 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2021-10-31 17:23:34 +0200 |
| commit | 2dbfcfc56ecf564cf301e1479522f83d6ca0c966 (patch) | |
| tree | 8151f9d6666f558719a096368e1ab686d0fbfad1 /internal/server/handlers/readcommand.go | |
| parent | 1d33bfc81a975923f0ac4947f9f73d327cdf2aa1 (diff) | |
add dmap integration test with stdin input pipe
Diffstat (limited to 'internal/server/handlers/readcommand.go')
| -rw-r--r-- | internal/server/handlers/readcommand.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/internal/server/handlers/readcommand.go b/internal/server/handlers/readcommand.go index bd536de..6d1b55a 100644 --- a/internal/server/handlers/readcommand.go +++ b/internal/server/handlers/readcommand.go @@ -50,8 +50,9 @@ func (r *readCommand) Start(ctx context.Context, ltx lcontext.LContext, // In serverless mode, can also read data from pipe // e.g.: grep foo bar.log | dmap 'from STATS select ...' if r.isInputFromPipe() { - dlog.Server.Debug("Reading data from pipe") - r.read(ctx, ltx, "PIPE", "PIPE", re) + dlog.Server.Debug("Reading data from stdin pipe") + // Empty file path and globID "-" represents reading from the stdin pipe. + r.read(ctx, ltx, "", "-", re) return } |