Skip to content

Commit

Permalink
Merge pull request #59 from centreon/enginemerge
Browse files Browse the repository at this point in the history 
enh(centengine) : add ChangeObjectIntVar into grpc
  • Loading branch information
@tmpaccount01
tmpaccount01 committed Aug 3, 2020
2 parents 1b417cb + e9ce6a2 commit 135f263
Show file tree
Hide file tree
Showing 5 changed files with 1,325 additions and 29 deletions.
42 changes: 37 additions & 5 deletions include/com/centreon/engine/engine_impl.hh
View file
Original file line number Diff line number Diff line change
Expand Up @@ -95,11 +95,12 @@ class engine_impl final : public Engine::Service {
const ServiceIdentifier* request,
CommandSuccess* response) override;
grpc::Status AcknowledgementHostProblem(grpc::ServerContext* context,
const EngineAcknowledgement* request,
CommandSuccess* response) override;
grpc::Status AcknowledgementServiceProblem(grpc::ServerContext* context,
const EngineAcknowledgement* request,
CommandSuccess* response) override;
const EngineAcknowledgement* request,
CommandSuccess* response) override;
grpc::Status AcknowledgementServiceProblem(
grpc::ServerContext* context,
const EngineAcknowledgement* request,
CommandSuccess* response) override;
grpc::Status ScheduleHostDowntime(grpc::ServerContext* context,
const ScheduleDowntimeIdentifier* request,
CommandSuccess* response) override;
Expand Down Expand Up @@ -176,6 +177,37 @@ class engine_impl final : public Engine::Service {
grpc::Status DelayServiceNotification(grpc::ServerContext* context,
const ServiceDelayIdentifier* request,
CommandSuccess* response) override;
grpc::Status ChangeHostObjectIntVar(grpc::ServerContext* context,
const ChangeObjectInt* request,
CommandSuccess* response) override;
grpc::Status ChangeServiceObjectIntVar(grpc::ServerContext* context,
const ChangeObjectInt* request,
CommandSuccess* response) override;
grpc::Status ChangeContactObjectIntVar(grpc::ServerContext* context,
const ChangeContactObjectInt* request,
CommandSuccess* response) override;
grpc::Status ChangeHostObjectCharVar(grpc::ServerContext* context,
const ChangeObjectChar* request,
CommandSuccess* response) override;
grpc::Status ChangeServiceObjectCharVar(grpc::ServerContext* context,
const ChangeObjectChar* request,
CommandSuccess* response) override;
grpc::Status ChangeContactObjectCharVar(
grpc::ServerContext* context,
const ChangeContactObjectChar* request,
CommandSuccess* response) override;
grpc::Status ChangeHostObjectCustomVar(grpc::ServerContext* context
__attribute__((unused)),
const ChangeObjectCustomVar* request,
CommandSuccess* response) override;
grpc::Status ChangeServiceObjectCustomVar(
grpc::ServerContext* context __attribute__((unused)),
const ChangeObjectCustomVar* request,
CommandSuccess* response) override;
grpc::Status ChangeContactObjectCustomVar(
grpc::ServerContext* context __attribute__((unused)),
const ChangeObjectCustomVar* request,
CommandSuccess* response) override;
};

CCE_END()
Expand Down
82 changes: 81 additions & 1 deletion src/cce_rpc/engine.proto
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@ package com.centreon.engine;
service Engine {
rpc GetVersion(google.protobuf.Empty) returns (Version) {}
rpc GetStats(GenericString) returns (Stats) {}

rpc GetHost(HostIdentifier) returns (EngineHost) {}
rpc GetContact(ContactIdentifier) returns (EngineContact) {}
rpc GetService(ServiceIdentifier) returns (EngineService) {}
Expand Down Expand Up @@ -96,6 +95,25 @@ service Engine {
returns (CommandSuccess) {}
rpc SignalProcess(EngineSignalProcess)
returns (CommandSuccess) {}
rpc ChangeHostObjectIntVar(ChangeObjectInt)
returns (CommandSuccess) {}
rpc ChangeServiceObjectIntVar(ChangeObjectInt)
returns (CommandSuccess) {}
rpc ChangeContactObjectIntVar(ChangeContactObjectInt)
returns (CommandSuccess) {}
rpc ChangeHostObjectCharVar(ChangeObjectChar)
returns (CommandSuccess) {}
rpc ChangeServiceObjectCharVar(ChangeObjectChar)
returns (CommandSuccess) {}
rpc ChangeContactObjectCharVar(ChangeContactObjectChar)
returns (CommandSuccess) {}
rpc ChangeHostObjectCustomVar(ChangeObjectCustomVar)
returns (CommandSuccess) {}
rpc ChangeServiceObjectCustomVar(ChangeObjectCustomVar)
returns (CommandSuccess) {}
rpc ChangeContactObjectCustomVar(ChangeObjectCustomVar)
returns (CommandSuccess) {}

}

message GenericString {
Expand Down Expand Up @@ -455,3 +473,65 @@ message EngineAcknowledgement {
bool notify = 6;
bool persistent = 7;
}

/* used for a host or a service */
message ChangeObjectInt {
string host_name = 1;
string service_desc = 2;
enum Mode {
NORMAL_CHECK_INTERVAL = 0;
RETRY_CHECK_INTERVAL = 1;
MAX_ATTEMPTS = 2;
MODATTR = 3;
}
Mode mode = 3;
uint32 intval = 4;
double dval = 5;
}

/* used for a contact */
message ChangeContactObjectInt {
string contact_name = 1;
enum Mode {
MODATTR = 0;
MODHATTR = 1;
MODSATTR = 2;
}
Mode mode = 2;
uint32 intval = 3;
double dval = 4;
}

/* used for a host or a service */
message ChangeObjectChar {
string host_name = 1;
string service_desc = 2;
enum Mode {
CHANGE_GLOBAL_EVENT_HANDLER = 0;
CHANGE_EVENT_HANDLER = 1;
CHANGE_CHECK_COMMAND = 2;
CHANGE_CHECK_TIMEPERIOD = 3;
CHANGE_NOTIFICATION_TIMEPERIOD = 4;
}
Mode mode = 3;
string charval = 4;
}

/* used for a contact */
message ChangeContactObjectChar {
string contact = 1;
enum Mode {
CHANGE_CONTACT_HOST_NOTIFICATION_TIMEPERIOD = 0;
CHANGE_CONTACT_SVC_NOTIFICATION_TIMEPERIOD = 1;
}
Mode mode = 2;
string charval = 3;
}

message ChangeObjectCustomVar {
string host_name = 1;
string service_desc = 2;
string contact = 3;
string varname = 4;
string varvalue = 5;
}
Loading

0 comments on commit 135f263

Please sign in to comment.