Function EncodeProbePayload

internal/protocol/protocol.go:27–35

(clientVersion string)

}

func EncodeProbePayload(clientVersion string) []byte {
	probe := VersionProbe{
		Type:          "version_probe",
		ClientVersion: clientVersion,
		Protocol:      ProtocolVersion,
	}
	b, _ := json.Marshal(probe)
	return append([]byte(ProbePrefix+"|"), b...)
}

func IsProbePayload(payload []byte) bool {
	return bytes.HasPrefix(payload, []byte(ProbePrefix+"|")) || bytes.Equal(payload, []byte(ProbePrefix))