fixed context in gRPC code

This commit is contained in:
Krishna Upadhyaya 2022-07-27 19:07:48 +05:30
parent 00c2b3329c
commit f55f816351
3 changed files with 4 additions and 4 deletions

View file

@ -11,7 +11,7 @@ import (
) )
func (h *HeimdallGRPCClient) FetchCheckpointCount(ctx context.Context) (int64, error) { func (h *HeimdallGRPCClient) FetchCheckpointCount(ctx context.Context) (int64, error) {
res, err := h.client.FetchCheckpointCount(context.Background(), nil) res, err := h.client.FetchCheckpointCount(ctx, nil)
if err != nil { if err != nil {
return 0, err return 0, err
} }
@ -24,7 +24,7 @@ func (h *HeimdallGRPCClient) FetchCheckpoint(ctx context.Context, number int64)
ID: number, ID: number,
} }
res, err := h.client.FetchCheckpoint(context.Background(), req) res, err := h.client.FetchCheckpoint(ctx, req)
if err != nil { if err != nil {
return nil, err return nil, err
} }

View file

@ -15,7 +15,7 @@ func (h *HeimdallGRPCClient) Span(ctx context.Context, spanID uint64) (*span.Hei
ID: spanID, ID: spanID,
} }
res, err := h.client.Span(context.Background(), req) res, err := h.client.Span(ctx, req)
if err != nil { if err != nil {
return nil, err return nil, err
} }

View file

@ -18,7 +18,7 @@ func (h *HeimdallGRPCClient) StateSyncEvents(ctx context.Context, fromID uint64,
Limit: uint64(stateFetchLimit), Limit: uint64(stateFetchLimit),
} }
res, err := h.client.StateSyncEvents(context.Background(), req) res, err := h.client.StateSyncEvents(ctx, req)
if err != nil { if err != nil {
return nil, err return nil, err
} }