Package pstest provides a fake Cloud PubSub service for testing. It implements asimplified form of the service, suitable for unit tests. It may behavedifferently from the actual service in ways in which the service isnon-deterministic or unspecified: timing, delivery order, etc.

This package is EXPERIMENTAL and is subject to change without notice.

See the example for usage.

ResetMinAckDeadline resets the minack deadline to the default.

SetMinAckDeadline changes the minack deadline to n. Must begreater than or equal to 1 second. Remember to reset this valueto the default after your test changes it. Example usage:

pstest.SetMinAckDeadlineSecs(1)defer pstest.ResetMinAckDeadlineSecs()

ValidateFilter validates if the filter string is parsable.

GServer is the underlying service implementor. It is not intended to be useddirectly.

Acknowledge marks the message as acknowleged.

CommitSchema commits a new schema revision.

CreateSchema creates a new schema.

CreateSubscription creates a Pub/Sub subscription.

CreateTopic creates a topic.

DeleteSchema deletes an existing schema.

DeleteSchemaRevision deletes a schema revision.

DeleteSubscription deletes the Pub/Sub subscription.

DeleteTopic deletes the topic.

DetachSubscription detaches the subscription from the topic.

GetSchema gets an existing schema details.

GetSubscription fetches an existing Pub/Sub subscription details.

GetTopic gets a Pub/Sub topic.

ListSchemaRevisions lists the schema revisions.

ListSchemas lists the available schemas in this server.

ListSubscriptions lists the Pub/Sub subscriptions in this server.

ListTopicSubscriptions lists the subscriptions associated with a topic.

ListTopics lists the topics in this server.

ModifyAckDeadline modifies the ack deadline of the message.

Publish sends a message to the topic.

Pull returns a list of unacknowledged messages from a subscription.

RollbackSchema rolls back the current schema to a previous revision by copying and creating a new revision.

Seek updates a subscription to a specific point in time or snapshot.

StreamingPull return a stream to pull messages from a subscription.

UpdateSubscription updates an existing Pub/Sub subscription.

UpdateTopic updates the Pub/Sub topic.

ValidateMessage mocks the ValidateMessage call but only checks that the schema definition to validate themessage against is not empty.

ValidateSchema mocks the ValidateSchema call but only checks that the schema definition is not empty.

A Message is a message that was published to the server.

Modack represents a modack sent to the server.

Reactor is an interface to allow reaction function to a certain call.

ReactorOptions is a map that Server uses to look up reactors.Key is the function name, value is array of reactor for the function.

Server is a fake Pub/Sub server.

NewServer creates a new fake server running in the current process.

NewServerWithAddress creates a new fake server running in the current processat the specified address (host and port).

NewServerWithCallback creates new fake server running in the current processat the specified port. Before starting the server, the provided callback iscalled to allow caller to register additional fakes into grpc server.

NewServerWithPort creates a new fake server running in the current process atthe specified port.

AddPublishResponse adds a new publish response to the channel used forresponding to publish requests.

ClearMessages removes all published messagesfrom internal containers.

Close shuts down the server and releases all resources.

Message returns the message with the given ID, or nil if no messagewith that ID was published.

Messages returns information about all messages ever published.

Publish behaves as if the Publish RPC was called with a message with the givendata and attrs. It returns the ID of the message.The topic will be created if it doesn't exist.

Publish panics if there is an error, which is appropriate for testing.

PublishOrdered behaves as if the Publish RPC was called with a message with the givendata, attrs and ordering key. It returns the ID of the message.The topic will be created if it doesn't exist.

PublishOrdered panics if there is an error, which is appropriate for testing.

ResetPublishResponses resets the buffered publishResponses channelwith a new buffered channel with the given size.

SetAutoPublishResponse controls whether to automatically respondto messages published or to use user-added responses from thepublishResponses channel.

SetStreamTimeout sets the amount of time a stream will be active before it shutsitself down. This mimics the real service's behavior of closing streams after 30minutes. If SetStreamTimeout is never called or is passed zero, streams never shutdown.

SetTimeNowFunc registers f as a function tobe used instead of time.Now for this server.

Wait blocks until all server activity has completed.

ServerReactorOption is options passed to the server for reactor creation.

WithErrorInjection creates a ServerReactorOption that injects error with defined status code andmessage for a certain function.