From 1a221d4d37f4bdee1fb45141828e201948e8ddd3 Mon Sep 17 00:00:00 2001 From: hozan23 Date: Sat, 15 Jun 2024 05:46:08 +0200 Subject: fix typos --- example_test.go | 70 --------------------------------------------------------- 1 file changed, 70 deletions(-) delete mode 100644 example_test.go (limited to 'example_test.go') diff --git a/example_test.go b/example_test.go deleted file mode 100644 index ca4a642..0000000 --- a/example_test.go +++ /dev/null @@ -1,70 +0,0 @@ -package karyongo - -import ( - "encoding/json" - "math/rand/v2" - "os" - "time" - - rpc "github.com/karyontech/karyon-go/jsonrpc/client" - log "github.com/sirupsen/logrus" -) - -type Pong struct{} - -func runNewClient() error { - config := rpc.RPCClientConfig{ - Addr: "ws://127.0.0.1:6000", - } - - client, err := rpc.NewRPCClient(config) - if err != nil { - return err - } - defer client.Close() - - subID, ch, err := client.Subscribe("Calc.log_subscribe", nil) - if err != nil { - return err - } - log.Infof("Subscribed successfully: %d\n", subID) - - go func() { - for notification := range ch { - log.Infof("Receive new notification: %s\n", notification) - } - }() - - for { - millisecond := rand.IntN(2000-500) + 500 - time.Sleep(time.Duration(millisecond) * time.Millisecond) - result, err := client.Call("Calc.ping", nil) - if err != nil { - return err - } - - pongMsg := Pong{} - err = json.Unmarshal(*result, &pongMsg) - if err != nil { - return err - } - } - -} - -func main() { - lvl, ok := os.LookupEnv("LOG_LEVEL") - if !ok { - lvl = "debug" - } - ll, err := log.ParseLevel(lvl) - if err != nil { - ll = log.DebugLevel - } - log.SetLevel(ll) - - err = runNewClient() - if err != nil { - log.Fatal(err) - } -} -- cgit v1.2.3