Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

enh(centengine) : add ChangeObjectIntVar into grpc #59

Merged
merged 3 commits into from
Aug 3, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
42 changes: 37 additions & 5 deletions include/com/centreon/engine/engine_impl.hh
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
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