io.micronaut.ignite

Class IgniteThinSyncCache

java.lang.Object

io.micronaut.ignite.IgniteThinSyncCache

All Implemented Interfaces:

io.micronaut.cache.Cache<org.apache.ignite.client.ClientCache>, io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

public class IgniteThinSyncCache
extends java.lang.Object
implements io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

Constructor Summary

Constructors

Constructor and Description
IgniteThinSyncCache(io.micronaut.core.convert.ConversionService<?> conversionService, java.util.concurrent.ExecutorService executorService, org.apache.ignite.client.ClientCache nativeCache)

Method Summary

Modifier and Type	Method and Description
<T> java.util.Optional<T>	get(java.lang.Object key, io.micronaut.core.type.Argument<T> requiredType)
<T> T	get(java.lang.Object key, io.micronaut.core.type.Argument<T> requiredType, java.util.function.Supplier<T> supplier)
java.util.concurrent.ExecutorService	getExecutorService()
java.lang.String	getName()
org.apache.ignite.client.ClientCache	getNativeCache()
void	invalidate(java.lang.Object key)
void	invalidateAll()
void	put(java.lang.Object key, java.lang.Object value)
<T> java.util.Optional<T>	putIfAbsent(java.lang.Object key, T value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.cache.SyncCache

async, get, get, putIfAbsent

Methods inherited from interface io.micronaut.cache.Cache

getCacheInfo

Constructor Detail

IgniteThinSyncCache

public IgniteThinSyncCache(io.micronaut.core.convert.ConversionService<?> conversionService,
                           java.util.concurrent.ExecutorService executorService,
                           org.apache.ignite.client.ClientCache nativeCache)

Method Detail

getExecutorService

@Nullable
public java.util.concurrent.ExecutorService getExecutorService()

Specified by:

getExecutorService in interface io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

get

@NonNull
public <T> java.util.Optional<T> get(@NonNull
                                              java.lang.Object key,
                                              @NonNull
                                              io.micronaut.core.type.Argument<T> requiredType)

Specified by:

get in interface io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

get

public <T> T get(@NonNull
                 java.lang.Object key,
                 @NonNull
                 io.micronaut.core.type.Argument<T> requiredType,
                 @NonNull
                 java.util.function.Supplier<T> supplier)

Specified by:

get in interface io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

putIfAbsent

@NonNull
public <T> java.util.Optional<T> putIfAbsent(@NonNull
                                                      java.lang.Object key,
                                                      @NonNull
                                                      T value)

Specified by:

putIfAbsent in interface io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

put

public void put(@NonNull
                java.lang.Object key,
                @NonNull
                java.lang.Object value)

Specified by:

put in interface io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

invalidate

public void invalidate(@NonNull
                       java.lang.Object key)

Specified by:

invalidate in interface io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

invalidateAll

public void invalidateAll()

Specified by:

invalidateAll in interface io.micronaut.cache.SyncCache<org.apache.ignite.client.ClientCache>

getName

public java.lang.String getName()

Specified by:

getName in interface io.micronaut.cache.Cache<org.apache.ignite.client.ClientCache>

getNativeCache

public org.apache.ignite.client.ClientCache getNativeCache()

Specified by:

getNativeCache in interface io.micronaut.cache.Cache<org.apache.ignite.client.ClientCache>