tree: d1231c0b4b6ecefbc9d6ad42db0c018d8e4cc93d [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. README.md
  9. resources.go
  10. resources_test.go
  11. rpc.go
  12. settings.go
  13. settings_test.go
  14. 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.