ErrorEqual compares two errors for equivalence.

ErrorHasCode returns true if an error has the desired canonical code.

ErrorHasMsg returns true if an error message contains the desired substring.

MakeAny packs a message into an Any proto.

NewCondition creates a new condition.

NewDuplicateMsgDetector creates a new DuplicateMsgDetector.

NewMsgTracker creates a new message tracker.

NewOrderingReceiver creates a new OrderingReceiver.

NewOrderingSender creats a new OrderingSender.

NewRPCVerifier creates a new verifier for requests received by the server.

NewServer creates a new mock Pub/Sub Lite server.

NewVerifiers creates a new instance of Verifiers for a test.

RandomLiteZone chooses a random Pub/Sub Lite zone for integration tests.

Barrier is used to perform two-way synchronization betwen the server and client (test) to ensure tests are deterministic.

Condition allows tests to wait for some event to occur, or check that it has not occurred.

DuplicateMsgDetector can be used to detect duplicate messages, either due to duplicate publishes or receives.

FakeSource is a fake source that returns a configurable constant.

MsgTracker is a helper for checking whether a set of messages make a full round trip from publisher to subscriber.

OrderingReceiver consumes a message string generated by OrderingSender and verifies that messages in a partition are ordered.

OrderingSender generates strings containing a message index to use for verifying message ordering.

RPCVerifier stores an queue of requests expected from the client, and the corresponding response or error to return.

Server is a mock Pub/Sub Lite server that can be used for unit testing.

Verifiers contains RPCVerifiers for unary RPCs and streaming RPCs.

MockServer is an in-memory mock implementation of a Pub/Sub Lite service, which allows unit tests to inspect requests received by the server and send fake responses.