Package org.languagetool.rules

Class GRPCPostProcessing

java.lang.Object

org.languagetool.rules.GRPCPostProcessing

public class GRPCPostProcessing
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private io.grpc.ManagedChannel	channel
private final io.github.resilience4j.circuitbreaker.CircuitBreaker	circuitBreaker
private RemoteRuleConfig	config
static final String	CONFIG_TYPE
private static ConcurrentMap<Language,Set<String>>	configIDs
private static ConcurrentMap<String,GRPCPostProcessing>	instances
private PostProcessingServerGrpc.PostProcessingServerBlockingStub	stub

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GRPCPostProcessing(RemoteRuleConfig config)

Method Summary

Modifier and Type	Method	Description
private MLServerProto.PostProcessingRequest	buildRequest(List<AnalyzedSentence> sentences, List<RuleMatch> ruleMatches, List<Integer> offset, Long textSessionId, boolean inputLogging)
static void	configure(Language lang, List<RemoteRuleConfig> configs)
List<RuleMatch>	filter(List<AnalyzedSentence> sentences, List<RuleMatch> ruleMatches, Long textSessionID, boolean inputLogging)
static List<GRPCPostProcessing>	get(Language lang)
protected List<RuleMatch>	runPostprocessing(List<AnalyzedSentence> sentences, List<RuleMatch> ruleMatches, Long textSessionID, boolean inputLogging, int chars)
protected MLServerProto.MatchResponse	sendRequest(MLServerProto.PostProcessingRequest req, long timeout)

Methods inherited from class java.lang.Object

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

Field Details

CONFIG_TYPE

public static final String CONFIG_TYPE

See Also:

• Constant Field Values

circuitBreaker

private final io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker

channel

private io.grpc.ManagedChannel channel

stub

private PostProcessingServerGrpc.PostProcessingServerBlockingStub stub

config

private RemoteRuleConfig config

instances

private static ConcurrentMap<String,GRPCPostProcessing> instances

configIDs

private static ConcurrentMap<Language,Set<String>> configIDs

Constructor Details

GRPCPostProcessing

protected GRPCPostProcessing(RemoteRuleConfig config)
                      throws Exception

Throws:

Exception

Method Details

get

@NotNull
public static List<GRPCPostProcessing> get(Language lang)

configure

public static void configure(Language lang,
 List<RemoteRuleConfig> configs)

buildRequest

private MLServerProto.PostProcessingRequest buildRequest(List<AnalyzedSentence> sentences,
 List<RuleMatch> ruleMatches,
 List<Integer> offset,
 Long textSessionId,
 boolean inputLogging)

filter

public List<RuleMatch> filter(List<AnalyzedSentence> sentences,
 List<RuleMatch> ruleMatches,
 Long textSessionID,
 boolean inputLogging)

sendRequest

protected MLServerProto.MatchResponse sendRequest(MLServerProto.PostProcessingRequest req,
 long timeout)
                                           throws Exception

Throws:

Exception

runPostprocessing

protected List<RuleMatch> runPostprocessing(List<AnalyzedSentence> sentences,
 List<RuleMatch> ruleMatches,
 Long textSessionID,
 boolean inputLogging,
 int chars)
                                     throws Exception

Throws:

Exception