flip/convox
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/convox.git synced 2026-02-06 10:56:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

gcp: implement logs --no-follow (#47)

Browse Source
This commit is contained in:
David Dollar 2019-12-10 16:29:30 -05:00 committed by GitHub
parent dbeb8e4163
commit 7f5380ea77
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
provider/gcp/log.go
View File

@ -15,6 +15,10 @@ import (
"google.golang.org/api/iterator"
)
const (
logTimeFormat = "2006-01-02T15:04:05.999999999Z"
)
var sequenceTokens sync.Map
func (p *Provider) Log(app, stream string, ts time.Time, message string) error {
@ -58,10 +62,19 @@ func (p *Provider) logFilter(ctx context.Context, w io.WriteCloser, filter strin
since = time.Now().UTC().Add(-1 * *opts.Since)
}
now := time.Now().UTC()
follow := common.DefaultBool(opts.Follow, true)
Iteration:
for {
it := p.LogAdmin.Entries(ctx, logadmin.Filter(fmt.Sprintf("%s AND timestamp > %q", filter, since.Format("2006-01-02T15:04:05.999999999Z"))))
where := fmt.Sprintf("%s AND timestamp > %q", filter, since.Format(logTimeFormat))
if !follow {
where = fmt.Sprintf("%s AND timestamp < %q", where, now.Format(logTimeFormat))
}
it := p.LogAdmin.Entries(ctx, logadmin.Filter(where))
for {
// check for closed writer
@ -75,6 +88,9 @@ Iteration:
default:
entry, err := it.Next()
if err == iterator.Done {
if !follow {
return
}
time.Sleep(2 * time.Second)
continue Iteration
}