Skip to content

[PGSCHED] replacing protobuf object columns of the PGSCHED DB tables by appropriate DB structure

After removal of the compiled protobuf file rowblobs.proto from the code #582 (closed), the related DB fields (names as *_pb) need to be replaced by appropriate DB structure to contain this information.

The ArchiveJobFailLogs were already replaces by 2 TEXT fields in the archive_job_queue table, others will follow. The DB structure design related to the archival queue is being followed in #603 (closed).

The file contained the following info:

syntax = "proto3";
package cta.postgresscheddb.blobser;

enum RetrieveJobStatus {
  RJS_ToTransfer = 0;
  RJS_ToReportToUserForFailure = 1;
  RJS_Failed = 2;
  RJS_ToReportToRepackForSuccess = 3;
  RJS_ToReportToRepackForFailure = 4;
}

message TapeFile {
  string vid = 1;
  uint64 fseq = 2;
  uint64 blockid = 3;
  uint64 filesize = 4;
  uint32 copynb = 5;
  uint64 creationtime = 6;
  bytes checksumblob = 7;
}

message RetrieveJob {
  uint32 copynb = 1;
  uint32 maxtotalretries = 2;
  uint32 maxretrieswithinmount = 3;
  uint32 retrieswithinmount = 4;
  uint32 totalretries = 5;
  RetrieveJobStatus status = 6;
  uint64 lastmountwithfailure = 7;
  repeated string failurelogs = 8;
  uint32 maxreportretries = 9;
  uint32 totalreportretries = 10;
  TapeFile tapefile = 11;
  repeated string reportfailurelogs = 12;
  bool isfailed = 13;
}

message RetrieveJobs {
  repeated RetrieveJob jobs = 1;
}

message RetrieveRequestArchiveRoute {
  uint32 copynb = 1;
  string tapepool = 2;
}

message RetrieveRequestRepackInfo {
  repeated RetrieveRequestArchiveRoute archive_routes = 1;
  repeated uint32 copy_nbs_to_rearchive = 2;
  string file_buffer_url = 3;
  uint64 fseq = 4;
  bool has_user_provided_file = 5;
}


/* This was already moved to 2 columns of type TEXT in the ARCHIVE_JOB_QUEUE

message ArchiveJobFailLogs {
  repeated string failurelogs = 1;
  repeated string reportfailurelogs = 2;
}
*/


message RepackSubRequestPointer {
  string address = 1;
  uint64 fseq = 2;
  bool retrieve_accounted = 3;
  repeated uint32 archive_copynb_accounted = 4;
  bool subrequest_deleted = 5;
}

message RepackDestinationInfo {
  string vid = 1;
  uint64 files = 2;
  uint64 bytes = 3;
}

message RepackSubRequestPointers {
  repeated RepackSubRequestPointer reqs = 1;
}

message RepackDestinationInfos {
  repeated RepackDestinationInfo infos = 1;
}
Edited by Jaroslav Guenther