Skip to content

Commit b122859

Browse files
committed
feat: adding ping
1 parent b629b13 commit b122859

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

client/client.go

+6
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,12 @@ func (c *Client) Close() error {
2121
return c.conn.Close()
2222
}
2323

24+
func (c *Client) PingChrono() error {
25+
if response, err := c.conn.Execute("PING"); err != nil || response != "OK" {
26+
return fmt.Errorf("ping failed: %v", err)
27+
}
28+
return nil
29+
}
2430
func (c *Client) CreateStream(chrono string, stream string) error {
2531
if response, err := c.conn.Execute("CREATE STREAM " + stream); err != nil || response != "OK" {
2632
return fmt.Errorf("create failed: %v", err)

0 commit comments

Comments
 (0)