Uses of Interface
io.kroxylicious.proxy.internal.filter.FilterInvoker
Packages that use FilterInvoker
-
Uses of FilterInvoker in io.kroxylicious.proxy.internal.filter
Classes in io.kroxylicious.proxy.internal.filter that implement FilterInvokerModifier and TypeClassDescriptionclassAn invoker for AddOffsetsToTxnRequestFilter.classAn invoker for AddOffsetsToTxnResponseFilter.classAn invoker for AddPartitionsToTxnRequestFilter.classAn invoker for AddPartitionsToTxnResponseFilter.classAn invoker for AddRaftVoterRequestFilter.classAn invoker for AddRaftVoterResponseFilter.classAn invoker for AllocateProducerIdsRequestFilter.classAn invoker for AllocateProducerIdsResponseFilter.classAn invoker for AlterClientQuotasRequestFilter.classAn invoker for AlterClientQuotasResponseFilter.classAn invoker for AlterConfigsRequestFilter.classAn invoker for AlterConfigsResponseFilter.classAn invoker for AlterPartitionReassignmentsRequestFilter.classAn invoker for AlterPartitionReassignmentsResponseFilter.classAn invoker for AlterPartitionRequestFilter.classAn invoker for AlterPartitionResponseFilter.classAn invoker for AlterReplicaLogDirsRequestFilter.classAn invoker for AlterReplicaLogDirsResponseFilter.classAn invoker for AlterShareGroupOffsetsRequestFilter.classAn invoker for AlterShareGroupOffsetsResponseFilter.classAn invoker for AlterUserScramCredentialsRequestFilter.classAn invoker for AlterUserScramCredentialsResponseFilter.classAn invoker for ApiVersionsRequestFilter.classAn invoker for ApiVersionsResponseFilter.classAn invoker for AssignReplicasToDirsRequestFilter.classAn invoker for AssignReplicasToDirsResponseFilter.classAn invoker for BeginQuorumEpochRequestFilter.classAn invoker for BeginQuorumEpochResponseFilter.classAn invoker for BrokerHeartbeatRequestFilter.classAn invoker for BrokerHeartbeatResponseFilter.classAn invoker for BrokerRegistrationRequestFilter.classAn invoker for BrokerRegistrationResponseFilter.classAn invoker for ConsumerGroupDescribeRequestFilter.classAn invoker for ConsumerGroupDescribeResponseFilter.classAn invoker for ConsumerGroupHeartbeatRequestFilter.classAn invoker for ConsumerGroupHeartbeatResponseFilter.classAn invoker for ControllerRegistrationRequestFilter.classAn invoker for ControllerRegistrationResponseFilter.classAn invoker for CreateAclsRequestFilter.classAn invoker for CreateAclsResponseFilter.classAn invoker for CreateDelegationTokenRequestFilter.classAn invoker for CreateDelegationTokenResponseFilter.classAn invoker for CreatePartitionsRequestFilter.classAn invoker for CreatePartitionsResponseFilter.classAn invoker for CreateTopicsRequestFilter.classAn invoker for CreateTopicsResponseFilter.classAn invoker for DeleteAclsRequestFilter.classAn invoker for DeleteAclsResponseFilter.classAn invoker for DeleteGroupsRequestFilter.classAn invoker for DeleteGroupsResponseFilter.classAn invoker for DeleteRecordsRequestFilter.classAn invoker for DeleteRecordsResponseFilter.classAn invoker for DeleteShareGroupOffsetsRequestFilter.classAn invoker for DeleteShareGroupOffsetsResponseFilter.classAn invoker for DeleteShareGroupStateRequestFilter.classAn invoker for DeleteShareGroupStateResponseFilter.classAn invoker for DeleteTopicsRequestFilter.classAn invoker for DeleteTopicsResponseFilter.classAn invoker for DescribeAclsRequestFilter.classAn invoker for DescribeAclsResponseFilter.classAn invoker for DescribeClientQuotasRequestFilter.classAn invoker for DescribeClientQuotasResponseFilter.classAn invoker for DescribeClusterRequestFilter.classAn invoker for DescribeClusterResponseFilter.classAn invoker for DescribeConfigsRequestFilter.classAn invoker for DescribeConfigsResponseFilter.classAn invoker for DescribeDelegationTokenRequestFilter.classAn invoker for DescribeDelegationTokenResponseFilter.classAn invoker for DescribeGroupsRequestFilter.classAn invoker for DescribeGroupsResponseFilter.classAn invoker for DescribeLogDirsRequestFilter.classAn invoker for DescribeLogDirsResponseFilter.classAn invoker for DescribeProducersRequestFilter.classAn invoker for DescribeProducersResponseFilter.classAn invoker for DescribeQuorumRequestFilter.classAn invoker for DescribeQuorumResponseFilter.classAn invoker for DescribeShareGroupOffsetsRequestFilter.classAn invoker for DescribeShareGroupOffsetsResponseFilter.classAn invoker for DescribeTopicPartitionsRequestFilter.classAn invoker for DescribeTopicPartitionsResponseFilter.classAn invoker for DescribeTransactionsRequestFilter.classAn invoker for DescribeTransactionsResponseFilter.classAn invoker for DescribeUserScramCredentialsRequestFilter.classAn invoker for DescribeUserScramCredentialsResponseFilter.classAn invoker for ElectLeadersRequestFilter.classAn invoker for ElectLeadersResponseFilter.classAn invoker for EndQuorumEpochRequestFilter.classAn invoker for EndQuorumEpochResponseFilter.classAn invoker for EndTxnRequestFilter.classAn invoker for EndTxnResponseFilter.classAn invoker for EnvelopeRequestFilter.classAn invoker for EnvelopeResponseFilter.classAn invoker for ExpireDelegationTokenRequestFilter.classAn invoker for ExpireDelegationTokenResponseFilter.classAn invoker for FetchRequestFilter.classAn invoker for FetchResponseFilter.classAn invoker for FetchSnapshotRequestFilter.classAn invoker for FetchSnapshotResponseFilter.classAn invoker for FindCoordinatorRequestFilter.classAn invoker for FindCoordinatorResponseFilter.classAn invoker for GetTelemetrySubscriptionsRequestFilter.classAn invoker for GetTelemetrySubscriptionsResponseFilter.final recordclassAn invoker for HeartbeatRequestFilter.classAn invoker for HeartbeatResponseFilter.classAn invoker for IncrementalAlterConfigsRequestFilter.classAn invoker for IncrementalAlterConfigsResponseFilter.classAn invoker for InitializeShareGroupStateRequestFilter.classAn invoker for InitializeShareGroupStateResponseFilter.classAn invoker for InitProducerIdRequestFilter.classAn invoker for InitProducerIdResponseFilter.classAn invoker for JoinGroupRequestFilter.classAn invoker for JoinGroupResponseFilter.classAn invoker for LeaveGroupRequestFilter.classAn invoker for LeaveGroupResponseFilter.classAn invoker for ListConfigResourcesRequestFilter.classAn invoker for ListConfigResourcesResponseFilter.classAn invoker for ListGroupsRequestFilter.classAn invoker for ListGroupsResponseFilter.classAn invoker for ListOffsetsRequestFilter.classAn invoker for ListOffsetsResponseFilter.classAn invoker for ListPartitionReassignmentsRequestFilter.classAn invoker for ListPartitionReassignmentsResponseFilter.classAn invoker for ListTransactionsRequestFilter.classAn invoker for ListTransactionsResponseFilter.classAn invoker for MetadataRequestFilter.classAn invoker for MetadataResponseFilter.classAn invoker for OffsetCommitRequestFilter.classAn invoker for OffsetCommitResponseFilter.classAn invoker for OffsetDeleteRequestFilter.classAn invoker for OffsetDeleteResponseFilter.classAn invoker for OffsetFetchRequestFilter.classAn invoker for OffsetFetchResponseFilter.classAn invoker for OffsetForLeaderEpochRequestFilter.classAn invoker for OffsetForLeaderEpochResponseFilter.classAn invoker for ProduceRequestFilter.classAn invoker for ProduceResponseFilter.classAn invoker for PushTelemetryRequestFilter.classAn invoker for PushTelemetryResponseFilter.classAn invoker for ReadShareGroupStateRequestFilter.classAn invoker for ReadShareGroupStateResponseFilter.classAn invoker for ReadShareGroupStateSummaryRequestFilter.classAn invoker for ReadShareGroupStateSummaryResponseFilter.classAn invoker for RemoveRaftVoterRequestFilter.classAn invoker for RemoveRaftVoterResponseFilter.classAn invoker for RenewDelegationTokenRequestFilter.classAn invoker for RenewDelegationTokenResponseFilter.final recordfinal recordfinal recordfinal recordWraps a delegate invoker so that onRequest and onResponse can be safely called even if this Invoker does not want to handle this message, in this case the message will be forwarded without the delegate doing anything with it.classAn invoker for SaslAuthenticateRequestFilter.classAn invoker for SaslAuthenticateResponseFilter.classAn invoker for SaslHandshakeRequestFilter.classAn invoker for SaslHandshakeResponseFilter.classAn invoker for ShareAcknowledgeRequestFilter.classAn invoker for ShareAcknowledgeResponseFilter.classAn invoker for ShareFetchRequestFilter.classAn invoker for ShareFetchResponseFilter.classAn invoker for ShareGroupDescribeRequestFilter.classAn invoker for ShareGroupDescribeResponseFilter.classAn invoker for ShareGroupHeartbeatRequestFilter.classAn invoker for ShareGroupHeartbeatResponseFilter.classInvoker for Filters that implement any number of Specific Message interfaces (for exampleAlterConfigsResponseFilter.classAn invoker for StreamsGroupDescribeRequestFilter.classAn invoker for StreamsGroupDescribeResponseFilter.classAn invoker for StreamsGroupHeartbeatRequestFilter.classAn invoker for StreamsGroupHeartbeatResponseFilter.classAn invoker for SyncGroupRequestFilter.classAn invoker for SyncGroupResponseFilter.classAn invoker for TxnOffsetCommitRequestFilter.classAn invoker for TxnOffsetCommitResponseFilter.classAn invoker for UnregisterBrokerRequestFilter.classAn invoker for UnregisterBrokerResponseFilter.classAn invoker for UpdateFeaturesRequestFilter.classAn invoker for UpdateFeaturesResponseFilter.classAn invoker for UpdateRaftVoterRequestFilter.classAn invoker for UpdateRaftVoterResponseFilter.classAn invoker for VoteRequestFilter.classAn invoker for VoteResponseFilter.classAn invoker for WriteShareGroupStateRequestFilter.classAn invoker for WriteShareGroupStateResponseFilter.classAn invoker for WriteTxnMarkersRequestFilter.classAn invoker for WriteTxnMarkersResponseFilter.Fields in io.kroxylicious.proxy.internal.filter declared as FilterInvokerMethods in io.kroxylicious.proxy.internal.filter that return FilterInvokerModifier and TypeMethodDescriptionstatic FilterInvokerFilterInvokers.arrayInvoker(io.kroxylicious.proxy.filter.Filter filter) Create an invoker for this filter that avoids instanceof when deciding if the filter should be consulted/handle messages.static FilterInvokerFilterInvokers.handleNothingInvoker()An invoker that does not handle any requests or responsesFilterAndInvoker.invoker()Returns the value of theinvokerrecord component.SafeInvoker.invoker()Returns the value of theinvokerrecord component.Constructors in io.kroxylicious.proxy.internal.filter with parameters of type FilterInvokerModifierConstructorDescriptionFilterAndInvoker(String filterName, io.kroxylicious.proxy.filter.Filter filter, FilterInvoker invoker) A Filter and it's respective invokerSafeInvoker(FilterInvoker invoker) Creates an instance of aSafeInvokerrecord class.