Commit 255870c
File tree
- build
- flyweight-maven-plugin
- cloud
- docker-image
- src/main/docker
- helm-chart
- conf
- incubator
- binding-amqp.spec
- src/main/scripts/io/aklivity/zilla/specs/binding/amqp/streams/network
- link
- attach.as.receiver.only
- attach.as.receiver.then.detach.with.error.then.flow
- attach.as.receiver.then.sender
- attach.as.receiver.when.source.does.not.exist
- attach.as.sender.only
- attach.as.sender.then.receiver
- attach.as.sender.when.target.does.not.exist
- detach.exchange
- flow.with.unattached.handle
- flow.without.handle
- handle.max.exceeded
- link.credit.exceeded
- max.frame.size.exceeded.with.multiple.sessions.and.links
- reject.attach.when.handle.in.use
- reject.durable.message.when.durable.not.supported
- reject.flow.with.inconsistent.fields
- reject.transfer.with.more.inconsistent.fields
- server.sent.flush
- transfer.to.client.at.least.once
- transfer.to.client.max.message.size.exceeded
- transfer.to.client.when.first.fragment.aborted
- transfer.to.client.when.fragmented
- transfer.to.client.when.last.fragment.aborted
- transfer.to.client.when.links.interleaved.and.max.frame.size.exceeded
- transfer.to.client.when.links.interleaved
- transfer.to.client.when.max.frame.size.exceeded
- transfer.to.client.when.middle.fragment.aborted
- transfer.to.client.with.annotations
- transfer.to.client.with.application.properties
- transfer.to.client.with.array32
- transfer.to.client.with.array8
- transfer.to.client.with.boolean
- transfer.to.client.with.byte
- transfer.to.client.with.char
- transfer.to.client.with.delivery.annotations
- transfer.to.client.with.false
- transfer.to.client.with.headers
- transfer.to.client.with.int
- transfer.to.client.with.list0
- transfer.to.client.with.list32
- transfer.to.client.with.list8
- transfer.to.client.with.long
- transfer.to.client.with.map32
- transfer.to.client.with.map8
- transfer.to.client.with.multiple.data
- transfer.to.client.with.multiple.sequence
- transfer.to.client.with.null
- transfer.to.client.with.properties
- transfer.to.client.with.short
- transfer.to.client.with.single.data
- transfer.to.client.with.single.sequence
- transfer.to.client.with.smallint
- transfer.to.client.with.smalllong
- transfer.to.client.with.smalluint
- transfer.to.client.with.smallulong
- transfer.to.client.with.str32utf8
- transfer.to.client.with.str8utf8
- transfer.to.client.with.sym32
- transfer.to.client.with.sym8
- transfer.to.client.with.timestamp
- transfer.to.client.with.true
- transfer.to.client.with.ubyte
- transfer.to.client.with.uint0
- transfer.to.client.with.uint
- transfer.to.client.with.ulong0
- transfer.to.client.with.ulong
- transfer.to.client.with.ushort
- transfer.to.client.with.vbin32
- transfer.to.client.with.vbin8
- transfer.to.server.at.least.once
- transfer.to.server.max.message.size.exceeded
- transfer.to.server.then.flow.with.echo.on.link
- transfer.to.server.then.flow.with.echo.on.session
- transfer.to.server.when.first.fragment.aborted
- transfer.to.server.when.fragmented
- transfer.to.server.when.last.fragment.aborted
- transfer.to.server.when.links.interleaved.and.fragmented
- transfer.to.server.when.links.interleaved
- transfer.to.server.when.max.frame.size.exceeded
- transfer.to.server.when.middle.fragment.aborted
- transfer.to.server.with.annotations
- transfer.to.server.with.application.properties
- transfer.to.server.with.array32
- transfer.to.server.with.array8
- transfer.to.server.with.boolean
- transfer.to.server.with.byte
- transfer.to.server.with.char
- transfer.to.server.with.delivery.annotations
- transfer.to.server.with.false
- transfer.to.server.with.headers
- transfer.to.server.with.int
- transfer.to.server.with.invalid.delivery.id
- transfer.to.server.with.large.delivery.count
- transfer.to.server.with.large.next.incoming.id
- transfer.to.server.with.list0
- transfer.to.server.with.list32
- transfer.to.server.with.list8
- transfer.to.server.with.long
- transfer.to.server.with.map32
- transfer.to.server.with.map8
- transfer.to.server.with.multiple.data
- transfer.to.server.with.multiple.sequence
- transfer.to.server.with.null
- transfer.to.server.with.properties
- transfer.to.server.with.short
- transfer.to.server.with.single.data
- transfer.to.server.with.single.sequence
- transfer.to.server.with.smallint
- transfer.to.server.with.smalllong
- transfer.to.server.with.smalluint
- transfer.to.server.with.smallulong
- transfer.to.server.with.str32utf8
- transfer.to.server.with.str8utf8
- transfer.to.server.with.sym32
- transfer.to.server.with.sym8
- transfer.to.server.with.timestamp
- transfer.to.server.with.true
- transfer.to.server.with.ubyte
- transfer.to.server.with.uint0
- transfer.to.server.with.uint
- transfer.to.server.with.ulong0
- transfer.to.server.with.ulong
- transfer.to.server.with.ushort
- transfer.to.server.with.vbin32
- transfer.to.server.with.vbin8
- session
- begin.channel.max.exceeded
- begin.exchange
- begin.multiple.sessions
- begin.then.close
- discard.after.end
- end.exchange.simultaneous
- end.exchange
- incoming.window.exceeded
- incoming.window.reduced
- reject.errant.link
- send.to.client.multiple.sessions
- transfer.to.client.when.sessions.interleaved.and.fragmented
- transfer.to.client.when.sessions.interleaved.and.max.frame.size.exceeded
- transfer.to.client.when.sessions.interleaved
- transfer.to.server.when.sessions.interleaved.and.fragmented
- transfer.to.server.when.sessions.interleaved
- binding-amqp
- src/test/java/io/aklivity/zilla/runtime/binding/amqp/internal/stream/server
- binding-pgsql-kafka.spec
- binding-pgsql-kafka
- binding-pgsql.spec
- binding-pgsql
- binding-risingwave.spec
- binding-risingwave
- command-dump
- src
- main/java/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
- binding-echo
- binding-fan
- binding-filesystem
- binding-grpc-kafka
- binding-grpc
- binding-http-filesystem
- binding-http-kafka
- binding-http
- src/test/java/io/aklivity/zilla/runtime/binding/http/internal/streams/rfc7540
- client
- server
- binding-kafka-grpc
- binding-kafka
- binding-mqtt-kafka
- binding-mqtt
- binding-openapi-asyncapi
- binding-openapi
- binding-proxy
- binding-sse-kafka
- binding-sse
- binding-tcp
- binding-tls
- binding-ws
- src/test/java/io/aklivity/zilla/runtime/binding/ws/internal/streams
- client
- server
- catalog-apicurio
- catalog-filesystem
- catalog-inline
- catalog-karapace
- catalog-schema-registry
- command-metrics
- command-start
- command-stop
- command-version
- command
- common
- engine
- src
- main/java/io/aklivity/zilla/runtime/engine
- test/java/io/aklivity/zilla/runtime/engine/internal
- exporter-otlp
- exporter-prometheus
- exporter-stdout
- filesystem-http
- guard-jwt
- metrics-grpc
- metrics-http
- metrics-stream
- model-avro
- model-core
- model-json
- model-protobuf
- resolver-env
- vault-filesystem
- specs
- binding-asyncapi.spec
- binding-echo.spec
- binding-fan.spec
- binding-filesystem.spec
- binding-grpc-kafka.spec
- binding-grpc.spec
- binding-http-filesystem.spec
- binding-http-kafka.spec
- binding-http.spec
- src/main/scripts/io/aklivity/zilla/specs/binding/http/streams
- application
- rfc7230/access.control/allow.origin.same.origin.implicit.http.port
- rfc7540
- access.control
- allow.credentials.cookie
- allow.headers
- allow.methods
- allow.origin.omitted
- allow.origin.present
- allow.origin.same.origin.implicit.http.port
- allow.origin.same.origin.implicit.https.port
- allow.origin.same.origin
- allow.origin
- expose.headers
- message.format
- connection.headers.override
- connection.headers
- network/rfc7540
- access.control
- allow.credentials.cookie
- allow.headers.credentials.cached
- allow.headers.credentials
- allow.headers.explicit.cached
- allow.headers.explicit
- allow.headers.wildcard.cached
- allow.headers.wildcard
- allow.methods.credentials.cached
- allow.methods.credentials
- allow.methods.explicit.cached
- allow.methods.explicit
- allow.methods.wildcard.cached
- allow.methods.wildcard
- allow.origin.credentials
- allow.origin.explicit
- allow.origin.omitted.cross.origin
- allow.origin.omitted.same.origin
- allow.origin.present
- allow.origin.same.origin.implicit.http.port
- allow.origin.same.origin.implicit.https.port
- allow.origin.same.origin
- allow.origin.wildcard
- expose.headers.credentials
- expose.headers.explicit
- expose.headers.wildcard
- reject.header.not.allowed
- reject.method.not.allowed
- reject.origin.not.allowed
- reject.origin.omitted
- authorization
- authorize.credentials.cookie
- authorize.credentials.header
- authorize.credentials.query
- challenge.credentials.cookie
- challenge.credentials.header
- challenge.credentials.query
- expire.credentials.cookie
- expire.credentials.header
- expire.credentials.query
- reauthorize.credentials.cookie
- reauthorize.credentials.header
- reauthorize.credentials.query
- reject.credentials.cookie
- reject.credentials.header
- reject.credentials.missing
- reject.credentials.query
- message.format
- client.invalid.hpack.index
- connection.headers
- invalid.hpack.index
- binding-kafka-grpc.spec
- binding-kafka.spec
- binding-mqtt-kafka.spec
- binding-mqtt.spec
- src/main/scripts/io/aklivity/zilla/specs/binding/mqtt/streams
- application
- client.sent.abort
- client.sent.close
- connect.maximum.qos.0
- connect.non.successful.disconnect
- connect.reject.will.retain.not.supported
- connect.retain.not.supported
- disconnect.after.subscribe.and.publish
- publish.10k
- publish.empty.message
- publish.empty.retained.message
- publish.message.with.topic.alias
- publish.messages.with.topic.alias.distinct
- publish.messages.with.topic.alias.invalid.scope
- publish.messages.with.topic.alias.repeated
- publish.messages.with.topic.alias.replaced
- publish.mixture.qos
- publish.multiple.clients
- publish.multiple.messages.timeout
- publish.multiple.messages
- publish.one.message.properties
- publish.qos1.dup.after.puback
- publish.qos2.ack.with.reasoncode
- publish.qos2.no.dupicate.before.pubrel
- publish.reject.large.message
- publish.reject.qos.not.supported
- publish.reject.retain.not.supported
- publish.retained.multiple.topic
- publish.retained
- publish.session.takeover
- publish.subscribe.batched
- publish.unroutable
- publish.valid.message
- publish.valid.user.property
- publish.with.user.properties.distinct
- publish.with.user.properties.repeated
- publish.with.user.property
- session.abort.reconnect.non.clean.start
- session.client.takeover
- session.connect.abort
- session.connect.authorization
- session.connect.override.session.expiry
- session.connect.redirect.support
- session.connect.with.session.expiry
- session.connect
- session.exists.clean.start
- session.invalid.session.timeout.after.connack
- session.invalid.session.timeout.before.connack
- session.publish
- session.server.redirect.after.connack
- session.server.redirect.before.connack
- session.server.sent.abort
- session.subscribe.invalid.state
- session.subscribe.multiple.isolated
- session.subscribe.publish.routing
- session.subscribe.via.session.state
- session.subscribe
- session.unsubscribe.after.subscribe.deferred
- session.unsubscribe.after.subscribe
- session.unsubscribe.via.session.state
- session.will.message.10k
- session.will.message.abort
- session.will.message.normal.disconnect
- session.will.message.retain
- subscribe.get.retained.as.published
- subscribe.one.message.receive.response.topic.and.correlation.data
- subscribe.one.message.user.properties.unaltered
- subscribe.one.message
- subscribe.publish.no.local
- subscribe.qos0.publish.retained.no.replay
- subscribe.qos0.replay.retained.no.packet.id
- subscribe.receive.message.overlapping.wildcard.mixed.qos
- subscribe.receive.message.overlapping.wildcard
- subscribe.receive.message.qos0.published.qos1
- subscribe.receive.message.qos0.published.qos2
- subscribe.receive.message.qos1.published.qos2
- subscribe.receive.message.qos1
- subscribe.receive.message.qos2
- subscribe.receive.message.wildcard
- subscribe.receive.messages.mixture.qos
- subscribe.receive.messages.topic.alias.repeated
- subscribe.receive.message
- subscribe.reconnect.publish.no.subscription
- subscribe.reconnect.replay.qos1.unacked.message
- subscribe.reconnect.replay.qos2.incomplete.message
- subscribe.reconnect.replay.qos2.unreceived.message
- subscribe.reject.subscription.ids.not.supported
- subscribe.reject.wildcard.subscriptions.not.supported
- subscribe.replay.retained.message.qos1.v4
- subscribe.replay.retained.message.qos1
- subscribe.replay.retained.message.qos2.v4
- subscribe.replay.retained.message.qos2
- subscribe.retain.as.published
- subscribe.topic.filter.multi.level.wildcard
- subscribe.topic.filter.single.and.multi.level.wildcard
- subscribe.topic.filter.single.exact
- subscribe.topic.filter.single.level.wildcard
- subscribe.topic.filter.two.single.level.wildcard
- subscribe.topic.filters.aggregated.both.exact
- subscribe.topic.filters.aggregated.exact.and.wildcard
- subscribe.topic.filters.disjoint.wildcards
- subscribe.topic.filters.isolated.both.exact
- subscribe.topic.filters.isolated.both.wildcard
- subscribe.topic.filters.isolated.exact.and.wildcard
- subscribe.topic.filters.non.successful
- subscribe.topic.filters.overlapping.wildcards
- subscribe.unroutable
- unsubscribe.after.subscribe
- unsubscribe.aggregated.topic.filters.both.exact
- unsubscribe.publish.unfragmented
- unsubscribe.topic.filter.single
- unsubscribe.topic.filters.non.successful
- network
- v4/subscribe.receive.message.qos0.published.qos
- v5
- client.sent.abort
- client.sent.close
- client.sent.reset
- connect.delegate.connack.properties
- connect.non.successful.connack
- connect.non.successful.disconnect
- connect.password.authentication.successful
- connect.username.authentication.successful
- disconnect.after.subscribe.and.publish
- ping.no.pingresp
- ping.server.override.keep.alive
- ping
- publish.10k
- publish.empty.message
- publish.empty.retained.message
- publish.invalid.message
- publish.invalid.user.property
- publish.mixture.qos
- publish.multiple.clients
- publish.multiple.messages.with.delay
- publish.multiple.messages
- publish.one.message.disconnect
- publish.one.message.properties
- publish.qos1.dup.after.puback
- publish.qos2.ack.with.reasoncode
- publish.qos2.no.dupicate.before.pubrel
- publish.qos2.recovery
- publish.reject.large.message
- publish.retained.multiple.topic
- publish.retained
- publish.session.takeover
- publish.valid.message
- publish.valid.user.property
- publish.with.user.properties.distinct
- publish.with.user.properties.repeated
- publish.with.user.property
- session.abort.reconnect.non.clean.start
- session.client.takeover
- session.connect.with.session.expiry
- session.exists.clean.start
- session.subscribe.multiple.isolated
- session.subscribe.via.session.state
- session.subscribe
- session.unsubscribe.after.subscribe
- session.will.message.10k
- session.will.message.disconnect.with.will.message
- session.will.message.normal.disconnect
- session.will.message.retain
- subscribe.get.retained.as.published
- subscribe.one.message.receive.response.topic.and.correlation.data
- subscribe.one.message.user.properties.unaltered
- subscribe.one.message
- subscribe.publish.no.local
- subscribe.qos0.publish.retained.no.replay
- subscribe.qos0.replay.retained.no.packet.id
- subscribe.receive.message.overlapping.wildcard.mixed.qos
- subscribe.receive.message.overlapping.wildcard
- subscribe.receive.message.qos0.published.qos
- subscribe.receive.message.qos1
- subscribe.receive.message.qos2
- subscribe.receive.message.wildcard
- subscribe.receive.messages.mixture.qos
- subscribe.receive.messages.topic.alias.repeated
- subscribe.receive.message
- subscribe.reconnect.publish.no.subscription
- subscribe.reconnect.replay.qos1.unacked.message
- subscribe.reconnect.replay.qos2.incomplete.message
- subscribe.reconnect.replay.qos2.unreceived.message
- subscribe.replay.retained.message.qos1
- subscribe.replay.retained.message.qos2
- subscribe.retain.as.published
- subscribe.topic.filter.multi.level.wildcard
- subscribe.topic.filter.single.and.multi.level.wildcard
- subscribe.topic.filter.single.exact
- subscribe.topic.filter.single.level.wildcard
- subscribe.topic.filter.two.single.level.wildcard
- subscribe.topic.filters.aggregated.both.exact
- subscribe.topic.filters.aggregated.exact.and.wildcard
- subscribe.topic.filters.disjoint.wildcards
- subscribe.topic.filters.isolated.both.exact.no.subscription.id
- subscribe.topic.filters.isolated.both.exact
- subscribe.topic.filters.isolated.both.wildcard
- subscribe.topic.filters.isolated.exact.and.wildcard
- subscribe.topic.filters.non.successful
- subscribe.topic.filters.overlapping.wildcards
- unsubscribe.after.subscribe
- unsubscribe.aggregated.topic.filters.both.exact
- unsubscribe.topic.filter.single
- unsubscribe.topic.filters.non.successful
- binding-openapi-asyncapi.spec
- binding-openapi.spec
- binding-proxy.spec
- binding-sse-kafka.spec
- binding-sse.spec
- binding-tcp.spec
- binding-tls.spec
- src/main/scripts/io/aklivity/zilla/specs/binding/tls/streams
- application/echo.payload.length.1000k
- network
- echo.payload.length.1000k
- echo.payload.length.100k
- binding-ws.spec
- catalog-apicurio.spec
- catalog-filesystem.spec
- catalog-inline.spec
- catalog-karapace.spec
- catalog-schema-registry.spec
- engine.spec
- 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.
| 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 | + | |
6 | 16 | | |
7 | 17 | | |
8 | 18 | | |
| |||
| 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 | |
|---|---|---|---|
| |||
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 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
61 | 61 | | |
62 | 62 | | |
63 | 63 | | |
64 | | - | |
| 64 | + | |
65 | 65 | | |
66 | 66 | | |
67 | 67 | | |
| |||
0 commit comments