22.2.3 • Published 2 years ago

@vectorizedio/wasm-api v22.2.3

Weekly downloads
60
License
ISC
Repository
-
Last release
2 years ago

vectorized wasm-api

Redpanda coprocessing client library for nodejs

How to use?

  1. Simply include the library and create your own instance of the SimpleTransform class.
const wasmJs = const {
  SimpleTransform,
} = require("@vectorizedio/wasm-api");
const transform = new SimpleTransform();
  1. Specify what topics you want your script to consume from:
transform.subscribe(["my-topic", PolicyInjection.Stored]);
  1. And write your custom transform logic that may filter or transform records in any way you'd like.
transform.processRecord((recordBatch) => {
   return Promise.resolve(new Map(....));
});

Whats the expected output?

Use the map returned from the processRecord method to determine what output topics you'd like to produce onto. For example if the recordBatch arrived from 'my-topic' and your Map contains a single key 'Foo', the transformed recordBatch will be produced onto a materialized topic named 'my-topic.$Foo$'. Materialized topics share all topic attributes with its source topic.

22.2.2-rc2

2 years ago

22.2.2-rc3

2 years ago

22.2.2-rc1

2 years ago

22.2.3-rc1

2 years ago

22.1.6-rc1

2 years ago

22.1.6-rc2

2 years ago

21.11.20-beta1

2 years ago

22.1.7

2 years ago

22.1.6

2 years ago

21.11.18-rc1

2 years ago

21.11.19-beta1

2 years ago

21.11.19

2 years ago

21.11.18

2 years ago

22.2.1

2 years ago

22.2.3

2 years ago

22.2.2

2 years ago

21.11.18-beta1

2 years ago

21.11.18-beta2

2 years ago

22.2.1-rc3

2 years ago

22.2.1-rc4

2 years ago

22.2.1-rc5

2 years ago

22.2.1-rc2

2 years ago

22.1.7-rc1

2 years ago

22.2.1-rc1

2 years ago

22.1.5-rc1

2 years ago

22.1.5

2 years ago

22.1.4-rc1

2 years ago

21.11.17-beta2

2 years ago

21.11.17-beta1

2 years ago

22.1.4

2 years ago

21.11.17

2 years ago

21.11.13-beta1

2 years ago

22.1.3-rc1

2 years ago

22.1.1-rc3

2 years ago

22.1.1-rc2

2 years ago

22.1.1-rc5

2 years ago

22.1.1-rc4

2 years ago

21.11.14-beta1

2 years ago

22.1.2

2 years ago

22.1.1

2 years ago

22.1.3

2 years ago

21.11.15

2 years ago

21.11.14

2 years ago

21.11.13

2 years ago

21.11.16

2 years ago

21.11.16-beta1

2 years ago

21.11.12-beta2

2 years ago

21.11.12

2 years ago

21.11.10-beta1

2 years ago

21.11.10-beta2

2 years ago

21.11.11-beta1

2 years ago

21.11.12-beta1

2 years ago

21.11.11

2 years ago

21.11.10

2 years ago

22.1.1-rc1

2 years ago

21.11.5-beta1

2 years ago

21.11.7-beta1

2 years ago

21.11.9

2 years ago

21.11.8

2 years ago

21.11.7

2 years ago

21.11.6

2 years ago

21.11.5

2 years ago

21.11.9-beta1

2 years ago

21.11.3-beta6

2 years ago

21.11.3-beta5

2 years ago

21.11.3-beta2

2 years ago

21.11.3-beta1

2 years ago

21.11.3-beta4

2 years ago

21.11.3-beta3

2 years ago

21.11.4-beta2

2 years ago

21.11.4-beta1

2 years ago

21.11.3-si-beta8

2 years ago

21.11.3-si-beta6

2 years ago

21.11.3-si-beta7

2 years ago

21.11.3-si-beta4

2 years ago

21.11.3-si-beta5

2 years ago

21.11.3-si-beta3

2 years ago

21.13.1

2 years ago

21.11.4

2 years ago

21.11.3

2 years ago

21.11.2-beta1

2 years ago

21.10.2-beta1

3 years ago

21.10.2-beta2

2 years ago

21.11.1-beta2

2 years ago

21.11.1-beta1

2 years ago

21.11.1-beta3

2 years ago

21.10.3

2 years ago

21.10.2

2 years ago

21.10.1

3 years ago

21.10.3-beta3

2 years ago

21.10.3-beta2

2 years ago

21.10.3-beta1

2 years ago

21.11.2

2 years ago

21.11.1

2 years ago

21.10.1-beta2

3 years ago

21.10.1-beta1

3 years ago

21.9.3

3 years ago

21.9.5

3 years ago

21.9.4

3 years ago

21.9.6

3 years ago

21.10.1-si-beta2

3 years ago

21.10.1-si-beta6

3 years ago

21.10.1-si-beta5

3 years ago

21.10.1-si-beta4

3 years ago

21.10.1-si-beta3

3 years ago

21.10.1-si-beta9

3 years ago

21.10.1-si-beta8

3 years ago

21.10.1-si-beta7

3 years ago

21.9.3-beta1

3 years ago

21.9.2

3 years ago

21.9.1-beta4

3 years ago

21.9.1

3 years ago

21.9.1-beta3

3 years ago

21.9.1-beta2

3 years ago

21.8.3-beta1

3 years ago

21.9.1-beta1

3 years ago

21.8.2

3 years ago

21.8.1

3 years ago

21.8.2-beta1

3 years ago

21.8.1-beta8

3 years ago

21.8.1-beta7

3 years ago

21.8.1-beta6

3 years ago

21.8.1-beta5

3 years ago

21.8.1-beta4

3 years ago

21.8.1-beta3

3 years ago

21.8.1-beta2

3 years ago

21.8.1-beta1

3 years ago

21.7.5

3 years ago

21.7.6

3 years ago

21.7.4

3 years ago

21.7.3

3 years ago

21.7.2

3 years ago

21.7.1

3 years ago

21.6.6

3 years ago

21.6.5

3 years ago

21.6.4

3 years ago

21.6.3

3 years ago

21.6.2

3 years ago

21.5.6-beta1

3 years ago

21.6.1

3 years ago

21.5.7

3 years ago

21.5.6

3 years ago

21.5.2-beta3

3 years ago

21.4.13

3 years ago

21.4.14

3 years ago

21.4.15

3 years ago

21.4.16-beta1

3 years ago

21.5.2-beta2

3 years ago

21.5.2-beta1

3 years ago

21.5.5

3 years ago

21.5.4

3 years ago

21.5.1

3 years ago

21.5.3

3 years ago

21.5.2

3 years ago

21.4.12

3 years ago

21.4.11

3 years ago

21.4.10

3 years ago

21.4.8

3 years ago

21.4.9

3 years ago

21.4.7

3 years ago

21.4.6

3 years ago

21.4.5

3 years ago

21.4.4

3 years ago

21.4.3

3 years ago

21.4.2

3 years ago

21.4.1

3 years ago

21.3.7

3 years ago

21.3.6-beta1

3 years ago

21.3.6

3 years ago

21.3.5

3 years ago

21.3.5-beta6

3 years ago

21.3.5-beta5

3 years ago

21.3.5-beta4

3 years ago

21.3.5-beta3

3 years ago

21.3.5-beta2

3 years ago

21.3.5-beta1

3 years ago

21.3.4-beta1

3 years ago

21.3.4-beta

3 years ago

21.3.4

3 years ago

21.2.2

3 years ago

21.2.1

3 years ago

21.1.5

3 years ago

21.1.4

3 years ago

21.1.3

3 years ago

21.1.2

3 years ago

21.1.1

3 years ago

21.1.0

3 years ago

20.12.9

3 years ago

20.12.8

3 years ago

20.12.7

3 years ago

1.1.2

3 years ago

1.2.0

4 years ago

1.0.2

4 years ago

1.0.1

3 years ago

1.0.0

3 years ago

1.0.0-beta

4 years ago