backbeat
Zenko Backbeat is the core engine for asynchronous replication, optimized for queuing metadata updates and dispatching work to long-running tasks in the background.
파일 탐색기
최종 버전 다운로드 (.zip)- action.yaml
- config.json
- Dockerfile
- requirements.sh
- docker-compose.yaml
- metadata-config.json
- Dockerfile
- start-kafka.sh
- initReplicaSet.js
- mongo-run.sh
- mongod.conf
- Dockerfile
- Dockerfile
- sproxyd.conf
- Dockerfile
- check_image_kerberos_support.sh
- run_ft_tests.bash
- run_server_tests.bash
- alerts.yaml
- docker-build.yaml
- release.yaml
- review.yml
- tests.yaml
- copilot-instructions.md
- ISSUE_TEMPLATE.md
- backbeat.js
- ensureServiceUser
- ingestion.js
- queuePopulator.js
- replication.js
- main.go
- console.go
- interactive.go
- logging.go
- types.go
- by_status_counter_set.go
- by_status_counter_set_test.go
- counter_set.go
- counter_set_test.go
- replication_suite_test.go
- base_counter.go
- base_counter_test.go
- counter_suite_test.go
- tracking_counter.go
- types.go
- exporter.go
- exporter_suite_test.go
- exporter_test.go
- types.go
- types_suite_test.go
- types_test.go
- exampledata.txt
- stream.go
- LICENSE
- .travis.yml
- go.mod
- go.sum
- LICENSE.txt
- README.md
- xxhash.go
- xxhash_amd64.go
- xxhash_amd64.s
- xxhash_other.go
- xxhash_safe.go
- xxhash_unsafe.go
- .gitignore
- bundle-import.sh
- import.sh
- librdkafka.go
- librdkafka_darwin.a
- librdkafka_glibc_linux.a
- librdkafka_musl_linux.a
- LICENSES.txt
- rdkafka.h
- README.md
- .gitignore
- 00version.go
- adminapi.go
- adminoptions.go
- api.html
- build_darwin.go
- build_dynamic.go
- build_glibc_linux.go
- build_musl_linux.go
- config.go
- consumer.go
- context.go
- error.go
- error_gen.go
- event.go
- generated_errors.go
- glue_rdkafka.h
- handle.go
- header.go
- kafka.go
- log.go
- message.go
- metadata.go
- misc.go
- offset.go
- producer.go
- README.md
- select_rdkafka.h
- testconf-example.json
- testhelpers.go
- time.go
- LICENSE
- .editorconfig
- .gitattributes
- .gitignore
- .travis.yml
- AUTHORS
- CHANGELOG.md
- CONTRIBUTING.md
- fen.go
- fsnotify.go
- go.mod
- go.sum
- inotify.go
- inotify_poller.go
- kqueue.go
- LICENSE
- open_mode_bsd.go
- open_mode_darwin.go
- README.md
- windows.go
- .gitignore
- .travis.yml
- BUILD.bazel
- client.go
- go.mod
- go.sum
- LICENSE
- middleware.go
- README.md
- redirect.go
- request.go
- response.go
- resty.go
- retry.go
- trace.go
- transport.go
- transport112.go
- util.go
- WORKSPACE
- 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
- .travis.yml
- doc.go
- go.mod
- LICENSE
- Makefile
- README.md
- terminal_size.go
- terminal_size_windows.go
- writer.go
- writer_posix.go
- writer_windows.go
- ast.go
- walk.go
- error.go
- parser.go
- nodes.go
- printer.go
- scanner.go
- quote.go
- position.go
- token.go
- flatten.go
- parser.go
- scanner.go
- position.go
- token.go
- .gitignore
- .travis.yml
- appveyor.yml
- decoder.go
- go.mod
- go.sum
- hcl.go
- lex.go
- LICENSE
- Makefile
- parse.go
- README.md
- LICENSE
- README.md
- trap_others.go
- trap_windows.go
- trap_windows_1.4.go
- .gitignore
- .travis.yml
- CHANGELOG.md
- decode.go
- doc.go
- go.mod
- integrate.go
- lex.go
- LICENSE
- load.go
- parser.go
- properties.go
- rangecheck.go
- README.md
- .travis.yml
- doc.go
- isatty_appengine.go
- isatty_bsd.go
- isatty_linux.go
- isatty_linux_ppc64x.go
- isatty_others.go
- isatty_solaris.go
- isatty_windows.go
- LICENSE
- README.md
- .gitignore
- decode.go
- doc.go
- encode.go
- Makefile
- LICENSE
- NOTICE
- .travis.yml
- CHANGELOG.md
- decode_hooks.go
- error.go
- go.mod
- LICENSE
- mapstructure.go
- README.md
- leakybucket.go
- Licence
- memory.go
- storage.go
- util.go
- filechanges.go
- inotify.go
- inotify_tracker.go
- polling.go
- watch.go
- winfile.go
- .gitignore
- CHANGES.md
- Dockerfile
- go.mod
- go.sum
- LICENSE
- README.md
- tail.go
- tail_posix.go
- tail_windows.go
- config.go
- code_location.go
- container_node.go
- failer.go
- init.go
- benchmarker.go
- interfaces.go
- it_node.go
- measure_node.go
- runner.go
- setup_nodes.go
- suite_nodes.go
- synchronized_after_suite_node.go
- synchronized_before_suite_node.go
- aggregator.go
- forwarding_reporter.go
- output_interceptor.go
- output_interceptor_unix.go
- output_interceptor_win.go
- server.go
- spec.go
- specs.go
- index_computer.go
- parallel_spec_iterator.go
- serial_spec_iterator.go
- sharded_parallel_spec_iterator.go
- spec_iterator.go
- random_id.go
- spec_runner.go
- suite.go
- testing_t_proxy.go
- fake_writer.go
- writer.go
- colorable_others.go
- colorable_windows.go
- LICENSE
- noncolorable.go
- README.md
- doc.go
- isatty_appengine.go
- isatty_bsd.go
- isatty_linux.go
- isatty_solaris.go
- isatty_windows.go
- LICENSE
- README.md
- console_logging.go
- fake_stenographer.go
- stenographer.go
- default_reporter.go
- fake_reporter.go
- junit_reporter.go
- reporter.go
- teamcity_reporter.go
- code_location.go
- synchronization.go
- types.go
- .gitignore
- .travis.yml
- CHANGELOG.md
- CONTRIBUTING.md
- ginkgo_dsl.go
- go.mod
- go.sum
- LICENSE
- README.md
- RELEASING.md
- format.go
- assertion.go
- async_assertion.go
- oracle_matcher.go
- testing_t_support.go
- bipartitegraph.go
- bipartitegraphmatching.go
- edge.go
- node.go
- util.go
- and.go
- assignable_to_type_of_matcher.go
- attributes_slice.go
- be_a_directory.go
- be_a_regular_file.go
- be_an_existing_file.go
- be_closed_matcher.go
- be_element_of_matcher.go
- be_empty_matcher.go
- be_equivalent_to_matcher.go
- be_false_matcher.go
- be_identical_to.go
- be_nil_matcher.go
- be_numerically_matcher.go
- be_sent_matcher.go
- be_temporally_matcher.go
- be_true_matcher.go
- be_zero_matcher.go
- consist_of.go
- contain_element_matcher.go
- contain_elements_matcher.go
- contain_substring_matcher.go
- equal_matcher.go
- have_cap_matcher.go
- have_http_status_matcher.go
- have_key_matcher.go
- have_key_with_value_matcher.go
- have_len_matcher.go
- have_occurred_matcher.go
- have_prefix_matcher.go
- have_suffix_matcher.go
- match_error_matcher.go
- match_json_matcher.go
- match_regexp_matcher.go
- match_xml_matcher.go
- match_yaml_matcher.go
- not.go
- or.go
- panic_matcher.go
- receive_matcher.go
- semi_structured_data_support.go
- succeed_matcher.go
- type_support.go
- with_transform.go
- types.go
- .gitignore
- .travis.yml
- CHANGELOG.md
- CONTRIBUTING.md
- docker-compose.yaml
- Dockerfile
- go.mod
- go.sum
- gomega_dsl.go
- LICENSE
- Makefile
- matchers.go
- README.md
- RELEASING.md
- .gitignore
- .travis.yml
- benchmark.json
- benchmark.sh
- benchmark.toml
- benchmark.yml
- doc.go
- example-crlf.toml
- example.toml
- fuzz.go
- fuzz.sh
- keysparsing.go
- lexer.go
- LICENSE
- marshal.go
- marshal_test.toml
- parser.go
- position.go
- README.md
- test.sh
- token.go
- toml.go
- tomltree_create.go
- tomltree_write.go
- .gitignore
- .travis.yml
- appveyor.yml
- errors.go
- go113.go
- LICENSE
- Makefile
- README.md
- stack.go
- metric.go
- auto.go
- delegator.go
- http.go
- instrument_client.go
- instrument_server.go
- .gitignore
- build_info.go
- build_info_pre_1.12.go
- collector.go
- counter.go
- desc.go
- doc.go
- expvar_collector.go
- fnv.go
- gauge.go
- go_collector.go
- histogram.go
- labels.go
- metric.go
- observer.go
- process_collector.go
- process_collector_other.go
- process_collector_windows.go
- README.md
- registry.go
- summary.go
- timer.go
- untyped.go
- value.go
- vec.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
- metric.go
- model.go
- signature.go
- silence.go
- time.go
- value.go
- LICENSE
- NOTICE
- fs.go
- parse.go
- readfile.go
- sysreadfile.go
- sysreadfile_compat.go
- valueparser.go
- .gitignore
- .golangci.yml
- arp.go
- buddyinfo.go
- CODE_OF_CONDUCT.md
- CONTRIBUTING.md
- cpuinfo.go
- cpuinfo_armx.go
- cpuinfo_mipsx.go
- cpuinfo_others.go
- cpuinfo_ppcx.go
- cpuinfo_s390x.go
- cpuinfo_x86.go
- crypto.go
- doc.go
- fixtures.ttar
- fs.go
- fscache.go
- go.mod
- go.sum
- ipvs.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_sockstat.go
- net_softnet.go
- net_udp.go
- net_unix.go
- NOTICE
- proc.go
- proc_cgroup.go
- proc_environ.go
- proc_fdinfo.go
- proc_io.go
- proc_limits.go
- proc_maps.go
- proc_ns.go
- proc_psi.go
- proc_smaps.go
- proc_stat.go
- proc_status.go
- README.md
- schedstat.go
- stat.go
- swaps.go
- ttar
- vm.go
- xfrm.go
- zoneinfo.go
- .gitignore
- .golangci.yml
- .travis.yml
- alt_exit.go
- appveyor.yml
- buffer_pool.go
- CHANGELOG.md
- doc.go
- entry.go
- exported.go
- formatter.go
- go.mod
- go.sum
- hooks.go
- json_formatter.go
- LICENSE
- logger.go
- logrus.go
- README.md
- terminal_check_appengine.go
- terminal_check_bsd.go
- terminal_check_js.go
- terminal_check_no_terminal.go
- terminal_check_notappengine.go
- terminal_check_solaris.go
- terminal_check_unix.go
- terminal_check_windows.go
- text_formatter.go
- writer.go
- dir.go
- dirmap.go
- file.go
- .travis.yml
- afero.go
- appveyor.yml
- basepath.go
- cacheOnReadFs.go
- const_bsds.go
- const_win_unix.go
- copyOnWriteFs.go
- go.mod
- httpFs.go
- ioutil.go
- LICENSE.txt
- lstater.go
- match.go
- memmap.go
- os.go
- path.go
- README.md
- readonlyfs.go
- regexpfs.go
- unionFile.go
- util.go
- .gitignore
- .travis.yml
- cast.go
- caste.go
- go.mod
- go.sum
- LICENSE
- Makefile
- README.md
- .gitignore
- .golangci.yml
- .mailmap
- .travis.yml
- args.go
- bash_completions.go
- bash_completions.md
- CHANGELOG.md
- cobra.go
- command.go
- command_notwin.go
- command_win.go
- CONDUCT.md
- CONTRIBUTING.md
- custom_completions.go
- fish_completions.go
- fish_completions.md
- go.mod
- go.sum
- LICENSE.txt
- Makefile
- powershell_completions.go
- powershell_completions.md
- projects_using_cobra.md
- README.md
- shell_completions.go
- shell_completions.md
- zsh_completions.go
- zsh_completions.md
- .gitignore
- default_notepad.go
- go.mod
- LICENSE
- log_counter.go
- notepad.go
- README.md
- .gitignore
- .travis.yml
- bool.go
- bool_slice.go
- bytes.go
- count.go
- duration.go
- duration_slice.go
- flag.go
- float32.go
- float32_slice.go
- float64.go
- float64_slice.go
- go.mod
- go.sum
- 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
- LICENSE
- README.md
- string.go
- string_array.go
- string_slice.go
- string_to_int.go
- string_to_int64.go
- string_to_string.go
- uint.go
- uint16.go
- uint32.go
- uint64.go
- uint8.go
- uint_slice.go
- .editorconfig
- .gitignore
- .golangci.yml
- flags.go
- go.mod
- go.sum
- LICENSE
- Makefile
- README.md
- util.go
- viper.go
- .env
- .env.invalid
- .gitignore
- .travis.yml
- appveyor.yml
- CHANGELOG.md
- gotenv.go
- LICENSE
- README.md
- atom.go
- table.go
- charset.go
- const.go
- doc.go
- doctype.go
- entity.go
- escape.go
- foreign.go
- node.go
- parse.go
- render.go
- token.go
- list.go
- table.go
- AUTHORS
- CONTRIBUTORS
- LICENSE
- PATENTS
- unsafeheader.go
- .gitignore
- affinity_linux.go
- aliases.go
- asm_aix_ppc64.s
- asm_darwin_386.s
- asm_darwin_amd64.s
- asm_darwin_arm.s
- asm_darwin_arm64.s
- asm_dragonfly_amd64.s
- asm_freebsd_386.s
- asm_freebsd_amd64.s
- asm_freebsd_arm.s
- asm_freebsd_arm64.s
- asm_linux_386.s
- asm_linux_amd64.s
- asm_linux_arm.s
- asm_linux_arm64.s
- asm_linux_mips64x.s
- asm_linux_mipsx.s
- asm_linux_ppc64x.s
- asm_linux_riscv64.s
- asm_linux_s390x.s
- asm_netbsd_386.s
- asm_netbsd_amd64.s
- asm_netbsd_arm.s
- asm_netbsd_arm64.s
- asm_openbsd_386.s
- asm_openbsd_amd64.s
- asm_openbsd_arm.s
- asm_openbsd_arm64.s
- asm_openbsd_mips64.s
- asm_solaris_amd64.s
- bluetooth_linux.go
- cap_freebsd.go
- constants.go
- dev_aix_ppc.go
- dev_aix_ppc64.go
- dev_darwin.go
- dev_dragonfly.go
- dev_freebsd.go
- dev_linux.go
- dev_netbsd.go
- dev_openbsd.go
- dirent.go
- endian_big.go
- endian_little.go
- env_unix.go
- errors_freebsd_386.go
- errors_freebsd_amd64.go
- errors_freebsd_arm.go
- errors_freebsd_arm64.go
- fcntl.go
- fcntl_darwin.go
- fcntl_linux_32bit.go
- fdset.go
- gccgo.go
- gccgo_c.c
- gccgo_linux_amd64.go
- ioctl.go
- mkall.sh
- mkerrors.sh
- pagesize_unix.go
- pledge_openbsd.go
- ptrace_darwin.go
- ptrace_ios.go
- race.go
- race0.go
- readdirent_getdents.go
- readdirent_getdirentries.go
- README.md
- sockcmsg_dragonfly.go
- sockcmsg_linux.go
- sockcmsg_unix.go
- sockcmsg_unix_other.go
- str.go
- syscall.go
- syscall_aix.go
- syscall_aix_ppc.go
- syscall_aix_ppc64.go
- syscall_bsd.go
- syscall_darwin.1_12.go
- syscall_darwin.1_13.go
- syscall_darwin.go
- syscall_darwin_386.go
- syscall_darwin_amd64.go
- syscall_darwin_arm.go
- syscall_darwin_arm64.go
- syscall_darwin_libSystem.go
- syscall_dragonfly.go
- syscall_dragonfly_amd64.go
- syscall_freebsd.go
- syscall_freebsd_386.go
- syscall_freebsd_amd64.go
- syscall_freebsd_arm.go
- syscall_freebsd_arm64.go
- syscall_illumos.go
- syscall_linux.go
- syscall_linux_386.go
- syscall_linux_amd64.go
- syscall_linux_amd64_gc.go
- syscall_linux_arm.go
- syscall_linux_arm64.go
- syscall_linux_gc.go
- syscall_linux_gc_386.go
- syscall_linux_gc_arm.go
- syscall_linux_gccgo_386.go
- syscall_linux_gccgo_arm.go
- syscall_linux_mips64x.go
- syscall_linux_mipsx.go
- syscall_linux_ppc64x.go
- syscall_linux_riscv64.go
- syscall_linux_s390x.go
- syscall_linux_sparc64.go
- syscall_netbsd.go
- syscall_netbsd_386.go
- syscall_netbsd_amd64.go
- syscall_netbsd_arm.go
- syscall_netbsd_arm64.go
- syscall_openbsd.go
- syscall_openbsd_386.go
- syscall_openbsd_amd64.go
- syscall_openbsd_arm.go
- syscall_openbsd_arm64.go
- syscall_openbsd_mips64.go
- syscall_solaris.go
- syscall_solaris_amd64.go
- syscall_unix.go
- syscall_unix_gc.go
- syscall_unix_gc_ppc64x.go
- timestruct.go
- unveil_openbsd.go
- xattr_bsd.go
- zerrors_aix_ppc.go
- zerrors_aix_ppc64.go
- zerrors_darwin_386.go
- zerrors_darwin_amd64.go
- zerrors_darwin_arm.go
- zerrors_darwin_arm64.go
- zerrors_dragonfly_amd64.go
- zerrors_freebsd_386.go
- zerrors_freebsd_amd64.go
- zerrors_freebsd_arm.go
- zerrors_freebsd_arm64.go
- zerrors_linux.go
- zerrors_linux_386.go
- zerrors_linux_amd64.go
- zerrors_linux_arm.go
- zerrors_linux_arm64.go
- zerrors_linux_mips.go
- zerrors_linux_mips64.go
- zerrors_linux_mips64le.go
- zerrors_linux_mipsle.go
- zerrors_linux_ppc64.go
- zerrors_linux_ppc64le.go
- zerrors_linux_riscv64.go
- zerrors_linux_s390x.go
- zerrors_linux_sparc64.go
- zerrors_netbsd_386.go
- zerrors_netbsd_amd64.go
- zerrors_netbsd_arm.go
- zerrors_netbsd_arm64.go
- zerrors_openbsd_386.go
- zerrors_openbsd_amd64.go
- zerrors_openbsd_arm.go
- zerrors_openbsd_arm64.go
- zerrors_openbsd_mips64.go
- zerrors_solaris_amd64.go
- zptrace_armnn_linux.go
- zptrace_linux_arm64.go
- zptrace_mipsnn_linux.go
- zptrace_mipsnnle_linux.go
- zptrace_x86_linux.go
- zsyscall_aix_ppc.go
- zsyscall_aix_ppc64.go
- zsyscall_aix_ppc64_gc.go
- zsyscall_aix_ppc64_gccgo.go
- zsyscall_darwin_386.1_13.go
- zsyscall_darwin_386.1_13.s
- zsyscall_darwin_386.go
- zsyscall_darwin_386.s
- zsyscall_darwin_amd64.1_13.go
- zsyscall_darwin_amd64.1_13.s
- zsyscall_darwin_amd64.go
- zsyscall_darwin_amd64.s
- zsyscall_darwin_arm.1_13.go
- zsyscall_darwin_arm.1_13.s
- zsyscall_darwin_arm.go
- zsyscall_darwin_arm.s
- zsyscall_darwin_arm64.1_13.go
- zsyscall_darwin_arm64.1_13.s
- zsyscall_darwin_arm64.go
- zsyscall_darwin_arm64.s
- zsyscall_dragonfly_amd64.go
- zsyscall_freebsd_386.go
- zsyscall_freebsd_amd64.go
- zsyscall_freebsd_arm.go
- zsyscall_freebsd_arm64.go
- zsyscall_illumos_amd64.go
- zsyscall_linux.go
- zsyscall_linux_386.go
- zsyscall_linux_amd64.go
- zsyscall_linux_arm.go
- zsyscall_linux_arm64.go
- zsyscall_linux_mips.go
- zsyscall_linux_mips64.go
- zsyscall_linux_mips64le.go
- zsyscall_linux_mipsle.go
- zsyscall_linux_ppc64.go
- zsyscall_linux_ppc64le.go
- zsyscall_linux_riscv64.go
- zsyscall_linux_s390x.go
- zsyscall_linux_sparc64.go
- zsyscall_netbsd_386.go
- zsyscall_netbsd_amd64.go
- zsyscall_netbsd_arm.go
- zsyscall_netbsd_arm64.go
- zsyscall_openbsd_386.go
- zsyscall_openbsd_amd64.go
- zsyscall_openbsd_arm.go
- zsyscall_openbsd_arm64.go
- zsyscall_openbsd_mips64.go
- zsyscall_solaris_amd64.go
- zsysctl_openbsd_386.go
- zsysctl_openbsd_amd64.go
- zsysctl_openbsd_arm.go
- zsysctl_openbsd_arm64.go
- zsysctl_openbsd_mips64.go
- zsysnum_darwin_386.go
- zsysnum_darwin_amd64.go
- zsysnum_darwin_arm.go
- zsysnum_darwin_arm64.go
- zsysnum_dragonfly_amd64.go
- zsysnum_freebsd_386.go
- zsysnum_freebsd_amd64.go
- zsysnum_freebsd_arm.go
- zsysnum_freebsd_arm64.go
- zsysnum_linux_386.go
- zsysnum_linux_amd64.go
- zsysnum_linux_arm.go
- zsysnum_linux_arm64.go
- zsysnum_linux_mips.go
- zsysnum_linux_mips64.go
- zsysnum_linux_mips64le.go
- zsysnum_linux_mipsle.go
- zsysnum_linux_ppc64.go
- zsysnum_linux_ppc64le.go
- zsysnum_linux_riscv64.go
- zsysnum_linux_s390x.go
- zsysnum_linux_sparc64.go
- zsysnum_netbsd_386.go
- zsysnum_netbsd_amd64.go
- zsysnum_netbsd_arm.go
- zsysnum_netbsd_arm64.go
- zsysnum_openbsd_386.go
- zsysnum_openbsd_amd64.go
- zsysnum_openbsd_arm.go
- zsysnum_openbsd_arm64.go
- zsysnum_openbsd_mips64.go
- ztypes_aix_ppc.go
- ztypes_aix_ppc64.go
- ztypes_darwin_386.go
- ztypes_darwin_amd64.go
- ztypes_darwin_arm.go
- ztypes_darwin_arm64.go
- ztypes_dragonfly_amd64.go
- ztypes_freebsd_386.go
- ztypes_freebsd_amd64.go
- ztypes_freebsd_arm.go
- ztypes_freebsd_arm64.go
- ztypes_linux.go
- ztypes_linux_386.go
- ztypes_linux_amd64.go
- ztypes_linux_arm.go
- ztypes_linux_arm64.go
- ztypes_linux_mips.go
- ztypes_linux_mips64.go
- ztypes_linux_mips64le.go
- ztypes_linux_mipsle.go
- ztypes_linux_ppc64.go
- ztypes_linux_ppc64le.go
- ztypes_linux_riscv64.go
- ztypes_linux_s390x.go
- ztypes_linux_sparc64.go
- ztypes_netbsd_386.go
- ztypes_netbsd_amd64.go
- ztypes_netbsd_arm.go
- ztypes_netbsd_arm64.go
- ztypes_openbsd_386.go
- ztypes_openbsd_amd64.go
- ztypes_openbsd_arm.go
- ztypes_openbsd_arm64.go
- ztypes_openbsd_mips64.go
- ztypes_solaris_amd64.go
- aliases.go
- dll_windows.go
- empty.s
- env_windows.go
- eventlog.go
- exec_windows.go
- memory_windows.go
- mkerrors.bash
- mkknownfolderids.bash
- mksyscall.go
- race.go
- race0.go
- security_windows.go
- service.go
- setupapierrors_windows.go
- str.go
- syscall.go
- syscall_windows.go
- types_windows.go
- types_windows_386.go
- types_windows_amd64.go
- types_windows_arm.go
- zerrors_windows.go
- zknownfolderids_windows.go
- zsyscall_windows.go
- AUTHORS
- CONTRIBUTORS
- LICENSE
- PATENTS
- charmap.go
- tables.go
- htmlindex.go
- map.go
- tables.go
- identifier.go
- mib.go
- internal.go
- all.go
- eucjp.go
- iso2022jp.go
- shiftjis.go
- tables.go
- euckr.go
- tables.go
- all.go
- gbk.go
- hzgb2312.go
- tables.go
- big5.go
- tables.go
- override.go
- unicode.go
- encoding.go
- compact.go
- language.go
- parents.go
- tables.go
- tags.go
- common.go
- compact.go
- compose.go
- coverage.go
- language.go
- lookup.go
- match.go
- parse.go
- tables.go
- tags.go
- tag.go
- utf8internal.go
- coverage.go
- doc.go
- go1_1.go
- go1_2.go
- language.go
- match.go
- parse.go
- tables.go
- tags.go
- cond.go
- runes.go
- transform.go
- composition.go
- forminfo.go
- input.go
- iter.go
- normalize.go
- readwriter.go
- tables10.0.0.go
- tables11.0.0.go
- tables12.0.0.go
- tables9.0.0.go
- transform.go
- trie.go
- AUTHORS
- CONTRIBUTORS
- LICENSE
- PATENTS
- decode.go
- doc.go
- encode.go
- wire.go
- stringer.go
- options.go
- rand.go
- default.go
- messageset.go
- tag.go
- decode.go
- decode_number.go
- decode_string.go
- decode_token.go
- doc.go
- encode.go
- errors.go
- is_go112.go
- is_go113.go
- any_gen.go
- api_gen.go
- descriptor_gen.go
- doc.go
- duration_gen.go
- empty_gen.go
- field_mask_gen.go
- source_context_gen.go
- struct_gen.go
- timestamp_gen.go
- type_gen.go
- wrappers_gen.go
- fieldsort.go
- build.go
- desc.go
- desc_init.go
- desc_lazy.go
- desc_list.go
- desc_list_gen.go
- placeholder.go
- build.go
- flags.go
- proto_legacy_disable.go
- proto_legacy_enable.go
- name.go
- api_export.go
- checkinit.go
- codec_extension.go
- codec_field.go
- codec_gen.go
- codec_map.go
- codec_map_go111.go
- codec_map_go112.go
- codec_message.go
- codec_messageset.go
- codec_reflect.go
- codec_tables.go
- codec_unsafe.go
- convert.go
- convert_list.go
- convert_map.go
- decode.go
- encode.go
- enum.go
- extension.go
- legacy_enum.go
- legacy_export.go
- legacy_extension.go
- legacy_file.go
- legacy_message.go
- merge.go
- merge_gen.go
- message.go
- message_reflect.go
- message_reflect_field.go
- message_reflect_gen.go
- pointer_reflect.go
- pointer_unsafe.go
- validate.go
- weak.go
- mapsort.go
- pragma.go
- ints.go
- strings.go
- strings_pure.go
- strings_unsafe.go
- version.go
- checkinit.go
- decode.go
- decode_gen.go
- doc.go
- encode.go
- encode_gen.go
- equal.go
- extension.go
- merge.go
- messageset.go
- proto.go
- proto_methods.go
- proto_reflect.go
- reset.go
- size.go
- size_gen.go
- wrappers.go
- methods.go
- proto.go
- source.go
- type.go
- value.go
- value_pure.go
- value_union.go
- value_unsafe.go
- registry.go
- legacy.go
- methods.go
- impl.go
- version.go
- any.pb.go
- duration.pb.go
- timestamp.pb.go
- AUTHORS
- CONTRIBUTORS
- LICENSE
- PATENTS
- .gitignore
- .travis.yml
- data_source.go
- deprecated.go
- error.go
- file.go
- helper.go
- ini.go
- key.go
- LICENSE
- Makefile
- parser.go
- README.md
- section.go
- struct.go
- LICENSE
- README.md
- tomb.go
- .travis.yml
- apic.go
- decode.go
- emitterc.go
- encode.go
- go.mod
- LICENSE
- LICENSE.libyaml
- NOTICE
- parserc.go
- readerc.go
- README.md
- resolve.go
- scannerc.go
- sorter.go
- writerc.go
- yaml.go
- yamlh.go
- yamlprivateh.go
- modules.txt
- go.mod
- go.sum
- authdata.json
- config.json
- locationConfig.json
- crr-to-aws-s3.md
- data-mover.md
- healthcheck.md
- lifecycle.md
- metrics.md
- oob-s3-ring.md
- pause-resume.md
- probe-requests.md
- RELEASE.md
- replication-metrics.md
- run-crr-replay-locally.md
- run-oob-locally.md
- run-transition-locally.md
- transient-crr-source.md
- GarbageCollectorTask.js
- GarbageCollector.js
- GarbageCollectorConfigValidator.js
- GarbageCollectorMetrics.js
- GarbageCollectorProducer.js
- index.js
- policy.json
- service.js
- constants.js
- index.js
- IngestionConfigValidator.js
- IngestionQueuePopulator.js
- LifecycleBucketProcessor.js
- policy.json
- task.js
- LifecycleConductor.js
- policy.json
- policy_index_management.json
- service.js
- LifecycleObjectExpirationProcessor.js
- LifecycleObjectProcessor.js
- LifecycleObjectTransitionProcessor.js
- policy.json
- policy_transition.json
- task.js
- LifecycleColdStatusArchiveTask.js
- LifecycleDeleteObjectTask.js
- LifecycleRequeueTask.js
- LifecycleResetTransitionInProgressTask.js
- LifecycleRetriggerRestoreTask.js
- LifecycleTask.js
- LifecycleTaskV2.js
- LifecycleUpdateExpirationTask.js
- LifecycleUpdateTransitionTask.js
- mongoRules.js
- rules.js
- RulesReducer.js
- CircuitBreakerGroup.js
- index.js
- LifecycleConfigValidator.js
- LifecycleMetrics.js
- LifecycleOplogPopulatorUtils.js
- LifecycleQueuePopulator.js
- management.js
- BucketMemState.js
- contentTypeHelper.js
- constants.js
- index.js
- MongoProcessorConfigValidator.js
- MongoProcessorMetrics.js
- mongoProcessorTask.js
- MongoQueueProcessor.js
- BaseConfigManager.js
- MongoConfigManager.js
- ZookeeperConfigManager.js
- index.js
- KafkaNotificationDestination.js
- KafkaProducer.js
- NotificationDestination.js
- QueueProcessor.js
- task.js
- auth.js
- config.js
- message.js
- constants.js
- index.js
- NotificationConfigManager.js
- NotificationConfigValidator.js
- NotificationOplogPopulatorUtils.js
- NotificationQueuePopulator.js
- AllocationStrategy.js
- ImmutableConnector.js
- LeastFullConnector.js
- RetainBucketsDecorator.js
- UniqueConnector.js
- Allocator.js
- Connector.js
- ConnectorsManager.js
- MultipleBucketsPipelineFactory.js
- PipelineFactory.js
- WildcardPipelineFactory.js
- constants.js
- index.js
- OplogPopulator.js
- OplogPopulatorConfigValidator.js
- OplogPopulatorMetrics.js
- OplogPopulatorTask.js
- FailedCRRConsumer.js
- FailedCRRProducer.js
- QueueProcessor.js
- task.js
- taskSchedulerHelpers.js
- ReplayProducer.js
- ReplicationStatusProcessor.js
- task.js
- CopyLocationTask.js
- EchoBucket.js
- MultipleBackendTask.js
- ReplicateObject.js
- UpdateReplicationStatus.js
- getExtMetrics.js
- getRedisClient.js
- ObjectFailureEntry.js
- SetupReplication.js
- constants.js
- index.js
- management.js
- ReplicationAPI.js
- ReplicationConfigValidator.js
- ReplicationMetric.js
- ReplicationMetrics.js
- ReplicationOplogPopulatorUtils.js
- ReplicationQueuePopulator.js
- AccountIdCache.js
- BucketMdQueueEntry.js
- LocationStatusStream.js
- MongoUtils.js
- VaultClientWrapper.js
- index.js
- Dockerfile
- BackbeatAPI.js
- BackbeatRequest.js
- BackbeatServer.js
- Healthcheck.js
- Metrics.js
- routes.js
- ClientManager.js
- utils.js
- VaultClientCache.js
- zookeeper.js
- ZookeeperManager.js
- configItems.joi.js
- AccountCredentials.js
- CredentialsManager.js
- getVaultCredentials.js
- RoleCredentials.js
- applyWorkflowUpdates.js
- convertOverlayFormat.js
- convertServiceStateFormat.js
- getWorkflowUpdates.js
- index.js
- operatorBackend.js
- patchConfiguration.js
- pensieveBackend.js
- serviceState.js
- ActionQueueEntry.js
- BucketMdQueueEntry.js
- BucketQueueEntry.js
- ColdStorageStatusQueueEntry.js
- DeleteOpQueueEntry.js
- MetricsModel.js
- ObjectQueueEntry.js
- QueueEntry.js
- RaftLogEntry.js
- ProvisionDispatcher.js
- KafkaLogConsumerMetrics.js
- ListRecordStream.js
- LogConsumer.js
- BucketFileLogReader.js
- IngestionPopulator.js
- IngestionPopulatorMetrics.js
- IngestionProducer.js
- IngestionReader.js
- KafkaLogReader.js
- LogReader.js
- QueuePopulator.js
- QueuePopulatorExtension.js
- RaftLogReader.js
- BackbeatTask.js
- TaskScheduler.js
- index.js
- buffer.js
- entry.js
- LocationStatusManager.js
- metrics.js
- OplogPopulatorUtils.js
- probe.js
- replicationPermissionError.js
- runTasksWithConcurrency.js
- safeJsonParse.js
- sortedSetHelper.js
- topic.js
- versioning.js
- ChangeStream.js
- KafkaConnectWrapper.js
- BackbeatConsumer.js
- BackbeatConsumerManager.js
- BackbeatMetadataProxy.js
- BackbeatProducer.js
- CircuitBreaker.js
- config.joi.js
- Config.js
- constants.js
- KafkaBacklogMetrics.js
- MetricsConsumer.js
- MetricsProducer.js
- OffsetLedger.js
- dashboard.json
- ingestion-global-dashboard.json
- ingestion-processor-alert.yaml
- ingestion-processor-dashboard.json
- ingestion-producer-alert.yaml
- ingestion-producer-dashboard.json
- alerts.test.yaml
- alerts.yaml
- dashboard.json
- dashboard.py
- alerts.test.yaml
- alerts.yaml
- dashboard.json
- dashboard.py
- alerts.test.yaml
- alerts.yaml
- dashboard.json
- dashboard.py
- alerts.test.yaml
- alerts.yaml
- dashboard.json
- dashboard.py
- __init__.py
- queue_populator_policy.json
- read_accounts.json
- backbeat-crr.png
- backbeat-logo.png
- design-overview.png
- queuePopulator.js
- Metrics.js
- retry.js
- routes.js
- DummyPensieveCredentials.json
- DummySSHKey.json
- expectedEntries.js
- IngestionProducer.js
- IngestionReader.js
- MongoQueueProcessor.js
- pauseResumeState.js
- S3Mock.js
- LogConsumer.js
- BackbeatClient.js
- BackbeatConsumer.js
- BackbeatProducer.js
- KafkaBacklogMetrics.spec.js
- ZookeeperManager.js
- configObjects.js
- LifecycleBucketProcessor.spec.js
- LifecycleConductor.spec.js
- LifecycleObjectProcessor.spec.js
- LifecycleTask.js
- LifecycleTaskV2-versioned.js
- LifecycleTaskV2.js
- utils.js
- NotificationConfigManager.js
- PipelineFactory.js
- s3c-config.json
- queuePopulator.spec.js
- pauseResumeState.js
- queueProcessor.js
- streamedCopy.spec.js
- mockAPI.js
- zkStateHelper.js
- BackbeatTestConsumer.spec.js
- getUrl.js
- httpHelpers.js
- MetadataMock.js
- mockRes.json
- mockZookeeperClient.js
- S3Mock.js
- sortedSetHelpers.js
- timeMachine.js
- VaultMock.js
- conductor-check-memory-balloon.js
- BackbeatAPI.spec.js
- BackbeatRequest.spec.js
- routes.spec.js
- VaultClientCache.spec.js
- ZookeeperManager.js
- replicationMultiDestConfig.json
- replicationServersConfig.json
- Config.js
- CredentialsManager.js
- external-creds.json
- utils.js
- GarbageCollector.spec.js
- GarbageCollectorProducer.spec.js
- GarbageCollectorTask.spec.js
- IngestionConfigValidator.spec.js
- IngestionPopulator.js
- IngestionQueuePopulator.spec.js
- IngestionReader.js
- mongoProcessorMetrics.js
- config.json
- Config.spec.js
- ActionQueueEntry.spec.js
- ColdStorageStatusQueueEntry.spec.js
- MetricsModel.js
- ObjectQueueEntry.spec.js
- KafkaLogConsumerMetrics.js
- ListRecordStream.js
- LogConsumer.js
- LogReader.spec.js
- BackbeatTask.spec.js
- TaskScheduler.spec.js
- buffer.spec.js
- circuitBreaker.spec.js
- entry.spec.js
- LocationStatusManager.spec.js
- metrics.spec.js
- probe.spec.js
- replicationPermissionError.spec.js
- runTasksWithConcurrency.spec.js
- ChangeStream.js
- kafkaConnectWrapper.js
- BackbeatConsumer.spec.js
- AccountIdCache.spec.js
- CircuitBreakerGroup.spec.js
- LifecycleBucketProcessor.spec.js
- LifecycleBucketProcessorPolicy.spec.js
- LifecycleColdStatusArchiveTask.spec.js
- LifecycleConductor.spec.js
- LifecycleDeleteObjectTask.spec.js
- LifecycleMetrics.spec.js
- LifecycleObjectExpirationProcessor.spec.js
- LifecycleObjectTransitionProcessor.spec.js
- LifecycleOplogPopulatorUtils.spec.js
- LifecycleQueuePopulator.spec.js
- LifecycleRequeueTask.spec.js
- LifecycleResetTransitionInProgressTask.spec.js
- LifecycleRetriggerRestoreTask.spec.js
- LifecycleTask.spec.js
- LifecycleUpdateExpirationTask.spec.js
- LifecycleUpdateTransitionTask.spec.js
- mongoRules.spec.js
- rules.spec.js
- RulesReducer.spec.js
- RulesReducerWithVersion.spec.js
- rulesWithVersion.spec.js
- applyWorkflowUpdates.spec.js
- convertOverlayFormat.spec.js
- convertServiceStateFormat.spec.js
- getWorkflowUpdates.spec.js
- patchConfiguration.js
- MongoProcessorConfigValidator.spec.js
- MongoQueueProcessor.spec.js
- MongoConfigManager.spec.js
- ZookeeperConfigManager.spec.js
- auth.js
- config.js
- message.js
- KafkaNotificationDestination.js
- NotificationConfigManager.js
- NotificationConfigValidator.js
- NotificationQueuePopulator.js
- NotificationQueueProcessor.js
- QueueProcessor.spec.js
- AllocationStrategy.js
- ImmutableConnector.js
- LeastFullConnector.js
- RetainBucketsDecorator.js
- UniqueConnector.js
- MultipleBucketsPipelineFactory.js
- PipelineFactory.js
- WildcardPipelineFactory.js
- Allocator.js
- Connector.js
- ConnectorsManager.js
- oplogPopulator.js
- OplogPopulatorConfigValidator.js
- QueuePopulatorExtension.spec.js
- admin-backbeat.json
- CopyLocationTask.spec.js
- MultipleBackendTask.js
- ObjectFailureEntry.spec.js
- QueueEntry.spec.js
- QueueProcessor.spec.js
- ReplicateObject.spec.js
- ReplicationAPI.spec.js
- ReplicationConfigValidator.spec.js
- ReplicationMetrics.js
- ReplicationQueuePopulator.spec.js
- ReplicationStatusProcessor.js
- taskSchedulerHelpers.spec.js
- UpdateReplicationStatus.js
- LocationStatusStream.spec.js
- MongoUtils.js
- VaultClientWrapper.spec.js
- backbeatConsumer.js
- backbeatProducer.js
- mocks.js
- OffsetLedger.spec.js
- ProvisionDispatcher.spec.js
- QueuePopulator.spec.js
- ReplicationMetric.js
- RoleCredentials.js
- sortedSetHelper.js
- BackbeatClientMock.js
- BackbeatTestConsumer.js
- DummyLogger.js
- fakeLogger.js
- kafkaEntries.js
- mockEntries.js
- mockIngestionSite.js
- Rule.js
- S3ClientMock.js
- syntheticbucketd.js
- TestConfigurator.js
- wait_for_local_port.bash
- withActiveSpan.js
- config.json
- config.notification.json
- config.roleAuth.json~origin_feature_S3C-4491-backbeat-expiration-backport
- .dockerignore
- .gitignore
- .nycrc
- _config.yml
- circle.yml
- CLAUDE.md
- codecov.yml
- DESIGN.md
- docker-entrypoint.sh
- Dockerfile
- eslint.config.mjs
- index.js
- LICENSE
- package.json
- README.md
- Using.md
- yarn.lock
// repository documentation
Was this content helpful?
(0 ratings)
