-
Notifications
You must be signed in to change notification settings - Fork 218
/
main.go
54 lines (47 loc) · 1.45 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
/*
Copyright 2021 The CloudEvents Authors
SPDX-License-Identifier: Apache-2.0
*/
package main
import (
"context"
cloudevents "github.com/cloudevents/sdk-go/v2"
"github.com/cloudevents/sdk-go/v2/protocol/gochan"
"log"
"time"
)
func main() {
c, err := cloudevents.NewClient(gochan.New(), cloudevents.WithTimeNow(), cloudevents.WithUUIDs())
if err != nil {
log.Fatalf("failed to create client: %v", err)
}
ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(time.Millisecond*50)) // wait
// Start the receiver
go func() {
if err := c.StartReceiver(ctx, func(ctx context.Context, event cloudevents.Event) {
log.Printf("[receiver] %s", event)
}); err != nil && err.Error() != "context deadline exceeded" {
log.Fatalf("[receiver] start receiver returned an error: %s", err)
}
log.Println("[receiver] stopped")
}()
// Start sending the events
for i := 0; i < 10; i++ {
e := cloudevents.NewEvent()
e.SetType("com.cloudevents.sample.sent")
e.SetSource("https://github.com/cloudevents/sdk-go/v2/samples/gochan")
_ = e.SetData(cloudevents.ApplicationJSON, map[string]interface{}{
"id": i,
"message": "Hello, World!",
})
if res := c.Send(ctx, e); cloudevents.IsUndelivered(res) {
log.Printf("[sender] failed to send: %v", res)
} else {
log.Printf("[sender] sent: %d, accepted: %t", i, cloudevents.IsACK(res))
}
}
// Wait for the timeout.
<-ctx.Done()
cancel()
log.Println("[sender] stopped")
}