A B C D E F G H I J L O P R S T W
All Classes All Packages

A

accept(List<T>) - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue.HBCacheEvictOperation

accept(List<T>) - Method in class org.alfresco.heartbeat.datasender.internal.HBDataConsumer

accumulator() - Method in class org.alfresco.heartbeat.datasender.internal.stream.BatchCollector

add(T) - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

addAll(List<T>) - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

B

batchCollector(int, Consumer<List<T>>) - Static method in class org.alfresco.heartbeat.datasender.internal.stream.StreamUtils

Creates a new batch collector

BatchCollector<T> - Class in org.alfresco.heartbeat.datasender.internal.stream

Collects elements in the stream and calls the supplied batch processor after the configured batch size is reached.

build() - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceBuilder

builder() - Static method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceBuilder

C

cache - Variable in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

characteristics() - Method in class org.alfresco.heartbeat.datasender.internal.stream.BatchCollector

clear() - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

COLLECTOR_ID_KEY - Static variable in class org.alfresco.heartbeat.datasender.HBData

COLLECTOR_VERSION_KEY - Static variable in class org.alfresco.heartbeat.datasender.HBData

combiner() - Method in class org.alfresco.heartbeat.datasender.internal.stream.BatchCollector

D

DATA_KEY - Static variable in class org.alfresco.heartbeat.datasender.HBData

DATE_FORMAT - Static variable in class org.alfresco.heartbeat.datasender.util.JsonUtil

E

enable(boolean) - Method in interface org.alfresco.heartbeat.datasender.HBDataSenderService

Enables or disables the heartbeat sending data process.

enable(boolean) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceBuilder

enable(boolean) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

execute(JobExecutionContext) - Method in class org.alfresco.heartbeat.datasender.internal.schedule.HBDataSenderJob

F

finisher() - Method in class org.alfresco.heartbeat.datasender.internal.stream.BatchCollector

G

getCacheCount() - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

getCollectorId() - Method in class org.alfresco.heartbeat.datasender.HBData

getCollectorVersion() - Method in class org.alfresco.heartbeat.datasender.HBData

getCronExpression() - Method in class org.alfresco.heartbeat.datasender.internal.schedule.HBSendDataScheduler

getData() - Method in class org.alfresco.heartbeat.datasender.HBData

getHeartBeatIngestionUrl() - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

getScheduler() - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

getSchemaVersion() - Method in class org.alfresco.heartbeat.datasender.HBData

getSystemId() - Method in class org.alfresco.heartbeat.datasender.HBData

getTarget() - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceBuilder

getTimestamp() - Method in class org.alfresco.heartbeat.datasender.HBData

H

HBCacheEvictOperation(Queue<T>) - Constructor for class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue.HBCacheEvictOperation

HBData - Class in org.alfresco.heartbeat.datasender

Heartbeat data collector bean

HBData(String, String, String, Date) - Constructor for class org.alfresco.heartbeat.datasender.HBData

HBData(String, String, String, Date, Map<String, Object>) - Constructor for class org.alfresco.heartbeat.datasender.HBData

HBDataCacheQueue<T> - Class in org.alfresco.heartbeat.datasender.internal

Heartbeat cache implementation - data is consumed in batches and after that evicted from the cache.

HBDataCacheQueue() - Constructor for class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

HBDataCacheQueue.HBCacheEvictOperation - Class in org.alfresco.heartbeat.datasender.internal

Functional consumer that removes a batch of entries from the cache

HBDataConsumer<T> - Class in org.alfresco.heartbeat.datasender.internal

Process/consume operation for heartbeat data (see HBData).

HBDataConsumer(String) - Constructor for class org.alfresco.heartbeat.datasender.internal.HBDataConsumer

HBDataSenderException - Exception in org.alfresco.heartbeat.datasender

Heartbeat sending data exception

HBDataSenderException(String) - Constructor for exception org.alfresco.heartbeat.datasender.HBDataSenderException

HBDataSenderException(String, Throwable) - Constructor for exception org.alfresco.heartbeat.datasender.HBDataSenderException

HBDataSenderJob - Class in org.alfresco.heartbeat.datasender.internal.schedule

Simple Quartz job that executes a scheduled heartbeat data processing.

HBDataSenderJob() - Constructor for class org.alfresco.heartbeat.datasender.internal.schedule.HBDataSenderJob

HBDataSenderService - Interface in org.alfresco.heartbeat.datasender

Service dealing with sending collected data to the Heartbeat server.

HBDataSenderServiceBuilder - Class in org.alfresco.heartbeat.datasender

Data sender service builder.

HBDataSenderServiceImpl - Class in org.alfresco.heartbeat.datasender

Heartbeat Data Sender service implementation - collected data is sent to an ingestion endpoint (AWS).

HBDataSenderServiceImpl() - Constructor for class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

HBSendDataScheduler - Class in org.alfresco.heartbeat.datasender.internal.schedule

Schedule/start/stop the heartbeat sender job.

HBSendDataScheduler(HBDataSenderService, CronExpression) - Constructor for class org.alfresco.heartbeat.datasender.internal.schedule.HBSendDataScheduler

I

isTargetAvailable() - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

J

JsonUtil - Class in org.alfresco.heartbeat.datasender.util

JSON serialization/deserialization helper class, it uses a pre-configured object mapper, making it easier to control the format of the data being sent to the Heartbeat server.

L

loadCache() - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

O

org.alfresco.heartbeat.datasender - package org.alfresco.heartbeat.datasender

org.alfresco.heartbeat.datasender.internal - package org.alfresco.heartbeat.datasender.internal

org.alfresco.heartbeat.datasender.internal.schedule - package org.alfresco.heartbeat.datasender.internal.schedule

org.alfresco.heartbeat.datasender.internal.stream - package org.alfresco.heartbeat.datasender.internal.stream

org.alfresco.heartbeat.datasender.util - package org.alfresco.heartbeat.datasender.util

P

persistCache() - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

process() - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

Process the data in batches.

process(int, Consumer<List<T>>) - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

Data is consumed in batches; if the processing is successful, the batch is removed from the cache.

process(Consumer<List<HBData>>) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

Process the data in batches with a given consumer.

R

removeAll(List<T>) - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

S

scheduleJob() - Method in class org.alfresco.heartbeat.datasender.internal.schedule.HBSendDataScheduler

Triggers the job that sends the heartbeat data to the server.

SCHEMA_VERSION - Static variable in class org.alfresco.heartbeat.datasender.HBData

SCHEMA_VERSION_KEY - Static variable in class org.alfresco.heartbeat.datasender.HBData

sendData(List<HBData>) - Method in interface org.alfresco.heartbeat.datasender.HBDataSenderService

Sends a list of heartbeat collected data to the Heartbeat server

sendData(List<HBData>) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

sendData(HBData) - Method in interface org.alfresco.heartbeat.datasender.HBDataSenderService

Sends heartbeat collected data to the Heartbeat server

sendData(HBData) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

setBatchSize(int) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

setCacheMaxEntries(long) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

setCollectorId(String) - Method in class org.alfresco.heartbeat.datasender.HBData

setCollectorVersion(String) - Method in class org.alfresco.heartbeat.datasender.HBData

setData(Map<String, Object>) - Method in class org.alfresco.heartbeat.datasender.HBData

setHeartBeatUrl(String) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

setMaxEntries(long) - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

setScheduler(HBSendDataScheduler) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceImpl

setSchemaVersion(String) - Method in class org.alfresco.heartbeat.datasender.HBData

setSystemId(String) - Method in class org.alfresco.heartbeat.datasender.HBData

setTimestamp(Date) - Method in class org.alfresco.heartbeat.datasender.HBData

size() - Method in class org.alfresco.heartbeat.datasender.internal.HBDataCacheQueue

stopJob() - Method in class org.alfresco.heartbeat.datasender.internal.schedule.HBSendDataScheduler

StreamUtils - Class in org.alfresco.heartbeat.datasender.internal.stream

supplier() - Method in class org.alfresco.heartbeat.datasender.internal.stream.BatchCollector

SYSTEM_ID_KEY - Static variable in class org.alfresco.heartbeat.datasender.HBData

T

TIMESTAMP_KEY - Static variable in class org.alfresco.heartbeat.datasender.HBData

W

withHeartbeatURL(String) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceBuilder

withSendingSchedule(String) - Method in class org.alfresco.heartbeat.datasender.HBDataSenderServiceBuilder

writeValueAsBytes(Object) - Static method in class org.alfresco.heartbeat.datasender.util.JsonUtil

A B C D E F G H I J L O P R S T W
All Classes All Packages