Package org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies

Class IgniteClientDelegate

java.lang.Object
org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies.IgniteClientDelegate
All Implemented Interfaces:
AutoCloseable, org.apache.ignite.client.IgniteClient
public class IgniteClientDelegate extends Object implements org.apache.ignite.client.IgniteClient
Static delegate that exposes an IgniteClientProxy as IgniteClient.

The cacheConfigConverter function converts ClientCacheConfiguration (Ignite 2 thin-client API) to CacheConfiguration (Ignite 2 full API) as expected by the adapter implementation. It is looked up once at construction time via the guest classloader.

  • Constructor Summary

    Constructors
    Constructor
    Description
    IgniteClientDelegate(org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies.client.IgniteClientProxy target, Function<org.apache.ignite.client.ClientCacheConfiguration,org.apache.ignite.configuration.CacheConfiguration<?,?>> cacheConfigConverter)
    Creates a delegate wrapping the given proxy and using the given converter for cache configuration.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.ignite.client.ClientAtomicLong
    atomicLong(String name, long initVal, boolean create)
     
    org.apache.ignite.client.ClientAtomicLong
    atomicLong(String name, org.apache.ignite.client.ClientAtomicConfiguration cfg, long initVal, boolean create)
     
    org.apache.ignite.client.ClientAtomicSequence
    atomicSequence(String name, long initVal, boolean create)
     
    org.apache.ignite.client.ClientAtomicSequence
    atomicSequence(String name, org.apache.ignite.client.ClientAtomicConfiguration cfg, long initVal, boolean create)
     
    org.apache.ignite.IgniteBinary
    binary()
     
    <K, V> org.apache.ignite.client.ClientCache<K,V>
    cache(String cacheName)
     
    Collection<String>
    cacheNames()
     
    org.apache.ignite.client.IgniteClientFuture<Collection<String>>
    cacheNamesAsync()
     
    void
    close()
     
    org.apache.ignite.client.ClientCluster
    cluster()
     
    org.apache.ignite.client.ClientCompute
    compute()
     
    org.apache.ignite.client.ClientCompute
    compute(org.apache.ignite.client.ClientClusterGroup grp)
     
    <K, V> org.apache.ignite.client.ClientCache<K,V>
    createCache(String cacheName)
     
    <K, V> org.apache.ignite.client.ClientCache<K,V>
    createCache(org.apache.ignite.client.ClientCacheConfiguration cacheCfg)
     
    <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>>
    createCacheAsync(String cacheName)
     
    <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>>
    createCacheAsync(org.apache.ignite.client.ClientCacheConfiguration cacheCfg)
     
    void
    destroyCache(String cacheName)
     
    org.apache.ignite.client.IgniteClientFuture<Void>
    destroyCacheAsync(String cacheName)
     
    <K, V> org.apache.ignite.client.ClientCache<K,V>
    getOrCreateCache(String cacheName)
     
    <K, V> org.apache.ignite.client.ClientCache<K,V>
    getOrCreateCache(org.apache.ignite.client.ClientCacheConfiguration cacheCfg)
     
    <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>>
    getOrCreateCacheAsync(String cacheName)
     
    <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>>
    getOrCreateCacheAsync(org.apache.ignite.client.ClientCacheConfiguration cacheCfg)
     
    org.apache.ignite.cache.query.FieldsQueryCursor<List<?>>
    query(org.apache.ignite.cache.query.SqlFieldsQuery qry)
     
    org.apache.ignite.client.ClientServices
    services()
     
    org.apache.ignite.client.ClientServices
    services(org.apache.ignite.client.ClientClusterGroup grp)
     
    <T> org.apache.ignite.client.ClientIgniteSet<T>
    set(String name, org.apache.ignite.client.ClientCollectionConfiguration cfg)
     
    org.apache.ignite.client.ClientTransactions
    transactions()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • IgniteClientDelegate

      public IgniteClientDelegate(org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies.client.IgniteClientProxy target, Function<org.apache.ignite.client.ClientCacheConfiguration,org.apache.ignite.configuration.CacheConfiguration<?,?>> cacheConfigConverter)
      Creates a delegate wrapping the given proxy and using the given converter for cache configuration.

  • Method Details

    • getOrCreateCache

      public <K, V> org.apache.ignite.client.ClientCache<K,V> getOrCreateCache(String cacheName) throws org.apache.ignite.client.ClientException
      Specified by:
      getOrCreateCache in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • getOrCreateCache

      public <K, V> org.apache.ignite.client.ClientCache<K,V> getOrCreateCache(org.apache.ignite.client.ClientCacheConfiguration cacheCfg) throws org.apache.ignite.client.ClientException
      Specified by:
      getOrCreateCache in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • getOrCreateCacheAsync

      public <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>> getOrCreateCacheAsync(String cacheName) throws org.apache.ignite.client.ClientException
      Specified by:
      getOrCreateCacheAsync in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • getOrCreateCacheAsync

      public <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>> getOrCreateCacheAsync(org.apache.ignite.client.ClientCacheConfiguration cacheCfg) throws org.apache.ignite.client.ClientException
      Specified by:
      getOrCreateCacheAsync in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • cache

      public <K, V> org.apache.ignite.client.ClientCache<K,V> cache(String cacheName)
      Specified by:
      cache in interface org.apache.ignite.client.IgniteClient

    • cacheNames

      public Collection<String> cacheNames() throws org.apache.ignite.client.ClientException
      Specified by:
      cacheNames in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • cacheNamesAsync

      public org.apache.ignite.client.IgniteClientFuture<Collection<String>> cacheNamesAsync() throws org.apache.ignite.client.ClientException
      Specified by:
      cacheNamesAsync in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • destroyCache

      public void destroyCache(String cacheName) throws org.apache.ignite.client.ClientException
      Specified by:
      destroyCache in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • destroyCacheAsync

      public org.apache.ignite.client.IgniteClientFuture<Void> destroyCacheAsync(String cacheName) throws org.apache.ignite.client.ClientException
      Specified by:
      destroyCacheAsync in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • createCache

      public <K, V> org.apache.ignite.client.ClientCache<K,V> createCache(String cacheName) throws org.apache.ignite.client.ClientException
      Specified by:
      createCache in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • createCache

      public <K, V> org.apache.ignite.client.ClientCache<K,V> createCache(org.apache.ignite.client.ClientCacheConfiguration cacheCfg) throws org.apache.ignite.client.ClientException
      Specified by:
      createCache in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • createCacheAsync

      public <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>> createCacheAsync(String cacheName) throws org.apache.ignite.client.ClientException
      Specified by:
      createCacheAsync in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • createCacheAsync

      public <K, V> org.apache.ignite.client.IgniteClientFuture<org.apache.ignite.client.ClientCache<K,V>> createCacheAsync(org.apache.ignite.client.ClientCacheConfiguration cacheCfg) throws org.apache.ignite.client.ClientException
      Specified by:
      createCacheAsync in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.client.ClientException

    • binary

      public org.apache.ignite.IgniteBinary binary()
      Specified by:
      binary in interface org.apache.ignite.client.IgniteClient

    • query

      public org.apache.ignite.cache.query.FieldsQueryCursor<List<?>> query(org.apache.ignite.cache.query.SqlFieldsQuery qry)
      Specified by:
      query in interface org.apache.ignite.client.IgniteClient

    • transactions

      public org.apache.ignite.client.ClientTransactions transactions()
      Specified by:
      transactions in interface org.apache.ignite.client.IgniteClient

    • compute

      public org.apache.ignite.client.ClientCompute compute()
      Specified by:
      compute in interface org.apache.ignite.client.IgniteClient

    • compute

      public org.apache.ignite.client.ClientCompute compute(org.apache.ignite.client.ClientClusterGroup grp)
      Specified by:
      compute in interface org.apache.ignite.client.IgniteClient

    • cluster

      public org.apache.ignite.client.ClientCluster cluster()
      Specified by:
      cluster in interface org.apache.ignite.client.IgniteClient

    • services

      public org.apache.ignite.client.ClientServices services()
      Specified by:
      services in interface org.apache.ignite.client.IgniteClient

    • services

      public org.apache.ignite.client.ClientServices services(org.apache.ignite.client.ClientClusterGroup grp)
      Specified by:
      services in interface org.apache.ignite.client.IgniteClient

    • atomicLong

      public org.apache.ignite.client.ClientAtomicLong atomicLong(String name, long initVal, boolean create)
      Specified by:
      atomicLong in interface org.apache.ignite.client.IgniteClient

    • atomicLong

      public org.apache.ignite.client.ClientAtomicLong atomicLong(String name, org.apache.ignite.client.ClientAtomicConfiguration cfg, long initVal, boolean create)
      Specified by:
      atomicLong in interface org.apache.ignite.client.IgniteClient

    • set

      public <T> org.apache.ignite.client.ClientIgniteSet<T> set(String name, org.apache.ignite.client.ClientCollectionConfiguration cfg)
      Specified by:
      set in interface org.apache.ignite.client.IgniteClient

    • atomicSequence

      public org.apache.ignite.client.ClientAtomicSequence atomicSequence(String name, long initVal, boolean create) throws org.apache.ignite.IgniteException
      Specified by:
      atomicSequence in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.IgniteException

    • atomicSequence

      public org.apache.ignite.client.ClientAtomicSequence atomicSequence(String name, org.apache.ignite.client.ClientAtomicConfiguration cfg, long initVal, boolean create) throws org.apache.ignite.IgniteException
      Specified by:
      atomicSequence in interface org.apache.ignite.client.IgniteClient
      Throws:
      org.apache.ignite.IgniteException

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface org.apache.ignite.client.IgniteClient