Name | Date | Size | #Lines | LOC | ||
---|---|---|---|---|---|---|
.. | 02-Apr-2021 | - | ||||
README.md | H A D | 02-Apr-2021 | 783 | 18 | 13 | |
acks.go | H A D | 02-Apr-2021 | 7.5 KiB | 263 | 163 | |
acks_test.go | H A D | 02-Apr-2021 | 11.3 KiB | 326 | 250 | |
assigner.go | H A D | 02-Apr-2021 | 4.9 KiB | 175 | 123 | |
assigner_test.go | H A D | 02-Apr-2021 | 6.1 KiB | 198 | 143 | |
committer.go | H A D | 02-Apr-2021 | 6.9 KiB | 242 | 171 | |
committer_test.go | H A D | 02-Apr-2021 | 10.3 KiB | 315 | 234 | |
errors.go | H A D | 02-Apr-2021 | 2.2 KiB | 58 | 20 | |
flow_control.go | H A D | 02-Apr-2021 | 5.5 KiB | 181 | 120 | |
flow_control_test.go | H A D | 02-Apr-2021 | 10.4 KiB | 307 | 273 | |
main_test.go | H A D | 02-Apr-2021 | 977 | 44 | 23 | |
message_router.go | H A D | 02-Apr-2021 | 3 KiB | 105 | 65 | |
message_router_test.go | H A D | 02-Apr-2021 | 3.2 KiB | 139 | 115 | |
partition_count.go | H A D | 02-Apr-2021 | 3.9 KiB | 142 | 91 | |
partition_count_test.go | H A D | 02-Apr-2021 | 4.4 KiB | 125 | 89 | |
periodic_task.go | H A D | 02-Apr-2021 | 1.6 KiB | 77 | 48 | |
periodic_task_test.go | H A D | 02-Apr-2021 | 1.5 KiB | 68 | 44 | |
publish_batcher.go | H A D | 02-Apr-2021 | 6.7 KiB | 201 | 141 | |
publish_batcher_test.go | H A D | 02-Apr-2021 | 15 KiB | 444 | 351 | |
publisher.go | H A D | 02-Apr-2021 | 12.7 KiB | 407 | 270 | |
publisher_test.go | H A D | 02-Apr-2021 | 35.3 KiB | 1,038 | 762 | |
requests_test.go | H A D | 02-Apr-2021 | 5.4 KiB | 219 | 171 | |
resources.go | H A D | 02-Apr-2021 | 5.7 KiB | 181 | 103 | |
resources_test.go | H A D | 02-Apr-2021 | 6.8 KiB | 273 | 252 | |
rpc.go | H A D | 02-Apr-2021 | 7.4 KiB | 247 | 185 | |
rpc_test.go | H A D | 02-Apr-2021 | 2.6 KiB | 92 | 74 | |
service.go | H A D | 02-Apr-2021 | 9.8 KiB | 345 | 234 | |
service_test.go | H A D | 02-Apr-2021 | 18.1 KiB | 566 | 443 | |
service_util_test.go | H A D | 02-Apr-2021 | 2.6 KiB | 96 | 66 | |
settings.go | H A D | 02-Apr-2021 | 6.5 KiB | 177 | 90 | |
settings_test.go | H A D | 02-Apr-2021 | 4.5 KiB | 170 | 147 | |
streams.go | H A D | 02-Apr-2021 | 10.2 KiB | 356 | 221 | |
streams_test.go | H A D | 02-Apr-2021 | 11.3 KiB | 361 | 269 | |
subscriber.go | H A D | 02-Apr-2021 | 15.9 KiB | 550 | 404 | |
subscriber_test.go | H A D | 02-Apr-2021 | 38.5 KiB | 1,059 | 818 | |
version.go | H A D | 02-Apr-2021 | 1.8 KiB | 67 | 42 | |
version_not112.go | H A D | 02-Apr-2021 | 775 | 27 | 8 | |
version_test.go | H A D | 02-Apr-2021 | 2.4 KiB | 97 | 78 |
README.md
1# Wire 2 3This directory contains internal implementation details for Cloud Pub/Sub Lite. 4Its exported interface can change at any time. 5 6## Conventions 7 8The following are general conventions used in this package: 9 10* Capitalized methods and fields of a struct denotes its public interface. They 11 are safe to call from outside the struct (e.g. accesses immutable fields or 12 guarded by a mutex). All other methods are considered internal implementation 13 details that should not be called from outside the struct. 14* unsafeFoo() methods indicate that the caller is expected to have already 15 acquired the struct's mutex. Since Go does not support re-entrant locks, they 16 do not acquire the mutex. These are typically common util methods that need 17 to be atomic with other operations. 18