blob: 17a64b27c2668a75d834ff9f2fbeeee1e9b28570 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.ignite.client;
import java.util.Collection;
import java.util.Set;
import org.apache.ignite.cache.query.ContinuousQuery;
import org.apache.ignite.cache.query.Query;
import org.apache.ignite.cache.query.SqlFieldsQuery;
import org.apache.ignite.cluster.ClusterState;
/**
* Client operation type.
*/
public enum ClientOperationType {
/**
* Create cache ({@link IgniteClient#createCache(String)},
* {@link IgniteClient#createCache(ClientCacheConfiguration)}).
*/
CACHE_CREATE,
/**
* Get or create cache ({@link IgniteClient#getOrCreateCache(String)},
* {@link IgniteClient#getOrCreateCache(ClientCacheConfiguration)}).
*/
CACHE_GET_OR_CREATE,
/**
* Get cache names ({@link IgniteClient#cacheNames()}).
*/
CACHE_GET_NAMES,
/**
* Destroy cache ({@link IgniteClient#destroyCache(String)}).
*/
CACHE_DESTROY,
/**
* Get value from cache ({@link ClientCache#get(Object)}).
*/
CACHE_GET,
/**
* Put value to cache ({@link ClientCache#put(Object, Object)}).
*/
CACHE_PUT,
/**
* Determines if the cache contains a key ({@link ClientCache#containsKey(Object)}).
*/
CACHE_CONTAINS_KEY,
/**
* Determines if the cache contains multiple keys ({@link ClientCache#containsKeys}).
*/
CACHE_CONTAINS_KEYS,
/**
* Get cache configuration ({@link ClientCache#getConfiguration()}).
*/
CACHE_GET_CONFIGURATION,
/**
* Get cache size ({@link ClientCache#size}).
*/
CACHE_GET_SIZE,
/**
* Put values to cache ({@link ClientCache#putAll}).
*/
CACHE_PUT_ALL,
/**
* Get values from cache ({@link ClientCache#getAll}).
*/
CACHE_GET_ALL,
/**
* Replace cache value ({@link ClientCache#replace(Object, Object)},
* {@link ClientCache#replace(Object, Object, Object)}).
*/
CACHE_REPLACE,
/**
* Remove entry from cache ({@link ClientCache#remove(Object)}, {@link ClientCache#remove(Object, Object)}).
*/
CACHE_REMOVE_ONE,
/**
* Remove entries from cache ({@link ClientCache#removeAll(Set)}).
*/
CACHE_REMOVE_MULTIPLE,
/**
* Remove everything from cache ({@link ClientCache#removeAll()}).
*/
CACHE_REMOVE_EVERYTHING,
/**
* Clear cache entry ({@link ClientCache#clear(Object)} ).
*/
CACHE_CLEAR_ONE,
/**
* Clear multiple cache entries ({@link ClientCache#clearAll(Set)}).
*/
CACHE_CLEAR_MULTIPLE,
/**
* Clear entire cache ({@link ClientCache#clear()}).
*/
CACHE_CLEAR_EVERYTHING,
/**
* Get and put ({@link ClientCache#getAndPut(Object, Object)}).
*/
CACHE_GET_AND_PUT,
/**
* Get and remove ({@link ClientCache#getAndRemove(Object)}).
*/
CACHE_GET_AND_REMOVE,
/**
* Get and replace ({@link ClientCache#getAndReplace(Object, Object)}).
*/
CACHE_GET_AND_REPLACE,
/**
* Put if absent ({@link ClientCache#putIfAbsent(Object, Object)}).
*/
CACHE_PUT_IF_ABSENT,
/**
* Get and put if absent ({@link ClientCache#getAndPutIfAbsent(Object, Object)}).
*/
CACHE_GET_AND_PUT_IF_ABSENT,
/**
* Scan query ({@link ClientCache#query(Query)}).
*/
QUERY_SCAN,
/**
* SQL query ({@link ClientCache#query(SqlFieldsQuery)}).
*/
QUERY_SQL,
/**
* Continuous query ({@link ClientCache#query(ContinuousQuery, ClientDisconnectListener)}).
*/
QUERY_CONTINUOUS,
/**
* Index query ({@link ClientCache#query(Query)}).
*/
QUERY_INDEX,
/**
* Start transaction ({@link ClientTransactions#txStart}).
*/
TRANSACTION_START,
/**
* Get cluster state ({@link ClientCluster#state()}).
*/
CLUSTER_GET_STATE,
/**
* Change cluster state ({@link ClientCluster#state(ClusterState)}).
*/
CLUSTER_CHANGE_STATE,
/**
* Get cluster WAL state ({@link ClientCluster#isWalEnabled(String)}).
*/
CLUSTER_GET_WAL_STATE,
/**
* Change cluster WAL state ({@link ClientCluster#enableWal(String)}, {@link ClientCluster#disableWal(String)}).
*/
CLUSTER_CHANGE_WAL_STATE,
/**
* Get cluster nodes ({@link ClientCluster#nodes()}).
*/
CLUSTER_GROUP_GET_NODES,
/**
* Execute compute task ({@link ClientCompute#execute(String, Object)}).
*/
COMPUTE_TASK_EXECUTE,
/**
* Invoke service.
*/
SERVICE_INVOKE,
/**
* Get service descriptors ({@link ClientServices#serviceDescriptors()}).
*/
SERVICE_GET_DESCRIPTORS,
/**
* Get service descriptor ({@link ClientServices#serviceDescriptor(String)}).
*/
SERVICE_GET_DESCRIPTOR,
/**
* Get or create an AtomicLong ({@link IgniteClient#atomicLong(String, long, boolean)},
* {@link IgniteClient#atomicLong(String, ClientAtomicConfiguration, long, boolean)}).
*/
ATOMIC_LONG_CREATE,
/**
* Remove an AtomicLong ({@link ClientAtomicLong#close()}).
*/
ATOMIC_LONG_REMOVE,
/**
* Check if AtomicLong exists ({@link ClientAtomicLong#removed()}).
*/
ATOMIC_LONG_EXISTS,
/**
* AtomicLong.get ({@link ClientAtomicLong#get()}).
*/
ATOMIC_LONG_VALUE_GET,
/**
* AtomicLong.addAndGet (includes {@link ClientAtomicLong#addAndGet(long)}, {@link ClientAtomicLong#incrementAndGet()},
* {@link ClientAtomicLong#getAndIncrement()}, {@link ClientAtomicLong#getAndAdd(long)}, {@link ClientAtomicLong#decrementAndGet()},
* {@link ClientAtomicLong#getAndDecrement()}).
*/
ATOMIC_LONG_VALUE_ADD_AND_GET,
/**
* AtomicLong.getAndSet ({@link ClientAtomicLong#getAndSet(long)}).
*/
ATOMIC_LONG_VALUE_GET_AND_SET,
/**
* AtomicLong.compareAndSet ({@link ClientAtomicLong#compareAndSet(long, long)}).
*/
ATOMIC_LONG_VALUE_COMPARE_AND_SET,
/**
* Create an IgniteSet ({@link IgniteClient#set(String, ClientCollectionConfiguration)}).
*/
SET_GET_OR_CREATE,
/**
* Remove an IgniteSet ({@link ClientIgniteSet#close()}).
*/
SET_REMOVE,
/**
* Check if IgniteSet exists ({@link ClientIgniteSet#removed()}).
*/
SET_EXISTS,
/**
* IgniteSet.add ({@link ClientIgniteSet#add(Object)}).
*/
SET_VALUE_ADD,
/**
* IgniteSet.addAll ({@link ClientIgniteSet#addAll(Collection)}).
*/
SET_VALUE_ADD_ALL,
/**
* IgniteSet.remove ({@link ClientIgniteSet#remove}).
*/
SET_VALUE_REMOVE,
/**
* IgniteSet.removeAll ({@link ClientIgniteSet#removeAll}).
*/
SET_VALUE_REMOVE_ALL,
/**
* IgniteSet.contains ({@link ClientIgniteSet#contains(Object)}).
*/
SET_VALUE_CONTAINS,
/**
* IgniteSet.containsAll ({@link ClientIgniteSet#containsAll}).
*/
SET_VALUE_CONTAINS_ALL,
/**
* IgniteSet.retainAll ({@link ClientIgniteSet#retainAll}).
*/
SET_VALUE_RETAIN_ALL,
/**
* IgniteSet.size ({@link ClientIgniteSet#size()}).
*/
SET_SIZE,
/**
* IgniteSet.clear ({@link ClientIgniteSet#clear()}).
*/
SET_CLEAR,
/**
* IgniteSet.iterator ({@link ClientIgniteSet#iterator()}, {@link ClientIgniteSet#toArray()}).
*/
SET_ITERATOR
}