This is an automated email from the ASF dual-hosted git repository.
squakez pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
from 06b7e109b chore(doc): proper var name
new ad5bbf162 Fix #5935: Add ArkMQ operator queue Pipe binding
new 2fe006e0f feat(binding): support ActiveMQArtemis broker direct binding
in Pipe
new 6e95ab0ff Fix #5935: Verify Kubernetes Service in ArkMQ binding and
wait for queue in e2e setup
new d0b278577 Fix #5935: Fallback to existing namespace broker when
applyTo is omitted
new d7cf8f2f0 Fix #5935: Use context client instead of internal clientset
in ArkMQ binding
new af5b6bf3b Fix #5935: Add note on ArkMQ headless service convention and
future consistency
new 2345ff5fe Fix #5935: Simplify ArkMQ address lookup to direct
metadata.name Get
new 3b0267005 Fix #5935: Regenerate Helm RBAC templates and clean up
script/gen_client.sh
new 70ca06d17 Fix #5935: Address linter warnings in ArkMQ binding
new 39d0e4865 Fix #5935: Make e2e/arkmq/setup/setup.sh executable
new 1c118def2 Fix #5935: Restore ArkMQ clientset generation in
script/gen_client.sh
new 5aa092050 Fix #5935: Use AMQP component and ApplicationProperties for
ArkMQ binding
new 1ad7f909b Fix #5935: Allow multicast routing type in ArkMQ address
binding
new 931c679ca Fix #5935: Parameterize ArkMQ operator version in e2e setup
script
new 966f6ccfa Fix #5935: Use applyToCrNames in ArkMQ address spec and e2e
setup
new bd3662c07 Fix #5935: Remove unsupported wait for ready condition on
address in e2e setup
new 55e391d76 Fix #5935: Add watch RBAC and configure AMQP acceptor on
broker
new 6cb3095df Fix #5935: Drop registry action, use dev mode with embedded
registry
new 7f1446a43 Fix #5935: Use kubectl delete pipe instead of kamel delete
in e2e test
The 19 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/{kafka.yml => arkmq.yml} | 10 +-
docs/modules/ROOT/pages/pipes/pipes.adoc | 61 +-
.../arkmq_binding_test.go} | 41 +-
.../files/arkmq-to-log.yaml} | 10 +-
.../files/timer-to-arkmq.yaml} | 14 +-
.../setup/broker.yaml} | 16 +-
.../setup/gateway.yaml => arkmq/setup/queue.yaml} | 12 +-
e2e/{cert-manager => arkmq}/setup/setup.sh | 29 +-
helm/camel-k/templates/rbacs-descoped.yaml | 32 +
helm/camel-k/templates/rbacs-namespaced.yaml | 31 +
...uck_v1.go => addtoscheme_arkmq_duck_v1beta1.go} | 4 +-
.../duck/{certmanager/v1 => arkmq/v1beta1}/doc.go | 6 +-
pkg/apis/duck/arkmq/v1beta1/duck_types.go | 105 +++
.../{certmanager/v1 => arkmq/v1beta1}/register.go | 15 +-
.../duck/arkmq/v1beta1/zz_generated.deepcopy.go | 212 ++++++
.../clientset/internalclientset/clientset.go | 16 +-
.../internalclientset/fake/clientset_generated.go | 12 +-
.../clientset/internalclientset}/fake/doc.go | 0
.../clientset/internalclientset}/fake/register.go | 4 +-
.../clientset/internalclientset}/scheme/doc.go | 0
.../clientset/internalclientset/scheme/register.go | 4 +-
.../typed/arkmq/v1beta1/activemqartemis.go | 63 ++
.../typed/arkmq/v1beta1/activemqartemisaddress.go | 63 ++
.../typed/arkmq/v1beta1/arkmq_client.go} | 48 +-
.../internalclientset/typed/arkmq/v1beta1}/doc.go | 2 +-
.../typed/arkmq/v1beta1}/fake/doc.go | 0
.../arkmq/v1beta1/fake/fake_activemqartemis.go | 53 ++
.../v1beta1/fake/fake_activemqartemisaddress.go | 53 ++
.../typed/arkmq/v1beta1/fake/fake_arkmq_client.go} | 14 +-
.../typed/arkmq/v1beta1}/generated_expansion.go | 6 +-
pkg/controller/pipe/initialize_test.go | 164 ++++-
pkg/internal/client.go | 3 +-
.../config/rbac/descoped/kustomization.yaml | 2 +
...nager.yaml => operator-cluster-role-arkmq.yaml} | 8 +-
...ml => operator-cluster-role-binding-arkmq.yaml} | 4 +-
.../config/rbac/namespaced/kustomization.yaml | 2 +
...e-certmanager.yaml => operator-role-arkmq.yaml} | 8 +-
...-keda.yaml => operator-role-binding-arkmq.yaml} | 4 +-
pkg/util/bindings/arkmq.go | 328 +++++++++
pkg/util/bindings/arkmq_test.go | 748 +++++++++++++++++++++
script/Makefile | 8 +
script/gen_client.sh | 10 +
42 files changed, 2084 insertions(+), 141 deletions(-)
copy .github/workflows/{kafka.yml => arkmq.yml} (95%)
copy e2e/{common/cli/it_apply_test.go => arkmq/arkmq_binding_test.go} (52%)
copy e2e/{kafka/files/kafkatopic-to-log.yaml => arkmq/files/arkmq-to-log.yaml}
(88%)
copy e2e/{kafka/files/kafkatopic-to-log.yaml =>
arkmq/files/timer-to-arkmq.yaml} (86%)
copy e2e/{cert-manager/setup/cluster-issuer.yaml => arkmq/setup/broker.yaml}
(81%)
copy e2e/{gateway/setup/gateway.yaml => arkmq/setup/queue.yaml} (84%)
copy e2e/{cert-manager => arkmq}/setup/setup.sh (51%)
copy pkg/apis/{addtoscheme_certmanager_duck_v1.go =>
addtoscheme_arkmq_duck_v1beta1.go} (86%)
copy pkg/apis/duck/{certmanager/v1 => arkmq/v1beta1}/doc.go (88%)
create mode 100644 pkg/apis/duck/arkmq/v1beta1/duck_types.go
copy pkg/apis/duck/{certmanager/v1 => arkmq/v1beta1}/register.go (82%)
create mode 100644 pkg/apis/duck/arkmq/v1beta1/zz_generated.deepcopy.go
copy pkg/client/{strimzi => arkmq}/clientset/internalclientset/clientset.go
(87%)
copy pkg/client/{keda =>
arkmq}/clientset/internalclientset/fake/clientset_generated.go (86%)
copy pkg/client/{camel/clientset/versioned =>
arkmq/clientset/internalclientset}/fake/doc.go (100%)
copy pkg/client/{camel/clientset/versioned =>
arkmq/clientset/internalclientset}/fake/register.go (95%)
copy pkg/client/{camel/clientset/versioned =>
arkmq/clientset/internalclientset}/scheme/doc.go (100%)
copy pkg/client/{strimzi =>
arkmq}/clientset/internalclientset/scheme/register.go (95%)
create mode 100644
pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemis.go
create mode 100644
pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/activemqartemisaddress.go
copy
pkg/client/{strimzi/clientset/internalclientset/typed/strimzi/v1/strimzi_client.go
=> arkmq/clientset/internalclientset/typed/arkmq/v1beta1/arkmq_client.go} (59%)
copy pkg/client/{camel/clientset/versioned/typed/camel/v1 =>
arkmq/clientset/internalclientset/typed/arkmq/v1beta1}/doc.go (98%)
copy pkg/client/{camel/clientset/versioned/typed/camel/v1 =>
arkmq/clientset/internalclientset/typed/arkmq/v1beta1}/fake/doc.go (100%)
create mode 100644
pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemis.go
create mode 100644
pkg/client/arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_activemqartemisaddress.go
copy
pkg/client/{keda/clientset/internalclientset/typed/keda/v1alpha1/fake/fake_keda_client.go
=>
arkmq/clientset/internalclientset/typed/arkmq/v1beta1/fake/fake_arkmq_client.go}
(67%)
copy pkg/client/{keda/clientset/internalclientset/typed/keda/v1alpha1 =>
arkmq/clientset/internalclientset/typed/arkmq/v1beta1}/generated_expansion.go
(88%)
copy
pkg/resources/config/rbac/descoped/{operator-cluster-role-certmanager.yaml =>
operator-cluster-role-arkmq.yaml} (91%)
copy
pkg/resources/config/rbac/descoped/{operator-cluster-role-binding-keda.yaml =>
operator-cluster-role-binding-arkmq.yaml} (94%)
copy pkg/resources/config/rbac/namespaced/{operator-role-certmanager.yaml =>
operator-role-arkmq.yaml} (91%)
copy pkg/resources/config/rbac/namespaced/{operator-role-binding-keda.yaml =>
operator-role-binding-arkmq.yaml} (94%)
create mode 100644 pkg/util/bindings/arkmq.go
create mode 100644 pkg/util/bindings/arkmq_test.go
