s_mysql_group_replication_message_service_recv Struct Reference

A service that gets called whenever an agnostic message from the group replication stream is to be delivered by the group replication receiver thread. More...

#include <group_replication_message_service.h>

Public Attributes
mysql_service_status_t(*	recv )(const char *tag, const unsigned char *payload, const size_t payload_length)
	This function of every service implementation SHALL be called by group replication whenever the group replication receive a service message sent to the group. More...

Detailed Description

A service that gets called whenever an agnostic message from the group replication stream is to be delivered by the group replication receiver thread.

The implementation MUST NOT block the caller.

This only works if the component is on a server with group replication running and the member state is ONLINE. If server isn't ONLINE message won't be notified about messages received.

DEFINE_BOOL_METHOD(recv, (const char *tag, const unsigned char *data,
                          size_t data_length)) {
 
  // If tag is of interest do something with data
  return false;
}
 
BEGIN_SERVICE_IMPLEMENTATION(listener_example,
                             group_replication_message_service_recv)
recv, END_SERVICE_IMPLEMENTATION();
 
bool register_listener() {
  SERVICE_TYPE(registry) *plugin_registry = mysql_plugin_registry_acquire();
  my_service<SERVICE_TYPE(registry_registration)> reg("registry_registration",
                                                      plugin_registry);
  using group_replication_message_service_recv_t =
      SERVICE_TYPE_NO_CONST(group_replication_message_service_recv);
  bool result = reg->register_service(
      "group_replication_message_service_recv.listener_example",
      reinterpret_cast<my_h_service>(
          const_cast<group_replication_message_service_recv_t *>(
              &SERVICE_IMPLEMENTATION(
                  listener_example,
                  group_replication_message_service_recv))));

Member Data Documentation

recv

mysql_service_status_t(* s_mysql_group_replication_message_service_recv::recv) (const char *tag, const unsigned char *payload, const size_t payload_length)

This function of every service implementation SHALL be called by group replication whenever the group replication receive a service message sent to the group.

Parameters

[out]	tag	tag identifies message
[out]	payload	data to be deliver
[out]	payload_length	size of data

Returns

false success, true on failure.

---

The documentation for this struct was generated from the following file:

• include/mysql/components/services/group_replication_message_service.h