Google Git
Sign in
fuchsia/third_party/github.com/googleapis/google-cloud-go/refs/heads/upstream/bigtable-session-debug/./pubsublite/internal/wire
tree: d55a9c1dc64364155531c5b958bffe8608cfa867
  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. kafka_publisher.go
  11. kafka_subscriber.go
  12. main_test.go
  13. message_router.go
  14. message_router_test.go
  15. partition_count.go
  16. partition_count_test.go
  17. periodic_task.go
  18. periodic_task_test.go
  19. publish_batcher.go
  20. publish_batcher_test.go
  21. publisher.go
  22. publisher_test.go
  23. README.md
  24. request_timer.go
  25. request_timer_test.go
  26. requests_test.go
  27. resources.go
  28. resources_test.go
  29. rpc.go
  30. rpc_test.go
  31. service.go
  32. service_test.go
  33. service_util_test.go
  34. settings.go
  35. settings_test.go
  36. streams.go
  37. streams_test.go
  38. subscriber.go
  39. subscriber_test.go
  40. version.go
  41. 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.