pcm-slurm/pb/slurm.proto

syntax = "proto3";

package slurm;
option go_package = "/slurm";

import "common.proto";
import "node.proto";
import "job.proto";
import "user.proto";
import "tres.proto";
import "association.proto";
import "partition.proto";
import "reservation.proto";
import "qos.proto";
import "account.proto";
import "cluster.proto";
import "wckey.proto";
import "configuration.proto";
import "diagnostics.proto";
import "ping.proto";

//token
  //syncToken
  message syncTokenReq {
  }
  message syncTokenResp {
  }

//job
  //listJob
  message listJobReq{
    uint32 update_time = 1;
  }
  message listJobResp{
    repeated error                   errors = 1;
    repeated job_response_properties jobs   = 2;
  }
  //updateJob
  message updateJobReq{
    job_update job_update = 1;
  }
  message updateJobResp{
  }
  //cancelJob
  message cancelJobReq{
    string job_id = 1;
  }
  message cancelJobResp{
  }
  //getJob
  message getJobReq{
    string job_id = 1;
  }
  message getJobResp{
    Jobs jobs = 1;
  }
  //submitJob
  message submitJobReq{
    string                  script = 1;
    job_properties          job    = 2;
    repeated job_properties jobs   = 3;
  }
  message submitJobResp{
    repeated error errors              = 1;
    uint32         job_id              = 2;
    string         step_id             = 3;
    string         job_submit_user_msg = 4;
  }


//user
  //listUser
  message listUserReq{
  }
  message listUserResp{
    repeated error errors = 1;
    repeated user  users   = 2;
  }
  //getUser
  message getUserReq{
    string user_name = 1;
  }
  message getUserResp{
    repeated error errors = 1;
    repeated user  users   = 2;
  }
  //updateUser
  message updateUserReq{
    user user = 1;
  }
  message updateUserResp{
    repeated error errors = 1;
  }
  //deleteUser
  message deleteUserReq{
    string user_name = 1;
  }
  message deleteUserResp{
    repeated error errors = 1;
  }
//partition
//listPartition
  message listPartitionReq{
  }
  message listPartitionResp{
    repeated error errors = 1;
    repeated partition  partitions   = 2;
  }
  //getPartition
  message getPartitionReq{
    string partition_name = 1;
  }
  message getPartitionResp{
    repeated error errors = 1;
    repeated partition  partitions   = 2;
  }
//node
  //getNode
  message getNodeReq{
      string node_name = 1;
  }
  message getNodeResp{
    repeated error errors = 1;
    repeated node  nodes   = 2;
  }
  //listNode
  message listNodeReq{
  }
  message listNodeResp{
    repeated error errors = 1;
    repeated node  nodes   = 2;
  }


//reservation
  //getReservation
  message getReservationReq{
    string reservation_name = 1;
  }
  message getReservationResp{
    repeated error errors = 1;
    repeated reservation  reservations   = 2;
  }
  //listReservation
  message listReservationReq{
  }
  message listReservationResp{
    repeated error errors = 1;
    repeated reservation  reservations   = 2;
  }

//configuration
    message dumpConfigurationReq{
    }
    message dumpConfigurationResp{
      repeated configuration configurations = 1;
    }
    message loadConfigurationReq{
      configuration configuration = 1;
    }
    message loadConfigurationResp{
      repeated error errors = 1;
    }
//QOS
    message listQosReq{
    }
    message listQosResp{
      repeated qos Qos = 1;
    }
    message getQosReq{
    }
    message getQosResp{
      repeated qos qos = 1;
    }
    message deleteQosReq{
      qos qos = 1;
    }
    message deleteQosResp{
    }
//TRES
    message listTresReq{
    }
    message listTresResp{
      repeated tres tres = 1;
    }
    message setTresReq{
      tres tres = 1;
    }
    message setTresResp{
    }
//account
    //listAccount
    message listAccountReq{
    }
    message listAccountResp{
      repeated error errors = 1;
      repeated account  accounts   = 2;
    }
    //getAccount
    message getAccountReq{
      string user_name = 1;
    }
    message getAccountResp{
      repeated error errors = 1;
      repeated account  accounts   = 2;
    }
    //updateAccount
    message updateAccountReq{
      account account = 1;
    }
    message updateAccountResp{
      repeated error errors = 1;
    }
    //deleteAccount
    message deleteAccountReq{
      string account_name = 1;
    }
    message deleteAccountResp{
      repeated error errors = 1;
    }
//cluster
    message listClusterReq{
    }
    message listClusterResp{
      repeated cluster clusters = 1;
    }
    message addClusterReq{
      cluster cluster = 1;
    }
    message addClusterResp{
    }
    message getClusterReq{
    }
    message getClusterResp{
      repeated cluster clusters = 1;
    }
    message deleteClusterReq{
      cluster cluster = 1;
    }
    message deleteClusterResp{
    }
//wckey
    message listWckeyReq{
    }
    message listWckeyResp{
      repeated wckey wckeys = 1;
    }
    message addWckeyReq{
      wckey wckey = 1;
    }
    message addWckeyResp{
    }
    message getWckeyReq{
    }
    message getWckeyResp{
      repeated wckey wckeys = 1;
    }
    message deleteWckeyReq{
      wckey wckey = 1;
    }
    message deleteWckeyResp{
    }
//diagnostics
    message listDiagnosticsReq{
    }
    message listDiagnosticsResp{
      repeated diagnostics diagnosticses = 1;
    }
    message listDbDiagnosticsReq{
    }
    message listDbDiagnosticsResp{
      repeated diagnostics_db diagnostics_dbs = 1;
    }
//association
  message listAssociationReq{
  }
  message listAssociationResp{
    repeated association Association = 1;
  }
  message setAssociationReq{
    association association = 1;
  }
  message setAssociationResp{
  }
  message getAssociationReq{
  }
  message getAssociationResp{
    repeated association association = 1;
  }
  message deleteAssociationReq{
    association association = 1;
  }
  message deleteAssociationResp{
  }

//ping
  message errorPing{
    string description  = 1;
    int32 error_number = 2;
    string error = 3;
    string source = 4;
  }
  message pingReq{
  }
  message pingResp{
    meta meta = 1;
    repeated errorPing errors = 2;
    repeated ping pings = 3;
  }

service slurm {
  rpc syncToken(syncTokenReq) returns (syncTokenResp) {};

  rpc ping(pingReq) returns (pingResp) {};

  rpc listJob(listJobReq) returns (listJobResp) {};
  rpc getJob(getJobReq) returns (getJobResp) {};
  rpc updateJob(updateJobReq) returns (updateJobResp) {};
  rpc cancelJob(cancelJobReq) returns (cancelJobResp) {};
  rpc submitJob(submitJobReq) returns (submitJobResp) {};

  rpc listUser(listUserReq) returns (listUserResp) {};
  rpc getUser(getUserReq) returns (getUserResp) {};
  rpc updateUser(updateUserReq) returns (updateUserResp) {};
  rpc deleteUser(deleteUserReq) returns (deleteUserResp) {};

  rpc listPartition(listPartitionReq) returns (listPartitionResp) {};
  rpc getPartition(getPartitionReq) returns (getPartitionResp) {};


  rpc listNode(listNodeReq) returns (listNodeResp) {};
  rpc getNode(getNodeReq) returns (getNodeResp) {};

  rpc listReservation(listReservationReq) returns (listReservationResp) {};
  rpc getReservation(getReservationReq) returns (getReservationResp) {};

  rpc loadConfiguration(loadConfigurationReq) returns (loadConfigurationResp) {};
  rpc dumpConfiguration(dumpConfigurationReq) returns (dumpConfigurationResp) {};

  rpc listQos(listQosReq) returns (listQosResp) {};
  rpc getQos(getQosReq) returns (getQosResp) {};
  rpc deleteQos(deleteQosReq) returns (deleteQosResp) {};

  rpc listTres(listTresReq) returns (listTresResp) {};
  rpc setTres(setTresReq) returns (setTresResp) {};

  rpc listAccount(listAccountReq) returns (listAccountResp) {};
  rpc getAccount(getAccountReq) returns (getAccountResp) {};
  rpc updateAccount(updateAccountReq) returns (updateAccountResp) {};
  rpc deleteAccount(deleteAccountReq) returns (deleteAccountResp) {};

  rpc listCluster(listClusterReq) returns (listClusterResp) {};
  rpc getCluster(getClusterReq) returns (getClusterResp) {};
  rpc addCluster(addClusterReq) returns (addClusterResp) {};
  rpc deleteCluster(deleteClusterReq) returns (deleteClusterResp) {};

  rpc listWckey(listWckeyReq) returns (listWckeyResp) {};
  rpc getWckey(getWckeyReq) returns (getWckeyResp) {};
  rpc addWckey(addWckeyReq) returns (addWckeyResp) {};
  rpc deleteWckey(deleteWckeyReq) returns (deleteWckeyResp) {};

  rpc listAssociation(listAssociationReq) returns (listAssociationResp) {};
  rpc getAssociation(getAssociationReq) returns (getAssociationResp) {};
  rpc setAssociation(setAssociationReq) returns (setAssociationResp) {};
  rpc deleteAssociation(deleteAssociationReq) returns (deleteAssociationResp) {};

  rpc getDiagnostics(listDiagnosticsReq) returns (listDiagnosticsResp) {};
  rpc getDbDiagnostics(listDbDiagnosticsReq) returns (listDbDiagnosticsResp) {};
}