Commit 328aedb
File tree
406 files changed
+7995
-15499
lines changed- build
- flyweight-maven-plugin
- src/main/java/io/aklivity/zilla/build/maven/plugins/flyweight/internal/generate
- cloud
- docker-image
- src/main/docker
- helm-chart
- conf
- incubator
- binding-amqp.spec
- binding-amqp
- command-dump
- src
- main
- java/io/aklivity/zilla/runtime/command/dump/internal/airline
- resources/io/aklivity/zilla/runtime/command/dump/internal/airline
- test
- java/io/aklivity/zilla/runtime/command/dump/internal/test
- resources/io/aklivity/zilla/runtime/command/dump/internal
- command-log
- command-tune
- manager
- runtime
- binding-asyncapi
- src
- main
- java/io/aklivity/zilla/runtime/binding/asyncapi
- config
- internal
- config
- composite
- model
- bindings
- http
- kafka
- kafka
- sse
- kafka
- parser
- resolver
- stream
- view
- moditect
- test/java/io/aklivity/zilla/runtime/binding/asyncapi/internal
- config
- stream
- view
- binding-echo
- binding-fan
- binding-filesystem
- binding-grpc-kafka
- binding-grpc
- binding-http-filesystem
- binding-http-kafka
- src/main/java/io/aklivity/zilla/runtime/binding/http/kafka
- config
- internal
- config
- stream
- binding-http
- src
- main/java/io/aklivity/zilla/runtime/binding/http
- config
- internal
- config
- stream
- test/java/io/aklivity/zilla/runtime/binding/http/config
- binding-kafka-grpc
- binding-kafka
- src
- main/java/io/aklivity/zilla/runtime/binding/kafka
- config
- internal
- cache
- config
- stream
- test/java/io/aklivity/zilla/runtime/binding/kafka/internal/config
- binding-mqtt-kafka
- src/main/java/io/aklivity/zilla/runtime/binding/mqtt/kafka
- config
- internal
- config
- stream
- binding-mqtt
- src
- main/java/io/aklivity/zilla/runtime/binding/mqtt
- config
- internal
- config
- stream
- test/java/io/aklivity/zilla/runtime/binding/mqtt
- config
- internal
- config
- stream/server/v4
- binding-openapi-asyncapi
- src
- main/java/io/aklivity/zilla/runtime/binding/openapi/asyncapi
- config
- internal/config
- test/java/io/aklivity/zilla/runtime/binding/openapi/asyncapi/internal/config
- binding-openapi
- src/main/java/io/aklivity/zilla/runtime/binding/openapi/internal/config
- binding-proxy
- src/main/java/io/aklivity/zilla/runtime/binding/proxy/internal/stream
- binding-sse-kafka
- src/main/java/io/aklivity/zilla/runtime/binding/sse/kafka
- config
- internal
- config
- stream
- binding-sse
- src
- main/java/io/aklivity/zilla/runtime/binding/sse
- config
- internal
- config
- stream
- test/java/io/aklivity/zilla/runtime/binding/sse/config
- binding-tcp
- src/main/java/io/aklivity/zilla/runtime/binding/tcp
- config
- internal/stream
- binding-tls
- src/main/java/io/aklivity/zilla/runtime/binding/tls/config
- binding-ws
- catalog-apicurio
- catalog-filesystem
- catalog-inline
- src
- main/java/io/aklivity/zilla/runtime/catalog/inline/config
- test/java/io/aklivity/zilla/runtime/catalog/inline
- config
- internal
- catalog-karapace
- catalog-schema-registry
- command-metrics
- command-start
- command-stop
- command-version
- command
- common
- engine
- src/main/java/io/aklivity/zilla/runtime/engine
- config
- internal/config
- exporter-otlp
- exporter-prometheus
- exporter-stdout
- filesystem-http
- guard-jwt
- metrics-grpc
- metrics-http
- metrics-stream
- model-avro
- model-core
- src/main/java/io/aklivity/zilla/runtime/model/core/config
- model-json
- model-protobuf
- resolver-env
- vault-filesystem
- specs
- binding-asyncapi.spec
- src
- main
- java/io/aklivity/zilla/specs/binding/asyncapi
- scripts/io/aklivity/zilla/specs/binding/asyncapi
- config
- schema
- streams
- asyncapi
- http
- create.pet
- verify.customer.async
- kafka
- create.pet
- produce.message
- publish
- server.sent.messages
- verify.customer
- mqtt
- publish.and.subscribe
- publish
- produce.message
- proxy.http.create.pet
- publish.and.subscribe
- sse
- data.multiple
- server.sent.messages
- composite
- http/create.pet
- kafka/produce.message
- mqtt/publish.and.subscribe
- sse/data.multiple
- http/create.pet
- test/java/io/aklivity/zilla/specs/binding/asyncapi
- streams
- asyncapi
- http
- binding-echo.spec
- binding-fan.spec
- binding-filesystem.spec
- binding-grpc-kafka.spec
- binding-grpc.spec
- binding-http-filesystem.spec
- binding-http-kafka.spec
- src
- main/scripts/io/aklivity/zilla/specs/binding/http/kafka
- config
- schema
- test/java/io/aklivity/zilla/specs/binding/http/kafka/config
- binding-http.spec
- src/main/java/io/aklivity/zilla/specs/binding/http/internal
- binding-kafka-grpc.spec
- binding-kafka.spec
- src/main
- java/io/aklivity/zilla/specs/binding/kafka/internal
- scripts/io/aklivity/zilla/specs/binding/kafka
- config
- schema
- binding-mqtt-kafka.spec
- binding-mqtt.spec
- src/main/java/io/aklivity/zilla/specs/binding/mqtt/internal
- binding-openapi-asyncapi.spec
- src/main/scripts/io/aklivity/zilla/specs/binding/openapi/asyncapi/streams/asyncapi
- async.verify.customer
- create.pet
- binding-openapi.spec
- src/test/java/io/aklivity/zilla/specs/binding/openapi/internal
- binding-proxy.spec
- binding-sse-kafka.spec
- binding-sse.spec
- src
- main
- java/io/aklivity/zilla/specs/binding/sse/internal
- scripts/io/aklivity/zilla/specs/binding/sse/streams/application/reconnect/last.event.id.end.fragmented
- test/java/io/aklivity/zilla/specs/binding/sse/internal
- binding-tcp.spec
- binding-tls.spec
- src/main/scripts/io/aklivity/zilla/specs/binding/tls/schema
- binding-ws.spec
- src/main/scripts/io/aklivity/zilla/specs/binding/ws/streams/network
- advise
- client.sent.challenge
- client.sent.flush
- server.sent.challenge
- server.sent.flush
- closing
- client.send.close.frame.with.code.1005
- client.send.empty.close.frame
- control
- client.send.pong.payload.length.0
- client.send.pong.payload.length.125
- client.send.pong.payload.length.126
- server.send.ping.payload.length.0
- server.send.ping.payload.length.125
- flowcontrol/echo.payload.with.padding
- fragmentation/client.echo.binary.payload.length.125.fragmented
- framing
- echo.binary.payload.length.0
- echo.binary.payload.length.125
- echo.binary.payload.length.126
- echo.binary.payload.length.65535
- opening
- connection.established
- request.header.sec.websocket.protocol.negotiated
- request.header.sec.websocket.protocol
- catalog-apicurio.spec
- catalog-filesystem.spec
- catalog-inline.spec
- catalog-karapace.spec
- catalog-schema-registry.spec
- engine.spec
- src/main
- java/io/aklivity/zilla/specs/engine/internal
- resources/META-INF/zilla
- exporter-otlp.spec
- exporter-prometheus.spec
- exporter-stdout.spec
- filesystem-http.spec
- guard-jwt.spec
- metrics-grpc.spec
- metrics-http.spec
- metrics-stream.spec
- model-avro.spec
- model-core.spec
- model-json.spec
- model-protobuf.spec
- vault-filesystem.spec
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
406 files changed
+7995
-15499
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
5 | | - | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
6 | 20 | | |
7 | 21 | | |
8 | 22 | | |
| |||
18 | 32 | | |
19 | 33 | | |
20 | 34 | | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
21 | 45 | | |
22 | 46 | | |
23 | 47 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
Lines changed: 13 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
| 42 | + | |
42 | 43 | | |
43 | 44 | | |
44 | 45 | | |
| |||
957 | 958 | | |
958 | 959 | | |
959 | 960 | | |
960 | | - | |
| 961 | + | |
961 | 962 | | |
962 | 963 | | |
963 | 964 | | |
| |||
1016 | 1017 | | |
1017 | 1018 | | |
1018 | 1019 | | |
1019 | | - | |
| 1020 | + | |
| 1021 | + | |
| 1022 | + | |
1020 | 1023 | | |
1021 | 1024 | | |
1022 | 1025 | | |
1023 | 1026 | | |
1024 | 1027 | | |
| 1028 | + | |
| 1029 | + | |
| 1030 | + | |
| 1031 | + | |
| 1032 | + | |
| 1033 | + | |
| 1034 | + | |
| 1035 | + | |
1025 | 1036 | | |
1026 | 1037 | | |
1027 | 1038 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
27 | 27 | | |
28 | 28 | | |
29 | 29 | | |
30 | | - | |
| 30 | + | |
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| |||
0 commit comments