tree: 5177f2c7999eec653b8fc04cd7d1fc4cde5bdda6 [path history] [tgz]
  1. acks.go
  2. acks_test.go
  3. errors.go
  4. flow_control.go
  5. flow_control_test.go
  6. message_router.go
  7. message_router_test.go
  8. periodic_task.go
  9. periodic_task_test.go
  10. README.md
  11. requests_test.go
  12. resources.go
  13. resources_test.go
  14. rpc.go
  15. service.go
  16. service_test.go
  17. settings.go
  18. settings_test.go
  19. streams.go
pubsublite/internal/wire/README.md

Wire

This directory contains internal implementation details for Cloud Pub/Sub Lite. Its exported interface can change at any time.

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.