mirror of https://github.com/grpc/grpc.git
Yash Tibrewal
6 years ago
parent
813865acaf
commit
2c4c8438cc
21 changed files with 312 additions and 49 deletions
@ -0,0 +1,75 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2019 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
* |
||||
*/ |
||||
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#include "src/core/ext/filters/client_channel/health/health_check_parser.h" |
||||
|
||||
namespace grpc_core { |
||||
namespace { |
||||
size_t health_check_parser_index; |
||||
} |
||||
|
||||
UniquePtr<ServiceConfigParsedObject> HealthCheckParser::ParseGlobalParams( |
||||
const grpc_json* json, grpc_error** error) { |
||||
GPR_DEBUG_ASSERT(error != nullptr && *error == GRPC_ERROR_NONE); |
||||
const char* service_name = nullptr; |
||||
for (grpc_json* field = json->child; field != nullptr; field = field->next) { |
||||
if (field->key == nullptr) { |
||||
continue; |
||||
} |
||||
if (strcmp(field->key, "healthCheckConfig") == 0) { |
||||
if (field->type != GRPC_JSON_OBJECT) { |
||||
*error = GRPC_ERROR_CREATE_FROM_STATIC_STRING( |
||||
"field:healthCheckConfig error:should be of type object"); |
||||
return nullptr; |
||||
} |
||||
for (grpc_json* sub_field = field->child; sub_field != nullptr; |
||||
sub_field = sub_field->next) { |
||||
if (sub_field->key == nullptr) { |
||||
continue; |
||||
} |
||||
if (strcmp(sub_field->key, "serviceName") == 0) { |
||||
if (service_name != nullptr) { |
||||
*error = GRPC_ERROR_CREATE_FROM_STATIC_STRING( |
||||
"field:healthCheckConfig field:serviceName error:Duplicate " |
||||
"entry"); |
||||
return nullptr; |
||||
} |
||||
if (sub_field->type != GRPC_JSON_STRING) { |
||||
*error = GRPC_ERROR_CREATE_FROM_STATIC_STRING( |
||||
"field:healthCheckConfig error:should be of type string"); |
||||
return nullptr; |
||||
} |
||||
service_name = sub_field->value; |
||||
} |
||||
} |
||||
} |
||||
} |
||||
return UniquePtr<ServiceConfigParsedObject>( |
||||
New<HealthCheckParsedObject>(service_name)); |
||||
} |
||||
|
||||
void HealthCheckParser::Register() { |
||||
health_check_parser_index = ServiceConfig::RegisterParser( |
||||
UniquePtr<ServiceConfigParser>(New<HealthCheckParser>())); |
||||
} |
||||
|
||||
size_t HealthCheckParser::ParserIndex() { return health_check_parser_index; } |
||||
|
||||
} // namespace grpc_core
|
||||
@ -0,0 +1,49 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2019 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
* |
||||
*/ |
||||
|
||||
#ifndef GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_HEALTH_HEALTH_CHECK_PARSER_H |
||||
#define GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_HEALTH_HEALTH_CHECK_PARSER_H |
||||
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#include "src/core/ext/filters/client_channel/service_config.h" |
||||
|
||||
namespace grpc_core { |
||||
|
||||
class HealthCheckParsedObject : public ServiceConfigParsedObject { |
||||
public: |
||||
HealthCheckParsedObject(const char* service_name) |
||||
: service_name_(service_name) {} |
||||
|
||||
const char* service_name() const { return service_name_; } |
||||
|
||||
private: |
||||
const char* service_name_; |
||||
}; |
||||
|
||||
class HealthCheckParser : public ServiceConfigParser { |
||||
public: |
||||
UniquePtr<ServiceConfigParsedObject> ParseGlobalParams( |
||||
const grpc_json* json, grpc_error** error) override; |
||||
|
||||
static void Register(); |
||||
|
||||
static size_t ParserIndex(); |
||||
}; |
||||
} // namespace grpc_core
|
||||
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_HEALTH_HEALTH_CHECK_PARSER_H */ |
||||
Loading…
Reference in new issue