Method
PushBytesV2
(ctx context.Context, _ *tempopb.PushBytesRequest)
Source from the content-addressed store, hash-verified
| 87 | } |
| 88 | |
| 89 | func (s *mockService) PushBytesV2(ctx context.Context, _ *tempopb.PushBytesRequest) (*tempopb.PushResponse, error) { |
| 90 | select { |
| 91 | case <-time.After(s.apiTimeout): |
| 92 | case <-ctx.Done(): |
| 93 | return nil, ctx.Err() |
| 94 | } |
| 95 | |
| 96 | return &tempopb.PushResponse{}, nil |
| 97 | } |
| 98 | |
| 99 | func (s *mockService) SearchTags(*tempopb.SearchTagsRequest, tempopb.StreamingQuerier_SearchTagsServer) error { |
| 100 | return nil |
Callers
nothing calls this directly
Tested by
no test coverage detected