org.thales.punch.kafka.platform

Class KafkaShivaConstants

java.lang.Object

org.thales.punch.kafka.platform.KafkaShivaConstants

public class KafkaShivaConstants
extends Object

This class groups the various values that are part of the Punch protocol implemented on top of Kafka.

This protocol is used by the core punch administration to keep track of channels and applications status, as well as by the shiva application scheduler.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASSIGNEMENT_V1 A leader has been elected.
static String	COMMAND_V1 The prefix header for start and stop commands.
static String	COMMAND_V2 large message are only handled by V2 start command.
static String	PING_V1 Leader send this message on the control topic periodically.
static String	PONG_V1 Worker send this message every time a leader sent its PING_V1 message.
static String	SHIVA_LEADER_GROUP_ID The group identifier used by all leaders.
static String	SHIVA_WORKER_GROUP_ID_PREFIX Workers have each their own group id so that they all read the same topics.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

SHIVA_LEADER_GROUP_ID

public static final String SHIVA_LEADER_GROUP_ID

The group identifier used by all leaders.

See Also:

Constant Field Values

SHIVA_WORKER_GROUP_ID_PREFIX

public static final String SHIVA_WORKER_GROUP_ID_PREFIX

Workers have each their own group id so that they all read the same topics.

See Also:

Constant Field Values

ASSIGNEMENT_V1

public static final String ASSIGNEMENT_V1

A leader has been elected. He sends this message periodically onto the assignment topic. The value is a json document completely describing the latest assignment view of the leader.

Worker respond with their description. If they do not the leader will consider them death.

See Also:

Constant Field Values

PONG_V1

public static final String PONG_V1

Worker send this message every time a leader sent its PING_V1 message.

See Also:

Constant Field Values

PING_V1

public static final String PING_V1

Leader send this message on the control topic periodically. Workers must reply with a PONG_V1.

See Also:

Constant Field Values

COMMAND_V1

public static final String COMMAND_V1

The prefix header for start and stop commands.

See Also:

Constant Field Values

COMMAND_V2

public static final String COMMAND_V2

large message are only handled by V2 start command.

See Also:

Constant Field Values