replication-processor-ts/processor.ttl at main · rdf-connect/replication-processor-ts · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
@prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#>.
@prefix owl: <http://www.w3.org/2002/07/owl#>.
@prefix rdfc: <https://w3id.org/rdf-connect#>.
@prefix xsd: <http://www.w3.org/2001/XMLSchema#>.
@prefix sh: <http://www.w3.org/ns/shacl#>.

### WriteReplication ###
rdfc:WriteReplication rdfc:jsImplementationOf rdfc:Processor;
    rdfc:file <./lib/index.js>;
    rdfc:class "WriteReplication";
    rdfs:label "Write Replication Processor";
    rdfs:comment "Processor that writes data from an incoming Reader channel to a text file on the filesystem.";
    rdfc:entrypoint <./>.

[ ] a sh:NodeShape;
    sh:targetClass rdfc:WriteReplication;
    sh:property [
        sh:class rdfc:Reader;
        sh:path rdfc:incoming;
        sh:codeIdentifier "incoming";
        sh:name "Incoming stream";
        sh:description "Reader channel IRI that provides the data stream to be written to the text file.";
        sh:maxCount 1;
        sh:minCount 1;
    ], [
        sh:datatype xsd:boolean;
        sh:path rdfc:append;
        sh:codeIdentifier "append";
        sh:name "Append";
        sh:description "Whether to append new replication data to the file. Set to true to append, false (or omitted) to overwrite/create new file.";
        sh:minCount 0;
        sh:maxCount 1;
    ], [
        sh:datatype xsd:string;
        sh:path rdfc:savePath;
        sh:codeIdentifier "savePath";
        sh:name "Save path";
        sh:description "Filesystem path where the processor should save output data (e.g. /tmp/output.replication).";
        sh:minCount 1;
        sh:maxCount 1;
    ], [
        sh:datatype xsd:integer;
        sh:path rdfc:max;
        sh:codeIdentifier "max";
        sh:name "Max records";
        sh:description "Optional integer limit for the maximum number of members to write to the file. If 0, all members are written. Default is 0.";
        sh:minCount 0;
        sh:maxCount 1;
    ].


### ReadReplication ###
rdfc:ReadReplication rdfc:jsImplementationOf rdfc:Processor;
    rdfc:file <./lib/index.js>;
    rdfc:class "ReadReplication";
    rdfs:label "Read Replication Processor";
    rdfs:comment "Processor that reads data from a filesystem text file and writes it to an outgoing Writer channel.";
    rdfc:entrypoint <./>.

[ ] a sh:NodeShape;
    sh:targetClass rdfc:ReadReplication;
    sh:property [
        sh:class rdfc:Writer;
        sh:path rdfc:outgoing;
        sh:codeIdentifier "outgoing";
        sh:name "Outgoing stream";
        sh:description "Writer channel IRI to which the data from the text file is written.";
        sh:maxCount 1;
        sh:minCount 1;
      ], [
        sh:datatype xsd:string;
        sh:path rdfc:savePath;
        sh:codeIdentifier "savePath";
        sh:name "Save path";
        sh:description "Filesystem path where the processor should read from.";
        sh:minCount 1;
        sh:maxCount 1;
    ].