eventing-kafka
Kafka integrations with Knative Eventing.
File Explorer
Download Latest Version (.zip)Showing a partial file list β download the zip above to see everything.
- bug.md
- feature-request.md
- kind-e2e.yaml
- knative-go-build.yaml
- knative-go-test.yaml
- knative-security.yaml
- knative-stale.yaml
- knative-style.yaml
- knative-verify.yaml
- issue-template.md
- pull-request-template.md
- main.go
- OWNERS
- main.go
- OWNERS
- README.md
- config-descheduler.yaml
- config-kafka-source-defaults.yaml
- config-scheduler.yaml
- controller-service.yaml
- controller.yaml
- kafkabinding.yaml
- kafkasource.yaml
- kafkabinding.yaml
- kafkasource.yaml
- kafka.yaml
- clusterrolebinding.yaml
- serviceaccount.yaml
- adapter.yaml
- controller.yaml
- clusterrole.yaml
- 200-adapter-serviceaccount.yaml
- 200-serviceaccount.yaml
- 201-adapter-clusterrole.yaml
- 201-clusterrole.yaml
- 202-adapter-clusterrolebinding.yaml
- 202-clusterrolebinding.yaml
- 300-kafkabinding.yaml
- 300-kafkasource.yaml
- 400-config-descheduler.yaml
- 400-config-kafka-source-defaults.yaml
- 400-config-scheduler.yaml
- 400-controller-service.yaml
- 500-adapter.yaml
- 500-controller.yaml
- 500-webhook-configuration.yaml
- OWNERS
- clusterrole.yaml
- placeholder.go
- serviceaccount.yaml
- storage-version-migrator.yaml
- kind_kafka_cluster.md
- metrics.md
- boilerplate.go.txt
- OWNERS
- README.md
- release.sh
- tools.go
- update-checksums.sh
- update-codegen.sh
- update-deps.sh
- update-k8s-deps.sh
- verify-codegen.sh
- doc.go
- fuzzer.go
- kafka_conversion.go
- kafka_conversion_test.go
- kafka_defaults.go
- kafka_lifecycle.go
- kafka_lifecycle_test.go
- kafka_types.go
- kafka_types_test.go
- kafka_validation.go
- register.go
- register_test.go
- roundtrip_test.go
- zz_generated.deepcopy.go
- register.go
- config-kafka-source-defaults.yaml
- doc.go
- kafka_defaults.go
- kafka_defaults_test.go
- store.go
- store_test.go
- kafka_lifecycle_mt_test.go
- doc.go
- fuzzer.go
- kafka_conversion.go
- kafka_conversion_test.go
- kafka_defaults.go
- kafka_defaults_test.go
- kafka_lifecycle.go
- kafka_lifecycle_mt.go
- kafka_lifecycle_test.go
- kafka_scheduling.go
- kafka_scheduling_test.go
- kafka_types.go
- kafka_types_test.go
- kafka_validation.go
- kafka_validation_test.go
- register.go
- register_test.go
- roundtrip_test.go
- zz_generated.deepcopy.go
- register.go
- clientset_generated.go
- doc.go
- register.go
- doc.go
- register.go
- doc.go
- fake_bindings_client.go
- fake_kafkabinding.go
- bindings_client.go
- doc.go
- generated_expansion.go
- kafkabinding.go
- doc.go
- fake_kafkasource.go
- fake_sources_client.go
- doc.go
- generated_expansion.go
- kafkasource.go
- sources_client.go
- clientset.go
- interface.go
- kafkabinding.go
- interface.go
- factory_interfaces.go
- interface.go
- kafkasource.go
- interface.go
- factory.go
- generic.go
- fake.go
- client.go
- fake.go
- fake.go
- kafkabinding.go
- kafkabinding.go
- fake.go
- fake_filtered_factory.go
- filtered_factory.go
- factory.go
- fake.go
- fake.go
- kafkasource.go
- kafkasource.go
- controller.go
- reconciler.go
- state.go
- controller.go
- reconciler.go
- state.go
- expansion_generated.go
- kafkabinding.go
- expansion_generated.go
- kafkasource.go
- util.go
- config.go
- config_test.go
- kafka_scram_client.go
- yaml.go
- yaml_test.go
- mock.go
- util.go
- eventingkafkaconfig.go
- kafkaconfigmapwatcher.go
- kafkaconfigmapwatcher_test.go
- util.go
- util_test.go
- configmapLoader.go
- configmapLoader.go
- constants.go
- consumer_factory.go
- consumer_factory_test.go
- consumer_handler.go
- consumer_handler_test.go
- consumergroup_offsets_checker.go
- managed_group.go
- managed_group_test.go
- offsets.go
- offsets_test.go
- batch_get_offsets.go
- batch_get_offsets_test.go
- sarama.go
- sarama_test.go
- mocks.go
- README.md
- stats_reporter.go
- stats_reporter_test.go
- constants.go
- mocks.go
- util.go
- tracing.go
- tracing_test.go
- adapter.go
- adapter_test.go
- message.go
- client.go
- client_test.go
- adapter.go
- adapter_test.go
- controller.go
- kafkasource.go
- controller.go
- finalizer.go
- finalizer_test.go
- controller.go
- doc.go
- kafkasource.go
- OWNERS
- README.md
- 100-kafka-ephemeral-triple-3.1.0.yaml
- 100-strimzi-cluster-operator-0.29.0.yaml
- 100-strimzi-users.yaml
- config-kafka-sasl.yaml
- config-kafka-tls.yaml
- config-tracing.yaml
- monitoring.yaml
- README.md
- main_test.go
- README.md
- source_crd_metadata_test.go
- source_crd_rbac_test.go
- source_crd_registry_test.go
- source_status_test.go
- kafka_binding_test_helper.go
- kafka_helper.go
- kafka_source.go
- kafka_source_test_helper.go
- kafka_binding_test.go
- kafka_source_claims_test.go
- kafka_source_reconciler_test.go
- kafka_source_test.go
- main_test.go
- README.md
- kafka.go
- sources.go
- creation.go
- deletion.go
- listers.go
- 100-source-perf-setup.yaml
- 101-source-perf-setup.yaml
- 200-source-perf.yaml
- data_plane.go
- mt_data_plane.go
- readiness.go
- readiness.go
- configmap.yaml
- kafkacat.go
- kafkacat.yaml
- kafkacat_test.go
- kafkasource.go
- kafkasource.yaml
- kafkasource_test.go
- topic.go
- topic.yaml
- topic_test.go
- kafka_source_test.go
- main_test.go
- README.md
- main.go
- pod.yaml
- dev.config
- HEAD
- refs
- dev.config
- kafka_load_generator.go
- kafka_load_generator_test.go
- main.go
- pod.yaml
- README.md
- main.go
- pod.yaml
- kafkasender.go
- source-config.toml
- source.go
- types.go
- verification.go
- eventing_core.go
- githead.go
- shell.go
- stable.go
- continual.go
- postdowngrade.go
- postupgrade.go
- preupgrade.go
- README.md
- smoke.go
- suite.go
- suite_test.go
- test_main.go
- upgrade_test.go
- config.go
- constants.go
- e2e-common.sh
- e2e-tests.sh
- e2e-upgrade-tests.sh
- markdown-lint-config.rc
- OWNERS
- presubmit-tests.sh
- README.md
- upload-test-images.sh
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- NOTICE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE.md
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- errwrap.go
- LICENSE
- README.md
- cleanhttp.go
- doc.go
- handlers.go
- LICENSE
- README.md
- append.go
- flatten.go
- format.go
- group.go
- LICENSE
- Makefile
- multierror.go
- prefix.go
- README.md
- sort.go
- .gitignore
- client.go
- LICENSE
- Makefile
- README.md
- roundtripper.go
- .travis.yml
- LICENSE
- README.md
- uuid.go
- lru.go
- lru_interface.go
- .gitignore
- .golangci.yml
- 2q.go
- arc.go
- doc.go
- LICENSE
- lru.go
- README.md
- testing.go
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- license.md
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- NOTICE
- LICENSE
- NOTICE
- README.txt
- LICENSE
- NOTICE
- LICENSE
- NOTICE
- LICENSE
- NOTICE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE
- LICENSE.txt
- LICENSE
- LICENSE.txt
- LICENSE.txt
- LICENSE
- 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
- NOTICE
- LICENSE
- version.go
- CHANGES.md
- LICENSE
- metadata.go
- README.md
- retry.go
- retry_linux.go
- tidyfix.go
- LICENSE
- iam_policy.pb.go
- options.pb.go
- policy.pb.go
- CHANGES.md
- iam.go
- LICENSE
- README.md
- optional.go
- trace.go
- update_version.sh
- version.go
- .repo-metadata-full.json
- annotate.go
- README.md
- retry.go
- storage.pb.go
- auxiliary.go
- doc.go
- gapic_metadata.json
- storage_client.go
- version.go
- version.go
- acl.go
- bucket.go
- CHANGES.md
- client.go
- copy.go
- doc.go
- emulator_test.sh
- grpc_client.go
- hmac.go
- http_client.go
- iam.go
- invoke.go
- LICENSE
- notifications.go
- option.go
- post_policy_v4.go
- reader.go
- README.md
- storage.go
- storage.replay
- writer.go
- LICENSE
- .gitignore
- .travis.yml
- common.go
- connection.go
- CONTRIBUTING.md
- LICENSE
- nodeinfo.go
- ocagent.go
- options.go
- README.md
- span_config.go
- transform_spans.go
- transform_stats_to_metrics.go
- version.go
- .gitignore
- .golangci.yml
- .travis.yml
- LICENSE
- Makefile
- prometheus.go
- README.md
- sanitize.go
- .travis.yml
- LICENSE
- Makefile
- README.md
- zipkin.go
- 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
- common.pb.go
- metrics_service.pb.go
- metrics_service.pb.gw.go
- trace_service.pb.go
- trace_service.pb.gw.go
- metrics.pb.go
- resource.pb.go
- trace.pb.go
- trace_config.pb.go
- AUTHORS
- LICENSE
- 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
- doc.go
- LICENSE
- message.go
- option.go
- protocol.go
- receiver.go
- sender.go
- write_producer_message.go
- 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
- doc.go
- format.go
- attributes.go
- doc.go
- match_exact_version.go
- spec.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
- 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
- breaker.go
- README.md
- LICENSE
- .gitignore
- .travis.yml
- LICENSE
- README.md
- snappy.go
- .gitignore
- .travis.yml
- LICENSE
- queue.go
- README.md
- log.go
- .gitignore
- .goconvey
- .travis.yml
- 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
- json.go
- jsoniter.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
- errors.go
- LICENSE
- merge.go
- patch.go
- README.md
- .gitignore
- capture_metrics.go
- docs.go
- LICENSE.txt
- Makefile
- README.md
- wrap_generated_gteq_1.8.go
- wrap_generated_lt_1.8.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
- BUG-BOUNTY.md
- CHANGELOG.md
- CONTRIBUTING.md
- crypter.go
- doc.go
- encoding.go
- jwe.go
- jwk.go
- jws.go
- LICENSE
- opaque.go
- README.md
- shared.go
- signing.go
- symmetric.go
- doc.go
- level.go
- .gitignore
- doc.go
- json_logger.go
- LICENSE
- log.go
- logfmt_logger.go
- nop_logger.go
- README.md
- staticcheck.conf
- stdlib.go
- sync.go
- value.go
- .gitignore
- CHANGELOG.md
- decode.go
- doc.go
- encode.go
- jsonstring.go
- LICENSE
- README.md
- funcr.go
- slogsink.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
- .editorconfig
- .gitignore
- CODE_OF_CONDUCT.md
- LICENSE
- pointer.go
- README.md
- normalize_url.go
- .gitignore
- .golangci.yml
- CODE_OF_CONDUCT.md
- LICENSE
- README.md
- reference.go
- .editorconfig
- .gitattributes
- .gitignore
- .golangci.yml
- CODE_OF_CONDUCT.md
- convert.go
- convert_types.go
- doc.go
- file.go
- json.go
- LICENSE
- loading.go
- name_lexem.go
- net.go
- path.go
- post_go18.go
- post_go19.go
- pre_go18.go
- pre_go19.go
- README.md
- split.go
- util.go
- yaml.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
- clone.go
- custom_gogo.go
- decode.go
- deprecated.go
- discard.go
- duration.go
- duration_gogo.go
- encode.go
- encode_gogo.go
- equal.go
- extensions.go
- extensions_gogo.go
- lib.go
- lib_gogo.go
- Makefile
- message_set.go
- pointer_reflect.go
- pointer_reflect_gogo.go
- pointer_unsafe.go
- pointer_unsafe_gogo.go
- properties.go
- properties_gogo.go
- skip_gogo.go
- table_marshal.go
- table_marshal_gogo.go
- table_merge.go
- table_unmarshal.go
- table_unmarshal_gogo.go
- text.go
- text_gogo.go
- text_parser.go
- timestamp.go
- timestamp_gogo.go
- wrappers.go
- wrappers_gogo.go
- sortkeys.go
- AUTHORS
- CONTRIBUTORS
- LICENSE
- logsink.go
- logsink_fatal.go
- stackdump.go
- glog.go
- glog_file.go
- glog_file_linux.go
- glog_file_other.go
- glog_file_posix.go
- glog_flags.go
- LICENSE
- README.md
- lru.go
- LICENSE
- decode.go
- encode.go
- json.go
- buffer.go
- defaults.go
- deprecated.go
- discard.go
- extensions.go
- properties.go
- proto.go
- registry.go
- text_decode.go
- text_encode.go
- wire.go
- wrappers.go
- any.pb.go
- duration.pb.go
- timestamp.pb.go
- any.go
- doc.go
- duration.go
- timestamp.go
- AUTHORS
- CONTRIBUTORS
- LICENSE
- .gitignore
- AUTHORS
- CONTRIBUTORS
- decode.go
- decode_amd64.s
- decode_arm64.s
- decode_asm.go
- decode_other.go
- encode.go
- encode_amd64.s
- encode_arm64.s
- encode_asm.go
- encode_other.go
- LICENSE
- README
- snappy.go
- 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
- 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
- activity.go
- activity_events.go
- activity_notifications.go
- activity_star.go
- activity_watching.go
- admin.go
- admin_orgs.go
- admin_stats.go
- admin_users.go
- apps.go
- apps_installation.go
- apps_marketplace.go
- authorizations.go
- checks.go
- doc.go
- event.go
- event_types.go
- gists.go
- gists_comments.go
- git.go
- git_blobs.go
- git_commits.go
- git_refs.go
- git_tags.go
- git_trees.go
- github-accessors.go
- github.go
- gitignore.go
- interactions.go
- interactions_orgs.go
- interactions_repos.go
- issues.go
- issues_assignees.go
- issues_comments.go
- issues_events.go
- issues_labels.go
- issues_milestones.go
- issues_timeline.go
- licenses.go
- messages.go
- migrations.go
- migrations_source_import.go
- migrations_user.go
- misc.go
- orgs.go
- orgs_hooks.go
- orgs_members.go
- orgs_outside_collaborators.go
- orgs_projects.go
- orgs_users_blocking.go
- projects.go
- pulls.go
- pulls_comments.go
- pulls_reviewers.go
- pulls_reviews.go
- reactions.go
- repos.go
- repos_collaborators.go
- repos_comments.go
- repos_commits.go
- repos_community_health.go
- repos_contents.go
- repos_deployments.go
- repos_forks.go
- repos_hooks.go
- repos_invitations.go
- repos_keys.go
- repos_merging.go
- repos_pages.go
- repos_prereceive_hooks.go
- repos_projects.go
- repos_releases.go
- repos_stats.go
- repos_statuses.go
- repos_traffic.go
- search.go
- strings.go
- teams.go
- teams_discussion_comments.go
- teams_discussions.go
- teams_members.go
- timestamp.go
- users.go
- users_administration.go
- users_blocking.go
- users_emails.go
- users_followers.go
- users_gpg_keys.go
- users_keys.go
- with_appengine.go
- without_appengine.go
- AUTHORS
- LICENSE
- encode.go
- LICENSE
- bytesource.go
- .travis.yml
- CONTRIBUTING.md
- doc.go
- fuzz.go
- LICENSE
- README.md
- threshold_analyzer.pb.go
- utest_analyzer.pb.go
- window_deviation.pb.go
- quickstore.go
- common_deps.go
- quickstore.pb.go
- quickstore.pb.go
- mako.pb.go
- LICENSE
- s2a_fallback.go
- authinfo.go
- service.go
- handshaker.go
- common.pb.go
- s2a_context.pb.go
- s2a.pb.go
- s2a_grpc.pb.go
- common.pb.go
- s2a_context.pb.go
- s2a.pb.go
- s2a_grpc.pb.go
- aeadcrypter.go
- aesgcm.go
- chachapoly.go
- common.go
- ciphersuite.go
- counter.go
- expander.go
- halfconn.go
- record.go
- ticketsender.go
- tokenmanager.go
- client_intermediate_cert.der
- client_leaf_cert.der
- client_root_cert.der
- server_intermediate_cert.der
- server_leaf_cert.der
- server_root_cert.der
- certverifier.go
- client_cert.der
- client_cert.pem
- client_key.pem
- server_cert.der
- server_cert.pem
- server_key.pem
- remotesigner.go
- client_cert.pem
- client_key.pem
- server_cert.pem
- server_key.pem
- client_cert.pem
- client_key.pem
- server_cert.pem
- server_key.pem
- tlsconfigstore.go
- README.md
- s2av2.go
- retry.go
- s2a_stream.go
- client_cert.pem
- client_key.pem
- mds_client_cert.pem
- mds_client_key.pem
- mds_root_cert.pem
- mds_server_cert.pem
- mds_server_key.pem
- self_signed_cert.pem
- self_signed_key.pem
- server_cert.pem
- server_key.pem
- .gitignore
- CODE_OF_CONDUCT.md
- CONTRIBUTING.md
- LICENSE.md
- README.md
- s2a.go
- s2a_options.go
- s2a_utils.go
- 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
- util.go
- client.go
- LICENSE
- custom_error.pb.go
- custom_error.proto
- error.pb.go
- error.proto
- README.md
- apierror.go
- callctx.go
- version.go
- .release-please-manifest.json
- call_option.go
- CHANGES.md
- content_type.go
- gax.go
- header.go
- invoke.go
- LICENSE
- proto_json_stream.go
- release-please-config.json
- 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.txt
- errwrap.go
- LICENSE
- README.md
- cleanhttp.go
- doc.go
- handlers.go
- LICENSE
- README.md
- append.go
- flatten.go
- format.go
- group.go
- LICENSE
- Makefile
- multierror.go
- prefix.go
- README.md
- sort.go
- .gitignore
- client.go
- LICENSE
- Makefile
- README.md
- roundtripper.go
- .travis.yml
- LICENSE
- README.md
- uuid.go
- lru.go
- lru_interface.go
- .gitignore
- .golangci.yml
- 2q.go
- arc.go
- doc.go
- LICENSE
- lru.go
- README.md
- testing.go
- .deepsource.toml
- .gitignore
- .travis.yml
- CODE_OF_CONDUCT.md
- doc.go
- LICENSE
- map.go
- merge.go
- mergo.go
- README.md
- .gitignore
- centroid.go
- LICENSE
- README.md
- tdigest.go
- aescts.go
- LICENSE
- LICENSE
- srv.go
- asn1.go
- common.go
- marshal.go
- README.md
- pbkdf2.go
- LICENSE
- tools.go
- ASExchange.go
- cache.go
- client.go
- network.go
- passwd.go
- session.go
- settings.go
- TGSExchange.go
- error.go
- hosts.go
- krb5conf.go
- ccache.go
- credentials.go
- common.go
- etype.go
- encryption.go
- keyDerivation.go
- nfold.go
- encryption.go
- keyDerivation.go
- checksum.go
- encryption.go
- keyDerivation.go
- msgtype.go
- encryption.go
- keyDerivation.go
- aes128-cts-hmac-sha1-96.go
- aes128-cts-hmac-sha256-128.go
- aes256-cts-hmac-sha1-96.go
- aes256-cts-hmac-sha384-192.go
- crypto.go
- des3-cbc-sha1-kd.go
- rc4-hmac.go
- contextFlags.go
- gssapi.go
- MICToken.go
- README.md
- wrapToken.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- constants.go
- changepasswddata.go
- message.go
- passwd.go
- keytab.go
- error.go
- APRep.go
- APReq.go
- KDCRep.go
- KDCReq.go
- KRBCred.go
- KRBError.go
- KRBPriv.go
- KRBSafe.go
- Ticket.go
- client_claims.go
- client_info.go
- credentials_info.go
- device_claims.go
- device_info.go
- kerb_validation_info.go
- pac_type.go
- s4u_delegation_info.go
- signature_data.go
- supplemental_cred.go
- upn_dns_info.go
- Authenticator.go
- AuthorizationData.go
- Cryptosystem.go
- HostAddress.go
- KerberosFlags.go
- PAData.go
- PrincipalName.go
- TypedData.go
- LICENSE
- claims.go
- common.go
- filetime.go
- group_membership.go
- kerb_sid_and_attributes.go
- reader.go
- rpc_unicode_string.go
- sid.go
- user_session_key.go
- arrays.go
- decoder.go
- error.go
- header.go
- pipe.go
- primitives.go
- rawbytes.go
- strings.go
- tags.go
- union.go
- LICENSE
- intern.go
- license.md
- README.md
- .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
- bitreader.go
- bitwriter.go
- bytereader.go
- compress.go
- decompress.go
- fse.go
- README.md
- .gitignore
- bitreader.go
- bitwriter.go
- bytereader.go
- compress.go
- decompress.go
- decompress_amd64.go
- decompress_amd64.s
- decompress_generic.go
- huff0.go
- README.md
- cpuinfo.go
- cpuinfo_amd64.go
- cpuinfo_amd64.s
- decode.go
- decode_other.go
- encode.go
- encode_other.go
- LICENSE
- snappy.go
- LICENSE.txt
- README.md
- xxhash.go
- xxhash_amd64.s
- xxhash_arm64.s
- xxhash_asm.go
- xxhash_other.go
- xxhash_safe.go
- bitreader.go
- bitwriter.go
- blockdec.go
- blockenc.go
- blocktype_string.go
- bytebuf.go
- bytereader.go
- decodeheader.go
- decoder.go
- decoder_options.go
- dict.go
- enc_base.go
- enc_best.go
- enc_better.go
- enc_dfast.go
- enc_fast.go
- encoder.go
- encoder_options.go
- framedec.go
- frameenc.go
- fse_decoder.go
- fse_decoder_amd64.go
- fse_decoder_amd64.s
- fse_decoder_generic.go
- fse_encoder.go
- fse_predefined.go
- hash.go
- history.go
- matchlen_amd64.go
- matchlen_amd64.s
- matchlen_generic.go
- README.md
- seqdec.go
- seqdec_amd64.go
- seqdec_amd64.s
- seqdec_generic.go
- seqenc.go
- snappy.go
- zip.go
- zstd.go
- .gitattributes
- .gitignore
- .goreleaser.yml
- compressible.go
- gen.sh
- LICENSE
- README.md
- s2sx.mod
- s2sx.sum
- SECURITY.md
- pool.go
- bytestostr.go
- bytestostr_nounsafe.go
- error.go
- lexer.go
- writer.go
- .gitignore
- .travis.yml
- helpers.go
- LICENSE
- Makefile
- raw.go
- README.md
- unknown_fields.go
- homedir.go
- LICENSE
- README.md
- .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
- idgenerator.go
- annotation.go
- doc.go
- endpoint.go
- kind.go
- span.go
- span_id.go
- traceid.go
- propagation.go
- http.go
- reporter.go
- serializer.go
- .gitattributes
- .gitignore
- .golangci.yml
- context.go
- doc.go
- endpoint.go
- LICENSE
- Makefile
- noop.go
- README.md
- sample.go
- span.go
- span_implementation.go
- span_options.go
- tags.go
- tracer.go
- tracer_options.go
- ast.go
- builder.go
- kind.go
- danger.go
- typeid.go
- key.go
- seen.go
- tracker.go
- .dockerignore
- .gitattributes
- .gitignore
- .golangci.toml
- .goreleaser.yaml
- ci.sh
- CONTRIBUTING.md
- decode.go
- doc.go
- Dockerfile
- errors.go
- LICENSE
- localtime.go
- marshaler.go
- parser.go
- README.md
- scanner.go
- SECURITY.md
- strict.go
- toml.abnf
- types.go
- unmarshaler.go
- utf8.go
- block.go
- blocks.go
- decode_amd64.s
- decode_arm.s
- decode_arm64.s
- decode_asm.go
- decode_other.go
- errors.go
- block.go
- frame.go
- frame_gen.go
- xxh32zero.go
- xxh32zero_arm.go
- xxh32zero_arm.s
- xxh32zero_other.go
- .gitignore
- LICENSE
- lz4.go
- options.go
- options_gen.go
- reader.go
- README.md
- state.go
- state_gen.go
- writer.go
- .gitignore
- .travis.yml
- appveyor.yml
- errors.go
- go113.go
- LICENSE
- Makefile
- README.md
- stack.go
- difflib.go
- LICENSE
- almost_equal.go
- difflib.go
- go_collector_options.go
- go_runtime_metrics.go
- metric.go
- delegator.go
- http.go
- instrument_client.go
- instrument_server.go
- option.go
- .gitignore
- build_info_collector.go
- collector.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_go116.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_js.go
- process_collector_other.go
- process_collector_wasip1.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
- autoneg.go
- README.txt
- alert.go
- fingerprinting.go
- fnv.go
- labels.go
- labelset.go
- metadata.go
- metric.go
- model.go
- signature.go
- silence.go
- time.go
- value.go
- value_float.go
- LICENSE
- NOTICE
- .gitignore
- .golangci.yml
- acl_bindings.go
- acl_create_request.go
- acl_create_response.go
- acl_delete_request.go
- acl_delete_response.go
- acl_describe_request.go
- acl_describe_response.go
- acl_filter.go
- acl_types.go
- add_offsets_to_txn_request.go
- add_offsets_to_txn_response.go
- add_partitions_to_txn_request.go
- add_partitions_to_txn_response.go
- admin.go
- alter_client_quotas_request.go
- alter_client_quotas_response.go
- alter_configs_request.go
- alter_configs_response.go
- alter_partition_reassignments_request.go
- alter_partition_reassignments_response.go
- alter_user_scram_credentials_request.go
- alter_user_scram_credentials_response.go
- api_versions_request.go
- api_versions_response.go
- async_producer.go
- balance_strategy.go
- broker.go
- CHANGELOG.md
- client.go
- compress.go
- config.go
- config_resource_type.go
- consumer.go
- consumer_group.go
- consumer_group_members.go
- consumer_metadata_request.go
- consumer_metadata_response.go
- control_record.go
- crc32_field.go
- create_partitions_request.go
- create_partitions_response.go
- create_topics_request.go
- create_topics_response.go
- decompress.go
- delete_groups_request.go
- delete_groups_response.go
- delete_offsets_request.go
- delete_offsets_response.go
- delete_records_request.go
- delete_records_response.go
- delete_topics_request.go
- delete_topics_response.go
- describe_client_quotas_request.go
- describe_client_quotas_response.go
- describe_configs_request.go
- describe_configs_response.go
- describe_groups_request.go
- describe_groups_response.go
- describe_log_dirs_request.go
- describe_log_dirs_response.go
- describe_user_scram_credentials_request.go
- describe_user_scram_credentials_response.go
- dev.yml
- docker-compose.yml
- Dockerfile.kafka
- encoder_decoder.go
- end_txn_request.go
- end_txn_response.go
- entrypoint.sh
- errors.go
- fetch_request.go
- fetch_response.go
- find_coordinator_request.go
- find_coordinator_response.go
- gssapi_kerberos.go
- heartbeat_request.go
- heartbeat_response.go
- incremental_alter_configs_request.go
- incremental_alter_configs_response.go
- init_producer_id_request.go
- init_producer_id_response.go
- interceptors.go
- join_group_request.go
- join_group_response.go
- kerberos_client.go
- leave_group_request.go
- leave_group_response.go
- length_field.go
- LICENSE
- list_groups_request.go
- list_groups_response.go
- list_partition_reassignments_request.go
- list_partition_reassignments_response.go
- Makefile
- message.go
- message_set.go
- metadata_request.go
- metadata_response.go
- metrics.go
- mockbroker.go
- mockkerberos.go
- mockresponses.go
- offset_commit_request.go
- offset_commit_response.go
- offset_fetch_request.go
- offset_fetch_response.go
- offset_manager.go
- offset_request.go
- offset_response.go
- packet_decoder.go
- packet_encoder.go
- partitioner.go
- prep_encoder.go
- produce_request.go
- produce_response.go
- produce_set.go
- quota_types.go
- README.md
- real_decoder.go
- real_encoder.go
- record.go
- record_batch.go
- records.go
- request.go
- response_header.go
- sarama.go
- sasl_authenticate_request.go
- sasl_authenticate_response.go
- sasl_handshake_request.go
- sasl_handshake_response.go
- scram_formatter.go
- sticky_assignor_user_data.go
- sync_group_request.go
- sync_group_response.go
- sync_producer.go
- timestamp.go
- transaction_manager.go
- txn_offset_commit_request.go
- txn_offset_commit_response.go
- utils.go
- Vagrantfile
- version.go
- zstd.go
- .codecov.yaml
- .gitattributes
- .gitignore
- .golangci.yaml
- .ko.yaml
- .wokeignore
- CODE-OF-CONDUCT.md
- go.mod
- go.sum
- LICENSE
- OWNERS
- OWNERS_ALIASES
- README.md
- vendor.yml
// repository documentation
Was this content helpful?
(0 ratings)