| 112 | var _ tempopb.BackendSchedulerClient = (*mockScheduler)(nil) |
| 113 | |
| 114 | type mockScheduler struct { |
| 115 | grpc_health_v1.HealthClient |
| 116 | // next mock to be overridden in test scenarios if needed |
| 117 | next func(ctx context.Context, in *tempopb.NextJobRequest, opts ...grpc.CallOption) (*tempopb.NextJobResponse, error) |
| 118 | // next mock to be overridden in test scenarios if needed |
| 119 | updateJob func(ctx context.Context, in *tempopb.UpdateJobStatusRequest, opts ...grpc.CallOption) (*tempopb.UpdateJobStatusResponse, error) |
| 120 | } |
| 121 | |
| 122 | func (i *mockScheduler) Next(ctx context.Context, req *tempopb.NextJobRequest, _ ...grpc.CallOption) (*tempopb.NextJobResponse, error) { |
| 123 | return i.next(ctx, req) |
nothing calls this directly
no outgoing calls
no test coverage detected