1
#include "source/extensions/access_loggers/grpc/http_config.h"
2

            
3
#include "envoy/extensions/access_loggers/grpc/v3/als.pb.h"
4
#include "envoy/extensions/access_loggers/grpc/v3/als.pb.validate.h"
5
#include "envoy/registry/registry.h"
6
#include "envoy/server/filter_config.h"
7

            
8
#include "source/common/common/assert.h"
9
#include "source/common/common/macros.h"
10
#include "source/common/grpc/async_client_impl.h"
11
#include "source/common/protobuf/protobuf.h"
12
#include "source/extensions/access_loggers/grpc/config_utils.h"
13
#include "source/extensions/access_loggers/grpc/grpc_access_log_proto_descriptors.h"
14
#include "source/extensions/access_loggers/grpc/http_grpc_access_log_impl.h"
15

            
16
namespace Envoy {
17
namespace Extensions {
18
namespace AccessLoggers {
19
namespace HttpGrpc {
20

            
21
AccessLog::InstanceSharedPtr HttpGrpcAccessLogFactory::createAccessLogInstance(
22
    const Protobuf::Message& config, AccessLog::FilterPtr&& filter,
23
    Server::Configuration::GenericFactoryContext& context,
24
15
    std::vector<Formatter::CommandParserPtr>&& command_parsers) {
25
15
  GrpcCommon::validateProtoDescriptors();
26

            
27
15
  const auto& proto_config = MessageUtil::downcastAndValidate<
28
15
      const envoy::extensions::access_loggers::grpc::v3::HttpGrpcAccessLogConfig&>(
29
15
      config, context.messageValidationVisitor());
30

            
31
15
  return std::make_shared<HttpGrpcAccessLog>(
32
15
      std::move(filter), proto_config, context.serverFactoryContext().threadLocal(),
33
15
      GrpcCommon::getGrpcAccessLoggerCacheSingleton(context.serverFactoryContext()),
34
15
      command_parsers);
35
15
}
36

            
37
23
ProtobufTypes::MessagePtr HttpGrpcAccessLogFactory::createEmptyConfigProto() {
38
23
  return std::make_unique<envoy::extensions::access_loggers::grpc::v3::HttpGrpcAccessLogConfig>();
39
23
}
40

            
41
47
std::string HttpGrpcAccessLogFactory::name() const { return "envoy.access_loggers.http_grpc"; }
42

            
43
/**
44
 * Static registration for the HTTP gRPC access log. @see RegisterFactory.
45
 */
46
LEGACY_REGISTER_FACTORY(HttpGrpcAccessLogFactory, AccessLog::AccessLogInstanceFactory,
47
                        "envoy.http_grpc_access_log");
48

            
49
} // namespace HttpGrpc
50
} // namespace AccessLoggers
51
} // namespace Extensions
52
} // namespace Envoy