Skip navigation links
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 
Skip navigation links

Copyright © 2019. All rights reserved.