apm.hpp

Go to the documentation of this file.

// Copyright 2009-present MongoDB, Inc.
//
// 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.
 
#pragma once
 
#include <functional>
 
#include <mongocxx/options/apm-fwd.hpp>
 
#include <mongocxx/events/command_failed_event.hpp>
#include <mongocxx/events/command_started_event.hpp>
#include <mongocxx/events/command_succeeded_event.hpp>
#include <mongocxx/events/heartbeat_failed_event.hpp>
#include <mongocxx/events/heartbeat_started_event.hpp>
#include <mongocxx/events/heartbeat_succeeded_event.hpp>
#include <mongocxx/events/server_changed_event.hpp>
#include <mongocxx/events/server_closed_event.hpp>
#include <mongocxx/events/server_opening_event.hpp>
#include <mongocxx/events/topology_changed_event.hpp>
#include <mongocxx/events/topology_closed_event.hpp>
#include <mongocxx/events/topology_opening_event.hpp>
 
#include <mongocxx/config/prelude.hpp>
 
namespace mongocxx {
namespace v_noabi {
namespace options {
 
class apm {
   public:
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_command_started(std::function<void MONGOCXX_ABI_CDECL(const events::command_started_event&)>
                           command_started);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::command_started_event&)>&)
    command_started() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_command_failed(
        std::function<void MONGOCXX_ABI_CDECL(const events::command_failed_event&)> command_failed);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::command_failed_event&)>&)
    command_failed() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_command_succeeded(
        std::function<void MONGOCXX_ABI_CDECL(const events::command_succeeded_event&)>
            command_succeeded);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::command_succeeded_event&)>&)
    command_succeeded() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_server_opening(
        std::function<void MONGOCXX_ABI_CDECL(const events::server_opening_event&)> server_opening);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::server_opening_event&)>&)
    server_opening() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_server_closed(
        std::function<void MONGOCXX_ABI_CDECL(const events::server_closed_event&)> server_closed);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::server_closed_event&)>&)
    server_closed() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_server_changed(
        std::function<void MONGOCXX_ABI_CDECL(const events::server_changed_event&)> server_changed);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::server_changed_event&)>&)
    server_changed() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_topology_opening(
        std::function<void MONGOCXX_ABI_CDECL(const events::topology_opening_event&)>
            topology_opening);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::topology_opening_event&)>&)
    topology_opening() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_topology_closed(std::function<void MONGOCXX_ABI_CDECL(const events::topology_closed_event&)>
                           topology_closed);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::topology_closed_event&)>&)
    topology_closed() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_topology_changed(
        std::function<void MONGOCXX_ABI_CDECL(const events::topology_changed_event&)>
            topology_changed);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::topology_changed_event&)>&)
    topology_changed() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_heartbeat_started(
        std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_started_event&)>
            heartbeat_started);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_started_event&)>&)
    heartbeat_started() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_heartbeat_failed(
        std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_failed_event&)>
            heartbeat_failed);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_failed_event&)>&)
    heartbeat_failed() const;
 
    MONGOCXX_ABI_EXPORT_CDECL(apm&)
    on_heartbeat_succeeded(
        std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_succeeded_event&)>
            heartbeat_succeeded);
 
    MONGOCXX_ABI_EXPORT_CDECL(
        const std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_succeeded_event&)>&)
    heartbeat_succeeded() const;
 
   private:
    std::function<void MONGOCXX_ABI_CDECL(const events::command_started_event&)> _command_started;
    std::function<void MONGOCXX_ABI_CDECL(const events::command_failed_event&)> _command_failed;
    std::function<void MONGOCXX_ABI_CDECL(const events::command_succeeded_event&)>
        _command_succeeded;
    std::function<void MONGOCXX_ABI_CDECL(const events::server_closed_event&)> _server_closed;
    std::function<void MONGOCXX_ABI_CDECL(const events::server_changed_event&)> _server_changed;
    std::function<void MONGOCXX_ABI_CDECL(const events::server_opening_event&)> _server_opening;
    std::function<void MONGOCXX_ABI_CDECL(const events::topology_closed_event&)> _topology_closed;
    std::function<void MONGOCXX_ABI_CDECL(const events::topology_changed_event&)> _topology_changed;
    std::function<void MONGOCXX_ABI_CDECL(const events::topology_opening_event&)> _topology_opening;
    std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_started_event&)>
        _heartbeat_started;
    std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_failed_event&)> _heartbeat_failed;
    std::function<void MONGOCXX_ABI_CDECL(const events::heartbeat_succeeded_event&)>
        _heartbeat_succeeded;
};
 
}  // namespace options
}  // namespace v_noabi
}  // namespace mongocxx
 
#include <mongocxx/config/postlude.hpp>