Skip to content
Snippets Groups Projects
Commit c797b35a authored by gwen-soleil's avatar gwen-soleil
Browse files

formatting

parent a8d3c4cf
No related branches found
No related tags found
No related merge requests found
......@@ -23,70 +23,32 @@ Sample code to register an attribute and insert a value:
```java
// build database connection
DatabaseConnectionConfig config = new DatabaseConnectionConfig();
config.
setName("tts");
config.
setHost("test-postgres-01");
config.
setDbType(DatabaseConnectionConfig.DataBaseType.POSTGRESQL);
config.
setName("tts");
config.
setUser("tts");
config.
setPassword("tts");
config.
setPort("5432");
config.
setConnectionTimeout(10000);
config.
setIdleTimeout(10000);
config.
setMaxPoolSize(90);
config.setName("tts");
config.setHost("test-postgres-01");
config.setDbType(DatabaseConnectionConfig.DataBaseType.POSTGRESQL);
config.setName("tts");
config.setUser("tts");
config.setPassword("tts");
config.setPort("5432");
config.setConnectionTimeout(10000);
config.setIdleTimeout(10000);
config.setMaxPoolSize(90);
// start an new attribute in periodic mode
final TangoArchivingInserterService insertService = new TangoArchivingServicesBuilder().buildInserter(config);
InsertionModes insertionModes = new InsertionModes();
insertionModes.
setPeriodic(true);
insertionModes.
setPeriodPeriodic(124);
insertService.
registerAttribute("archiving/source/tangotest.1/double_scalar",insertionModes, "archiving/archiver/1",0);
insertionModes.setPeriodic(true);
insertionModes.setPeriodPeriodic(124);
insertService.registerAttribute("archiving/source/tangotest.1/double_scalar",insertionModes, "archiving/archiver/1",0);
// insert a value
AttributeEvent event = new AttributeEvent();
event.
setDataTime(Timestamp.from(Instant.now()));
event.
setQuality(1);
event.
setFullName("archiving/source/tangotest.1/double_scalar");
event.
setValueR(1);
event.
setValueR(2);
insertService.
insertAttribute(event, AttrDataFormat.SCALAR, false);
event.setDataTime(Timestamp.from(Instant.now()));
event.setQuality(1);
event.setFullName("archiving/source/tangotest.1/double_scalar");
event.setValueR(1);
event.setValueR(2);
insertService.insertAttribute(event, AttrDataFormat.SCALAR, false);
```
### Tango data Fetching
......@@ -122,51 +84,27 @@ archiver)
```java
DatabaseConnectionConfig config = new DatabaseConnectionConfig();
config.
setName("tts");
config.
setHost("postgres-01");
config.
setUser("tts");
config.
setPassword("tts");
config.
setDbType(DatabaseConnectionConfig.DataBaseType.POSTGRESQL);
config.setName("tts");
config.setHost("postgres-01");
config.setUser("tts");
config.setPassword("tts");
config.setDbType(DatabaseConnectionConfig.DataBaseType.POSTGRESQL);
TangoArchiverProperties properties = new TangoArchiverProperties();
properties.
setArchiverClassName("TimeseriesArchiver");
properties.setArchiverClassName("TimeseriesArchiver");
TangoArchivingSystemConfigurationService service = new TangoArchivingSystemConfigurationBuilder().build(config, properties);
service.
updateArchiversList();
service.updateArchiversList();
ArchivingConfigs archivingConfigs = new ArchivingConfigs();
ArchivingConfig config = new ArchivingConfig();
AttributeConfig attributeConfig = new AttributeConfig();
InsertionModes modes = new InsertionModes();
modes.
setPeriodic(true);
modes.
setPeriodPeriodic(100);
config.
setModes(modes);
config.
setAttributeConfig(attributeConfig);
archivingConfigs.
addConfiguration(config);
modes.setPeriodic(true);
modes.setPeriodPeriodic(100);
config.setModes(modes);
config.setAttributeConfig(attributeConfig);
archivingConfigs.addConfiguration(config);
Map<String, ArchivingConfigs> result = service.startArchiving(archivingConfigs);
```
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment