Method
PushBytes
(ctx context.Context, _ *tempopb.PushBytesRequest)
Source from the content-addressed store, hash-verified
| 77 | } |
| 78 | |
| 79 | func (s *mockService) PushBytes(ctx context.Context, _ *tempopb.PushBytesRequest) (*tempopb.PushResponse, error) { |
| 80 | select { |
| 81 | case <-time.After(s.apiTimeout): |
| 82 | case <-ctx.Done(): |
| 83 | return nil, ctx.Err() |
| 84 | } |
| 85 | |
| 86 | return &tempopb.PushResponse{}, nil |
| 87 | } |
| 88 | |
| 89 | func (s *mockService) PushBytesV2(ctx context.Context, _ *tempopb.PushBytesRequest) (*tempopb.PushResponse, error) { |
| 90 | select { |
Callers
nothing calls this directly
Tested by
no test coverage detected