mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
Zach LeslieandGitHub
d2438570f9
* Initial retention job * Generate manifest * Clean up retention test * Lint * Fix work test for compaction job * Add provider package to handle the job loops * Improve nil job handling * Refactor backendscheduler to leverage provider * Generate manifest * Pick pint * Fix race in shutdown * Fix race in test * Drop spurious debug messages * Include compaction backoff when no compactions are needed * Configure the test backoff * Drop comment * Fix regression so we skip blocks which are already mentioned * Drop unused config after relocate * Leverage existing interface for HasBlocks call on compaction * Clean up config * Drop unused method * Improve retention test coverage * Clean, trace and metric the scheduler * Clean, trace and metric the compaction provider; prefer backoff over poll interval * Generate manifest, update test config reference * Fix lint * Avoid channel block for context handling * Address PR feedback
76 lines
1.7 KiB
Protocol Buffer
76 lines
1.7 KiB
Protocol Buffer
syntax = "proto3";
|
|
|
|
package tempopb;
|
|
|
|
import "github.com/gogo/protobuf/gogoproto/gogo.proto";
|
|
|
|
option (gogoproto.marshaler_all) = true;
|
|
option (gogoproto.unmarshaler_all) = true;
|
|
|
|
service BackendScheduler {
|
|
// Get next available job
|
|
rpc Next(NextJobRequest) returns (NextJobResponse) {}
|
|
|
|
// Update job status
|
|
rpc UpdateJob(UpdateJobStatusRequest) returns (UpdateJobStatusResponse) {}
|
|
}
|
|
|
|
enum JobType {
|
|
JOB_TYPE_UNSPECIFIED = 0;
|
|
JOB_TYPE_COMPACTION = 1;
|
|
JOB_TYPE_RETENTION = 2;
|
|
}
|
|
|
|
enum JobStatus {
|
|
JOB_STATUS_UNSPECIFIED = 0;
|
|
JOB_STATUS_SUCCEEDED = 1;
|
|
JOB_STATUS_FAILED = 2;
|
|
JOB_STATUS_RUNNING = 3;
|
|
}
|
|
|
|
// CompactionDetail contains fields specific to compaction jobs
|
|
message CompactionDetail {
|
|
option (gogoproto.equal) = true;
|
|
option (gogoproto.compare) = true;
|
|
|
|
repeated string input = 1; // block IDs for compaction
|
|
repeated string output = 2; // block IDs resulting from compaction
|
|
}
|
|
message RetentionDetail {
|
|
option (gogoproto.equal) = true;
|
|
option (gogoproto.compare) = true;
|
|
}
|
|
|
|
// JobDetail contains the specific details for each job type
|
|
message JobDetail {
|
|
option (gogoproto.equal) = true; // Keep equal but remove compare
|
|
|
|
string tenant = 1;
|
|
// oneof detail {
|
|
CompactionDetail compaction = 2;
|
|
RetentionDetail retention = 3;
|
|
// CleanupDetail cleanup = 4;
|
|
// }
|
|
}
|
|
|
|
message NextJobRequest {
|
|
string worker_id = 1;
|
|
}
|
|
|
|
message NextJobResponse {
|
|
string job_id = 1;
|
|
JobType type = 2;
|
|
JobDetail detail = 3 [(gogoproto.nullable) = false];
|
|
}
|
|
|
|
message UpdateJobStatusRequest {
|
|
string job_id = 1;
|
|
JobStatus status = 2;
|
|
string error = 3; // populated if status is FAILED
|
|
CompactionDetail compaction = 4;
|
|
}
|
|
|
|
message UpdateJobStatusResponse {
|
|
bool success = 1;
|
|
}
|