com.twitter.heron.metricsmgr.sink.tmaster

Class TMasterClient

java.lang.Object

com.twitter.heron.common.network.HeronClient

com.twitter.heron.metricsmgr.sink.tmaster.TMasterClient

All Implemented Interfaces:

ISelectHandler, java.lang.Runnable

public class TMasterClient
extends HeronClient
implements java.lang.Runnable

TMasterClient connects to TMaster and then send TopologyMaster.PublishMetrics continuously. Note that TMaster will not send registerRequest or wait for registerResponse.

Field Summary

Fields inherited from class com.twitter.heron.common.network.HeronClient

contextMap, messageMap, responseMessageMap

Constructor Summary

Constructors

Constructor and Description
TMasterClient(NIOLooper s, java.lang.String host, int port, HeronSocketOptions options, Communicator<TopologyMaster.PublishMetrics> publishMetricsCommunicator) Constructor

Method Summary

Modifier and Type	Method and Description
void	onClose()
void	onConnect(StatusCode status)
void	onError()
void	onIncomingMessage(com.google.protobuf.Message message)
void	onResponse(StatusCode status, java.lang.Object ctx, com.google.protobuf.Message response)
void	run()
void	setReconnectIntervalSec(long interval)

Methods inherited from class com.twitter.heron.common.network.HeronClient

forceFlushWithBestEffort, getContextMap, getMessageMap, getNIOLooper, getOutstandingPackets, getResponseMessageMap, getSocketChannel, getSocketChannelHelper, handleAccept, handleConnect, handleError, handlePacket, handleRead, handleTimeout, handleWrite, isConnected, registerOnMessage, registerTimerEventInNanoSeconds, registerTimerEventInSeconds, sendMessage, sendRequest, sendRequest, start, startReading, startWriting, stop, stopReading, stopWriting

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TMasterClient

public TMasterClient(NIOLooper s,
                     java.lang.String host,
                     int port,
                     HeronSocketOptions options,
                     Communicator<TopologyMaster.PublishMetrics> publishMetricsCommunicator)

Constructor

Parameters:

s - the NIOLooper bind with this socket client

host - the host of remote endpoint to communicate with

port - the port of remote endpoint to communicate with

publishMetricsCommunicator - the queue to read PublishMetrics from and send to TMaster

Method Detail

setReconnectIntervalSec

public void setReconnectIntervalSec(long interval)

onError

public void onError()

Specified by:

onError in class HeronClient

onConnect

public void onConnect(StatusCode status)

Specified by:

onConnect in class HeronClient

onResponse

public void onResponse(StatusCode status,
                       java.lang.Object ctx,
                       com.google.protobuf.Message response)

Specified by:

onResponse in class HeronClient

onIncomingMessage

public void onIncomingMessage(com.google.protobuf.Message message)

Specified by:

onIncomingMessage in class HeronClient

onClose

public void onClose()

Specified by:

onClose in class HeronClient

run

public void run()

Specified by:

run in interface java.lang.Runnable