(t *testing.T, expected, actual *work.Job)
| 241 | } |
| 242 | |
| 243 | func equalJobs(t *testing.T, expected, actual *work.Job) { |
| 244 | require.Equal(t, expected.ID, actual.ID) |
| 245 | require.Equal(t, expected.CreatedTime.Unix(), actual.CreatedTime.Unix()) |
| 246 | require.Equal(t, expected.StartTime.Unix(), actual.StartTime.Unix()) |
| 247 | require.Equal(t, expected.EndTime.Unix(), actual.EndTime.Unix()) |
| 248 | require.Equal(t, expected.WorkerID, actual.WorkerID) |
| 249 | require.Equal(t, expected.Retries, actual.Retries) |
| 250 | require.Equal(t, expected.Status, actual.Status) |
| 251 | require.Equal(t, expected.Type, actual.Type) |
| 252 | require.Equal(t, expected.JobDetail, actual.JobDetail) |
| 253 | } |
| 254 | |
| 255 | func newStore(ctx context.Context, t testing.TB, tmpDir string) (storage.Store, backend.RawReader, backend.RawWriter) { |
| 256 | rr, ww, _, err := local.New(&local.Config{ |
no test coverage detected