Google Git
Sign in
code / gocloud / refs/tags/spanner/v1.21.0 / . / pubsublite / internal / wire
tree: 53976b00d69b1c73d3bb3f532357855079c00cb0 [path history] [tgz]
  1. acks.go
  2. acks_test.go
  3. assigner.go
  4. assigner_test.go
  5. committer.go
  6. committer_test.go
  7. errors.go
  8. flow_control.go
  9. flow_control_test.go
  10. main_test.go
  11. message_router.go
  12. message_router_test.go
  13. partition_count.go
  14. partition_count_test.go
  15. periodic_task.go
  16. periodic_task_test.go
  17. publish_batcher.go
  18. publish_batcher_test.go
  19. publisher.go
  20. publisher_test.go
  21. README.md
  22. requests_test.go
  23. resources.go
  24. resources_test.go
  25. rpc.go
  26. rpc_test.go
  27. service.go
  28. service_test.go
  29. service_util_test.go
  30. settings.go
  31. settings_test.go
  32. streams.go
  33. streams_test.go
  34. subscriber.go
  35. subscriber_test.go
  36. version.go
  37. version_not112.go
  38. version_test.go
pubsublite/internal/wire/README.md

Wire

This directory contains internal implementation details for Pub/Sub Lite.

Conventions

The following are general conventions used in this package:

  • Capitalized methods and fields of a struct denotes its public interface. They are safe to call from outside the struct (e.g. accesses immutable fields or guarded by a mutex). All other methods are considered internal implementation details that should not be called from outside the struct.
  • unsafeFoo() methods indicate that the caller is expected to have already acquired the struct's mutex. Since Go does not support re-entrant locks, they do not acquire the mutex. These are typically common util methods that need to be atomic with other operations.