Function newHeartbeatReq

heartbeat.go:24–50

(r *Request)

}

func newHeartbeatReq(r *Request) (*heartbeatReq, error) {
	if r.Args == nil {
		return nil, errors.New("empty heartbeat request")
	}

	args, err := r.Args.SliceOfLength(2)
	if err != nil {
		return nil, err
	}

	d, err := args[0].Float64()
	if err != nil {
		return nil, err
	}

	ping, err := args[1].Function()
	if err != nil {
		return nil, err
	}

	return &heartbeatReq{
		interval: time.Duration(d) * time.Second,
		ping: func() error {
			return ping.Call()
		},
	}, nil
}

func (k *Kite) processHeartbeats() {
	var (