Romeh’s gists

Romeh / Job.java

Created November 14, 2017 12:51

	import lombok.*;
	import org.apache.ignite.cache.query.annotations.QuerySqlField;

	//Sample job model
	@Builder
	@Getter
	@Setter
	@ToString
	@EqualsAndHashCode
	public class Job {

Romeh / JobsInterceptor.java

Created November 14, 2017 12:53

	import org.apache.ignite.Ignite;
	import org.apache.ignite.cache.CacheInterceptorAdapter;
	import org.apache.ignite.cluster.ClusterNode;
	import org.apache.ignite.resources.IgniteInstanceResource;
	import org.jetbrains.annotations.Nullable;

	import javax.cache.Cache;

	import static com.romeh.failover.demo.CacheNames.ICEP_JOBS;

Romeh / NodesInterceptor.java

Created November 14, 2017 12:54

	mport org.apache.ignite.Ignite;
	import org.apache.ignite.IgniteCache;
	import org.apache.ignite.cache.CacheInterceptorAdapter;
	import org.apache.ignite.cache.query.SqlQuery;
	import org.apache.ignite.cluster.ClusterNode;
	import org.apache.ignite.resources.IgniteInstanceResource;
	import org.jetbrains.annotations.Nullable;

	import javax.cache.Cache;

Romeh / IgniteCluster.xml

Created November 14, 2017 12:56

IgniteCluster.xml

Romeh / NodeApp.java

Created November 14, 2017 13:00

	import org.apache.ignite.*;
	import org.apache.ignite.events.DiscoveryEvent;
	import org.apache.ignite.events.EventType;

	import javax.cache.expiry.CreatedExpiryPolicy;
	import javax.cache.expiry.Duration;


	public class NodeApp {

Romeh / AlertEntry.java

Last active November 17, 2017 15:43

	@Builder
	@Getter
	@Setter
	@ToString
	@EqualsAndHashCode
	public class AlertEntry implements Serializable {
	@ApiModelProperty(notes = "the key value alert content for error description required to be entered by user into REST API ", required = true)
	@NotNull
	private Map<String,String> alertContent;
	@ApiModelProperty(notes = "alert error code required to be entered by user into REST API ", required = true)

Romeh / igniteConfig.java

Created November 17, 2017 15:00

	@Configuration
	public class AlertManagerConfiguration {

	@Value("${mail.service.baseUrl}")
	private String baseUrl;
	@Value("${mail.service.user}")
	private String user;
	@Value("${mail.service.password}")
	private String password;
	@Value("${enableFilePersistence}")

Romeh / ThreadSafeUpdate.java

Created November 17, 2017 15:02

	@Override
	public void updateAlertEntry(String serviceId, String serviceCode, AlertEntry alertEntry) {
	final IgniteCache<String, AlertEntry> alertsCache = getAlertsCache();
	// update the alert entry via cache invoke for atomicity
	alertsCache.invoke(alertEntry.getAlertId(), (mutableEntry, objects) -> {
	if (mutableEntry.exists() && mutableEntry.getValue() != null) {
	logger.debug("updating alert entry into the cache store invoke: {},{}", serviceId, serviceCode);
	mutableEntry.setValue(alertEntry);
	} else {
	throw new ResourceNotFoundException(String.format("Alert for %s with %s not found", serviceId, serviceCode));

Romeh / SqlQuery.java

Created November 17, 2017 15:04

	@Override
	public List<AlertEntry> getAlertForServiceId(String serviceId) {
	final String sql = "serviceId = ?";
	// create the sql query object with entity type of the value part of the key value cache
	SqlQuery<String, AlertEntry> query = new SqlQuery<>(AlertEntry.class, sql);
	// set the query params
	query.setArgs(serviceId);
	//then execute it over the cache
	return Optional.ofNullable(getAlertsCache().query(query).getAll().stream().map(stringAlertEntryEntry -> stringAlertEntryEntry.getValue()).collect(Collectors.toList()))
	.orElseThrow(() -> new ResourceNotFoundException(String.format("Alert for %s not found", serviceId)));

Romeh / DurableMemoryConfig.java

Created November 17, 2017 15:05

	// durable file memory persistence
	if(enableFilePersistence){
	PersistentStoreConfiguration persistentStoreConfiguration = new PersistentStoreConfiguration();
	persistentStoreConfiguration.setPersistentStorePath("./data/store");
	persistentStoreConfiguration.setWalArchivePath("./data/walArchive");
	persistentStoreConfiguration.setWalStorePath("./data/walStore");
	igniteConfiguration.setPersistentStoreConfiguration(persistentStoreConfiguration);
	}

MRomeh Romeh