作者:camlistor
项目:camlistor
func ExampleSubscription_Pull() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
sub := client.Subscription("subName")
it, err := sub.Pull(ctx)
if err != nil {
// TODO: Handle error.
}
// Ensure that the iterator is closed down cleanly.
defer it.Stop()
// Consume 10 messages.
for i := 0; i < 10; i++ {
m, err := it.Next()
if err == pubsub.Done {
// There are no more messages. This will happen if it.Stop is called.
break
}
if err != nil {
// TODO: Handle error.
break
}
fmt.Printf("message %d: %s\n", i, m.Data)
// Acknowledge the message.
m.Done(true)
}
}
作者:rawlings
项目:gofabric
func ExampleClient_Topics() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
it := client.Topics(ctx)
_ = it // TODO: iterate using Next.
}
作者:camlistor
项目:camlistor
func ExampleNewClient() {
ctx := context.Background()
_, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
// See the other examples to learn how to use the Client.
}
作者:camlistor
项目:camlistor
func ExampleClient_Subscriptions() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
// List all subscriptions of the project.
it := client.Subscriptions(ctx)
_ = it // See the SubscriptionIterator example for its usage.
}
作者:rawlings
项目:gofabric
func ExampleClient_Subscriptions() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
// List all subscriptions of the project.
it := client.Subscriptions(ctx)
_ = it // TODO: iterate using Next.
}
作者:GoogleCloudPlatfor
项目:golang-sample
func setup(t *testing.T) *pubsub.Client {
ctx := context.Background()
tc := testutil.SystemTest(t)
client, err := pubsub.NewClient(ctx, tc.ProjectID)
if err != nil {
t.Fatalf("failed to create client: %v", err)
}
return client
}
作者:camlistor
项目:camlistor
func ExampleClient_Topics() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
// List all topics.
it := client.Topics(ctx)
_ = it // See the TopicIterator example for its usage.
}
作者:rawlings
项目:gofabric
func ExampleSubscription_ModifyPushConfig() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
sub := client.Subscription("subName")
if err := sub.ModifyPushConfig(ctx, &pubsub.PushConfig{Endpoint: "https://example.com/push"}); err != nil {
// TODO: Handle error.
}
}
作者:camlistor
项目:camlistor
func ExampleTopic_Delete() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
topic := client.Topic("topicName")
if err := topic.Delete(ctx); err != nil {
// TODO: Handle error.
}
}
作者:camlistor
项目:camlistor
func ExampleSubscription_Delete() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
sub := client.Subscription("subName")
if err := sub.Delete(ctx); err != nil {
// TODO: Handle error.
}
}
作者:rawlings
项目:gofabric
func ExampleSubscription_Pull() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
it, err := client.Subscription("subName").Pull(ctx)
if err != nil {
// TODO: Handle error.
}
// Ensure that the iterator is closed down cleanly.
defer it.Stop()
}
作者:rawlings
项目:gofabric
func ExampleSubscription_Config() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
sub := client.Subscription("subName")
config, err := sub.Config(ctx)
if err != nil {
// TODO: Handle error.
}
fmt.Println(config)
}
作者:camlistor
项目:camlistor
func ExampleClient_NewTopic() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
// Create a new topic with the given name.
topic, err := client.CreateTopic(ctx, "topicName")
if err != nil {
// TODO: Handle error.
}
_ = topic // TODO: use the topic.
}
作者:broad
项目:with_emulator
func main() {
ctx := context.Background()
pubsubClient, err := pubsub.NewClient(ctx, "project")
if err != nil {
log.Fatalf("pubsub.NewClient: %v", err)
}
topic, err := pubsubClient.NewTopic(ctx, "topic")
if err != nil {
log.Fatalf("NewTopic: %v", err)
}
sub, err := pubsubClient.NewSubscription(ctx, "sub", topic, 0, nil)
if err != nil {
log.Fatalf("NewSubscription: %v", err)
}
if _, err := topic.Publish(ctx, &pubsub.Message{
Data: []byte("hello"),
}); err != nil {
log.Fatalf("Publish: %v", err)
}
it, err := sub.Pull(ctx)
if err != nil {
log.Fatalf("Pull: %v", err)
}
msg, err := it.Next()
if err != nil {
log.Fatalf("Next: %v", err)
}
log.Printf("pubsub message: %s", msg.Data)
msg.Done(true)
it.Stop()
datastoreClient, err := datastore.NewClient(ctx, "project")
if err != nil {
log.Fatalf("datastore.NewClient: %v", err)
}
k := datastore.NewIncompleteKey(ctx, "Foo", nil)
k, err = datastoreClient.Put(ctx, k, &Foo{F: "foo!"})
if err != nil {
log.Fatalf("Put: %v", err)
}
var f Foo
if err := datastoreClient.Get(ctx, k, &f); err != nil {
log.Fatalf("Get: %v", err)
}
log.Printf("datastore got %v", f)
}
作者:camlistor
项目:camlistor
func ExampleSubscription_Exists() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
sub := client.Subscription("subName")
ok, err := sub.Exists(ctx)
if err != nil {
// TODO: Handle error.
}
if !ok {
// Subscription doesn't exist.
}
}
作者:camlistor
项目:camlistor
func ExampleTopic_Publish() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
topic := client.Topic("topicName")
msgIDs, err := topic.Publish(ctx, &pubsub.Message{
Data: []byte("hello world"),
})
if err != nil {
// TODO: Handle error.
}
fmt.Printf("Published a message with a message ID: %s\n", msgIDs[0])
}
作者:camlistor
项目:camlistor
func ExampleTopic_Exists() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
topic := client.Topic("topicName")
ok, err := topic.Exists(ctx)
if err != nil {
// TODO: Handle error.
}
if !ok {
// Topic doesn't exist.
}
}
作者:GoogleCloudPlatfor
项目:golang-sample
func main() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, mustGetenv("GCLOUD_PROJECT"))
if err != nil {
log.Fatal(err)
}
// Create topic if it doesn't exist.
topic, _ = client.CreateTopic(ctx, mustGetenv("PUBSUB_TOPIC"))
http.HandleFunc("/", listHandler)
http.HandleFunc("/pubsub/publish", publishHandler)
http.HandleFunc("/pubsub/push", pushHandler)
appengine.Main()
}
作者:rawlings
项目:gofabric
func ExampleMessageIterator_Stop_defer() {
// If all uses of the iterator occur within the lifetime of a single
// function, stop it with defer.
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
it, err := client.Subscription("subName").Pull(ctx)
if err != nil {
// TODO: Handle error.
}
// Ensure that the iterator is closed down cleanly.
defer it.Stop()
// TODO: Use the iterator (see the example for MessageIterator.Next).
}
作者:camlistor
项目:camlistor
func ExampleTopic_Subscriptions() {
ctx := context.Background()
client, err := pubsub.NewClient(ctx, "project-id")
if err != nil {
// TODO: Handle error.
}
topic := client.Topic("topic-name")
// List all subscriptions of the topic (maybe of multiple projects).
for subs := topic.Subscriptions(ctx); ; {
sub, err := subs.Next()
if err == pubsub.Done {
break
}
if err != nil {
// TODO: Handle error.
}
_ = sub // TODO: use the subscription.
}
}