Package com.zendesk.maxwell.replication
Class BinlogConnectorDiagnostic
- java.lang.Object
-
- com.zendesk.maxwell.replication.BinlogConnectorDiagnostic
-
- All Implemented Interfaces:
MaxwellDiagnostic
public class BinlogConnectorDiagnostic extends Object implements MaxwellDiagnostic
-
-
Constructor Summary
Constructors Constructor Description BinlogConnectorDiagnostic(MaxwellContext context)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletableFuture<MaxwellDiagnosticResult.Check>
check()
CompletableFuture<Long>
getLatency()
String
getName()
String
getResource()
boolean
isMandatory()
-
-
-
Constructor Detail
-
BinlogConnectorDiagnostic
public BinlogConnectorDiagnostic(MaxwellContext context)
-
-
Method Detail
-
getName
public String getName()
- Specified by:
getName
in interfaceMaxwellDiagnostic
-
check
public CompletableFuture<MaxwellDiagnosticResult.Check> check()
- Specified by:
check
in interfaceMaxwellDiagnostic
-
isMandatory
public boolean isMandatory()
- Specified by:
isMandatory
in interfaceMaxwellDiagnostic
-
getResource
public String getResource()
- Specified by:
getResource
in interfaceMaxwellDiagnostic
-
getLatency
public CompletableFuture<Long> getLatency()
-
-