| commit | 7698eb91e02135df23dc1dcdfa1def247481a343 | [log] [tgz] |
|---|---|---|
| author | 冉小龙 <ranxiaolong716@gmail.com> | Fri Aug 09 18:30:23 2019 +0800 |
| committer | Jia Zhai <zhaijia@apache.org> | Fri Aug 09 18:30:23 2019 +0800 |
| tree | abea1537d3a87c7f79b414e0ff31b0754fee959f | |
| parent | dffa0553782af2f0f9dcfa37291faf298f731483 [diff] |
Fix test killed with quit: ran too long (#50)
Fixes #49
Motivation
By default, timeout exit after 10 minutes
go test --help
-timeout d
If a test binary runs longer than duration d, panic.
If d is 0, the timeout is disabled.
The default is 10 minutes (10m).
Note: this library is still a work in progress. For production usage, please refer to the CGo based client library, documented at http://pulsar.apache.org/docs/en/client-libraries-go/
This projects is developing a pure-Go client library for Pulsar that does not depend on the C++ Pulsar library.
Once feature parity and stability are reached, this will supersede the current CGo based library.
Check the Projects page at https://github.com/apache/pulsar-client-go/projects for tracking the status and the progress.
Import the client library:
import "github.com/apache/pulsar-client-go/pulsar"
client, err := pulsar.NewClient(pulsar.ClientOptions{
URL: "pulsar://localhost:6650",
})
producer, err := client.CreateProducer(pulsar.ProducerOptions{
Topic: "my-topic",
})
err = producer.Send(context.Background(), &pulsar.ProducerMessage{
Payload: []byte("hello"),
})
if err == nil {
fmt.Println("Published message")
} else {
fmt.Println("Failed to publish message", err)
}
| Name | Scope | |||
|---|---|---|---|---|
| users@pulsar.apache.org | User-related discussions | Subscribe | Unsubscribe | Archives |
| dev@pulsar.apache.org | Development-related discussions | Subscribe | Unsubscribe | Archives |
Pulsar slack channel #dev-go at https://apache-pulsar.slack.com/
You can self-register at https://apache-pulsar.herokuapp.com/
Licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0