• Home
  • History
  • Annotate
Name Date Size #Lines LOC

..02-Apr-2021-

README.mdH A D02-Apr-2021783 1813

acks.goH A D02-Apr-20217.5 KiB263163

acks_test.goH A D02-Apr-202111.3 KiB326250

assigner.goH A D02-Apr-20214.9 KiB175123

assigner_test.goH A D02-Apr-20216.1 KiB198143

committer.goH A D02-Apr-20216.9 KiB242171

committer_test.goH A D02-Apr-202110.3 KiB315234

errors.goH A D02-Apr-20212.2 KiB5820

flow_control.goH A D02-Apr-20215.5 KiB181120

flow_control_test.goH A D02-Apr-202110.4 KiB307273

main_test.goH A D02-Apr-2021977 4423

message_router.goH A D02-Apr-20213 KiB10565

message_router_test.goH A D02-Apr-20213.2 KiB139115

partition_count.goH A D02-Apr-20213.9 KiB14291

partition_count_test.goH A D02-Apr-20214.4 KiB12589

periodic_task.goH A D02-Apr-20211.6 KiB7748

periodic_task_test.goH A D02-Apr-20211.5 KiB6844

publish_batcher.goH A D02-Apr-20216.7 KiB201141

publish_batcher_test.goH A D02-Apr-202115 KiB444351

publisher.goH A D02-Apr-202112.7 KiB407270

publisher_test.goH A D02-Apr-202135.3 KiB1,038762

requests_test.goH A D02-Apr-20215.4 KiB219171

resources.goH A D02-Apr-20215.7 KiB181103

resources_test.goH A D02-Apr-20216.8 KiB273252

rpc.goH A D02-Apr-20217.4 KiB247185

rpc_test.goH A D02-Apr-20212.6 KiB9274

service.goH A D02-Apr-20219.8 KiB345234

service_test.goH A D02-Apr-202118.1 KiB566443

service_util_test.goH A D02-Apr-20212.6 KiB9666

settings.goH A D02-Apr-20216.5 KiB17790

settings_test.goH A D02-Apr-20214.5 KiB170147

streams.goH A D02-Apr-202110.2 KiB356221

streams_test.goH A D02-Apr-202111.3 KiB361269

subscriber.goH A D02-Apr-202115.9 KiB550404

subscriber_test.goH A D02-Apr-202138.5 KiB1,059818

version.goH A D02-Apr-20211.8 KiB6742

version_not112.goH A D02-Apr-2021775 278

version_test.goH A D02-Apr-20212.4 KiB9778

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