forked from JointCloud/pcm-hpc
1582 lines
57 KiB
Go
1582 lines
57 KiB
Go
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|
// versions:
|
|
// - protoc-gen-go-grpc v1.2.0
|
|
// - protoc v3.19.4
|
|
// source: slurm.proto
|
|
|
|
package slurm
|
|
|
|
import (
|
|
context "context"
|
|
grpc "google.golang.org/grpc"
|
|
codes "google.golang.org/grpc/codes"
|
|
status "google.golang.org/grpc/status"
|
|
)
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the grpc package it is being compiled against.
|
|
// Requires gRPC-Go v1.32.0 or later.
|
|
const _ = grpc.SupportPackageIsVersion7
|
|
|
|
// SlurmClient is the client API for Slurm service.
|
|
//
|
|
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
|
type SlurmClient interface {
|
|
SyncToken(ctx context.Context, in *SyncTokenReq, opts ...grpc.CallOption) (*SyncTokenResp, error)
|
|
Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingResp, error)
|
|
ListJob(ctx context.Context, in *ListJobReq, opts ...grpc.CallOption) (*ListJobResp, error)
|
|
GetJob(ctx context.Context, in *GetJobReq, opts ...grpc.CallOption) (*GetJobResp, error)
|
|
UpdateJob(ctx context.Context, in *UpdateJobReq, opts ...grpc.CallOption) (*UpdateJobResp, error)
|
|
CancelJob(ctx context.Context, in *CancelJobReq, opts ...grpc.CallOption) (*CancelJobResp, error)
|
|
SubmitJob(ctx context.Context, in *SubmitJobReq, opts ...grpc.CallOption) (*SubmitJobResp, error)
|
|
ListUser(ctx context.Context, in *ListUserReq, opts ...grpc.CallOption) (*ListUserResp, error)
|
|
GetUser(ctx context.Context, in *GetUserReq, opts ...grpc.CallOption) (*GetUserResp, error)
|
|
UpdateUser(ctx context.Context, in *UpdateUserReq, opts ...grpc.CallOption) (*UpdateUserResp, error)
|
|
DeleteUser(ctx context.Context, in *DeleteUserReq, opts ...grpc.CallOption) (*DeleteUserResp, error)
|
|
ListPartition(ctx context.Context, in *ListPartitionReq, opts ...grpc.CallOption) (*ListPartitionResp, error)
|
|
GetPartition(ctx context.Context, in *GetPartitionReq, opts ...grpc.CallOption) (*GetPartitionResp, error)
|
|
ListNode(ctx context.Context, in *ListNodeReq, opts ...grpc.CallOption) (*ListNodeResp, error)
|
|
GetNode(ctx context.Context, in *GetNodeReq, opts ...grpc.CallOption) (*GetNodeResp, error)
|
|
ListReservation(ctx context.Context, in *ListReservationReq, opts ...grpc.CallOption) (*ListReservationResp, error)
|
|
GetReservation(ctx context.Context, in *GetReservationReq, opts ...grpc.CallOption) (*GetReservationResp, error)
|
|
LoadConfiguration(ctx context.Context, in *LoadConfigurationReq, opts ...grpc.CallOption) (*LoadConfigurationResp, error)
|
|
DumpConfiguration(ctx context.Context, in *DumpConfigurationReq, opts ...grpc.CallOption) (*DumpConfigurationResp, error)
|
|
ListQos(ctx context.Context, in *ListQosReq, opts ...grpc.CallOption) (*ListQosResp, error)
|
|
GetQos(ctx context.Context, in *GetQosReq, opts ...grpc.CallOption) (*GetQosResp, error)
|
|
DeleteQos(ctx context.Context, in *DeleteQosReq, opts ...grpc.CallOption) (*DeleteQosResp, error)
|
|
ListTres(ctx context.Context, in *ListTresReq, opts ...grpc.CallOption) (*ListTresResp, error)
|
|
SetTres(ctx context.Context, in *SetTresReq, opts ...grpc.CallOption) (*SetTresResp, error)
|
|
ListAccount(ctx context.Context, in *ListAccountReq, opts ...grpc.CallOption) (*ListAccountResp, error)
|
|
GetAccount(ctx context.Context, in *GetAccountReq, opts ...grpc.CallOption) (*GetAccountResp, error)
|
|
UpdateAccount(ctx context.Context, in *UpdateAccountReq, opts ...grpc.CallOption) (*UpdateAccountResp, error)
|
|
DeleteAccount(ctx context.Context, in *DeleteAccountReq, opts ...grpc.CallOption) (*DeleteAccountResp, error)
|
|
ListCluster(ctx context.Context, in *ListClusterReq, opts ...grpc.CallOption) (*ListClusterResp, error)
|
|
GetCluster(ctx context.Context, in *GetClusterReq, opts ...grpc.CallOption) (*GetClusterResp, error)
|
|
AddCluster(ctx context.Context, in *AddClusterReq, opts ...grpc.CallOption) (*AddClusterResp, error)
|
|
DeleteCluster(ctx context.Context, in *DeleteClusterReq, opts ...grpc.CallOption) (*DeleteClusterResp, error)
|
|
ListWckey(ctx context.Context, in *ListWckeyReq, opts ...grpc.CallOption) (*ListWckeyResp, error)
|
|
GetWckey(ctx context.Context, in *GetWckeyReq, opts ...grpc.CallOption) (*GetWckeyResp, error)
|
|
AddWckey(ctx context.Context, in *AddWckeyReq, opts ...grpc.CallOption) (*AddWckeyResp, error)
|
|
DeleteWckey(ctx context.Context, in *DeleteWckeyReq, opts ...grpc.CallOption) (*DeleteWckeyResp, error)
|
|
ListAssociation(ctx context.Context, in *ListAssociationReq, opts ...grpc.CallOption) (*ListAssociationResp, error)
|
|
GetAssociation(ctx context.Context, in *GetAssociationReq, opts ...grpc.CallOption) (*GetAssociationResp, error)
|
|
SetAssociation(ctx context.Context, in *SetAssociationReq, opts ...grpc.CallOption) (*SetAssociationResp, error)
|
|
DeleteAssociation(ctx context.Context, in *DeleteAssociationReq, opts ...grpc.CallOption) (*DeleteAssociationResp, error)
|
|
GetDiagnostics(ctx context.Context, in *ListDiagnosticsReq, opts ...grpc.CallOption) (*ListDiagnosticsResp, error)
|
|
GetDbDiagnostics(ctx context.Context, in *ListDbDiagnosticsReq, opts ...grpc.CallOption) (*ListDbDiagnosticsResp, error)
|
|
}
|
|
|
|
type slurmClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewSlurmClient(cc grpc.ClientConnInterface) SlurmClient {
|
|
return &slurmClient{cc}
|
|
}
|
|
|
|
func (c *slurmClient) SyncToken(ctx context.Context, in *SyncTokenReq, opts ...grpc.CallOption) (*SyncTokenResp, error) {
|
|
out := new(SyncTokenResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/syncToken", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingResp, error) {
|
|
out := new(PingResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/ping", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListJob(ctx context.Context, in *ListJobReq, opts ...grpc.CallOption) (*ListJobResp, error) {
|
|
out := new(ListJobResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listJob", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetJob(ctx context.Context, in *GetJobReq, opts ...grpc.CallOption) (*GetJobResp, error) {
|
|
out := new(GetJobResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getJob", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) UpdateJob(ctx context.Context, in *UpdateJobReq, opts ...grpc.CallOption) (*UpdateJobResp, error) {
|
|
out := new(UpdateJobResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/updateJob", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) CancelJob(ctx context.Context, in *CancelJobReq, opts ...grpc.CallOption) (*CancelJobResp, error) {
|
|
out := new(CancelJobResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/cancelJob", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) SubmitJob(ctx context.Context, in *SubmitJobReq, opts ...grpc.CallOption) (*SubmitJobResp, error) {
|
|
out := new(SubmitJobResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/submitJob", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListUser(ctx context.Context, in *ListUserReq, opts ...grpc.CallOption) (*ListUserResp, error) {
|
|
out := new(ListUserResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listUser", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetUser(ctx context.Context, in *GetUserReq, opts ...grpc.CallOption) (*GetUserResp, error) {
|
|
out := new(GetUserResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getUser", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) UpdateUser(ctx context.Context, in *UpdateUserReq, opts ...grpc.CallOption) (*UpdateUserResp, error) {
|
|
out := new(UpdateUserResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/updateUser", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) DeleteUser(ctx context.Context, in *DeleteUserReq, opts ...grpc.CallOption) (*DeleteUserResp, error) {
|
|
out := new(DeleteUserResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/deleteUser", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListPartition(ctx context.Context, in *ListPartitionReq, opts ...grpc.CallOption) (*ListPartitionResp, error) {
|
|
out := new(ListPartitionResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listPartition", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetPartition(ctx context.Context, in *GetPartitionReq, opts ...grpc.CallOption) (*GetPartitionResp, error) {
|
|
out := new(GetPartitionResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getPartition", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListNode(ctx context.Context, in *ListNodeReq, opts ...grpc.CallOption) (*ListNodeResp, error) {
|
|
out := new(ListNodeResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listNode", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetNode(ctx context.Context, in *GetNodeReq, opts ...grpc.CallOption) (*GetNodeResp, error) {
|
|
out := new(GetNodeResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getNode", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListReservation(ctx context.Context, in *ListReservationReq, opts ...grpc.CallOption) (*ListReservationResp, error) {
|
|
out := new(ListReservationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listReservation", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetReservation(ctx context.Context, in *GetReservationReq, opts ...grpc.CallOption) (*GetReservationResp, error) {
|
|
out := new(GetReservationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getReservation", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) LoadConfiguration(ctx context.Context, in *LoadConfigurationReq, opts ...grpc.CallOption) (*LoadConfigurationResp, error) {
|
|
out := new(LoadConfigurationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/loadConfiguration", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) DumpConfiguration(ctx context.Context, in *DumpConfigurationReq, opts ...grpc.CallOption) (*DumpConfigurationResp, error) {
|
|
out := new(DumpConfigurationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/dumpConfiguration", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListQos(ctx context.Context, in *ListQosReq, opts ...grpc.CallOption) (*ListQosResp, error) {
|
|
out := new(ListQosResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listQos", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetQos(ctx context.Context, in *GetQosReq, opts ...grpc.CallOption) (*GetQosResp, error) {
|
|
out := new(GetQosResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getQos", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) DeleteQos(ctx context.Context, in *DeleteQosReq, opts ...grpc.CallOption) (*DeleteQosResp, error) {
|
|
out := new(DeleteQosResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/deleteQos", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListTres(ctx context.Context, in *ListTresReq, opts ...grpc.CallOption) (*ListTresResp, error) {
|
|
out := new(ListTresResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listTres", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) SetTres(ctx context.Context, in *SetTresReq, opts ...grpc.CallOption) (*SetTresResp, error) {
|
|
out := new(SetTresResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/setTres", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListAccount(ctx context.Context, in *ListAccountReq, opts ...grpc.CallOption) (*ListAccountResp, error) {
|
|
out := new(ListAccountResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listAccount", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetAccount(ctx context.Context, in *GetAccountReq, opts ...grpc.CallOption) (*GetAccountResp, error) {
|
|
out := new(GetAccountResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getAccount", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) UpdateAccount(ctx context.Context, in *UpdateAccountReq, opts ...grpc.CallOption) (*UpdateAccountResp, error) {
|
|
out := new(UpdateAccountResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/updateAccount", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) DeleteAccount(ctx context.Context, in *DeleteAccountReq, opts ...grpc.CallOption) (*DeleteAccountResp, error) {
|
|
out := new(DeleteAccountResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/deleteAccount", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListCluster(ctx context.Context, in *ListClusterReq, opts ...grpc.CallOption) (*ListClusterResp, error) {
|
|
out := new(ListClusterResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listCluster", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetCluster(ctx context.Context, in *GetClusterReq, opts ...grpc.CallOption) (*GetClusterResp, error) {
|
|
out := new(GetClusterResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getCluster", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) AddCluster(ctx context.Context, in *AddClusterReq, opts ...grpc.CallOption) (*AddClusterResp, error) {
|
|
out := new(AddClusterResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/addCluster", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) DeleteCluster(ctx context.Context, in *DeleteClusterReq, opts ...grpc.CallOption) (*DeleteClusterResp, error) {
|
|
out := new(DeleteClusterResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/deleteCluster", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListWckey(ctx context.Context, in *ListWckeyReq, opts ...grpc.CallOption) (*ListWckeyResp, error) {
|
|
out := new(ListWckeyResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listWckey", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetWckey(ctx context.Context, in *GetWckeyReq, opts ...grpc.CallOption) (*GetWckeyResp, error) {
|
|
out := new(GetWckeyResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getWckey", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) AddWckey(ctx context.Context, in *AddWckeyReq, opts ...grpc.CallOption) (*AddWckeyResp, error) {
|
|
out := new(AddWckeyResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/addWckey", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) DeleteWckey(ctx context.Context, in *DeleteWckeyReq, opts ...grpc.CallOption) (*DeleteWckeyResp, error) {
|
|
out := new(DeleteWckeyResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/deleteWckey", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) ListAssociation(ctx context.Context, in *ListAssociationReq, opts ...grpc.CallOption) (*ListAssociationResp, error) {
|
|
out := new(ListAssociationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/listAssociation", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetAssociation(ctx context.Context, in *GetAssociationReq, opts ...grpc.CallOption) (*GetAssociationResp, error) {
|
|
out := new(GetAssociationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getAssociation", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) SetAssociation(ctx context.Context, in *SetAssociationReq, opts ...grpc.CallOption) (*SetAssociationResp, error) {
|
|
out := new(SetAssociationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/setAssociation", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) DeleteAssociation(ctx context.Context, in *DeleteAssociationReq, opts ...grpc.CallOption) (*DeleteAssociationResp, error) {
|
|
out := new(DeleteAssociationResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/deleteAssociation", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetDiagnostics(ctx context.Context, in *ListDiagnosticsReq, opts ...grpc.CallOption) (*ListDiagnosticsResp, error) {
|
|
out := new(ListDiagnosticsResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getDiagnostics", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *slurmClient) GetDbDiagnostics(ctx context.Context, in *ListDbDiagnosticsReq, opts ...grpc.CallOption) (*ListDbDiagnosticsResp, error) {
|
|
out := new(ListDbDiagnosticsResp)
|
|
err := c.cc.Invoke(ctx, "/slurm.slurm/getDbDiagnostics", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// SlurmServer is the server API for Slurm service.
|
|
// All implementations must embed UnimplementedSlurmServer
|
|
// for forward compatibility
|
|
type SlurmServer interface {
|
|
SyncToken(context.Context, *SyncTokenReq) (*SyncTokenResp, error)
|
|
Ping(context.Context, *PingReq) (*PingResp, error)
|
|
ListJob(context.Context, *ListJobReq) (*ListJobResp, error)
|
|
GetJob(context.Context, *GetJobReq) (*GetJobResp, error)
|
|
UpdateJob(context.Context, *UpdateJobReq) (*UpdateJobResp, error)
|
|
CancelJob(context.Context, *CancelJobReq) (*CancelJobResp, error)
|
|
SubmitJob(context.Context, *SubmitJobReq) (*SubmitJobResp, error)
|
|
ListUser(context.Context, *ListUserReq) (*ListUserResp, error)
|
|
GetUser(context.Context, *GetUserReq) (*GetUserResp, error)
|
|
UpdateUser(context.Context, *UpdateUserReq) (*UpdateUserResp, error)
|
|
DeleteUser(context.Context, *DeleteUserReq) (*DeleteUserResp, error)
|
|
ListPartition(context.Context, *ListPartitionReq) (*ListPartitionResp, error)
|
|
GetPartition(context.Context, *GetPartitionReq) (*GetPartitionResp, error)
|
|
ListNode(context.Context, *ListNodeReq) (*ListNodeResp, error)
|
|
GetNode(context.Context, *GetNodeReq) (*GetNodeResp, error)
|
|
ListReservation(context.Context, *ListReservationReq) (*ListReservationResp, error)
|
|
GetReservation(context.Context, *GetReservationReq) (*GetReservationResp, error)
|
|
LoadConfiguration(context.Context, *LoadConfigurationReq) (*LoadConfigurationResp, error)
|
|
DumpConfiguration(context.Context, *DumpConfigurationReq) (*DumpConfigurationResp, error)
|
|
ListQos(context.Context, *ListQosReq) (*ListQosResp, error)
|
|
GetQos(context.Context, *GetQosReq) (*GetQosResp, error)
|
|
DeleteQos(context.Context, *DeleteQosReq) (*DeleteQosResp, error)
|
|
ListTres(context.Context, *ListTresReq) (*ListTresResp, error)
|
|
SetTres(context.Context, *SetTresReq) (*SetTresResp, error)
|
|
ListAccount(context.Context, *ListAccountReq) (*ListAccountResp, error)
|
|
GetAccount(context.Context, *GetAccountReq) (*GetAccountResp, error)
|
|
UpdateAccount(context.Context, *UpdateAccountReq) (*UpdateAccountResp, error)
|
|
DeleteAccount(context.Context, *DeleteAccountReq) (*DeleteAccountResp, error)
|
|
ListCluster(context.Context, *ListClusterReq) (*ListClusterResp, error)
|
|
GetCluster(context.Context, *GetClusterReq) (*GetClusterResp, error)
|
|
AddCluster(context.Context, *AddClusterReq) (*AddClusterResp, error)
|
|
DeleteCluster(context.Context, *DeleteClusterReq) (*DeleteClusterResp, error)
|
|
ListWckey(context.Context, *ListWckeyReq) (*ListWckeyResp, error)
|
|
GetWckey(context.Context, *GetWckeyReq) (*GetWckeyResp, error)
|
|
AddWckey(context.Context, *AddWckeyReq) (*AddWckeyResp, error)
|
|
DeleteWckey(context.Context, *DeleteWckeyReq) (*DeleteWckeyResp, error)
|
|
ListAssociation(context.Context, *ListAssociationReq) (*ListAssociationResp, error)
|
|
GetAssociation(context.Context, *GetAssociationReq) (*GetAssociationResp, error)
|
|
SetAssociation(context.Context, *SetAssociationReq) (*SetAssociationResp, error)
|
|
DeleteAssociation(context.Context, *DeleteAssociationReq) (*DeleteAssociationResp, error)
|
|
GetDiagnostics(context.Context, *ListDiagnosticsReq) (*ListDiagnosticsResp, error)
|
|
GetDbDiagnostics(context.Context, *ListDbDiagnosticsReq) (*ListDbDiagnosticsResp, error)
|
|
mustEmbedUnimplementedSlurmServer()
|
|
}
|
|
|
|
// UnimplementedSlurmServer must be embedded to have forward compatible implementations.
|
|
type UnimplementedSlurmServer struct {
|
|
}
|
|
|
|
func (UnimplementedSlurmServer) SyncToken(context.Context, *SyncTokenReq) (*SyncTokenResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method SyncToken not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) Ping(context.Context, *PingReq) (*PingResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListJob(context.Context, *ListJobReq) (*ListJobResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListJob not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetJob(context.Context, *GetJobReq) (*GetJobResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetJob not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) UpdateJob(context.Context, *UpdateJobReq) (*UpdateJobResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateJob not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) CancelJob(context.Context, *CancelJobReq) (*CancelJobResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CancelJob not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) SubmitJob(context.Context, *SubmitJobReq) (*SubmitJobResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method SubmitJob not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListUser(context.Context, *ListUserReq) (*ListUserResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListUser not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetUser(context.Context, *GetUserReq) (*GetUserResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetUser not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) UpdateUser(context.Context, *UpdateUserReq) (*UpdateUserResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateUser not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) DeleteUser(context.Context, *DeleteUserReq) (*DeleteUserResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteUser not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListPartition(context.Context, *ListPartitionReq) (*ListPartitionResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListPartition not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetPartition(context.Context, *GetPartitionReq) (*GetPartitionResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetPartition not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListNode(context.Context, *ListNodeReq) (*ListNodeResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListNode not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetNode(context.Context, *GetNodeReq) (*GetNodeResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetNode not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListReservation(context.Context, *ListReservationReq) (*ListReservationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListReservation not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetReservation(context.Context, *GetReservationReq) (*GetReservationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetReservation not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) LoadConfiguration(context.Context, *LoadConfigurationReq) (*LoadConfigurationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method LoadConfiguration not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) DumpConfiguration(context.Context, *DumpConfigurationReq) (*DumpConfigurationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DumpConfiguration not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListQos(context.Context, *ListQosReq) (*ListQosResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListQos not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetQos(context.Context, *GetQosReq) (*GetQosResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetQos not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) DeleteQos(context.Context, *DeleteQosReq) (*DeleteQosResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteQos not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListTres(context.Context, *ListTresReq) (*ListTresResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListTres not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) SetTres(context.Context, *SetTresReq) (*SetTresResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method SetTres not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListAccount(context.Context, *ListAccountReq) (*ListAccountResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListAccount not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetAccount(context.Context, *GetAccountReq) (*GetAccountResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetAccount not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) UpdateAccount(context.Context, *UpdateAccountReq) (*UpdateAccountResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateAccount not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) DeleteAccount(context.Context, *DeleteAccountReq) (*DeleteAccountResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteAccount not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListCluster(context.Context, *ListClusterReq) (*ListClusterResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListCluster not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetCluster(context.Context, *GetClusterReq) (*GetClusterResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetCluster not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) AddCluster(context.Context, *AddClusterReq) (*AddClusterResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method AddCluster not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) DeleteCluster(context.Context, *DeleteClusterReq) (*DeleteClusterResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteCluster not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListWckey(context.Context, *ListWckeyReq) (*ListWckeyResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListWckey not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetWckey(context.Context, *GetWckeyReq) (*GetWckeyResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetWckey not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) AddWckey(context.Context, *AddWckeyReq) (*AddWckeyResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method AddWckey not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) DeleteWckey(context.Context, *DeleteWckeyReq) (*DeleteWckeyResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteWckey not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) ListAssociation(context.Context, *ListAssociationReq) (*ListAssociationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListAssociation not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetAssociation(context.Context, *GetAssociationReq) (*GetAssociationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetAssociation not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) SetAssociation(context.Context, *SetAssociationReq) (*SetAssociationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method SetAssociation not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) DeleteAssociation(context.Context, *DeleteAssociationReq) (*DeleteAssociationResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteAssociation not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetDiagnostics(context.Context, *ListDiagnosticsReq) (*ListDiagnosticsResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetDiagnostics not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) GetDbDiagnostics(context.Context, *ListDbDiagnosticsReq) (*ListDbDiagnosticsResp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetDbDiagnostics not implemented")
|
|
}
|
|
func (UnimplementedSlurmServer) mustEmbedUnimplementedSlurmServer() {}
|
|
|
|
// UnsafeSlurmServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to SlurmServer will
|
|
// result in compilation errors.
|
|
type UnsafeSlurmServer interface {
|
|
mustEmbedUnimplementedSlurmServer()
|
|
}
|
|
|
|
func RegisterSlurmServer(s grpc.ServiceRegistrar, srv SlurmServer) {
|
|
s.RegisterService(&Slurm_ServiceDesc, srv)
|
|
}
|
|
|
|
func _Slurm_SyncToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(SyncTokenReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).SyncToken(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/syncToken",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).SyncToken(ctx, req.(*SyncTokenReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(PingReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).Ping(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/ping",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).Ping(ctx, req.(*PingReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListJobReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListJob(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listJob",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListJob(ctx, req.(*ListJobReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetJobReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetJob(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getJob",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetJob(ctx, req.(*GetJobReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_UpdateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(UpdateJobReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).UpdateJob(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/updateJob",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).UpdateJob(ctx, req.(*UpdateJobReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_CancelJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(CancelJobReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).CancelJob(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/cancelJob",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).CancelJob(ctx, req.(*CancelJobReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_SubmitJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(SubmitJobReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).SubmitJob(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/submitJob",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).SubmitJob(ctx, req.(*SubmitJobReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListUserReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListUser(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listUser",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListUser(ctx, req.(*ListUserReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetUserReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetUser(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getUser",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetUser(ctx, req.(*GetUserReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_UpdateUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(UpdateUserReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).UpdateUser(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/updateUser",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).UpdateUser(ctx, req.(*UpdateUserReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_DeleteUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(DeleteUserReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).DeleteUser(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/deleteUser",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).DeleteUser(ctx, req.(*DeleteUserReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListPartition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListPartitionReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListPartition(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listPartition",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListPartition(ctx, req.(*ListPartitionReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetPartition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetPartitionReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetPartition(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getPartition",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetPartition(ctx, req.(*GetPartitionReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListNode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListNodeReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListNode(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listNode",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListNode(ctx, req.(*ListNodeReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetNode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetNodeReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetNode(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getNode",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetNode(ctx, req.(*GetNodeReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListReservation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListReservationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListReservation(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listReservation",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListReservation(ctx, req.(*ListReservationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetReservation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetReservationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetReservation(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getReservation",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetReservation(ctx, req.(*GetReservationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_LoadConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(LoadConfigurationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).LoadConfiguration(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/loadConfiguration",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).LoadConfiguration(ctx, req.(*LoadConfigurationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_DumpConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(DumpConfigurationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).DumpConfiguration(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/dumpConfiguration",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).DumpConfiguration(ctx, req.(*DumpConfigurationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListQos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListQosReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListQos(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listQos",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListQos(ctx, req.(*ListQosReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetQos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetQosReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetQos(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getQos",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetQos(ctx, req.(*GetQosReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_DeleteQos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(DeleteQosReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).DeleteQos(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/deleteQos",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).DeleteQos(ctx, req.(*DeleteQosReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListTres_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListTresReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListTres(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listTres",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListTres(ctx, req.(*ListTresReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_SetTres_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(SetTresReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).SetTres(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/setTres",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).SetTres(ctx, req.(*SetTresReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListAccountReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListAccount(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listAccount",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListAccount(ctx, req.(*ListAccountReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetAccountReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetAccount(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getAccount",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetAccount(ctx, req.(*GetAccountReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_UpdateAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(UpdateAccountReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).UpdateAccount(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/updateAccount",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).UpdateAccount(ctx, req.(*UpdateAccountReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_DeleteAccount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(DeleteAccountReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).DeleteAccount(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/deleteAccount",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).DeleteAccount(ctx, req.(*DeleteAccountReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListClusterReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListCluster(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listCluster",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListCluster(ctx, req.(*ListClusterReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetClusterReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetCluster(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getCluster",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetCluster(ctx, req.(*GetClusterReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_AddCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(AddClusterReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).AddCluster(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/addCluster",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).AddCluster(ctx, req.(*AddClusterReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_DeleteCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(DeleteClusterReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).DeleteCluster(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/deleteCluster",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).DeleteCluster(ctx, req.(*DeleteClusterReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListWckey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListWckeyReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListWckey(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listWckey",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListWckey(ctx, req.(*ListWckeyReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetWckey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetWckeyReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetWckey(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getWckey",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetWckey(ctx, req.(*GetWckeyReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_AddWckey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(AddWckeyReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).AddWckey(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/addWckey",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).AddWckey(ctx, req.(*AddWckeyReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_DeleteWckey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(DeleteWckeyReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).DeleteWckey(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/deleteWckey",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).DeleteWckey(ctx, req.(*DeleteWckeyReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_ListAssociation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListAssociationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).ListAssociation(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/listAssociation",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).ListAssociation(ctx, req.(*ListAssociationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetAssociation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(GetAssociationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetAssociation(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getAssociation",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetAssociation(ctx, req.(*GetAssociationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_SetAssociation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(SetAssociationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).SetAssociation(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/setAssociation",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).SetAssociation(ctx, req.(*SetAssociationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_DeleteAssociation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(DeleteAssociationReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).DeleteAssociation(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/deleteAssociation",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).DeleteAssociation(ctx, req.(*DeleteAssociationReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetDiagnostics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListDiagnosticsReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetDiagnostics(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getDiagnostics",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetDiagnostics(ctx, req.(*ListDiagnosticsReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Slurm_GetDbDiagnostics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListDbDiagnosticsReq)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SlurmServer).GetDbDiagnostics(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/slurm.slurm/getDbDiagnostics",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SlurmServer).GetDbDiagnostics(ctx, req.(*ListDbDiagnosticsReq))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
// Slurm_ServiceDesc is the grpc.ServiceDesc for Slurm service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var Slurm_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "slurm.slurm",
|
|
HandlerType: (*SlurmServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "syncToken",
|
|
Handler: _Slurm_SyncToken_Handler,
|
|
},
|
|
{
|
|
MethodName: "ping",
|
|
Handler: _Slurm_Ping_Handler,
|
|
},
|
|
{
|
|
MethodName: "listJob",
|
|
Handler: _Slurm_ListJob_Handler,
|
|
},
|
|
{
|
|
MethodName: "getJob",
|
|
Handler: _Slurm_GetJob_Handler,
|
|
},
|
|
{
|
|
MethodName: "updateJob",
|
|
Handler: _Slurm_UpdateJob_Handler,
|
|
},
|
|
{
|
|
MethodName: "cancelJob",
|
|
Handler: _Slurm_CancelJob_Handler,
|
|
},
|
|
{
|
|
MethodName: "submitJob",
|
|
Handler: _Slurm_SubmitJob_Handler,
|
|
},
|
|
{
|
|
MethodName: "listUser",
|
|
Handler: _Slurm_ListUser_Handler,
|
|
},
|
|
{
|
|
MethodName: "getUser",
|
|
Handler: _Slurm_GetUser_Handler,
|
|
},
|
|
{
|
|
MethodName: "updateUser",
|
|
Handler: _Slurm_UpdateUser_Handler,
|
|
},
|
|
{
|
|
MethodName: "deleteUser",
|
|
Handler: _Slurm_DeleteUser_Handler,
|
|
},
|
|
{
|
|
MethodName: "listPartition",
|
|
Handler: _Slurm_ListPartition_Handler,
|
|
},
|
|
{
|
|
MethodName: "getPartition",
|
|
Handler: _Slurm_GetPartition_Handler,
|
|
},
|
|
{
|
|
MethodName: "listNode",
|
|
Handler: _Slurm_ListNode_Handler,
|
|
},
|
|
{
|
|
MethodName: "getNode",
|
|
Handler: _Slurm_GetNode_Handler,
|
|
},
|
|
{
|
|
MethodName: "listReservation",
|
|
Handler: _Slurm_ListReservation_Handler,
|
|
},
|
|
{
|
|
MethodName: "getReservation",
|
|
Handler: _Slurm_GetReservation_Handler,
|
|
},
|
|
{
|
|
MethodName: "loadConfiguration",
|
|
Handler: _Slurm_LoadConfiguration_Handler,
|
|
},
|
|
{
|
|
MethodName: "dumpConfiguration",
|
|
Handler: _Slurm_DumpConfiguration_Handler,
|
|
},
|
|
{
|
|
MethodName: "listQos",
|
|
Handler: _Slurm_ListQos_Handler,
|
|
},
|
|
{
|
|
MethodName: "getQos",
|
|
Handler: _Slurm_GetQos_Handler,
|
|
},
|
|
{
|
|
MethodName: "deleteQos",
|
|
Handler: _Slurm_DeleteQos_Handler,
|
|
},
|
|
{
|
|
MethodName: "listTres",
|
|
Handler: _Slurm_ListTres_Handler,
|
|
},
|
|
{
|
|
MethodName: "setTres",
|
|
Handler: _Slurm_SetTres_Handler,
|
|
},
|
|
{
|
|
MethodName: "listAccount",
|
|
Handler: _Slurm_ListAccount_Handler,
|
|
},
|
|
{
|
|
MethodName: "getAccount",
|
|
Handler: _Slurm_GetAccount_Handler,
|
|
},
|
|
{
|
|
MethodName: "updateAccount",
|
|
Handler: _Slurm_UpdateAccount_Handler,
|
|
},
|
|
{
|
|
MethodName: "deleteAccount",
|
|
Handler: _Slurm_DeleteAccount_Handler,
|
|
},
|
|
{
|
|
MethodName: "listCluster",
|
|
Handler: _Slurm_ListCluster_Handler,
|
|
},
|
|
{
|
|
MethodName: "getCluster",
|
|
Handler: _Slurm_GetCluster_Handler,
|
|
},
|
|
{
|
|
MethodName: "addCluster",
|
|
Handler: _Slurm_AddCluster_Handler,
|
|
},
|
|
{
|
|
MethodName: "deleteCluster",
|
|
Handler: _Slurm_DeleteCluster_Handler,
|
|
},
|
|
{
|
|
MethodName: "listWckey",
|
|
Handler: _Slurm_ListWckey_Handler,
|
|
},
|
|
{
|
|
MethodName: "getWckey",
|
|
Handler: _Slurm_GetWckey_Handler,
|
|
},
|
|
{
|
|
MethodName: "addWckey",
|
|
Handler: _Slurm_AddWckey_Handler,
|
|
},
|
|
{
|
|
MethodName: "deleteWckey",
|
|
Handler: _Slurm_DeleteWckey_Handler,
|
|
},
|
|
{
|
|
MethodName: "listAssociation",
|
|
Handler: _Slurm_ListAssociation_Handler,
|
|
},
|
|
{
|
|
MethodName: "getAssociation",
|
|
Handler: _Slurm_GetAssociation_Handler,
|
|
},
|
|
{
|
|
MethodName: "setAssociation",
|
|
Handler: _Slurm_SetAssociation_Handler,
|
|
},
|
|
{
|
|
MethodName: "deleteAssociation",
|
|
Handler: _Slurm_DeleteAssociation_Handler,
|
|
},
|
|
{
|
|
MethodName: "getDiagnostics",
|
|
Handler: _Slurm_GetDiagnostics_Handler,
|
|
},
|
|
{
|
|
MethodName: "getDbDiagnostics",
|
|
Handler: _Slurm_GetDbDiagnostics_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "slurm.proto",
|
|
}
|