Package io.confluent.security.auth.ipFiltering

Class IpFilteringAuthCache

java.lang.Object
io.confluent.security.auth.ipFiltering.IpFilteringAuthCache
All Implemented Interfaces:
io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>
public class IpFilteringAuthCache extends Object implements io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

  • Constructor Summary

    Constructors
    Constructor
    Description
    IpFilteringAuthCache()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    fail(int partition, String errorMessage)
     
    io.confluent.security.authorizer.provider.AuthorizeRule
    findRule(org.apache.kafka.common.security.auth.KafkaPrincipal sessionPrincipal, Set<org.apache.kafka.common.security.auth.KafkaPrincipal> groupPrincipals, String host, io.confluent.security.authorizer.Action action)
     
    io.confluent.security.auth.store.data.AuthValue
    get(io.confluent.security.auth.store.data.AuthKey key)
     
    Map<? extends io.confluent.security.auth.store.data.AuthKey,? extends io.confluent.security.auth.store.data.AuthValue>
    map(String entryType)
     
    io.confluent.security.auth.store.data.AuthValue
    put(io.confluent.security.auth.store.data.AuthKey key, io.confluent.security.auth.store.data.AuthValue value)
     
    io.confluent.security.auth.store.data.AuthValue
    remove(io.confluent.security.auth.store.data.AuthKey key)
     
    io.confluent.security.store.MetadataStoreStatus
    status(int partition)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • IpFilteringAuthCache

      public IpFilteringAuthCache()

  • Method Details

    • get

      public io.confluent.security.auth.store.data.AuthValue get(io.confluent.security.auth.store.data.AuthKey key)
      Specified by:
      get in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

    • put

      public io.confluent.security.auth.store.data.AuthValue put(io.confluent.security.auth.store.data.AuthKey key, io.confluent.security.auth.store.data.AuthValue value)
      Specified by:
      put in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

    • remove

      public io.confluent.security.auth.store.data.AuthValue remove(io.confluent.security.auth.store.data.AuthKey key)
      Specified by:
      remove in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

    • map

      public Map<? extends io.confluent.security.auth.store.data.AuthKey,? extends io.confluent.security.auth.store.data.AuthValue> map(String entryType)
      Specified by:
      map in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

    • fail

      public void fail(int partition, String errorMessage)
      Specified by:
      fail in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

    • status

      public io.confluent.security.store.MetadataStoreStatus status(int partition)
      Specified by:
      status in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

    • findRule

      public io.confluent.security.authorizer.provider.AuthorizeRule findRule(org.apache.kafka.common.security.auth.KafkaPrincipal sessionPrincipal, Set<org.apache.kafka.common.security.auth.KafkaPrincipal> groupPrincipals, String host, io.confluent.security.authorizer.Action action)