B C D E F G H I L N O P Q R S T U

B

batchSize - Variable in class org.dataone.cn.batch.logging.v1.NodeCommunication

C

ClientNodeService - Class in org.dataone.cn.batch.logging.v1

Manage the D1 client connections The class will pool the connections.

ClientNodeService - Class in org.dataone.cn.batch.logging.v2

Manage the D1 client connections The class will pool the connections.

close() - Method in class org.dataone.cn.batch.logging.GeoIPService

Close the GeoIP lookup service.

CommonsHttpClientProtocolRegistry - Class in org.dataone.solr.client.solrj.impl

CommonsHttpClientProtocolRegistry() - Constructor for class org.dataone.solr.client.solrj.impl.CommonsHttpClientProtocolRegistry

contains(String) - Method in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

A method to determine if an eventKey is present in the cache.

createInstance() - Static method in class org.dataone.solr.client.solrj.impl.CommonsHttpClientProtocolRegistry

D

d1NodeReference - Variable in class org.dataone.cn.batch.logging.v1.NodeCommunication

performs the retrieval of the log records from a DataONE node.

E

entryAdded(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.cn.batch.logging.listener.SystemMetadataEntryListener

entryEvicted(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.cn.batch.logging.listener.SystemMetadataEntryListener

entryRemoved(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.cn.batch.logging.listener.SystemMetadataEntryListener

entryUpdated(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.cn.batch.logging.listener.SystemMetadataEntryListener

execute(JobExecutionContext) - Method in class org.dataone.cn.batch.logging.jobs.LogAggregationHarvestJob

execute(JobExecutionContext) - Method in class org.dataone.cn.batch.logging.jobs.LogAggregrationManageScheduleJob

F

format - Static variable in interface org.dataone.cn.batch.logging.NodeHarvester

G

GeoIPService - Class in org.dataone.cn.batch.logging

Call the GeoLite (www.maxmind.com) database in order to determine a location from an IP address.

getAggregateLogs(NodeReference) - Method in class org.dataone.cn.batch.service.v2.impl.NodeRegistryLogAggregationServiceImpl

getAggregateLogs(NodeReference) - Method in interface org.dataone.cn.batch.service.v2.NodeRegistryLogAggregationService

getAggregateLogs(NodeReference) - Method in class org.dataone.cn.ldap.NodeRegistryLogAggregationFacade

getCity() - Method in class org.dataone.cn.batch.logging.GeoIPService

getCity() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getClientMNode(NodeReference) - Method in class org.dataone.cn.batch.logging.v1.ClientNodeService

getClientMNode(NodeReference) - Method in class org.dataone.cn.batch.logging.v2.ClientNodeService

getCountry() - Method in class org.dataone.cn.batch.logging.GeoIPService

getCountry() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getDateAggregated() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getDateLogged() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getDateUpdated() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getEntryId() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getEvent() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getFormatId() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getFormatType() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getFromDate() - Method in class org.dataone.cn.batch.logging.type.LogQueryDateRange

getGeohash_1() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_2() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_3() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_4() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_5() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_6() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_7() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_8() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getGeohash_9() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getId() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getInFullRobotList() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getInPartialRobotList() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getInstance(String) - Static method in class org.dataone.cn.batch.logging.GeoIPService

getInstance() - Static method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

getInstance() - Static method in class org.dataone.cn.batch.logging.SolrClientManager

getInstance() - Static method in class org.dataone.cn.batch.logging.v1.ClientNodeService

getInstance() - Static method in class org.dataone.cn.batch.logging.v2.ClientNodeService

getIpAddress() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getIsPublic() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getIsRepeatVisit() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getLatitude() - Method in class org.dataone.cn.batch.logging.GeoIPService

getLocation() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getLogLastAggregated(NodeReference) - Method in class org.dataone.cn.batch.service.v2.impl.NodeRegistryLogAggregationServiceImpl

getLogLastAggregated(NodeReference) - Method in interface org.dataone.cn.batch.service.v2.NodeRegistryLogAggregationService

getLogLastAggregated(NodeReference) - Method in class org.dataone.cn.ldap.NodeRegistryLogAggregationFacade

getLongitude() - Method in class org.dataone.cn.batch.logging.GeoIPService

getNode(NodeReference) - Method in class org.dataone.cn.batch.service.v2.impl.NodeRegistryLogAggregationServiceImpl

getNode(NodeReference) - Method in interface org.dataone.cn.batch.service.v2.NodeRegistryLogAggregationService

getNodeHarvester(Node) - Static method in class org.dataone.cn.batch.logging.NodeHarvesterFactory

getNodeIdentifier() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getNodeReference() - Method in interface org.dataone.cn.batch.logging.NodeHarvester

getNodeReference() - Method in class org.dataone.cn.batch.logging.v1.NodeCommunication

getPid() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getReadPermission() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getRegion() - Method in class org.dataone.cn.batch.logging.GeoIPService

getRegion() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getRightsHolder() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getScheduler() - Method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

getSeriesId() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getSize() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getSubject() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getSystemMetadataEntryListener() - Method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

getToDate() - Method in class org.dataone.cn.batch.logging.type.LogQueryDateRange

getUserAgent() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

getVersionCompliance() - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

H

harvest(Stack<LogQueryDateRange>, Integer) - Method in interface org.dataone.cn.batch.logging.NodeHarvester

harvest() - Method in class org.dataone.cn.batch.logging.tasks.LogHarvesterTask

Implement the Callable interface, retrieves logging information from a D1 Node and publishes a List to a hazelcast topic The logging information retrieved will not be for the current day, but for a previous time period

harvest(Stack<LogQueryDateRange>, Integer) - Method in class org.dataone.cn.batch.logging.v1.NodeCommunication

harvest(Stack<LogQueryDateRange>, Integer) - Method in class org.dataone.cn.batch.logging.v2.NodeCommunication

performs the retrieval of the log records from a DataONE node.

I

idMap - Variable in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

init() - Method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

Called by Spring to bootstrap log aggregation it will set up default intervals between job executions for Membernode harvesting it will initialize Quartz it will schedule membernodes for harvesting it also adds a listener for changes in the hazelcast Nodes map and hz partitioner Change in hzNodes or migration of partitions may entail rebalancing of quartz jobs

initLocation(String) - Method in class org.dataone.cn.batch.logging.GeoIPService

Set the location attributes for this object

isLaterOrSameAsLatestCachedTime(DateTime) - Method in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

Useful for checking that log Entries are being processed in chronological order.

isRepeatVisit(String, DateTime) - Method in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

Used to determine if an event is a repeatVisit.

L

listNodes() - Method in class org.dataone.cn.batch.service.v2.impl.NodeRegistryLogAggregationServiceImpl

listNodes() - Method in interface org.dataone.cn.batch.service.v2.NodeRegistryLogAggregationService

log - Static variable in class org.dataone.cn.ldap.NodeRegistryLogAggregationFacade

LogAccessRestriction - Class in org.dataone.cn.batch.logging

Get Access restrictions of Log Records

LogAccessRestriction() - Constructor for class org.dataone.cn.batch.logging.LogAccessRestriction

LogAggregationHarvestJob - Class in org.dataone.cn.batch.logging.jobs

Quartz Job that starts off the execution of harvesting logging for a CN or a Membernode It executes only for a given node, and while executing excludes via a lock any other execution of a job on that membernode Job may not be executed concurrently for a single membernode or coordinating node Keep track of last date harvested

LogAggregationHarvestJob() - Constructor for class org.dataone.cn.batch.logging.jobs.LogAggregationHarvestJob

LogAggregationScheduleManager - Class in org.dataone.cn.batch.logging

The bean must be managed by Spring.

LogAggregationScheduleManager() - Constructor for class org.dataone.cn.batch.logging.LogAggregationScheduleManager

LogAggregrationManageScheduleJob - Class in org.dataone.cn.batch.logging.jobs

LogAggregrationManageScheduleJob() - Constructor for class org.dataone.cn.batch.logging.jobs.LogAggregrationManageScheduleJob

LogEntrySolrItem - Class in org.dataone.cn.batch.logging.type

Allows the LogEntry domain object to be mapped to a Solr POJO

LogEntrySolrItem() - Constructor for class org.dataone.cn.batch.logging.type.LogEntrySolrItem

LogEntrySolrItem(LogEntry) - Constructor for class org.dataone.cn.batch.logging.type.LogEntrySolrItem

LogEntrySolrItem(LogEntry) - Constructor for class org.dataone.cn.batch.logging.type.LogEntrySolrItem

LogHarvesterTask - Class in org.dataone.cn.batch.logging.tasks

A executable task that retrieves a list of LogEntry by calling log on a MN or CN and then publishes them on the LogEntryTopic for processing.

LogHarvesterTask(NodeHarvester) - Constructor for class org.dataone.cn.batch.logging.tasks.LogHarvesterTask

LogQueryDateRange - Class in org.dataone.cn.batch.logging.type

Provide a date range for queries to a logging endpoint Used in conjuction with a stack to keep track of the branch of the query operation

LogQueryDateRange(Date, Date) - Constructor for class org.dataone.cn.batch.logging.type.LogQueryDateRange

N

NodeCommunication - Class in org.dataone.cn.batch.logging.v1

NodeCommunication(NodeReference) - Constructor for class org.dataone.cn.batch.logging.v1.NodeCommunication

NodeCommunication - Class in org.dataone.cn.batch.logging.v2

NodeCommunication(NodeReference) - Constructor for class org.dataone.cn.batch.logging.v2.NodeCommunication

NodeHarvester - Interface in org.dataone.cn.batch.logging

NodeHarvesterFactory - Class in org.dataone.cn.batch.logging

NodeHarvesterFactory() - Constructor for class org.dataone.cn.batch.logging.NodeHarvesterFactory

NodeRegistryLogAggregationFacade - Class in org.dataone.cn.ldap

Extend the NodeFacade class in d1_cn_noderegistery to allow for log aggregation specific behavior Expose public access to protected methods in NodeAccess The public methods will also control the borrowing and returning of LDAPContexts to the LDAP Pool

NodeRegistryLogAggregationFacade() - Constructor for class org.dataone.cn.ldap.NodeRegistryLogAggregationFacade

NodeRegistryLogAggregationService - Interface in org.dataone.cn.batch.service.v2

NodeRegistryLogAggregationServiceImpl - Class in org.dataone.cn.batch.service.v2.impl

Currently the service is handled by a Facade around the NodeRegistry However, when log aggregation is moved to a separate machine other than the CN, the use of ldap will be abandoned.

NodeRegistryLogAggregationServiceImpl() - Constructor for class org.dataone.cn.batch.service.v2.impl.NodeRegistryLogAggregationServiceImpl

O

org.dataone.cn.batch.logging - package org.dataone.cn.batch.logging

org.dataone.cn.batch.logging.exceptions - package org.dataone.cn.batch.logging.exceptions

org.dataone.cn.batch.logging.jobs - package org.dataone.cn.batch.logging.jobs

org.dataone.cn.batch.logging.listener - package org.dataone.cn.batch.logging.listener

org.dataone.cn.batch.logging.tasks - package org.dataone.cn.batch.logging.tasks

org.dataone.cn.batch.logging.type - package org.dataone.cn.batch.logging.type

org.dataone.cn.batch.logging.v1 - package org.dataone.cn.batch.logging.v1

org.dataone.cn.batch.logging.v2 - package org.dataone.cn.batch.logging.v2

org.dataone.cn.batch.service.v2 - package org.dataone.cn.batch.service.v2

org.dataone.cn.batch.service.v2.impl - package org.dataone.cn.batch.service.v2.impl

org.dataone.cn.ldap - package org.dataone.cn.ldap

org.dataone.solr.client.solrj.impl - package org.dataone.solr.client.solrj.impl

P

pruneOutdatedCacheEntries() - Method in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

Removes items from the cache that are more than the configured seconds older than the latest time in the cache.

putEvent(String, DateTime) - Method in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

Puts a read event into the cache, with the same add / replace semantics as Map.put.

Q

QueryLimitException - Exception in org.dataone.cn.batch.logging.exceptions

QueryLimitException() - Constructor for exception org.dataone.cn.batch.logging.exceptions.QueryLimitException

R

ReadEventCounterCache - Class in org.dataone.cn.batch.logging.type

The ReadEventCounterCache is used for detecting "double-clicks" by a user, as defined by Project Counter (see page 7 of https://www.projectcounter.org/wp-content/uploads/2016/03/Technical-pdf.pdf) The default constructor uses the Project Counter standard of 30 seconds to detect double-clicks, but provides a parameterized constructor for flexibility and testing purposes.

ReadEventCounterCache() - Constructor for class org.dataone.cn.batch.logging.type.ReadEventCounterCache

Creates a ReadEventCounterCache with the standard double-click window of 30 seconds.

ReadEventCounterCache(int) - Constructor for class org.dataone.cn.batch.logging.type.ReadEventCounterCache

Creates a ReadEventCounterCache with the specified double-click / repeatVisit time window.

S

scheduleHarvest() - Method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

will perform the initial calculation or the recalculation of the scheduler.

ScheduleManagerException - Exception in org.dataone.cn.batch.logging.exceptions

ScheduleManagerException() - Constructor for exception org.dataone.cn.batch.logging.exceptions.ScheduleManagerException

setAggregateLogs(NodeReference, Boolean) - Method in class org.dataone.cn.batch.service.v2.impl.NodeRegistryLogAggregationServiceImpl

setAggregateLogs(NodeReference, Boolean) - Method in interface org.dataone.cn.batch.service.v2.NodeRegistryLogAggregationService

setAggregateLogs(NodeReference, Boolean) - Method in class org.dataone.cn.ldap.NodeRegistryLogAggregationFacade

setApplicationContext(ApplicationContext) - Method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

setCity(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setCOUNTERfields(ArrayList<String>, ArrayList<String>, HashMap<String, DateTime>, HashSet<String>, int, List<CSVRecord>, Boolean) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setCountry(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setDateAggregated(Date) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setDateLogged(Date) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setDateUpdated(Date) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setEntryId(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setEvent(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setFormatId(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setFormatType(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_1(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_2(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_3(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_4(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_5(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_6(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_7(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_8(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setGeohash_9(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setId(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setInFullRobotList(boolean) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setInPartialRobotList(boolean) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setIpAddress(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setIsPublic(boolean) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setIsRepeatVisit(boolean) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setLocation(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setLogLastAggregated(NodeReference, Date) - Method in class org.dataone.cn.batch.service.v2.impl.NodeRegistryLogAggregationServiceImpl

setLogLastAggregated(NodeReference, Date) - Method in interface org.dataone.cn.batch.service.v2.NodeRegistryLogAggregationService

setLogLastAggregated(NodeReference, Date) - Method in class org.dataone.cn.ldap.NodeRegistryLogAggregationFacade

setNodeIdentifier(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setNodeReference(NodeReference) - Method in interface org.dataone.cn.batch.logging.NodeHarvester

setNodeReference(NodeReference) - Method in class org.dataone.cn.batch.logging.v1.NodeCommunication

setPid(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setReadPermission(List<String>) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setRegion(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setRightsHolder(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setScheduler(Scheduler) - Method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

setSeriesId(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setSize(long) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setSubject(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setSystemMetadataEntryListener(SystemMetadataEntryListener) - Method in class org.dataone.cn.batch.logging.LogAggregationScheduleManager

setUserAgent(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

setVersionCompliance(String) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

size() - Method in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

gets the number of IDs in the Cache

SolrClientManager - Class in org.dataone.cn.batch.logging

STANDARD_COUNTER_INTERVAL_PDF - Static variable in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

start() - Method in class org.dataone.cn.batch.logging.listener.SystemMetadataEntryListener

stop() - Method in class org.dataone.cn.batch.logging.listener.SystemMetadataEntryListener

subjectsAllowedRead(SystemMetadata) - Method in class org.dataone.cn.batch.logging.LogAccessRestriction

submitBeans(NodeReference, List<LogEntrySolrItem>) - Method in class org.dataone.cn.batch.logging.SolrClientManager

SystemMetadataEntryListener - Class in org.dataone.cn.batch.logging.listener

Access to Objects may change Listen to the systemMetadata maps and if the accessibility of the object has changed, then all log records associated with the object must also change All log records will need to be periodically swept for inconsistency should this listener go down

SystemMetadataEntryListener() - Constructor for class org.dataone.cn.batch.logging.listener.SystemMetadataEntryListener

T

timeMap - Variable in class org.dataone.cn.batch.logging.type.ReadEventCounterCache

U

updateLocationFields(GeoIPService) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

updateSysmetaFields(SystemMetadata) - Method in class org.dataone.cn.batch.logging.type.LogEntrySolrItem

B C D E F G H I L N O P Q R S T U