amigan/stillbox
1
1
Fork 0
Code Issues 33 Pull requests Projects Releases Packages Wiki Activity Actions

use new ctx

Browse source
This commit is contained in:
Daniel Ponte 2024-08-04 15:29:07 -04:00
parent 0e82b8a363
commit 3f11a70e8e
1 changed files with 1 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
pkg/gordio/server/ingest.go
View file

@ -4,13 +4,8 @@ import (
"context" "context"
"dynatron.me/x/stillbox/pkg/gordio/calls" "dynatron.me/x/stillbox/pkg/gordio/calls"
"dynatron.me/x/stillbox/pkg/gordio/database"
) )
func (s *Server) Ingest(ctx context.Context, call *calls.Call) { func (s *Server) Ingest(ctx context.Context, call *calls.Call) {
// decouple this context from the one we call sinks with s.sinks.EmitCall(context.Background(), call)
db := database.FromCtx(ctx)
nctx := database.CtxWithDB(context.Background(), db)
s.sinks.EmitCall(nctx, call)
} }