matsumana

## built-in TCP input
## $ echo <json> | fluent-cat <tag>
<source>
  type tcp
</source>

## match tag=debug.** and dump to console
<match debug.**>
  type stdout
</match>

matsumana

## built-in TCP input
## $ echo <json> | fluent-cat <tag>
<source>
  type tcp
</source>

## match tag=debug.** and dump to console
<match debug.**>
  type stdout
</match>

matsumana

// $ export CLASSPATH=.:./fluent-logger-0.2.5-SNAPSHOT-jar-with-dependencies.jar
// $ javac FluentLogClient.java
// $ java FluentLogClient

import java.util.HashMap;
import java.util.Map;
import org.fluentd.logger.FluentLogger;

public class FluentLogClient {
    private static FluentLogger LOG = FluentLogger.getLogger("myapp");

matsumana

[client]
port		= 3306
socket		= /var/lib/mysql/mysql.sock

[mysqld]
port		= 3306
socket		= /var/lib/mysql/mysql.sock
skip-external-locking
key_buffer_size = 16K
max_allowed_packet = 1M

matsumana

[client]
port		= 3306
socket		= /var/lib/mysql/mysql.sock

[mysqld]
port		= 3306
socket		= /var/lib/mysql/mysql.sock
skip-external-locking
key_buffer_size = 16K
max_allowed_packet = 1M

matsumana

[client]
port		= 3306
socket		= /var/lib/mysql/mysql.sock

[mysqld]
port		= 3306
socket		= /var/lib/mysql/mysql.sock
skip-external-locking
key_buffer_size = 16K
max_allowed_packet = 1M

matsumana

Replication Health Status
+-----------+-------+---------+--------+------------+---------------------------------------------------------------------------------------+---------------+-------------------+-----------------+------------+-------------+--------------+------------------+---------------+-----------+----------------+------------+---------------+
| host      | port  | role    | state  | gtid_mode  | health                                                                                | version       | master_log_file   | master_log_pos  | IO_Thread  | SQL_Thread  | Secs_Behind  | Remaining_Delay  | IO_Error_Num  | IO_Error  | SQL_Error_Num  | SQL_Error  | Trans_Behind  |
+-----------+-------+---------+--------+------------+---------------------------------------------------------------------------------------+---------------+-------------------+-----------------+------------+-------------+--------------+------------------+---------------+-----------+----------------+------------+---------------+
| deb

matsumana

Failover starting in 'auto' mode...
# Checking eligibility of slave debian01:3306 for candidate.
#   GTID_MODE=ON ... Ok
#   Replication user exists ... Ok
# Candidate slave debian01:3306 will become the new master.
# Preparing candidate for failover.
# LOCK STRING: FLUSH TABLES WITH READ LOCK
# Connecting candidate to debian02:3306 as a master to retrieve unprocessed GTIDs.
# Change master command for debian01:3306
# CHANGE MASTER TO MASTER_HOST = 'debian02', MASTER_USER = 'repl', MASTER_PASSWORD = '3306', MASTER_PORT = 3306, MASTER_AUTO_POSITION=1

matsumana

<source>
  type forward
</source>

<match apache.access.**>
  type rewrite
  add_prefix rewrited
  <rule>
    key     path
    pattern \.(gif|jpe?g|png|ico|css|js)$

matsumana

<source>
  type forward
</source>

<match apache.access.**>
  type rewrite_tag_filter
  capitalize_regex_backreference yes
  rewriterule1 path \.(gif|jpe?g|png|ico|css|js)$ ignore
  rewriterule2 path ^/$                           rewrited.apache.access.top
  rewriterule3 path ^\/([^\/]+)                   rewrited.apache.access.$1