- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for fmt (0.14 sec)
-
docs/bucket/notifications/README.md
package main // Import Go and NATS packages import ( "fmt" "runtime" "github.com/nats-io/stan.go" ) func main() { var stanConnection stan.Conn subscribe := func() { fmt.Printf("Subscribing to subject 'bucketevents'\n") stanConnection.Subscribe("bucketevents", func(m *stan.Msg) { // Handle the message fmt.Printf("Received a message: %s\n", string(m.Data)) }) }
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
internal/grid/README.md
Sample handler: ```go handler := func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr { fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context)) fmt.Println("Subroute:", GetSubroute(ctx)) for { select { case <-ctx.Done(): return nil case req, ok := <-in:
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
docs/lambda/README.md
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 04 19:15:28 GMT 2023 - 7.6K bytes - Viewed (0)