Name | Date | Size | #Lines | LOC | ||
---|---|---|---|---|---|---|
.. | 01-Mar-2021 | - | ||||
apiv1/ | H | 01-Mar-2021 | - | 5,065 | 3,760 | |
internal/ | H | 01-Mar-2021 | - | 2,047 | 1,418 | |
loadtest/ | H | 01-Mar-2021 | - | 1,249 | 948 | |
pstest/ | H | 01-Mar-2021 | - | 2,288 | 1,864 | |
testdata/ | H | 01-Mar-2021 | - | 10,005 | 10,002 | |
CHANGES.md | H A D | 01-Mar-2021 | 4.8 KiB | 118 | 70 | |
README.md | H A D | 01-Mar-2021 | 1.3 KiB | 47 | 39 | |
debug.go | H A D | 01-Mar-2021 | 1.5 KiB | 73 | 48 | |
doc.go | H A D | 01-Mar-2021 | 5.6 KiB | 141 | 1 | |
example_subscription_iterator_test.go | H A D | 01-Mar-2021 | 1.3 KiB | 55 | 31 | |
example_test.go | H A D | 01-Mar-2021 | 12.3 KiB | 480 | 336 | |
example_topic_iterator_test.go | H A D | 01-Mar-2021 | 1.2 KiB | 54 | 31 | |
flow_controller.go | H A D | 01-Mar-2021 | 4.1 KiB | 137 | 89 | |
flow_controller_test.go | H A D | 01-Mar-2021 | 6.4 KiB | 257 | 196 | |
go.mod | H A D | 01-Mar-2021 | 650 | 21 | 18 | |
go.sum | H A D | 01-Mar-2021 | 43.3 KiB | 441 | 440 | |
go_mod_tidy_hack.go | H A D | 01-Mar-2021 | 917 | 23 | 2 | |
integration_test.go | H A D | 01-Mar-2021 | 48.2 KiB | 1,728 | 1,454 | |
iterator.go | H A D | 01-Mar-2021 | 18.3 KiB | 589 | 420 | |
iterator_test.go | H A D | 01-Mar-2021 | 12.1 KiB | 403 | 305 | |
message.go | H A D | 01-Mar-2021 | 3.6 KiB | 128 | 77 | |
mock_test.go | H A D | 01-Mar-2021 | 4.7 KiB | 203 | 162 | |
nodebug.go | H A D | 01-Mar-2021 | 747 | 26 | 5 | |
pstest_test.go | H A D | 01-Mar-2021 | 2.5 KiB | 96 | 66 | |
pubsub.go | H A D | 01-Mar-2021 | 3.7 KiB | 123 | 78 | |
pullstream.go | H A D | 01-Mar-2021 | 5.9 KiB | 197 | 149 | |
pullstream_test.go | H A D | 01-Mar-2021 | 3.7 KiB | 140 | 108 | |
service.go | H A D | 01-Mar-2021 | 2.5 KiB | 87 | 55 | |
snapshot.go | H A D | 01-Mar-2021 | 5.2 KiB | 161 | 95 | |
streaming_pull_test.go | H A D | 01-Mar-2021 | 13 KiB | 468 | 393 | |
subscription.go | H A D | 01-Mar-2021 | 33.6 KiB | 970 | 579 | |
subscription_test.go | H A D | 01-Mar-2021 | 10.4 KiB | 402 | 350 | |
timeout_test.go | H A D | 01-Mar-2021 | 2.3 KiB | 95 | 70 | |
topic.go | H A D | 01-Mar-2021 | 19.3 KiB | 592 | 360 | |
topic_test.go | H A D | 01-Mar-2021 | 7.4 KiB | 310 | 253 | |
trace.go | H A D | 01-Mar-2021 | 9.9 KiB | 239 | 124 |
README.md
1## Cloud Pub/Sub [![Go Reference](https://pkg.go.dev/badge/cloud.google.com/go/pubsub.svg)](https://pkg.go.dev/cloud.google.com/go/pubsub) 2 3- [About Cloud Pubsub](https://cloud.google.com/pubsub/) 4- [API documentation](https://cloud.google.com/pubsub/docs) 5- [Go client documentation](https://pkg.go.dev/cloud.google.com/go/pubsub) 6- [Complete sample programs](https://github.com/GoogleCloudPlatform/golang-samples/tree/master/pubsub) 7 8### Example Usage 9 10First create a `pubsub.Client` to use throughout your application: 11 12[snip]:# (pubsub-1) 13```go 14client, err := pubsub.NewClient(ctx, "project-id") 15if err != nil { 16 log.Fatal(err) 17} 18``` 19 20Then use the client to publish and subscribe: 21 22[snip]:# (pubsub-2) 23```go 24// Publish "hello world" on topic1. 25topic := client.Topic("topic1") 26res := topic.Publish(ctx, &pubsub.Message{ 27 Data: []byte("hello world"), 28}) 29// The publish happens asynchronously. 30// Later, you can get the result from res: 31... 32msgID, err := res.Get(ctx) 33if err != nil { 34 log.Fatal(err) 35} 36 37// Use a callback to receive messages via subscription1. 38sub := client.Subscription("subscription1") 39err = sub.Receive(ctx, func(ctx context.Context, m *pubsub.Message) { 40 fmt.Println(m.Data) 41 m.Ack() // Acknowledge that we've consumed the message. 42}) 43if err != nil { 44 log.Println(err) 45} 46``` 47