Name | Date | Size | #Lines | LOC | ||
---|---|---|---|---|---|---|
.. | 29-Sep-2021 | - | ||||
README.md | H A D | 29-Sep-2021 | 730 | 17 | 12 | |
acks.go | H A D | 29-Sep-2021 | 8 KiB | 285 | 178 | |
acks_test.go | H A D | 29-Sep-2021 | 16.9 KiB | 484 | 387 | |
assigner.go | H A D | 29-Sep-2021 | 4.8 KiB | 168 | 119 | |
assigner_test.go | H A D | 29-Sep-2021 | 6.1 KiB | 198 | 143 | |
committer.go | H A D | 29-Sep-2021 | 7.7 KiB | 274 | 193 | |
committer_test.go | H A D | 29-Sep-2021 | 14.9 KiB | 466 | 349 | |
errors.go | H A D | 29-Sep-2021 | 2.2 KiB | 58 | 20 | |
flow_control.go | H A D | 29-Sep-2021 | 5.9 KiB | 196 | 132 | |
flow_control_test.go | H A D | 29-Sep-2021 | 11.7 KiB | 333 | 296 | |
main_test.go | H A D | 29-Sep-2021 | 977 | 44 | 23 | |
message_router.go | H A D | 29-Sep-2021 | 3 KiB | 105 | 65 | |
message_router_test.go | H A D | 29-Sep-2021 | 3.2 KiB | 139 | 115 | |
partition_count.go | H A D | 29-Sep-2021 | 4.5 KiB | 163 | 107 | |
partition_count_test.go | H A D | 29-Sep-2021 | 7.2 KiB | 202 | 147 | |
periodic_task.go | H A D | 29-Sep-2021 | 1.6 KiB | 77 | 48 | |
periodic_task_test.go | H A D | 29-Sep-2021 | 1.7 KiB | 67 | 40 | |
publish_batcher.go | H A D | 29-Sep-2021 | 6.7 KiB | 201 | 141 | |
publish_batcher_test.go | H A D | 29-Sep-2021 | 15 KiB | 444 | 351 | |
publisher.go | H A D | 29-Sep-2021 | 12.7 KiB | 405 | 267 | |
publisher_test.go | H A D | 29-Sep-2021 | 34.9 KiB | 1,030 | 754 | |
request_timer.go | H A D | 29-Sep-2021 | 1.9 KiB | 79 | 51 | |
request_timer_test.go | H A D | 29-Sep-2021 | 1.8 KiB | 62 | 39 | |
requests_test.go | H A D | 29-Sep-2021 | 5.8 KiB | 228 | 180 | |
resources.go | H A D | 29-Sep-2021 | 7 KiB | 208 | 120 | |
resources_test.go | H A D | 29-Sep-2021 | 8.6 KiB | 320 | 299 | |
rpc.go | H A D | 29-Sep-2021 | 8.7 KiB | 288 | 220 | |
rpc_test.go | H A D | 29-Sep-2021 | 4.4 KiB | 169 | 148 | |
service.go | H A D | 29-Sep-2021 | 10 KiB | 356 | 238 | |
service_test.go | H A D | 29-Sep-2021 | 18.5 KiB | 576 | 452 | |
service_util_test.go | H A D | 29-Sep-2021 | 2.6 KiB | 96 | 66 | |
settings.go | H A D | 29-Sep-2021 | 6.5 KiB | 177 | 90 | |
settings_test.go | H A D | 29-Sep-2021 | 4.5 KiB | 170 | 147 | |
streams.go | H A D | 29-Sep-2021 | 11.7 KiB | 398 | 252 | |
streams_test.go | H A D | 29-Sep-2021 | 15.5 KiB | 483 | 364 | |
subscriber.go | H A D | 29-Sep-2021 | 17.5 KiB | 593 | 422 | |
subscriber_test.go | H A D | 29-Sep-2021 | 49 KiB | 1,344 | 1,023 | |
version.go | H A D | 29-Sep-2021 | 1.8 KiB | 68 | 42 | |
version_not112.go | H A D | 29-Sep-2021 | 794 | 28 | 8 | |
version_test.go | H A D | 29-Sep-2021 | 2.4 KiB | 98 | 78 |
README.md
1# Wire 2 3This directory contains internal implementation details for Pub/Sub Lite. 4 5## Conventions 6 7The following are general conventions used in this package: 8 9* Capitalized methods and fields of a struct denotes its public interface. They 10 are safe to call from outside the struct (e.g. accesses immutable fields or 11 guarded by a mutex). All other methods are considered internal implementation 12 details that should not be called from outside the struct. 13* unsafeFoo() methods indicate that the caller is expected to have already 14 acquired the struct's mutex. Since Go does not support re-entrant locks, they 15 do not acquire the mutex. These are typically common util methods that need 16 to be atomic with other operations. 17