Skip to content

Commit

Permalink
Fix
Browse files Browse the repository at this point in the history
  • Loading branch information
trueleo committed Oct 16, 2023
1 parent 6218ce5 commit c4247b6
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 235 deletions.
16 changes: 6 additions & 10 deletions cmd/tail.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import (
"encoding/base64"
"encoding/json"
"fmt"

"pb/pkg/config"

"github.com/apache/arrow/go/v13/arrow/array"
Expand Down Expand Up @@ -56,17 +55,14 @@ func tail(profile config.Profile, stream string) error {
defer records.Release()

for {
if records.Next() {
record, err := records.Read()
if err != nil {
return err
}
var buf bytes.Buffer
array.RecordToJSON(record, &buf)
fmt.Println(buf.String())
record, err := records.Read()
if err != nil {
return err
}
var buf bytes.Buffer
array.RecordToJSON(record, &buf)
fmt.Println(buf.String())
}
return nil
}

func basicAuth(username, password string) string {
Expand Down
10 changes: 1 addition & 9 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ module pb
go 1.20

require (
github.com/apache/arrow/go/v12 v12.0.1
github.com/apache/arrow/go/v13 v13.0.0
github.com/charmbracelet/bubbles v0.16.1
github.com/charmbracelet/bubbletea v0.24.2
github.com/dustin/go-humanize v1.0.1
Expand All @@ -13,19 +13,12 @@ require (
)

require (
github.com/andybalholm/brotli v1.0.4 // indirect
github.com/apache/arrow/go/v13 v13.0.0 // indirect
github.com/apache/thrift v0.16.0 // indirect
github.com/goccy/go-json v0.10.0 // indirect
github.com/golang/protobuf v1.5.2 // indirect
github.com/golang/snappy v0.0.4 // indirect
github.com/google/flatbuffers v23.1.21+incompatible // indirect
github.com/inconshreveable/mousetrap v1.1.0 // indirect
github.com/klauspost/asmfmt v1.3.2 // indirect
github.com/klauspost/compress v1.15.15 // indirect
github.com/klauspost/cpuid/v2 v2.2.3 // indirect
github.com/minio/asm2plan9s v0.0.0-20200509001527-cdd76441f9d8 // indirect
github.com/minio/c2goasm v0.0.0-20190812172519-36a3d3bbc4f3 // indirect
github.com/pierrec/lz4/v4 v4.1.17 // indirect
github.com/spf13/pflag v1.0.5 // indirect
github.com/zeebo/xxh3 v1.0.2 // indirect
Expand All @@ -47,7 +40,6 @@ require (
)

require (
github.com/apache/arrow/go/arrow v0.0.0-20211112161151-bc219186db40
github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect
github.com/containerd/console v1.0.4-0.20230313162750-1ae8d489ac81 // indirect
github.com/lucasb-eyer/go-colorful v1.2.0 // indirect
Expand Down
Loading

0 comments on commit c4247b6

Please sign in to comment.