eventing-rabbitmq
RabbitMQ eventing components. Knative Source and Broker.
File Explorer
Download Latest Version (.zip)Showing a partial file list โ download the zip above to see everything.
- bug.md
- feature-request.md
- kind-conformance.yaml
- kind-e2e.yaml
- knative-go-build.yaml
- knative-go-test.yaml
- knative-security.yaml
- knative-stale.yaml
- knative-style.yaml
- knative-verify.yaml
- spec.md
- main.go
- main.go
- main.go
- main.go
- main.go
- main.go
- main.go
- main.go
- 200-rabbitmq-broker-binding.yaml
- 200-rabbitmq-broker-clusterrole.yaml
- 200-webhook-clusterrole.yaml
- 201-webhook-serviceaccount.yaml
- 300-rabbitmqbrokerconfig.yaml
- 500-broker-controller.yaml
- 500-webhook-defaulting.yaml
- 500-webhook-resource-validation.yaml
- 500-webhook-secret.yaml
- 500-webhook.yaml
- failer.yaml
- 100-namespace.yaml
- 200-serviceaccount.yaml
- 200-webhook-clusterrole.yaml
- 201-clusterrole.yaml
- 201-webhook-serviceaccount.yaml
- 202-clusterrolebinding.yaml
- 300-rabbitmqsource.yaml
- 400-controller-service.yaml
- 400-webhook-service.yaml
- 500-controller.yaml
- 500-webhook-config-validation.yaml
- 500-webhook-defaulting.yaml
- 500-webhook-resource-validation.yaml
- 500-webhook-secret.yaml
- 500-webhook-sinkbindings.yaml
- 500-webhook.yaml
- config-observability.yaml
- rabbitmq-knative-broker.png
- README.md
- README.md
- README.md
- rabbitmq-knative-source.png
- README.md
- source-example.yaml
- CONTRIBUTING.md
- DEVELOPMENT.md
- prerequisites.md
- README.md
- add-boilerplate.sh
- boilerplate.go.txt
- boilerplate.sh.txt
- OWNERS
- README.md
- release.sh
- tools.go
- update-codegen.sh
- update-deps.sh
- verify-codegen.sh
- adapter.go
- adapter_test.go
- doc.go
- rabbit.go
- register.go
- register_test.go
- zz_generated.deepcopy.go
- broker_validation.go
- broker_validation_test.go
- doc.go
- rabbitmq_defaults.go
- rabbitmq_defaults_test.go
- rabbitmq_types.go
- rabbitmq_types_test.go
- rabbitmq_validation.go
- rabbitmq_validation_test.go
- register.go
- trigger_validation.go
- trigger_validation_test.go
- zz_generated.deepcopy.go
- doc.go
- rabbitmq_defaults.go
- rabbitmq_defaults_test.go
- rabbitmq_lifecycle.go
- rabbitmq_lifecycle_test.go
- rabbitmq_types.go
- rabbitmq_types_test.go
- rabbitmq_validation.go
- rabbitmq_validation_test.go
- register.go
- register_test.go
- zz_generated.deepcopy.go
- register.go
- metrics.go
- service.go
- clientset_generated.go
- doc.go
- register.go
- doc.go
- register.go
- doc.go
- fake_eventing_client.go
- fake_rabbitmqbrokerconfig.go
- doc.go
- eventing_client.go
- generated_expansion.go
- rabbitmqbrokerconfig.go
- doc.go
- fake_rabbitmqsource.go
- fake_sources_client.go
- doc.go
- generated_expansion.go
- rabbitmqsource.go
- sources_client.go
- clientset.go
- interface.go
- rabbitmqbrokerconfig.go
- interface.go
- factory_interfaces.go
- interface.go
- rabbitmqsource.go
- interface.go
- factory.go
- generic.go
- fake.go
- client.go
- fake.go
- rabbit.go
- fake.go
- fake.go
- rabbitmqbrokerconfig.go
- rabbitmqbrokerconfig.go
- fake.go
- fake_filtered_factory.go
- filtered_factory.go
- factory.go
- fake.go
- fake.go
- rabbitmqsource.go
- rabbitmqsource.go
- fake.go
- client.go
- fake.go
- fake_filtered_factory.go
- filtered_factory.go
- factory.go
- fake.go
- fake.go
- binding.go
- binding.go
- fake.go
- fake.go
- exchange.go
- exchange.go
- fake.go
- fake.go
- permission.go
- permission.go
- fake.go
- fake.go
- policy.go
- policy.go
- fake.go
- fake.go
- queue.go
- queue.go
- fake.go
- fake.go
- schemareplication.go
- schemareplication.go
- fake.go
- fake.go
- user.go
- user.go
- fake.go
- fake.go
- vhost.go
- vhost.go
- controller.go
- reconciler.go
- state.go
- expansion_generated.go
- rabbitmqbrokerconfig.go
- expansion_generated.go
- rabbitmqsource.go
- dispatcher.go
- dispatcher_test.go
- binding.go
- binding_test.go
- connections_handler.go
- connections_handler_test.go
- exchange.go
- exchange_test.go
- label.go
- label_test.go
- message.go
- message_test.go
- queue.go
- queue_test.go
- rabbit_mocks.go
- secret.go
- secret_test.go
- service.go
- service_test.go
- types.go
- naming.go
- naming_test.go
- dispatcher.go
- dispatcher_test.go
- ingress.go
- ingress_test.go
- broker.go
- broker_lifecycle.go
- broker_test.go
- broker_test_helper.go
- controller.go
- controller_test.go
- closers.go
- labels.go
- labels_test.go
- receive_adapter.go
- receive_adapter_test.go
- controller.go
- doc.go
- rabbitmqsource.go
- factory.go
- listers.go
- dispatcher.go
- dispatcher_test.go
- controller.go
- controller_test.go
- trigger.go
- trigger_test.go
- envconfig.go
- filter.go
- helpers.go
- helpers_test.go
- http.go
- http_test.go
- rabbitmq_validation.go
- rabbitmq_validation_test.go
- resource_requirements.go
- resource_requirements_test.go
- 100-broker-config.yaml
- 200-broker.yaml
- 300-ping-sources.yaml
- 400-trigger.yaml
- 500-failer.yaml
- rabbitmq-sample-deployment.yaml
- 100-perf-test.yaml
- 200-source.yaml
- 100-namespace.yaml
- 200-secret.yaml
- 300-sink.yaml
- README.md
- 100-namespaces.yaml
- 200-rabbitmq-cluster.yaml
- 300-ping-events.yaml
- 400-pong-events.yaml
- README.md
- 100-predeclared-resources.yaml
- 200-perf-test.yaml
- 300-source.yaml
- 100-namespace.yaml
- 200-rabbitmq.yaml
- 300-sink.yaml
- README.md
- 100-broker-config.yaml
- 200-broker.yaml
- 300-ping-sources.yaml
- 400-trigger.yaml
- 500-failer.yaml
- 100-perf-test.yaml
- 200-source.yaml
- 100-namespace.yaml
- 200-rabbitmq.yaml
- 300-sink.yaml
- README.md
- 100-broker-config.yaml
- 200-broker.yaml
- 300-ping-sources.yaml
- 400-trigger.yaml
- 500-failer.yaml
- 100-perf-test.yaml
- 200-source.yaml
- 100-namespace.yaml
- 200-selfsigned-issuer-and-cert.yaml
- 300-cluster-issuer-and-cert.yaml
- 400-rabbitmq.yaml
- 500-sink.yaml
- README.md
- 100-broker-config.yaml
- 200-broker.yaml
- 300-ping-source.yaml
- 400-trigger.yaml
- 500-failer.yaml
- 100-perf-test.yaml
- 200-source.yaml
- 300-failer.yaml
- 100-namespace.yaml
- 200-rabbitmq.yaml
- 300-sink.yaml
- README.md
- 100-namespace.yaml
- 200-broker-config.yaml
- 300-broker.yaml
- 400-cluster.yaml
- 500-sink.yaml
- 600-source.yaml
- 700-trigger.yaml
- README.md
- main.go
- main.go
- 100-namespace.yaml
- 200-rabbitmq.yaml
- 250-broker-config.yaml
- 300-broker.yaml
- 400-trigger.yaml
- 500-sink.yaml
- 600-event-sender.yaml
- README.md
- perf-test.help.env.text
- config-logging.yaml
- quacken.yaml
- readyness.go
- rabbitmqcluster.go
- rabbitmqcluster.yaml
- base.yaml
- broker_config.yaml
- conformance_test.go
- main_test.go
- system.go
- main.go
- broker.go
- broker.yaml
- broker.yaml
- brokersecret.go
- trigger.yaml
- broker.yaml
- brokertrigger.go
- trigger.yaml
- broker.yaml
- brokertrigger.go
- trigger.yaml
- certsecret.go
- secret.yaml
- broker.yaml
- dlq.go
- failer.yaml
- trigger.yaml
- cluster.yaml
- rabbitmq.go
- smoke.go
- smoke.yaml
- smoke.go
- smoke.yaml
- rabbitmq-source.yaml
- source.go
- producer.yaml
- sourceproducer.go
- rabbitmq-source.yaml
- sourcesecret.go
- rabbitmq-source-vhost.yaml
- sourcevhost.go
- vhost-producer.yaml
- vhostsourceproducer.go
- register.go
- union.go
- broker_test.go
- kind.yaml
- main_test.go
- rabbitmqcluster.go
- README.md
- recorder.go
- selfsignedcerts.go
- source_test.go
- copy_images.sh
- presubmit-tests.sh
- README.md
- eventing-core.yaml
- eventing-crds.yaml
- binding_types.go
- conditions.go
- exchange_types.go
- federation_types.go
- groupversion_info.go
- operatorpolicy_types.go
- permission_types.go
- policy_types.go
- queue_types.go
- rabbitmq_cluster_reference.go
- schemareplication_types.go
- shovel_types.go
- topicpermission_types.go
- topology_resource.go
- user_types.go
- vhost_types.go
- zz_generated.deepcopy.go
- clientset_generated.go
- doc.go
- register.go
- doc.go
- register.go
- doc.go
- fake_binding.go
- fake_exchange.go
- fake_federation.go
- fake_operatorpolicy.go
- fake_permission.go
- fake_policy.go
- fake_queue.go
- fake_rabbitmq.com_client.go
- fake_schemareplication.go
- fake_shovel.go
- fake_user.go
- fake_vhost.go
- binding.go
- doc.go
- exchange.go
- federation.go
- generated_expansion.go
- operatorpolicy.go
- permission.go
- policy.go
- queue.go
- rabbitmq.com_client.go
- schemareplication.go
- shovel.go
- user.go
- vhost.go
- clientset.go
- factory_interfaces.go
- binding.go
- exchange.go
- federation.go
- interface.go
- operatorpolicy.go
- permission.go
- policy.go
- queue.go
- schemareplication.go
- shovel.go
- user.go
- vhost.go
- interface.go
- factory.go
- generic.go
- fake.go
- client.go
- fake.go
- fake_filtered_factory.go
- filtered_factory.go
- factory.go
- fake.go
- fake.go
- binding.go
- binding.go
- fake.go
- fake.go
- exchange.go
- exchange.go
- fake.go
- fake.go
- federation.go
- federation.go
- fake.go
- fake.go
- operatorpolicy.go
- operatorpolicy.go
- fake.go
- fake.go
- permission.go
- permission.go
- fake.go
- fake.go
- policy.go
- policy.go
- fake.go
- fake.go
- queue.go
- queue.go
- fake.go
- fake.go
- schemareplication.go
- schemareplication.go
- fake.go
- fake.go
- shovel.go
- shovel.go
- fake.go
- fake.go
- user.go
- user.go
- fake.go
- fake.go
- vhost.go
- vhost.go
- binding.go
- exchange.go
- expansion_generated.go
- federation.go
- operatorpolicy.go
- permission.go
- policy.go
- queue.go
- schemareplication.go
- shovel.go
- user.go
- vhost.go
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- NOTICE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- LICENSE
- README.md
- .gitignore
- CHANGELOG.md
- CODEOWNERS
- LICENSE
- Makefile
- README.md
- .gitignore
- .golangci.yml
- LICENSE
- README.md
- LICENSE
- license.md
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- NOTICE
- LICENSE
- NOTICE
- README.txt
- LICENSE
- NOTICE
- LICENSE
- NOTICE
- LICENSE
- NOTICE
- LICENSE
- LICENSE.txt
- LICENSE.txt
- NOTICE.txt
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- LICENSE
- LICENSE.txt
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- NOTICE.txt
- LICENSE
- LICENSE
- LICENSE
- NOTICE
- LICENSE
- NOTICE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- NOTICE
- LICENSE
- atn.go
- atn_config.go
- atn_config_set.go
- atn_deserialization_options.go
- atn_deserializer.go
- atn_simulator.go
- atn_state.go
- atn_type.go
- char_stream.go
- common_token_factory.go
- common_token_stream.go
- dfa.go
- dfa_serializer.go
- dfa_state.go
- diagnostic_error_listener.go
- error_listener.go
- error_strategy.go
- errors.go
- file_stream.go
- input_stream.go
- int_stream.go
- interval_set.go
- lexer.go
- lexer_action.go
- lexer_action_executor.go
- lexer_atn_simulator.go
- LICENSE
- ll1_analyzer.go
- parser.go
- parser_atn_simulator.go
- parser_rule_context.go
- prediction_context.go
- prediction_mode.go
- recognizer.go
- rule_context.go
- semantic_context.go
- token.go
- token_source.go
- token_stream.go
- tokenstream_rewriter.go
- trace_listener.go
- transition.go
- tree.go
- trees.go
- utils.go
- utils_set.go
- exampledata.txt
- stream.go
- LICENSE
- json.go
- LICENSE
- range.go
- semver.go
- sort.go
- sql.go
- .gitignore
- config.go
- core.go
- encoder.go
- http.go
- label.go
- LICENSE
- logger.go
- operation.go
- README.md
- report.go
- service.go
- source.go
- trace.go
- .gitignore
- backoff.go
- CHANGELOG.md
- error.go
- exponential.go
- LICENSE
- README.md
- retry.go
- ticker.go
- timer.go
- const.go
- doc.go
- register.go
- types.go
- types_challenge.go
- types_issuer.go
- types_order.go
- zz_generated.deepcopy.go
- doc.go
- const.go
- doc.go
- generic_issuer.go
- register.go
- types.go
- types_certificate.go
- types_certificaterequest.go
- types_issuer.go
- zz_generated.deepcopy.go
- doc.go
- doc.go
- register.go
- types.go
- zz_generated.deepcopy.go
- doc.go
- clientset_generated.go
- doc.go
- register.go
- doc.go
- register.go
- doc.go
- fake_acme_client.go
- fake_challenge.go
- fake_order.go
- acme_client.go
- challenge.go
- doc.go
- generated_expansion.go
- order.go
- doc.go
- fake_certificate.go
- fake_certificaterequest.go
- fake_certmanager_client.go
- fake_clusterissuer.go
- fake_issuer.go
- certificate.go
- certificaterequest.go
- certmanager_client.go
- clusterissuer.go
- doc.go
- generated_expansion.go
- issuer.go
- clientset.go
- certificate.go
- certificaterequest.go
- clusterissuer.go
- expansion_generated.go
- issuer.go
- LICENSE
- LICENSES
- LICENSE.txt
- README.md
- testall.sh
- xxhash.go
- xxhash_amd64.s
- xxhash_arm64.s
- xxhash_asm.go
- xxhash_other.go
- xxhash_safe.go
- xxhash_unsafe.go
- event.go
- read.go
- write.go
- http.go
- raw.go
- LICENSE
- client.go
- observability_service.go
- observable.go
- reporter.go
- trace_attributes.go
- http.go
- LICENSE
- client.go
- cloudevents_carrier.go
- otel_observability_service.go
- otel_options.go
- http.go
- LICENSE
- base_expressions.go
- comparison_expressions.go
- exists_expression.go
- function_invocation_expression.go
- identifier_expression.go
- in_expression.go
- integer_comparison_expressions.go
- like_expression.go
- literal_expression.go
- logic_expressions.go
- math_expressions.go
- negate_expression.go
- not_expression.go
- casting_functions.go
- function.go
- integer_functions.go
- string_functions.go
- CESQLParser.interp
- CESQLParser.tokens
- cesqlparser_base_visitor.go
- cesqlparser_lexer.go
- cesqlparser_parser.go
- cesqlparser_visitor.go
- CESQLParserLexer.interp
- CESQLParserLexer.tokens
- case_changing_stream.go
- expression_visitor.go
- parser.go
- functions_resolver.go
- casting.go
- event.go
- CESQLLexer.g4
- CESQLParser.g4
- expression.go
- function.go
- LICENSE
- Makefile
- README.md
- types.go
- acks_before_finish_message.go
- binary_buffer_message.go
- copy_message.go
- doc.go
- struct_buffer_message.go
- doc.go
- format.go
- attributes.go
- doc.go
- match_exact_version.go
- spec.go
- doc.go
- mock_binary_message.go
- mock_structured_message.go
- mock_transformer.go
- mock_unknown_message.go
- transformer.go
- add_metadata.go
- default_metadata.go
- delete_metadata.go
- doc.go
- set_metadata.go
- version.go
- binary_writer.go
- doc.go
- encoding.go
- event_message.go
- finish_message.go
- message.go
- structured_writer.go
- to_event.go
- transformer.go
- write.go
- client.go
- client_http.go
- client_observed.go
- defaulters.go
- doc.go
- http_receiver.go
- invoker.go
- observability.go
- options.go
- receiver.go
- context.go
- delegating.go
- doc.go
- logger.go
- retry.go
- data.go
- doc.go
- data.go
- doc.go
- data.go
- doc.go
- codec.go
- doc.go
- content_type.go
- data_content_encoding.go
- doc.go
- event.go
- event_data.go
- event_interface.go
- event_marshal.go
- event_reader.go
- event_unmarshal.go
- event_validation.go
- event_writer.go
- eventcontext.go
- eventcontext_v03.go
- eventcontext_v03_reader.go
- eventcontext_v03_writer.go
- eventcontext_v1.go
- eventcontext_v1_reader.go
- eventcontext_v1_writer.go
- extensions.go
- dataref_extension.go
- distributed_tracing_extension.go
- doc.go
- doc.go
- keys.go
- abuse_protection.go
- context.go
- doc.go
- headers.go
- message.go
- options.go
- protocol.go
- protocol_lifecycle.go
- protocol_rate.go
- protocol_retry.go
- result.go
- retries_result.go
- utility.go
- write_request.go
- write_responsewriter.go
- doc.go
- error.go
- inbound.go
- lifecycle.go
- outbound.go
- result.go
- doc.go
- event_asserts.go
- event_matchers.go
- event_mocks.go
- helpers.go
- allocate.go
- doc.go
- timestamp.go
- uri.go
- uriref.go
- value.go
- alias.go
- LICENSE
- staticcheck.conf
- jose.go
- jwks.go
- oidc.go
- verify.go
- LICENSE
- NOTICE
- bypass.go
- bypasssafe.go
- common.go
- config.go
- doc.go
- dump.go
- format.go
- spew.go
- LICENSE
- log.go
- .gitignore
- .goconvey
- bench_test.sh
- CHANGES.md
- compress.go
- compressor_cache.go
- compressor_pools.go
- compressors.go
- constants.go
- container.go
- cors_filter.go
- coverage.sh
- curly.go
- curly_route.go
- custom_verb.go
- doc.go
- entity_accessors.go
- extensions.go
- filter.go
- filter_adapter.go
- jsr311.go
- LICENSE
- logger.go
- Makefile
- mime.go
- options_filter.go
- parameter.go
- path_expression.go
- path_processor.go
- README.md
- request.go
- response.go
- route.go
- route_builder.go
- route_reader.go
- router.go
- SECURITY.md
- service_error.go
- Srcfile
- web_service.go
- web_service_container.go
- decode.go
- encode.go
- fold.go
- fuzz.go
- indent.go
- scanner.go
- stream.go
- tables.go
- tags.go
- errors.go
- LICENSE
- merge.go
- patch.go
- .gitignore
- capture_metrics.go
- docs.go
- LICENSE.txt
- Makefile
- README.md
- wrap_generated.go
- .gitignore
- .golangci.yml
- bytestring.go
- cache.go
- CODE_OF_CONDUCT.md
- common.go
- CONTRIBUTING.md
- decode.go
- decode_map_utils.go
- diagnose.go
- doc.go
- encode.go
- encode_map.go
- LICENSE
- omitzero_go124.go
- omitzero_pre_go124.go
- README.md
- SECURITY.md
- simplevalue.go
- stream.go
- structfields.go
- tag.go
- valid.go
- cbc_hmac.go
- concat_kdf.go
- ecdh_es.go
- key_wrap.go
- decode.go
- encode.go
- indent.go
- LICENSE
- README.md
- scanner.go
- stream.go
- tags.go
- builder.go
- claims.go
- doc.go
- errors.go
- jwt.go
- validation.go
- .gitignore
- .golangci.yml
- .travis.yml
- asymmetric.go
- CHANGELOG.md
- CONTRIBUTING.md
- crypter.go
- doc.go
- encoding.go
- jwe.go
- jwk.go
- jws.go
- LICENSE
- opaque.go
- README.md
- SECURITY.md
- shared.go
- signing.go
- symmetric.go
- funcr.go
- slogsink.go
- slogr.go
- .golangci.yaml
- CHANGELOG.md
- context.go
- context_noslog.go
- context_slog.go
- CONTRIBUTING.md
- discard.go
- LICENSE
- logr.go
- README.md
- SECURITY.md
- sloghandler.go
- slogr.go
- slogsink.go
- LICENSE
- README.md
- stdr.go
- .gitignore
- .golangci.yaml
- LICENSE
- README.md
- slogzapr.go
- zapr.go
- zapr_noslog.go
- zapr_slog.go
- doc.go
- go_name_provider.go
- ifaces.go
- name_provider.go
- .editorconfig
- .gitignore
- .golangci.yml
- CODE_OF_CONDUCT.md
- CONTRIBUTORS.md
- errors.go
- ifaces.go
- LICENSE
- NOTICE
- options.go
- pointer.go
- README.md
- SECURITY.md
- normalize_url.go
- .editorconfig
- .gitignore
- .golangci.yml
- CODE_OF_CONDUCT.md
- CONTRIBUTORS.md
- LICENSE
- NOTICE
- README.md
- reference.go
- SECURITY.md
- cmd_utils.go
- doc.go
- LICENSE
- convert.go
- convert_types.go
- doc.go
- format.go
- LICENSE
- sizeof.go
- type_constraints.go
- doc.go
- file.go
- LICENSE
- path.go
- doc.go
- ifaces.go
- registry_iface.go
- adapter.go
- doc.go
- lexer.go
- options.go
- ordered_map.go
- pool.go
- register.go
- writer.go
- doc.go
- registry.go
- concat.go
- doc.go
- json.go
- LICENSE
- ordered_map.go
- README.md
- doc.go
- errors.go
- json.go
- LICENSE
- loading.go
- options.go
- yaml.go
- BENCHMARK.md
- doc.go
- initialism_index.go
- LICENSE
- name_lexem.go
- name_mangler.go
- options.go
- pools.go
- split.go
- string_bytes.go
- util.go
- doc.go
- LICENSE
- net.go
- debug.go
- debug_off.go
- debug_on.go
- doc.go
- LICENSE
- pools.go
- README.md
- collection_formats.go
- doc.go
- LICENSE
- strings.go
- doc.go
- LICENSE
- types.go
- doc.go
- errors.go
- LICENSE
- ordered_map.go
- yaml.go
- .codecov.yml
- .editorconfig
- .gitattributes
- .gitignore
- .golangci.yml
- .mockery.yml
- cmdutils_iface.go
- CODE_OF_CONDUCT.md
- CONTRIBUTORS.md
- conv_iface.go
- doc.go
- fileutils_iface.go
- go.work
- go.work.sum
- jsonname_iface.go
- jsonutils_iface.go
- LICENSE
- loading_iface.go
- mangling_iface.go
- netutils_iface.go
- README.md
- SECURITY.md
- stringutils_iface.go
- typeutils_iface.go
- yamlutils_iface.go
- .gitignore
- .gometalinter.json
- acronyms.go
- camelize.go
- capitalize.go
- custom_data.go
- dasherize.go
- flect.go
- humanize.go
- ident.go
- LICENSE
- lower_upper.go
- Makefile
- ordinalize.go
- pascalize.go
- plural_rules.go
- pluralize.go
- README.md
- rule.go
- SHOULDERS.md
- singular_rules.go
- singularize.go
- titleize.go
- underscore.go
- version.go
- lru.go
- LICENSE
- context.go
- error.go
- extensions.go
- helpers.go
- main.go
- reader.go
- README.md
- extension.pb.go
- extension.proto
- extensions.go
- README.md
- base.go
- display.go
- models.go
- operations.go
- reader.go
- README.md
- schema.json
- writer.go
- document.go
- openapi-2.0.json
- OpenAPIv2.go
- OpenAPIv2.pb.go
- OpenAPIv2.proto
- README.md
- annotations.pb.go
- annotations.proto
- document.go
- OpenAPIv3.go
- OpenAPIv3.pb.go
- OpenAPIv3.proto
- README.md
- LICENSE
- equate.go
- ignore.go
- sort.go
- struct_filter.go
- xform.go
- debug_disable.go
- debug_enable.go
- diff.go
- flags.go
- func.go
- name.go
- pointer.go
- sort.go
- compare.go
- export.go
- options.go
- path.go
- report.go
- report_compare.go
- report_references.go
- report_reflect.go
- report_slices.go
- report_text.go
- report_value.go
- LICENSE
- sets.go
- stringset.go
- 0BSD.txt
- AFL-1.1.header.txt
- AFL-1.1.txt
- AFL-1.2.header.txt
- AFL-1.2.txt
- AFL-2.0.header.txt
- AFL-2.0.txt
- AFL-2.1.header.txt
- AFL-2.1.txt
- AFL-3.0.header.txt
- AFL-3.0.txt
- AGPL-1.0.txt
- AGPL-3.0.header.txt
- AGPL-3.0.txt
- Apache-1.0.txt
- Apache-1.1.txt
- Apache-2.0.header.txt
- Apache-2.0.txt
- APSL-1.0.header.txt
- APSL-1.0.txt
- APSL-1.1.header.txt
- APSL-1.1.txt
- APSL-1.2.header.txt
- APSL-1.2.txt
- APSL-2.0.header.txt
- APSL-2.0.txt
- Artistic-1.0-cl8.txt
- Artistic-1.0-Perl.txt
- Artistic-1.0.txt
- Artistic-2.0.txt
- BCL.txt
- Beerware.txt
- BSD-2-Clause-FreeBSD.txt
- BSD-2-Clause-NetBSD.txt
- BSD-2-Clause.txt
- BSD-3-Clause-Attribution.txt
- BSD-3-Clause-Clear.txt
- BSD-3-Clause-LBNL.txt
- BSD-3-Clause.txt
- BSD-4-Clause-UC.txt
- BSD-4-Clause.txt
- BSD-Protection.txt
- BSL-1.0.txt
- CC-BY-1.0.txt
- CC-BY-2.0.txt
- CC-BY-2.5.txt
- CC-BY-3.0.txt
- CC-BY-4.0.txt
- CC-BY-NC-1.0.txt
- CC-BY-NC-2.0.txt
- CC-BY-NC-2.5.txt
- CC-BY-NC-3.0.txt
- CC-BY-NC-4.0.txt
- CC-BY-NC-ND-1.0.txt
- CC-BY-NC-ND-2.0.txt
- CC-BY-NC-ND-2.5.txt
- CC-BY-NC-ND-3.0.txt
- CC-BY-NC-ND-4.0.txt
- CC-BY-NC-SA-1.0.txt
- CC-BY-NC-SA-2.0.txt
- CC-BY-NC-SA-2.5.txt
- CC-BY-NC-SA-3.0.txt
- CC-BY-NC-SA-4.0.txt
- CC-BY-ND-1.0.txt
- CC-BY-ND-2.0.txt
- CC-BY-ND-2.5.txt
- CC-BY-ND-3.0.txt
- CC-BY-ND-4.0.txt
- CC-BY-SA-1.0.txt
- CC-BY-SA-2.0.txt
- CC-BY-SA-2.5.txt
- CC-BY-SA-3.0.txt
- CC-BY-SA-4.0.txt
- CC0-1.0.txt
- CDDL-1.0.txt
- CDDL-1.1.txt
- Commons-Clause.txt
- CPAL-1.0.header.txt
- CPAL-1.0.txt
- CPL-1.0.txt
- dummy.go
- eGenix.txt
- EPL-1.0.txt
- EPL-2.0.txt
- EUPL-1.0.txt
- EUPL-1.1.txt
- Facebook-2-Clause.txt
- Facebook-3-Clause.txt
- Facebook-Examples.txt
- forbidden_licenses.db
- FreeImage.txt
- FTL.txt
- GPL-1.0.header.txt
- GPL-1.0.txt
- GPL-2.0-with-autoconf-exception.txt
- GPL-2.0-with-bison-exception.txt
- GPL-2.0-with-classpath-exception.txt
- GPL-2.0-with-font-exception.txt
- GPL-2.0-with-GCC-exception.txt
- GPL-2.0.header.txt
- GPL-2.0.txt
- GPL-3.0-with-autoconf-exception.txt
- GPL-3.0-with-GCC-exception.txt
- GPL-3.0.header.txt
- GPL-3.0.txt
- GUST-Font-License.txt
- ImageMagick.header.txt
- ImageMagick.txt
- IPL-1.0.txt
- ISC.txt
- LGPL-2.0.header.txt
- LGPL-2.0.txt
- LGPL-2.1.header.txt
- LGPL-2.1.txt
- LGPL-3.0.header.txt
- LGPL-3.0.txt
- LGPLLR.txt
- Libpng.txt
- licenses.db
- Lil-1.0.txt
- Linux-OpenIB.txt
- LPL-1.0.txt
- LPL-1.02.txt
- LPPL-1.3c.txt
- MIT.txt
- MPL-1.0.header.txt
- MPL-1.0.txt
- MPL-1.1.header.txt
- MPL-1.1.txt
- MPL-2.0-no-copyleft-exception.header.txt
- MPL-2.0.header.txt
- MPL-2.0.txt
- MS-PL.txt
- NCSA.txt
- NPL-1.0.txt
- NPL-1.1.txt
- OFL-1.1.txt
- OpenSSL.txt
- OpenVision.txt
- OSL-1.0.txt
- OSL-1.1.txt
- OSL-2.0.txt
- OSL-2.1.txt
- OSL-3.0.header.txt
- OSL-3.0.txt
- PHP-3.0.txt
- PHP-3.01.txt
- PIL.txt
- PostgreSQL.txt
- Python-2.0-complete.txt
- Python-2.0.txt
- QPL-1.0.txt
- README.md
- Ruby.txt
- SGI-B-1.0.header.txt
- SGI-B-1.0.txt
- SGI-B-1.1.header.txt
- SGI-B-1.1.txt
- SGI-B-2.0.txt
- SISSL-1.2.header.txt
- SISSL-1.2.txt
- SISSL.header.txt
- SISSL.txt
- Sleepycat.txt
- Unicode-DFS-2015.txt
- Unicode-DFS-2016.txt
- Unicode-TOU.txt
- Unlicense.txt
- UPL-1.0.txt
- W3C-19980720.txt
- W3C-20150513.txt
- W3C.header.txt
- W3C.txt
- WTFPL.txt
- X11.txt
- Xnet.txt
- Zend-2.0.txt
- zlib-acknowledgement.txt
- Zlib.txt
- ZPL-1.1.txt
- ZPL-2.0.txt
- ZPL-2.1.txt
- priority.go
- tokenizer.go
- searchset.go
- classifier.go
- CONTRIBUTING.md
- LICENSE
- README.md
- .travis.yml
- CHANGELOG
- classifier.go
- CONTRIBUTING.md
- file_system_resources.go
- forbidden.go
- LICENSE
- license_type.go
- README.md
- CHANGELOG.md
- CONTRIBUTING.md
- CONTRIBUTORS
- dce.go
- doc.go
- hash.go
- LICENSE
- marshal.go
- node.go
- node_js.go
- node_net.go
- null.go
- README.md
- sql.go
- time.go
- util.go
- uuid.go
- version1.go
- version4.go
- version6.go
- version7.go
- compile.go
- fuzz.go
- parse.go
- types.go
- context.go
- convert.go
- doc.go
- errors.go
- fieldmask.go
- handler.go
- marshal_httpbodyproto.go
- marshal_json.go
- marshal_jsonpb.go
- marshal_proto.go
- marshaler.go
- marshaler_registry.go
- mux.go
- pattern.go
- proto2_convert.go
- query.go
- doc.go
- pattern.go
- readerfactory.go
- string_array_flag.go
- trie.go
- LICENSE
- cleanhttp.go
- doc.go
- handlers.go
- LICENSE
- README.md
- .gitignore
- .go-version
- .golangci.yml
- cert_error_go119.go
- cert_error_go120.go
- CHANGELOG.md
- client.go
- CODEOWNERS
- LICENSE
- Makefile
- README.md
- roundtripper.go
- lru.go
- lru_interface.go
- .gitignore
- .golangci.yml
- 2q.go
- arc.go
- doc.go
- LICENSE
- lru.go
- README.md
- testing.go
- .codecov.yml
- .gitignore
- .travis.yml
- adapter.go
- any.go
- any_array.go
- any_bool.go
- any_float.go
- any_int32.go
- any_int64.go
- any_invalid.go
- any_nil.go
- any_number.go
- any_object.go
- any_str.go
- any_uint32.go
- any_uint64.go
- build.sh
- config.go
- fuzzy_mode_convert_table.md
- Gopkg.lock
- Gopkg.toml
- iter.go
- iter_array.go
- iter_float.go
- iter_int.go
- iter_object.go
- iter_skip.go
- iter_skip_sloppy.go
- iter_skip_strict.go
- iter_str.go
- jsoniter.go
- LICENSE
- pool.go
- README.md
- reflect.go
- reflect_array.go
- reflect_dynamic.go
- reflect_extension.go
- reflect_json_number.go
- reflect_json_raw_message.go
- reflect_map.go
- reflect_marshaler.go
- reflect_native.go
- reflect_optional.go
- reflect_slice.go
- reflect_struct_decoder.go
- reflect_struct_encoder.go
- stream.go
- stream_float.go
- stream_int.go
- stream_str.go
- test.sh
- .travis.yml
- doc.go
- env_os.go
- env_syscall.go
- envconfig.go
- LICENSE
- MAINTAINERS
- README.md
- usage.go
- .gitignore
- .travis.yml
- executor.go
- go_above_19.go
- go_below_19.go
- LICENSE
- log.go
- README.md
- test.sh
- unbounded_executor.go
- .gitignore
- .travis.yml
- go_above_118.go
- go_above_19.go
- go_below_118.go
- Gopkg.lock
- Gopkg.toml
- LICENSE
- README.md
- reflect2.go
- reflect2_amd64.s
- reflect2_kind.go
- relfect2_386.s
- relfect2_amd64p32.s
- relfect2_arm.s
- relfect2_arm64.s
- relfect2_mips64x.s
- relfect2_mipsx.s
- relfect2_ppc64x.s
- relfect2_s390x.s
- safe_field.go
- safe_map.go
- safe_slice.go
- safe_struct.go
- safe_type.go
- type_map.go
- unsafe_array.go
- unsafe_eface.go
- unsafe_field.go
- unsafe_iface.go
- unsafe_link.go
- unsafe_map.go
- unsafe_ptr.go
- unsafe_slice.go
- unsafe_struct.go
- unsafe_type.go
- autoneg.go
- LICENSE
- Makefile
- README.txt
- .gitignore
- .travis.yml
- appveyor.yml
- errors.go
- go113.go
- LICENSE
- Makefile
- README.md
- stack.go
- difflib.go
- LICENSE
- header.go
- negotiate.go
- LICENSE
- almost_equal.go
- difflib.go
- go_collector_options.go
- go_runtime_metrics.go
- metric.go
- compression.go
- delegator.go
- http.go
- instrument_client.go
- instrument_server.go
- option.go
- .gitignore
- build_info_collector.go
- collector.go
- collectorfunc.go
- counter.go
- desc.go
- doc.go
- expvar_collector.go
- fnv.go
- gauge.go
- get_pid.go
- get_pid_gopherjs.go
- go_collector.go
- go_collector_latest.go
- histogram.go
- labels.go
- metric.go
- num_threads.go
- num_threads_gopherjs.go
- observer.go
- process_collector.go
- process_collector_darwin.go
- process_collector_mem_cgo_darwin.c
- process_collector_mem_cgo_darwin.go
- process_collector_mem_nocgo_darwin.go
- process_collector_not_supported.go
- process_collector_procfsenabled.go
- process_collector_windows.go
- README.md
- registry.go
- summary.go
- timer.go
- untyped.go
- value.go
- vec.go
- vnext.go
- wrap.go
- LICENSE
- NOTICE
- metrics.pb.go
- LICENSE
- NOTICE
- decode.go
- encode.go
- expfmt.go
- fuzz.go
- openmetrics_create.go
- text_create.go
- text_parse.go
- alert.go
- fingerprinting.go
- fnv.go
- labels.go
- labelset.go
- labelset_string.go
- metadata.go
- metric.go
- model.go
- signature.go
- silence.go
- time.go
- value.go
- value_float.go
- value_histogram.go
- value_type.go
- LICENSE
- NOTICE
- .gitignore
- .golangci.yml
- CODE_OF_CONDUCT.md
- constants.go
- doc.go
- label_namer.go
- LICENSE
- MAINTAINERS.md
- metric_namer.go
- metric_type.go
- README.md
- SECURITY.md
- strategy.go
- strconv.go
- unit_namer.go
- fs.go
- parse.go
- readfile.go
- sysreadfile.go
- sysreadfile_compat.go
- valueparser.go
- .gitignore
- .golangci.yml
- arp.go
- buddyinfo.go
- cmdline.go
- CODE_OF_CONDUCT.md
- CONTRIBUTING.md
- cpuinfo.go
- cpuinfo_armx.go
- cpuinfo_loong64.go
- cpuinfo_mipsx.go
- cpuinfo_others.go
- cpuinfo_ppcx.go
- cpuinfo_riscvx.go
- cpuinfo_s390x.go
- cpuinfo_x86.go
- crypto.go
- doc.go
- fs.go
- fs_statfs_notype.go
- fs_statfs_type.go
- fscache.go
- ipvs.go
- kernel_hung.go
- kernel_random.go
- LICENSE
- loadavg.go
- MAINTAINERS.md
- Makefile
- Makefile.common
- mdstat.go
- meminfo.go
- mountinfo.go
- mountstats.go
- net_conntrackstat.go
- net_dev.go
- net_dev_snmp6.go
- net_ip_socket.go
- net_protocols.go
- net_route.go
- net_sockstat.go
- net_softnet.go
- net_tcp.go
- net_tls_stat.go
- net_udp.go
- net_unix.go
- net_wireless.go
- net_xfrm.go
- netstat.go
- nfnetlink_queue.go
- NOTICE
- proc.go
- proc_cgroup.go
- proc_cgroups.go
- proc_environ.go
- proc_fdinfo.go
- proc_interrupts.go
- proc_io.go
- proc_limits.go
- proc_maps.go
- proc_netstat.go
- proc_ns.go
- proc_psi.go
- proc_smaps.go
- proc_snmp.go
- proc_snmp6.go
- proc_stat.go
- proc_statm.go
- proc_status.go
- proc_sys.go
- README.md
- schedstat.go
- SECURITY.md
- slab.go
- softirqs.go
- stat.go
- swaps.go
- thread.go
- ttar
- vm.go
- zoneinfo.go
- .gitignore
- .golangci.yml
- allocator.go
- auth.go
- certs.sh
- change_version.sh
- CHANGELOG.md
- channel.go
- CLAUDE.md
- CODE_OF_CONDUCT.md
- confirms.go
- connection.go
- consumers.go
- CONTRIBUTING.md
- delivery.go
- doc.go
- fuzz.go
- gen.ps1
- gen.sh
- LICENSE
- lifecycle.go
- log.go
- Makefile
- read.go
- README.md
- recovery.go
- RELEASE.md
- return.go
- spec091.go
- types.go
- uri.go
- write.go
- groupversion_info.go
- rabbitmqcluster_status.go
- rabbitmqcluster_types.go
- zz_generated.deepcopy.go
- all_replicas_ready.go
- cluster_available.go
- no_warnings.go
- reconcile_success.go
- status.go
- zz_generated.deepcopy.go
- LICENSE.txt
- groupversion_info.go
- superstream_types.go
- zz_generated.deepcopy.go
- binding_types.go
- conditions.go
- exchange_types.go
- federation_types.go
- groupversion_info.go
- operatorpolicy_types.go
- permission_types.go
- policy_types.go
- queue_types.go
- rabbitmq_cluster_reference.go
- schemareplication_types.go
- shovel_types.go
- topicpermission_types.go
- topology_resource.go
- user_types.go
- vhost_types.go
- zz_generated.deepcopy.go
- clientset_generated.go
- doc.go
- register.go
- doc.go
- register.go
- doc.go
- fake_rabbitmq.com_client.go
- fake_superstream.go
- doc.go
- generated_expansion.go
- rabbitmq.com_client.go
- superstream.go
- doc.go
- fake_binding.go
- fake_exchange.go
- fake_federation.go
- fake_operatorpolicy.go
- fake_permission.go
- fake_policy.go
- fake_queue.go
- fake_rabbitmq.com_client.go
- fake_schemareplication.go
- fake_shovel.go
- fake_user.go
- fake_vhost.go
- binding.go
- doc.go
- exchange.go
- federation.go
- generated_expansion.go
- operatorpolicy.go
- permission.go
- policy.go
- queue.go
- rabbitmq.com_client.go
- schemareplication.go
- shovel.go
- user.go
- vhost.go
- clientset.go
- doc.go
- factory_interfaces.go
- interface.go
- superstream.go
- binding.go
- exchange.go
- federation.go
- interface.go
- operatorpolicy.go
- permission.go
- policy.go
- queue.go
- schemareplication.go
- shovel.go
- user.go
- vhost.go
- interface.go
- factory.go
- generic.go
- expansion_generated.go
- superstream.go
- binding.go
- exchange.go
- expansion_generated.go
- federation.go
- operatorpolicy.go
- permission.go
- policy.go
- queue.go
- schemareplication.go
- shovel.go
- user.go
- vhost.go
- LICENSE.txt
- NOTICE.txt
- doc.go
- format.go
- marshal.go
- parse.go
- period.go
- LICENSE
- .gitignore
- .travis.yml
- build+test.sh
- doc.go
- LICENSE
- plural.go
- README.md
- .gitignore
- .travis.yml
- chain.go
- constantdelay.go
- cron.go
- doc.go
- LICENSE
- logger.go
- option.go
- parser.go
- README.md
- spec.go
- diff.go
- diffmatchpatch.go
- match.go
- mathutil.go
- operation_string.go
- patch.go
- stringutil.go
- AUTHORS
- CONTRIBUTORS
- LICENSE
- .editorconfig
- .gitignore
- .golangci.yaml
- .travis.yml
- bool.go
- bool_func.go
- bool_slice.go
- bytes.go
- count.go
- duration.go
- duration_slice.go
- errors.go
- flag.go
- float32.go
- float32_slice.go
- float64.go
- float64_slice.go
- func.go
- golangflag.go
- int.go
- int16.go
- int32.go
- int32_slice.go
- int64.go
- int64_slice.go
- int8.go
- int_slice.go
- ip.go
- ip_slice.go
- ipmask.go
- ipnet.go
- ipnet_slice.go
- LICENSE
- README.md
- string.go
- string_array.go
- string_slice.go
- string_to_int.go
- string_to_int64.go
- string_to_string.go
- text.go
- time.go
- uint.go
- uint16.go
- uint32.go
- uint64.go
- uint8.go
- uint_slice.go
- yaml_custom.go
- yaml_default.go
- yaml_fail.go
- assertion_compare.go
- assertion_format.go
- assertion_format.go.tmpl
- assertion_forward.go
- assertion_forward.go.tmpl
- assertion_order.go
- assertions.go
- doc.go
- errors.go
- forward_assertions.go
- http_assertions.go
- doc.go
- forward_requirements.go
- require.go
- require.go.tmpl
- require_forward.go
- require_forward.go.tmpl
- requirements.go
- LICENSE
- .travis.yml
- bytebuffer.go
- doc.go
- LICENSE
- pool.go
- README.md
- .travis.yml
- float16.go
- LICENSE
- README.md
- tagencoding.go
- internal.go
- sanitize.go
- traceinternals.go
- doc.go
- exemplar.go
- label.go
- metric.go
- point.go
- type_string.go
- unit.go
- manager.go
- producer.go
- b3.go
- propagation.go
- client.go
- client_stats.go
- doc.go
- route.go
- server.go
- span_annotating_client_trace.go
- stats.go
- trace.go
- wrapped_body.go
- .gitignore
- appveyor.yml
- AUTHORS
- CONTRIBUTING.md
- LICENSE
- Makefile
- opencensus.go
- README.md
- .codecov.yaml
- .gitattributes
- .gitignore
- .golangci.yaml
- ADOPTERS.MD
- CODE-OF-CONDUCT.md
- go.mod
- go.sum
- LICENSE
- Makefile
- OWNERS
- OWNERS_ALIASES
- README.md
- SECURITY.md
# Installation Guide
1. Get the code
git clone https://github.com/knative-extensions/eventing-rabbitmq
Downloads the entire project code from GitHub to your computer.
cd eventing-rabbitmq
Moves into the project folder you just downloaded.
2. Go
Medium RecommendedPrerequisites
go build ./...
Compiles the Go program into an executable.
go run .
Runs the Go program directly without a separate build step.
If the build finishes without errors, it worked. If you used go run ., check the terminal output.
3. Make
MediumPrerequisites
- Git Needed to download the project code from GitHub.
- Make Usually pre-installed on Linux/macOS. On Windows, install separately (e.g. via MSYS2 or WSL).
make
Compiles the code based on the generated build configuration to produce an executable.
If it finishes without errors, it worked. Try running the generated executable directly.
// repository documentation
Was this content helpful?
(0 ratings)
