aboutsummaryrefslogtreecommitdiff
path: root/example_test.go
diff options
context:
space:
mode:
authorhozan23 <hozan23@karyontech.net>2024-06-15 05:46:08 +0200
committerhozan23 <hozan23@karyontech.net>2024-06-15 05:46:08 +0200
commit1a221d4d37f4bdee1fb45141828e201948e8ddd3 (patch)
treea6ed1a19e98c336bc598d4bfe97fe3965d14e2c8 /example_test.go
parente9af9bc115e0869570b9b79e1610b2bc08abe5a1 (diff)
fix typos
Diffstat (limited to 'example_test.go')
-rw-r--r--example_test.go70
1 files changed, 0 insertions, 70 deletions
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)
- }
-}