22.2.3 • Published 3 years ago

@vectorizedio/wasm-api v22.2.3

Weekly downloads
60
License
ISC
Repository
-
Last release
3 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

3 years ago

22.2.2-rc3

3 years ago

22.2.2-rc1

3 years ago

22.2.3-rc1

3 years ago

22.1.6-rc1

3 years ago

22.1.6-rc2

3 years ago

21.11.20-beta1

3 years ago

22.1.7

3 years ago

22.1.6

3 years ago

21.11.18-rc1

3 years ago

21.11.19-beta1

3 years ago

21.11.19

3 years ago

21.11.18

3 years ago

22.2.1

3 years ago

22.2.3

3 years ago

22.2.2

3 years ago

21.11.18-beta1

3 years ago

21.11.18-beta2

3 years ago

22.2.1-rc3

3 years ago

22.2.1-rc4

3 years ago

22.2.1-rc5

3 years ago

22.2.1-rc2

3 years ago

22.1.7-rc1

3 years ago

22.2.1-rc1

3 years ago

22.1.5-rc1

3 years ago

22.1.5

3 years ago

22.1.4-rc1

3 years ago

21.11.17-beta2

3 years ago

21.11.17-beta1

3 years ago

22.1.4

3 years ago

21.11.17

3 years ago

21.11.13-beta1

3 years ago

22.1.3-rc1

3 years ago

22.1.1-rc3

3 years ago

22.1.1-rc2

3 years ago

22.1.1-rc5

3 years ago

22.1.1-rc4

3 years ago

21.11.14-beta1

3 years ago

22.1.2

3 years ago

22.1.1

3 years ago

22.1.3

3 years ago

21.11.15

3 years ago

21.11.14

3 years ago

21.11.13

3 years ago

21.11.16

3 years ago

21.11.16-beta1

3 years ago

21.11.12-beta2

3 years ago

21.11.12

3 years ago

21.11.10-beta1

3 years ago

21.11.10-beta2

3 years ago

21.11.11-beta1

3 years ago

21.11.12-beta1

3 years ago

21.11.11

3 years ago

21.11.10

3 years ago

22.1.1-rc1

3 years ago

21.11.5-beta1

3 years ago

21.11.7-beta1

3 years ago

21.11.9

3 years ago

21.11.8

3 years ago

21.11.7

3 years ago

21.11.6

3 years ago

21.11.5

3 years ago

21.11.9-beta1

3 years ago

21.11.3-beta6

3 years ago

21.11.3-beta5

3 years ago

21.11.3-beta2

4 years ago

21.11.3-beta1

4 years ago

21.11.3-beta4

3 years ago

21.11.3-beta3

4 years ago

21.11.4-beta2

3 years ago

21.11.4-beta1

3 years ago

21.11.3-si-beta8

3 years ago

21.11.3-si-beta6

4 years ago

21.11.3-si-beta7

4 years ago

21.11.3-si-beta4

4 years ago

21.11.3-si-beta5

4 years ago

21.11.3-si-beta3

4 years ago

21.13.1

3 years ago

21.11.4

3 years ago

21.11.3

3 years ago

21.11.2-beta1

4 years ago

21.10.2-beta1

4 years ago

21.10.2-beta2

4 years ago

21.11.1-beta2

4 years ago

21.11.1-beta1

4 years ago

21.11.1-beta3

4 years ago

21.10.3

4 years ago

21.10.2

4 years ago

21.10.1

4 years ago

21.10.3-beta3

4 years ago

21.10.3-beta2

4 years ago

21.10.3-beta1

4 years ago

21.11.2

4 years ago

21.11.1

4 years ago

21.10.1-beta2

4 years ago

21.10.1-beta1

4 years ago

21.9.3

4 years ago

21.9.5

4 years ago

21.9.4

4 years ago

21.9.6

4 years ago

21.10.1-si-beta2

4 years ago

21.10.1-si-beta6

4 years ago

21.10.1-si-beta5

4 years ago

21.10.1-si-beta4

4 years ago

21.10.1-si-beta3

4 years ago

21.10.1-si-beta9

4 years ago

21.10.1-si-beta8

4 years ago

21.10.1-si-beta7

4 years ago

21.9.3-beta1

4 years ago

21.9.2

4 years ago

21.9.1-beta4

4 years ago

21.9.1

4 years ago

21.9.1-beta3

4 years ago

21.9.1-beta2

4 years ago

21.8.3-beta1

4 years ago

21.9.1-beta1

4 years ago

21.8.2

4 years ago

21.8.1

4 years ago

21.8.2-beta1

4 years ago

21.8.1-beta8

4 years ago

21.8.1-beta7

4 years ago

21.8.1-beta6

4 years ago

21.8.1-beta5

4 years ago

21.8.1-beta4

4 years ago

21.8.1-beta3

4 years ago

21.8.1-beta2

4 years ago

21.8.1-beta1

4 years ago

21.7.5

4 years ago

21.7.6

4 years ago

21.7.4

4 years ago

21.7.3

4 years ago

21.7.2

4 years ago

21.7.1

4 years ago

21.6.6

4 years ago

21.6.5

4 years ago

21.6.4

4 years ago

21.6.3

4 years ago

21.6.2

4 years ago

21.5.6-beta1

4 years ago

21.6.1

4 years ago

21.5.7

4 years ago

21.5.6

4 years ago

21.5.2-beta3

4 years ago

21.4.13

4 years ago

21.4.14

4 years ago

21.4.15

4 years ago

21.4.16-beta1

4 years ago

21.5.2-beta2

4 years ago

21.5.2-beta1

4 years ago

21.5.5

4 years ago

21.5.4

4 years ago

21.5.1

4 years ago

21.5.3

4 years ago

21.5.2

4 years ago

21.4.12

4 years ago

21.4.11

4 years ago

21.4.10

4 years ago

21.4.8

4 years ago

21.4.9

4 years ago

21.4.7

4 years ago

21.4.6

4 years ago

21.4.5

4 years ago

21.4.4

4 years ago

21.4.3

4 years ago

21.4.2

4 years ago

21.4.1

4 years ago

21.3.7

4 years ago

21.3.6-beta1

4 years ago

21.3.6

4 years ago

21.3.5

4 years ago

21.3.5-beta6

4 years ago

21.3.5-beta5

4 years ago

21.3.5-beta4

4 years ago

21.3.5-beta3

4 years ago

21.3.5-beta2

4 years ago

21.3.5-beta1

4 years ago

21.3.4-beta1

4 years ago

21.3.4-beta

4 years ago

21.3.4

4 years ago

21.2.2

4 years ago

21.2.1

4 years ago

21.1.5

4 years ago

21.1.4

4 years ago

21.1.3

4 years ago

21.1.2

4 years ago

21.1.1

4 years ago

21.1.0

4 years ago

20.12.9

5 years ago

20.12.8

5 years ago

20.12.7

5 years ago

1.1.2

5 years ago

1.2.0

5 years ago

1.0.2

5 years ago

1.0.1

5 years ago

1.0.0

5 years ago

1.0.0-beta

5 years ago