org.apache.flink.runtime.filters

Class AcceptRuleBasedIpFilter

java.lang.Object

org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter

org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

org.apache.flink.runtime.filters.AbstractRemoteAddressFilter<InetSocketAddress>

org.apache.flink.runtime.filters.AcceptRuleBasedIpFilter

All Implemented Interfaces:

org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler, org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler

public class AcceptRuleBasedIpFilter
extends AbstractRemoteAddressFilter<InetSocketAddress>

This class allows one to filter new Channels based on the HashSet passed to its constructor. If no rules are provided, no connections will be accepted.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
AcceptRuleBasedIpFilter(String[] ip)

Method Summary

Modifier and Type	Method and Description
protected boolean	accept(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx, InetSocketAddress remoteAddress) This method is called immediately after a io.netty.channel.Channel gets registered.

Methods inherited from class org.apache.flink.runtime.filters.AbstractRemoteAddressFilter

channelAccepted, channelActive, channelRegistered, channelRejected

Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

AcceptRuleBasedIpFilter

public AcceptRuleBasedIpFilter(String[] ip)

Method Detail

accept

protected boolean accept(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
                         InetSocketAddress remoteAddress)

Description copied from class: AbstractRemoteAddressFilter

This method is called immediately after a io.netty.channel.Channel gets registered.

Specified by:

accept in class AbstractRemoteAddressFilter<InetSocketAddress>

Returns:

Return true if connections from this IP address and port should be accepted. False otherwise.