public class SlackSelfHealingNotifier extends SelfHealingNotifier
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
_slackChannel |
protected java.lang.String |
_slackIcon |
protected java.lang.String |
_slackUser |
protected java.lang.String |
_slackWebhook |
static java.lang.String |
DEFAULT_SLACK_SELF_HEALING_NOTIFIER_ICON |
static java.lang.String |
DEFAULT_SLACK_SELF_HEALING_NOTIFIER_USER |
static java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_CHANNEL |
static java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_ICON |
static java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_USER |
static java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_WEBHOOK |
_brokerFailureAlertThresholdMs, _notifierStartTimeMs, _selfHealingEnabled, _selfHealingEnabledHistoricalDurationMs, _selfHealingStateChangeTimeMs, _selfHealingThresholdMs, _time
Constructor and Description |
---|
SlackSelfHealingNotifier() |
SlackSelfHealingNotifier(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
alert(java.lang.Object anomaly,
boolean autoFixTriggered,
long selfHealingStartTime,
AnomalyType anomalyType)
Alert on anomaly.
|
void |
configure(java.util.Map<java.lang.String,?> config)
Configure this class with the given key-value pairs
|
protected void |
sendSlackMessage(SlackMessage slackMessage,
java.lang.String slackWebhookUrl) |
onBrokerFailure, onGoalViolation, selfHealingEnabled, selfHealingEnabledRatio, setSelfHealingFor, uptimeMs
public static final java.lang.String SLACK_SELF_HEALING_NOTIFIER_WEBHOOK
public static final java.lang.String SLACK_SELF_HEALING_NOTIFIER_ICON
public static final java.lang.String SLACK_SELF_HEALING_NOTIFIER_USER
public static final java.lang.String SLACK_SELF_HEALING_NOTIFIER_CHANNEL
public static final java.lang.String DEFAULT_SLACK_SELF_HEALING_NOTIFIER_ICON
public static final java.lang.String DEFAULT_SLACK_SELF_HEALING_NOTIFIER_USER
protected java.lang.String _slackWebhook
protected java.lang.String _slackIcon
protected java.lang.String _slackChannel
protected java.lang.String _slackUser
public SlackSelfHealingNotifier()
public SlackSelfHealingNotifier(org.apache.kafka.common.utils.Time time)
public void configure(java.util.Map<java.lang.String,?> config)
CruiseControlConfigurable
configure
in interface CruiseControlConfigurable
configure
in class SelfHealingNotifier
public void alert(java.lang.Object anomaly, boolean autoFixTriggered, long selfHealingStartTime, AnomalyType anomalyType)
SelfHealingNotifier
alert
in class SelfHealingNotifier
anomaly
- Detected anomaly.autoFixTriggered
- True if auto fix has been triggered, false otherwise.selfHealingStartTime
- The time that the self healing started.anomalyType
- Type of anomaly.protected void sendSlackMessage(SlackMessage slackMessage, java.lang.String slackWebhookUrl) throws java.io.IOException
java.io.IOException