File tree
8,993 files changed
+21562
-9853
lines changed- build
- flyweight-maven-plugin
- src
- main
- antlr4/io/aklivity/zilla/build/maven/plugins/flyweight/internal/parser
- java/io/aklivity/zilla/build/maven/plugins/flyweight/internal
- ast
- parse
- visit
- generate
- moditect
- resources/META-INF/m2e
- test
- java/io/aklivity/zilla/build/maven/plugins/flyweight/internal
- ast/parse
- bench
- generated
- resources/test-project
- cloud
- docker-image
- src/main/docker
- helm-chart
- conf
- src/main/resources/io/aklivity/zilla/conf/checkstyle
- incubator
- binding-amqp
- src
- main
- java/io/aklivity/zilla/runtime/binding/amqp
- config
- internal
- config
- stream
- util
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/amqp/internal
- config
- stream
- server
- binding-amqp.spec
- src
- main
- java/io/aklivity/zilla/specs/binding/amqp/internal
- moditect
- resources/META-INF/zilla
- scripts/io/aklivity/zilla/specs/binding/amqp
- config
- streams
- application
- abort.after.sending.first.fragment
- connect.and.reset
- connect.as.receiver.only
- connect.as.receiver.then.abort
- connect.as.receiver.then.sender
- connect.as.sender.only
- connect.as.sender.then.abort
- connect.as.sender.then.receiver
- disconnect
- incoming.window.exceeded
- incoming.window.reduced
- link.credit.exceeded
- max.frame.size.exceeded.with.multiple.sessions.and.links
- send.to.client.at.least.once
- send.to.client.through.multiple.sessions
- send.to.client.when.first.fragment.aborted
- send.to.client.when.fragmented
- send.to.client.when.last.fragment.aborted
- send.to.client.when.links.interleaved
- send.to.client.when.links.interleaved.and.fragmented
- send.to.client.when.links.interleaved.and.max.frame.size.exceeded
- send.to.client.when.max.frame.size.exceeded
- send.to.client.when.middle.fragment.aborted
- send.to.client.when.sessions.interleaved
- send.to.client.when.sessions.interleaved.and.fragmented
- send.to.client.when.sessions.interleaved.and.max.frame.size.exceeded
- send.to.client.with.annotations
- send.to.client.with.application.properties
- send.to.client.with.array32
- send.to.client.with.array8
- send.to.client.with.boolean
- send.to.client.with.byte
- send.to.client.with.char
- send.to.client.with.delivery.annotations
- send.to.client.with.false
- send.to.client.with.headers
- send.to.client.with.int
- send.to.client.with.list0
- send.to.client.with.list32
- send.to.client.with.list8
- send.to.client.with.long
- send.to.client.with.map32
- send.to.client.with.map8
- send.to.client.with.multiple.data
- send.to.client.with.multiple.sequence
- send.to.client.with.null
- send.to.client.with.properties
- send.to.client.with.short
- send.to.client.with.single.data
- send.to.client.with.single.sequence
- send.to.client.with.smallint
- send.to.client.with.smalllong
- send.to.client.with.smalluint
- send.to.client.with.smallulong
- send.to.client.with.str32utf8
- send.to.client.with.str8utf8
- send.to.client.with.sym32
- send.to.client.with.sym8
- send.to.client.with.timestamp
- send.to.client.with.true
- send.to.client.with.ubyte
- send.to.client.with.uint
- send.to.client.with.uint0
- send.to.client.with.ulong
- send.to.client.with.ulong0
- send.to.client.with.ushort
- send.to.client.with.vbin32
- send.to.client.with.vbin8
- send.to.server.at.least.once
- send.to.server.then.flow.with.echo
- send.to.server.when.first.fragment.aborted
- send.to.server.when.fragmented
- send.to.server.when.last.fragment.aborted
- send.to.server.when.links.interleaved
- send.to.server.when.links.interleaved.and.fragmented
- send.to.server.when.max.frame.size.exceeded
- send.to.server.when.middle.fragment.aborted
- send.to.server.when.sessions.interleaved
- send.to.server.when.sessions.interleaved.and.fragmented
- send.to.server.with.annotations
- send.to.server.with.application.properties
- send.to.server.with.array32
- send.to.server.with.array8
- send.to.server.with.boolean
- send.to.server.with.byte
- send.to.server.with.char
- send.to.server.with.delivery.annotations
- send.to.server.with.false
- send.to.server.with.headers
- send.to.server.with.int
- send.to.server.with.invalid.delivery.id
- send.to.server.with.large.delivery.count
- send.to.server.with.list0
- send.to.server.with.list32
- send.to.server.with.list8
- send.to.server.with.long
- send.to.server.with.map32
- send.to.server.with.map8
- send.to.server.with.multiple.data
- send.to.server.with.multiple.sequence
- send.to.server.with.null
- send.to.server.with.properties
- send.to.server.with.short
- send.to.server.with.single.data
- send.to.server.with.single.sequence
- send.to.server.with.smallint
- send.to.server.with.smalllong
- send.to.server.with.smalluint
- send.to.server.with.smallulong
- send.to.server.with.str32utf8
- send.to.server.with.str8utf8
- send.to.server.with.sym32
- send.to.server.with.sym8
- send.to.server.with.timestamp
- send.to.server.with.true
- send.to.server.with.ubyte
- send.to.server.with.uint
- send.to.server.with.uint0
- send.to.server.with.ulong
- send.to.server.with.ulong0
- send.to.server.with.ushort
- send.to.server.with.vbin32
- send.to.server.with.vbin8
- server.sent.flush
- network
- connection
- client.idle.timeout.does.not.expire
- client.idle.timeout.expires
- close.exchange
- close.exchange.server.abandoned
- close.exchange.simultaneous
- header.exchange
- open.exchange
- open.exchange.pipelined
- open.with.outgoing.locales.negotiated.default
- open.with.outgoing.locales.negotiated.non.default
- protocol.header.unmatched
- reject.incorrect.fields.key.type
- sasl.exchange
- sasl.exchange.then.open.exchange.pipelined
- server.idle.timeout.does.not.expire
- server.idle.timeout.expires
- 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
- transfer.to.client.when.links.interleaved.and.fragmented
- transfer.to.client.when.links.interleaved.and.max.frame.size.exceeded
- 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.uint
- transfer.to.client.with.uint0
- transfer.to.client.with.ulong
- transfer.to.client.with.ulong0
- 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
- transfer.to.server.when.links.interleaved.and.fragmented
- 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.uint
- transfer.to.server.with.uint0
- transfer.to.server.with.ulong
- transfer.to.server.with.ulong0
- 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
- end.exchange.simultaneous
- incoming.window.exceeded
- incoming.window.reduced
- reject.errant.link
- send.to.client.multiple.sessions
- transfer.to.client.when.sessions.interleaved
- transfer.to.client.when.sessions.interleaved.and.fragmented
- transfer.to.client.when.sessions.interleaved.and.max.frame.size.exceeded
- transfer.to.server.when.sessions.interleaved
- transfer.to.server.when.sessions.interleaved.and.fragmented
- test/java/io/aklivity/zilla/specs/binding/amqp
- config
- internal
- streams
- application
- network
- binding-pgsql
- src
- main
- antlr4/io/aklivity/zilla/runtime/binding/pgsql/parser
- java/io/aklivity/zilla/runtime/binding/pgsql
- internal
- config
- stream
- parser
- listener
- model
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/pgsql
- internal/stream
- parser
- binding-pgsql-kafka
- src
- main
- java/io/aklivity/zilla/runtime/binding/pgsql/kafka/internal
- config
- schema
- stream
- moditect
- test/java/io/aklivity/zilla/runtime/binding/pgsql/kafka/internal/stream
- binding-pgsql-kafka.spec
- src
- main
- moditect
- scripts/io/aklivity/zilla/specs/binding/pgsql/kafka
- config
- streams
- kafka
- create.topic
- drop.topic
- pgsql
- alter.topic.add.column
- alter.topic.modify.column.rejected
- create.topic
- drop.topic
- test/java/io/aklivity/zilla/specs/binding/pgsql/kafka/streams
- binding-pgsql.spec
- src
- main
- java/io/aklivity/zilla/specs/binding/pgsql
- moditect
- resources/META-INF/zilla
- scripts/io/aklivity/zilla/specs/binding/pgsql
- config
- streams
- application
- cancel.request
- client.sent.read.abort
- client.sent.write.abort
- create.table.fragmented
- create.table.with.primary.key
- select.table
- select.table.with.error
- ssl.request
- termination.request
- network
- cancel.request
- client.sent.read.abort
- client.sent.write.abort
- create.table.fragmented
- create.table.with.primary.key
- select.table
- select.table.with.error
- ssl.request
- termination.request
- test/java/io/aklivity/zilla/specs/binding/pgsql/streams
- internal
- binding-risingwave
- src
- main
- java/io/aklivity/zilla/runtime/binding/risingwave
- config
- internal
- config
- statement
- stream
- moditect
- test/java/io/aklivity/zilla/runtime/binding/risingwave/internal
- config
- statement
- stream
- binding-risingwave.spec
- src
- main
- moditect
- scripts/io/aklivity/zilla/specs/binding/risingwave
- config
- schema
- streams
- effective
- create.function
- create.function.embedded
- create.function.embedded.python
- create.function.python
- create.function.return.struct
- create.function.return.table
- create.materialized.view
- create.stream
- create.stream.with.includes
- create.streams
- create.table.with.primary.key
- create.table.with.primary.key.and.includes
- drop.materialized.view
- drop.stream
- drop.table
- query.with.multiple.statements
- query.with.multiple.statements.errored
- set.variable
- show.tables.with.newline
- pgsql
- create.function
- create.function.embedded
- create.function.embedded.python
- create.function.python
- create.function.return.struct
- create.function.return.table
- create.materialized.view
- create.stream
- create.stream.with.includes
- create.streams
- create.table.with.primary.key
- create.table.with.primary.key.and.includes
- drop.materialized.view
- drop.stream
- drop.table
- query.with.multiple.statements
- query.with.multiple.statements.errored
- set.variable
- show.tables.with.newline
- test/java/io/aklivity/zilla/specs/binding/risingwave
- config
- streams
- command-dump
- src
- main
- java/io/aklivity/zilla/runtime/command/dump/internal
- airline
- labels
- layouts
- spy
- moditect
- resources
- META-INF/zilla
- io/aklivity/zilla/runtime/command/dump/internal/airline
- scripts/io/aklivity/zilla/runtime/command/dump/binding
- amqp/streams
- application/connect.as.receiver.only
- network/link/attach.as.receiver.only
- filesystem/streams/application/read.file.extension
- grpc/streams/application/server.stream.rpc/message.exchange
- http/streams
- application/rfc7540/authorization/challenge.credentials.header
- network/rfc7540/authorization/challenge.credentials.header
- kafka/streams
- application
- describe/topic.config.info
- fetch/partition.offset
- group/rebalance.sync.group
- init.producer.id/produce.new.id
- merged/merged.fetch.filter.sync
- meta/topic.partition.info
- offset.commit/update.topic.partition.offset
- offset.fetch/topic.offset.info
- produce/message.producer.id
- network/describe.configs.v0/topic.config.info
- mqtt/streams
- application
- publish.one.message.properties
- subscribe.one.message
- network/v5/publish.one.message.properties
- proxy/streams/application/connected.local.client.sent.begin.ext
- sse/streams/application/data/non.empty
- tls/streams
- application/connection.established
- network/connection.established
- ws/streams/application/advise/client.sent.challenge
- test
- java/io/aklivity/zilla/runtime/command/dump/internal
- test
- resources/io/aklivity/zilla/runtime/command/dump/internal/test
- command-log
- src/main
- java/io/aklivity/zilla/runtime/command/log/internal
- labels
- layouts
- spy
- moditect
- command-tune
- src/main
- java/io/aklivity/zilla/runtime/command/tune/internal
- airline
- labels
- moditect
- manager
- src
- main
- java/io/aklivity/zilla/manager/internal
- commands
- clean
- encrypt
- install
- adapters
- cache
- wrap
- settings
- types
- moditect
- test/java/io/aklivity/zilla/manager/internal
- commands
- clean
- encrypt
- install
- wrap
- settings
- 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
- src
- main
- java/io/aklivity/zilla/runtime/binding/echo/internal
- stream
- moditect
- test/java/io/aklivity/zilla/runtime/binding/echo/internal
- bench
- streams
- binding-fan
- src
- main
- java/io/aklivity/zilla/runtime/binding/fan/internal
- stream
- moditect
- test/java/io/aklivity/zilla/runtime/binding/fan/internal/streams
- binding-filesystem
- src
- main
- java/io/aklivity/zilla/runtime/binding/filesystem
- config
- internal
- config
- stream
- moditect
- test/java/io/aklivity/zilla/runtime/binding/filesystem/internal
- config
- stream
- binding-grpc
- src
- main
- antlr4/io/aklivity/zilla/runtime/binding/grpc/internal/parser
- java/io/aklivity/zilla/runtime/binding/grpc
- config
- internal
- config
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/grpc/internal
- config
- streams
- client
- server
- binding-grpc-kafka
- src
- main
- java/io/aklivity/zilla/runtime/binding/grpc/kafka
- config
- internal
- config
- stream
- moditect
- test/java/io/aklivity/zilla/runtime/blinding/grpc/kafka/internal
- config
- stream
- binding-http
- src
- main
- java/io/aklivity/zilla/runtime/binding/http
- config
- internal
- codec
- config
- hpack
- stream
- util
- function
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/http
- config
- internal
- codec
- config
- hpack
- streams
- rfc7230
- client
- server
- rfc7540
- client
- server
- test
- util
- function
- binding-http-filesystem
- src
- main
- java/io/aklivity/zilla/runtime/binding/http/filesystem
- config
- internal
- config
- stream
- moditect
- test/java/io/aklivity/zilla/runtime/binding/http/filesystem/internal
- config
- stream
- binding-http-kafka
- src
- main
- java/io/aklivity/zilla/runtime/binding/http/kafka
- config
- internal
- config
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/http/kafka/internal
- config
- stream
- binding-kafka
- src
- main
- java/io/aklivity/zilla/runtime/binding/kafka
- config
- identity
- internal
- budget
- cache
- config
- events
- identity
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/kafka
- identity
- internal
- cache
- config
- stream
- binding-kafka-grpc
- src
- main
- java/io/aklivity/zilla/runtime/binding/kafka/grpc
- config
- internal
- config
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/kafka/grpc/internal
- config
- stream
- binding-mqtt
- src
- main
- java/io/aklivity/zilla/runtime/binding/mqtt
- config
- internal
- config
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/mqtt
- config
- internal
- config
- stream
- client/v5
- server
- v4
- v5
- binding-mqtt-kafka
- src
- main
- java/io/aklivity/zilla/runtime/binding/mqtt/kafka
- config
- internal
- config
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/mqtt/kafka/internal
- config
- stream
- binding-openapi
- src
- main
- java/io/aklivity/zilla/runtime/binding/openapi
- config
- internal
- config
- model
- streams
- view
- moditect
- test/java/io/aklivity/zilla/runtime/binding/openapi/internal
- config
- streams
- binding-openapi-asyncapi
- src
- main
- java/io/aklivity/zilla/runtime/binding/openapi/asyncapi
- config
- internal
- config
- streams
- moditect
- test/java/io/aklivity/zilla/runtime/binding/openapi/asyncapi/internal
- config
- streams
- binding-proxy
- src
- main
- java/io/aklivity/zilla/runtime/binding/proxy
- config
- internal
- config
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/proxy/internal
- config
- streams
- binding-sse
- src
- main
- java/io/aklivity/zilla/runtime/binding/sse
- config
- internal
- config
- stream
- types/codec
- util
- moditect
- test/java/io/aklivity/zilla/runtime/binding/sse
- config
- internal
- config
- streams
- client
- server
- types/codec
- binding-sse-kafka
- src
- main
- java/io/aklivity/zilla/runtime/binding/sse/kafka
- config
- internal
- config
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/sse/kafka/internal
- config
- stream
- binding-tcp
- src
- main
- java/io/aklivity/zilla/runtime/binding/tcp
- config
- internal
- config
- stream
- util
- moditect
- test/java/io/aklivity/zilla/runtime/binding/tcp/internal
- bench
- config
- streams
- util
- binding-tls
- src
- main
- java/io/aklivity/zilla/runtime/binding/tls
- config
- internal
- config
- identity
- stream
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/binding/tls/internal
- bench
- config
- streams
- binding-ws
- src
- main
- java/io/aklivity/zilla/runtime/binding/ws
- config
- internal
- config
- stream
- types/codec
- util
- moditect
- test/java/io/aklivity/zilla/runtime/binding/ws/internal
- config
- streams
- client
- server
- catalog-apicurio
- src
- main
- java/io/aklivity/zilla/runtime/catalog/apicurio
- config
- internal
- config
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/catalog/apicurio/internal
- config
- catalog-filesystem
- src
- main
- java/io/aklivity/zilla/runtime/catalog/filesystem/internal
- config
- moditect
- test/java/io/aklivity/zilla/runtime/catalog/filesystem/internal
- config
- catalog-inline
- src
- main
- java/io/aklivity/zilla/runtime/catalog/inline
- config
- internal
- moditect
- test/java/io/aklivity/zilla/runtime/catalog/inline
- config
- internal
- catalog-karapace
- src
- main
- java/io/aklivity/zilla/runtime/catalog/karapace
- config
- internal
- config
- events
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/catalog/karapace/internal
- config
- catalog-schema-registry
- src
- main
- java/io/aklivity/zilla/runtime/catalog/schema/registry
- config
- internal
- config
- events
- handler
- serializer
- moditect
- zilla
- test/java/io/aklivity/zilla/runtime/catalog/schema/registry/internal
- config
- serializer
- command
- src
- main
- java/io/aklivity/zilla/runtime/command
- internal
- moditect
- test/java/io/aklivity/zilla/runtime/command/internal
- command-metrics
- src
- main
- java/io/aklivity/zilla/runtime/command/metrics/internal
- airline
- printer
- moditect
- test/java/io/aklivity/zilla/runtime/command/metrics/internal/printer
- command-start
- src/main
- java/io/aklivity/zilla/runtime/command/start/internal
- airline
- moditect
- command-stop
- src/main
- java/io/aklivity/zilla/runtime/command/stop/internal
- airline
- moditect
- command-version
- src/main
- java/io/aklivity/zilla/runtime/command/version/internal
- airline
- moditect
- common
- src/main
- java/io/aklivity/zilla/runtime/common/feature
- moditect
- engine
- src
- main
- java/io/aklivity/zilla/runtime/engine
- binding
- function
- budget
- buffer
- catalog
- concurrent
- config
- event
- exporter
- ext
- factory
- guard
- internal
- budget
- buffer
- concurent
- config
- schema
- event
- exporter
- layouts
- metrics
- poller
- registry
- spy
- stream
- watcher
- metrics
- reader
- model
- function
- namespace
- poller
- reader
- resolver
- security
- util/function
- vault
- moditect
- test
- java/io/aklivity/zilla/runtime/engine
- binding
- function
- catalog
- config
- exporter
- guard
- internal
- budget
- buffer
- concurrent
- bench
- config
- event
- layouts
- metrics
- model
- config
- metrics
- reader
- model
- function
- reader
- resolver
- security
- test
- annotation
- internal
- binding
- config
- catalog
- config
- event
- exporter
- config
- guard
- config
- k3po/ext
- behavior
- handler
- layout
- el
- types
- util
- function
- metrics
- model
- config
- resolver
- vault
- config
- util/function
- vault
- resources/io/aklivity/zilla/runtime/engine/internal
- scripts/io/aklivity/zilla/runtime/engine/test/k3po/ext
- duplex
- byteorder.default
- byteorder.native
- byteorder.network
- client.close
- client.flush.empty.data.with.ext
- client.flush.null.data.with.ext
- client.receive.null.data.with.ext.and.expression
- client.sent.data
- client.sent.data.ext
- client.sent.data.missing.ext
- client.sent.option.flags.fragmentation
- client.sent.option.flags.incomplete
- client.sent.option.flags.no.fragmentation
- client.sent.option.flags.skip
- client.sent.option.flags.then.reset.flags
- client.sent.overflow
- client.sent.read.abort
- client.sent.read.abort.server.replied.read.abort
- client.sent.read.abort.with.ext
- client.sent.read.advise.challenge
- client.sent.read.advise.challenge.ext
- client.sent.read.and.write.abort
- client.sent.throttle
- client.sent.throttle.initial.only
- client.sent.throttle.initial.only.message.aligned
- client.sent.throttle.message
- client.sent.write.abort
- client.sent.write.abort.server.replied.write.close
- client.sent.write.advise.flush
- client.sent.write.advise.flush.ext
- client.write.close
- client.write.close.ext
- client.write.empty.data.and.server.read.empty.data
- handshake
- handshake.abort
- handshake.authorized
- handshake.budget.id
- handshake.ext
- handshake.ext.rejected
- handshake.rejected
- handshake.unequal.authorization
- server.close
- server.flush.empty.data.with.ext
- server.flush.null.data.with.ext
- server.sent.data
- server.sent.data.ext
- server.sent.data.missing.ext
- server.sent.option.ack
- server.sent.option.flags.fragmentation
- server.sent.option.flags.incomplete
- server.sent.option.flags.no.fragmentation
- server.sent.option.flags.skip
- server.sent.option.flags.then.reset.flags
- server.sent.overflow
- server.sent.overflow.padding
- server.sent.read.abort
- server.sent.read.abort.with.ext
- server.sent.read.advise.challenge
- server.sent.read.advise.challenge.ext
- server.sent.read.and.write.abort
- server.sent.throttle
- server.sent.throttle.initial.only
- server.sent.throttle.initial.only.message.aligned
- server.sent.throttle.message
- server.sent.write.abort
- server.sent.write.abort.with.ext
- server.sent.write.advise.flush
- server.sent.write.advise.flush.ext
- server.write.close
- server.write.close.ext
- server.write.empty.data.and.client.read.empty.data
- server.write.empty.data.with.ext
- timestamps.false
- half.duplex
- client.close
- client.flush.empty.data.with.ext
- client.flush.null.data.with.ext
- client.sent.data
- client.sent.data.ext
- client.sent.data.missing.ext
- client.sent.option.flags.fragmentation
- client.sent.option.flags.incomplete
- client.sent.option.flags.no.fragmentation
- client.sent.option.flags.skip
- client.sent.option.flags.then.reset.flags
- client.sent.overflow
- client.sent.read.abort
- client.sent.read.abort.before.reply
- client.sent.read.abort.server.replied.read.abort
- client.sent.read.advise.challenge
- client.sent.read.advise.challenge.ext
- client.sent.throttle
- client.sent.throttle.initial.only
- client.sent.throttle.initial.only.message.aligned
- client.sent.throttle.message
- client.sent.write.abort
- client.sent.write.abort.server.replied.write.abort
- client.sent.write.abort.server.replied.write.close
- client.sent.write.advise.flush
- client.sent.write.advise.flush.ext
- client.sent.write.empty.data.and.server.read.empty.data
- client.write.close
- client.write.close.ext
- handshake
- handshake.abort
- handshake.authorized
- handshake.budget.id
- handshake.ext
- handshake.ext.rejected
- handshake.rejected
- handshake.unequal.authorization
- server.close
- server.flush.empty.data.with.ext
- server.flush.null.data.with.ext
- server.sent.data
- server.sent.data.ext
- server.sent.data.missing.ext
- server.sent.option.ack
- server.sent.option.flags.fragmentation
- server.sent.option.flags.incomplete
- server.sent.option.flags.no.fragmentation
- server.sent.option.flags.skip
- server.sent.option.flags.then.reset.flags
- server.sent.overflow
- server.sent.read.abort
- server.sent.read.advise.challenge
- server.sent.read.advise.challenge.ext
- server.sent.read.and.write.abort
- server.sent.throttle
- server.sent.throttle.initial.only
- server.sent.throttle.initial.only.message.aligned
- server.sent.throttle.message
- server.sent.write.abort
- server.sent.write.advise.flush
- server.sent.write.advise.flush.ext
- server.sent.write.empty.data.and.client.read.empty.data
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
8,993 files changed
+21562
-9853
lines changedLines changed: 42 additions & 1 deletion
Lines changed: 1 addition & 1 deletion
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 & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
| |||
13 | 13 |
| |
14 | 14 |
| |
15 | 15 |
| |
16 |
| - | |
17 | 16 |
| |
18 | 17 |
| |
19 | 18 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
0 commit comments