Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion mesh/mesh-light.yaml
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
defaultRegistry: ghcr.io/streamx-dev/streamx-blueprints
defaultImageTag: 2.0.0-jvm
defaultImageTag: 2.0.4-jvm

sources:
pim:
Expand Down
2 changes: 1 addition & 1 deletion mesh/mesh.yaml
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
defaultRegistry: ghcr.io/streamx-dev/streamx-blueprints
defaultImageTag: 2.0.0-jvm
defaultImageTag: 2.0.4-jvm
Comment thread
stan-r-ds marked this conversation as resolved.

sources:
Comment thread
stan-r-ds marked this conversation as resolved.
github:
Expand Down
Original file line number Diff line number Diff line change
@@ -1,39 +1,39 @@
{
"image": "ghcr.io/streamx-dev/streamx-blueprints/composition-engine-processing-service:2.0.0-jvm",
"image": "ghcr.io/streamx-dev/streamx-blueprints/composition-engine-processing-service:2.0.4-jvm",
"type": "processing",
"incoming": [
{
"name": "compositions",
"defaultSchemaId": "Composition_AVROSchema_bbf68f92760c44c80bb9e99920808ce28a13bd7b",
"defaultSchemaId": "Composition_AVROSchema_afd8af57a5cb908807474fe35700ee15543c015b",
"connector": "smallrye-pulsar"
},
{
"name": "layouts",
"defaultSchemaId": "Layout_AVROSchema_1022ea40d231155594d21d20cb51929c7165f11f",
"defaultSchemaId": "Layout_AVROSchema_8e05581e5d57b0d4d0a4ffea8aec65714daa631b",
"connector": "smallrye-pulsar"
},
{
"name": "incoming-page-compose-requests",
"defaultSchemaId": "PageComposeRequest_AVROSchema_9739fd8cbb16d26030fd1ef6b75b79cacbb11b03",
"defaultSchemaId": "PageComposeRequest_AVROSchema_3cf80f80b1b6571632fb372c972714dde3617105",
"connector": "smallrye-pulsar"
}
],
"outgoing": [
{
"name": "outgoing-page-compose-requests",
"defaultSchemaId": "PageComposeRequest_AVROSchema_9739fd8cbb16d26030fd1ef6b75b79cacbb11b03",
"defaultSchemaId": "PageComposeRequest_AVROSchema_3cf80f80b1b6571632fb372c972714dde3617105",
"connector": "smallrye-pulsar"
},
{
"name": "pages",
"defaultSchemaId": "Page_AVROSchema_b0b1294e06f8ab10892594723d6db7b22bae4d40",
"defaultSchemaId": "Page_AVROSchema_b2406fb7f3956ed6535681337ca1bed30ba499bc",
"connector": "smallrye-pulsar"
}
],
"schemas": {
"Layout_AVROSchema_1022ea40d231155594d21d20cb51929c7165f11f": {
"Page_AVROSchema_b2406fb7f3956ed6535681337ca1bed30ba499bc": {
"type": "record",
"name": "Layout",
"name": "Page",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
Expand All @@ -42,9 +42,9 @@
}
]
},
"Page_AVROSchema_b0b1294e06f8ab10892594723d6db7b22bae4d40": {
"Layout_AVROSchema_8e05581e5d57b0d4d0a4ffea8aec65714daa631b": {
"type": "record",
"name": "Page",
"name": "Layout",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
Expand All @@ -53,7 +53,7 @@
}
]
},
"PageComposeRequest_AVROSchema_9739fd8cbb16d26030fd1ef6b75b79cacbb11b03": {
"PageComposeRequest_AVROSchema_3cf80f80b1b6571632fb372c972714dde3617105": {
"type": "record",
"name": "PageComposeRequest",
"namespace": "dev.streamx.blueprints.composition",
Expand All @@ -68,7 +68,7 @@
}
]
},
"Composition_AVROSchema_bbf68f92760c44c80bb9e99920808ce28a13bd7b": {
"Composition_AVROSchema_afd8af57a5cb908807474fe35700ee15543c015b": {
"type": "record",
"name": "Composition",
"namespace": "dev.streamx.blueprints.data",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,27 +1,27 @@
{
"image": "ghcr.io/streamx-dev/streamx-blueprints/data-collector-processing-service:2.0.0-jvm",
"image": "ghcr.io/streamx-dev/streamx-blueprints/data-collector-processing-service:2.0.4-jvm",
"type": "processing",
"incoming": [
{
"name": "data",
"defaultSchemaId": "Data_AVROSchema_2a7cbb712e9b101ff9dc6167c76334e38d0aa71a",
"defaultSchemaId": "Data_AVROSchema_b6807e703af398df161220c621442f3e9f2acdae",
"connector": "smallrye-pulsar"
}
],
"outgoing": [
{
"name": "web-resources",
"defaultSchemaId": "WebResource_AVROSchema_ca473425346e07ac9a60bbc01eeaba7a872d37ce",
"defaultSchemaId": "WebResource_AVROSchema_5e9e26363c51912dddacc09aaf48d47b239f8dbc",
"connector": "smallrye-pulsar"
},
{
"name": "collected-data",
"defaultSchemaId": "Data_AVROSchema_2a7cbb712e9b101ff9dc6167c76334e38d0aa71a",
"defaultSchemaId": "Data_AVROSchema_b6807e703af398df161220c621442f3e9f2acdae",
"connector": "smallrye-pulsar"
}
],
"schemas": {
"Data_AVROSchema_2a7cbb712e9b101ff9dc6167c76334e38d0aa71a": {
"Data_AVROSchema_b6807e703af398df161220c621442f3e9f2acdae": {
"type": "record",
"name": "Data",
"namespace": "dev.streamx.blueprints.data",
Expand All @@ -32,7 +32,7 @@
}
]
},
"WebResource_AVROSchema_ca473425346e07ac9a60bbc01eeaba7a872d37ce": {
"WebResource_AVROSchema_5e9e26363c51912dddacc09aaf48d47b239f8dbc": {
"type": "record",
"name": "WebResource",
"namespace": "dev.streamx.blueprints.data",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,34 +1,34 @@
{
"image": "ghcr.io/streamx-dev/streamx-blueprints/image-optimization-processing-service:2.0.0-jvm",
"image": "ghcr.io/streamx-dev/streamx-blueprints/image-optimization-processing-service:2.0.4-jvm",
"type": "processing",
"incoming": [
{
"name": "incoming-assets",
"defaultSchemaId": "Asset_AVROSchema_7b9777c1cf366c0f7b95dee22fa886e571a78fe4",
"name": "incoming-pages",
"defaultSchemaId": "Page_AVROSchema_692a4be2160a8fd0652bb2d5504c674b3484014d",
"connector": "smallrye-pulsar"
},
{
"name": "incoming-pages",
"defaultSchemaId": "Page_AVROSchema_7941bfd98de2b3924db1ea9f28513f7adc82f1e0",
"name": "incoming-assets",
"defaultSchemaId": "Asset_AVROSchema_c63c289a2b77e5139c6760bacd226683da8628cd",
"connector": "smallrye-pulsar"
}
],
"outgoing": [
{
"name": "optimized-assets",
"defaultSchemaId": "Asset_AVROSchema_7b9777c1cf366c0f7b95dee22fa886e571a78fe4",
"name": "outgoing-pages",
"defaultSchemaId": "Page_AVROSchema_692a4be2160a8fd0652bb2d5504c674b3484014d",
"connector": "smallrye-pulsar"
},
{
"name": "outgoing-pages",
"defaultSchemaId": "Page_AVROSchema_7941bfd98de2b3924db1ea9f28513f7adc82f1e0",
"name": "optimized-assets",
"defaultSchemaId": "Asset_AVROSchema_c63c289a2b77e5139c6760bacd226683da8628cd",
"connector": "smallrye-pulsar"
}
],
"schemas": {
"Asset_AVROSchema_7b9777c1cf366c0f7b95dee22fa886e571a78fe4": {
"Page_AVROSchema_692a4be2160a8fd0652bb2d5504c674b3484014d": {
"type": "record",
"name": "Asset",
"name": "Page",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
Expand All @@ -37,9 +37,9 @@
}
]
},
"Page_AVROSchema_7941bfd98de2b3924db1ea9f28513f7adc82f1e0": {
"Asset_AVROSchema_c63c289a2b77e5139c6760bacd226683da8628cd": {
"type": "record",
"name": "Page",
"name": "Asset",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
Expand Down
Original file line number Diff line number Diff line change
@@ -1,53 +1,45 @@
{
"image": "ghcr.io/streamx-dev/streamx-blueprints/indexables-producer-processing-service:2.0.0-jvm",
"image": "ghcr.io/streamx-dev/streamx-blueprints/indexables-producer-processing-service:2.0.4-jvm",
"type": "processing",
"incoming": [
{
"name": "pages",
"defaultSchemaId": "Page_AVROSchema_3d5e7d1af2ba811345a0b247eb748f9beeba228a",
"name": "fragments",
"defaultSchemaId": "Fragment_AVROSchema_f66d929dec9b1f2cad65d110218fb7d33f2c2b34",
"connector": "smallrye-pulsar"
},
{
"name": "fragments",
"defaultSchemaId": "Fragment_AVROSchema_59e7d99f5417e111e78e4f3827b2062b6574ad01",
"name": "pages",
"defaultSchemaId": "Page_AVROSchema_bb827a955569628e9e5d692be490df1fabb11001",
"connector": "smallrye-pulsar"
}
],
"outgoing": [
{
"name": "indexable-resources",
"defaultSchemaId": "IndexableResource_AVROSchema_b33af00d3e52a9a48a5a8e1da23089265e8e4ed8",
"name": "indexable-resource-fragments",
"defaultSchemaId": "IndexableResourceFragment_AVROSchema_3140c736d024f2a4de0b9228419fd6bf9f8f7720",
"connector": "smallrye-pulsar"
},
{
"name": "indexable-resource-fragments",
"defaultSchemaId": "IndexableResourceFragment_AVROSchema_116a56cbd8cf121f086327639ab0fcee81283155",
"name": "indexable-resources",
"defaultSchemaId": "IndexableResource_AVROSchema_fb4a0780e2e58223d88c6726dc71f73f55f0cb99",
"connector": "smallrye-pulsar"
}
],
"schemas": {
"IndexableResource_AVROSchema_b33af00d3e52a9a48a5a8e1da23089265e8e4ed8": {
"IndexableResourceFragment_AVROSchema_3140c736d024f2a4de0b9228419fd6bf9f8f7720": {
"type": "record",
"name": "IndexableResource",
"name": "IndexableResourceFragment",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
"name": "fragmentKeys",
"type": {
"type": "array",
"items": "string",
"java-class": "java.util.Set"
}
},
{
"name": "content",
"type": "bytes"
}
]
},
"Fragment_AVROSchema_59e7d99f5417e111e78e4f3827b2062b6574ad01": {
"Page_AVROSchema_bb827a955569628e9e5d692be490df1fabb11001": {
"type": "record",
"name": "Fragment",
"name": "Page",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
Expand All @@ -56,9 +48,9 @@
}
]
},
"Page_AVROSchema_3d5e7d1af2ba811345a0b247eb748f9beeba228a": {
"Fragment_AVROSchema_f66d929dec9b1f2cad65d110218fb7d33f2c2b34": {
"type": "record",
"name": "Page",
"name": "Fragment",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
Expand All @@ -67,11 +59,19 @@
}
]
},
"IndexableResourceFragment_AVROSchema_116a56cbd8cf121f086327639ab0fcee81283155": {
"IndexableResource_AVROSchema_fb4a0780e2e58223d88c6726dc71f73f55f0cb99": {
"type": "record",
"name": "IndexableResourceFragment",
"name": "IndexableResource",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
"name": "fragmentKeys",
"type": {
"type": "array",
"items": "string",
"java-class": "java.util.Set"
}
},
{
"name": "content",
"type": "bytes"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,32 +1,32 @@
{
"image": "ghcr.io/streamx-dev/streamx-blueprints/json-aggregator-processing-service:2.0.0-jvm",
"image": "ghcr.io/streamx-dev/streamx-blueprints/json-aggregator-processing-service:2.0.4-jvm",
"type": "processing",
"incoming": [
{
"name": "data",
"defaultSchemaId": "Data_AVROSchema_ec296f1a28dd9ebf1d7ccfea59cbe8c44c860f4b",
"defaultSchemaId": "Data_AVROSchema_3148606aa307e1015e63eccbc69ad675190acf10",
"connector": "smallrye-pulsar"
},
{
"name": "multivalued-data",
"defaultSchemaId": "Data_AVROSchema_ec296f1a28dd9ebf1d7ccfea59cbe8c44c860f4b",
"defaultSchemaId": "Data_AVROSchema_3148606aa307e1015e63eccbc69ad675190acf10",
"connector": "smallrye-pulsar"
}
],
"outgoing": [
{
"name": "aggregated-data",
"defaultSchemaId": "Data_AVROSchema_ec296f1a28dd9ebf1d7ccfea59cbe8c44c860f4b",
"defaultSchemaId": "Data_AVROSchema_3148606aa307e1015e63eccbc69ad675190acf10",
"connector": "smallrye-pulsar"
},
{
"name": "aggregated-multivalued-data",
"defaultSchemaId": "Data_AVROSchema_ec296f1a28dd9ebf1d7ccfea59cbe8c44c860f4b",
"defaultSchemaId": "Data_AVROSchema_3148606aa307e1015e63eccbc69ad675190acf10",
"connector": "smallrye-pulsar"
}
],
"schemas": {
"Data_AVROSchema_ec296f1a28dd9ebf1d7ccfea59cbe8c44c860f4b": {
"Data_AVROSchema_3148606aa307e1015e63eccbc69ad675190acf10": {
"type": "record",
"name": "Data",
"namespace": "dev.streamx.blueprints.data",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,45 +1,45 @@
{
"image": "ghcr.io/streamx-dev/streamx-blueprints/message-converter-processing-service:2.0.0-jvm",
"image": "ghcr.io/streamx-dev/streamx-blueprints/message-converter-processing-service:2.0.4-jvm",
"type": "processing",
"incoming": [
{
"name": "data",
"defaultSchemaId": "Data_AVROSchema_fa58feedd00e07d4c58fd468c4d59f15d8cfae54",
"defaultSchemaId": "Data_AVROSchema_e4aded59c10ad1296898b9574816e1627aa78b2f",
"connector": "smallrye-pulsar"
}
],
"outgoing": [
{
"name": "indexable-resources",
"defaultSchemaId": "IndexableResource_AVROSchema_bc8562b60c746dab7194ae0d400b2b586722c43f",
"defaultSchemaId": "IndexableResource_AVROSchema_11918c58b95fd08365ca19951759562c1bea8a9a",
"connector": "smallrye-pulsar"
}
],
"schemas": {
"IndexableResource_AVROSchema_bc8562b60c746dab7194ae0d400b2b586722c43f": {
"Data_AVROSchema_e4aded59c10ad1296898b9574816e1627aa78b2f": {
"type": "record",
"name": "IndexableResource",
"name": "Data",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
"name": "fragmentKeys",
"type": {
"type": "array",
"items": "string",
"java-class": "java.util.Set"
}
},
{
"name": "content",
"type": "bytes"
}
]
},
"Data_AVROSchema_fa58feedd00e07d4c58fd468c4d59f15d8cfae54": {
"IndexableResource_AVROSchema_11918c58b95fd08365ca19951759562c1bea8a9a": {
"type": "record",
"name": "Data",
"name": "IndexableResource",
"namespace": "dev.streamx.blueprints.data",
"fields": [
{
"name": "fragmentKeys",
"type": {
"type": "array",
"items": "string",
"java-class": "java.util.Set"
}
},
{
"name": "content",
"type": "bytes"
Expand Down
Loading