Auditing

Auditing capabilities of GridGain are based on the event functionality. All user actions trigger specific events. The events contain the information about the user and the data that was accessed or modified by the action. You can track the events and export them into an external system.

You can use an event listener to listen to events, or you can create a custom event storage. On this page, we provide an example of an event storage that outputs information about events to System.out.

Enabling Events

Decide which actions you want to track and enable the corresponding event types. We recommend enabling only the specific events you really need. Too many events can have an impact on the performance of the cluster. The events must be enabled on every server node.

<bean class="org.apache.ignite.configuration.IgniteConfiguration">

    <property name="includeEventTypes">
        <list>
            <util:constant static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_PUT"/>
            <util:constant static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_REMOVED"/>
        </list>
    </property>

</bean>

IgniteConfiguration cfg = new IgniteConfiguration();
cfg.setIncludeEventTypes(
    EventType.EVT_CACHE_OBJECT_PUT,
    EventType.EVT_CACHE_OBJECT_REMOVED);

var cfg = new IgniteConfiguration
{
    IncludedEventTypes = new[]
    {
        EventType.CacheObjectPut,
        EventType.CacheObjectRemoved
    }
};

This API is not presently available for C++. You can use XML configuration.

Custom Event Storage

Implement a custom event storage and specify it in the node configuration. The storage does not have to store events, it can simply output the information to the log or export into an external system. The implementation will receive all events in the record() method.

The following example outputs the information about the event to console.

package com.gridgain.snippets;

import java.util.Collection;

import org.apache.ignite.IgniteLogger;
import org.apache.ignite.events.CacheEvent;
import org.apache.ignite.events.Event;
import org.apache.ignite.lang.IgnitePredicate;
import org.apache.ignite.plugin.security.SecuritySubject;
import org.apache.ignite.resources.LoggerResource;
import org.apache.ignite.spi.IgniteSpiAdapter;
import org.apache.ignite.spi.IgniteSpiException;
import org.apache.ignite.spi.IgniteSpiMultipleInstancesSupport;
import org.apache.ignite.spi.eventstorage.EventStorageSpi;

@IgniteSpiMultipleInstancesSupport(true)
public class CustomEventStorage extends IgniteSpiAdapter implements EventStorageSpi {

    public CustomEventStorage() {
    }

    @LoggerResource
    private IgniteLogger log;

    @Override
    public <T extends Event> Collection<T> localEvents(IgnitePredicate<T> p) {
        return null;
    }

    @Override
    public void record(Event evt) throws IgniteSpiException {

        if (evt instanceof CacheEvent) {
            CacheEvent e = (CacheEvent) evt;
            SecuritySubject subj = e.subjectId() != null ? getSpiContext().authenticatedSubject(e.subjectId()) : null;
            System.out.format("user = %s;", subj.login());

        }
        System.out.println("  " + evt.name() + ";");
    }

    @Override
    public void spiStop() throws IgniteSpiException {

    }

    @Override
    public void spiStart(String igniteInstanceName) throws IgniteSpiException {

    }
}

This API is not presently available for C#/.NET.

This API is not presently available for C++.

Specify your event storage class in the node configuration. The storage class must be available in the node’s classpath.

<bean class="org.apache.ignite.configuration.IgniteConfiguration">

    <property name="includeEventTypes">
        <list>
            <util:constant static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_PUT"/>
            <util:constant static-field="org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_REMOVED"/>
        </list>
    </property>

    <property name="eventStorageSpi">
        <!-- Insert the name of your implementation here. -->
        <bean class="com.gridgain.snippets.CustomEventStorage"/>
    </property>
</bean>

IgniteConfiguration cfg = new IgniteConfiguration();
cfg.setEventStorageSpi(new CustomEventStorage());

This API is not presently available for C#/.NET. You can use XML configuration.

This API is not presently available for C++. You can use XML configuration.

All nodes started with the above configuration will output the information about the “cache put” and “cache remove” events.

Identifying the User

If your cluster is protected by authentication, you can get the user name from the subjectID of an event. Note that subjectID may be not available in some events.

The following piece of code illustrates how to obtain the user name:

GridGain gg = ignite.plugin(GridGain.PLUGIN_NAME);

IgniteEvents events = ignite.events();

events.remoteListenAsync(new IgniteBiPredicate<UUID, CacheEvent>() {

    @Override
    public boolean apply(UUID uuid, CacheEvent e) {

        UUID subjectId = e.subjectId();

        if (subjectId != null) {
            // getting the user name
            SecuritySubject subj = gg.security().authenticatedSubject(subjectId);
            System.out.format("User '%s' executed operation %s on cache '%s'\n", subj.login(), e.name(),
                    e.cacheName());
        } else {
            System.out.println(e.toString());
        }
        return true;
    }

}, null, EventType.EVT_CACHE_OBJECT_PUT, EventType.EVT_CACHE_OBJECT_REMOVED);

© 2024 GridGain Systems, Inc. All Rights Reserved. Privacy Policy | Legal Notices. GridGain® is a registered trademark of GridGain Systems, Inc.
Apache, Apache Ignite, the Apache feather and the Apache Ignite logo are either registered trademarks or trademarks of The Apache Software Foundation.

Last updated on Nov 20, 2024