func (s *StatsRPC) GetStats(req StatsRequest, resp *StatsResponse) error {
if !s.serviceAvailable() {
- log.Println(statsErrorMsg)
+ log.Print(statsErrorMsg)
return errors.New("server does not support 'get stats' at this time, try again later")
}
log.Debugf("StatsRPC.GetStats - REQ: %+v", req)
func (s *BinapiRPC) NewAPIStream(req RPCStreamReqResp, resp *RPCStreamReqResp) error {
if !s.serviceAvailable() {
- log.Println(binapiErrorMsg)
+ log.Print(binapiErrorMsg)
return errors.New("server does not support RPC calls at this time, try again later")
}
log.Debugf("BinapiRPC.NewAPIStream - REQ: %#v", req)
func (s *BinapiRPC) SendMessage(req RPCStreamReqResp, resp *RPCStreamReqResp) error {
if !s.serviceAvailable() {
- log.Println(binapiErrorMsg)
+ log.Print(binapiErrorMsg)
return errors.New("server does not support RPC calls at this time, try again later")
}
log.Debugf("BinapiRPC.SendMessage - REQ: %#v", req)
func (s *BinapiRPC) ReceiveMessage(req RPCStreamReqResp, resp *RPCStreamReqResp) error {
if !s.serviceAvailable() {
- log.Println(binapiErrorMsg)
+ log.Print(binapiErrorMsg)
return errors.New("server does not support RPC calls at this time, try again later")
}
log.Debugf("BinapiRPC.ReceiveMessage - REQ: %#v", req)
func (s *BinapiRPC) CloseStream(req RPCStreamReqResp, resp *RPCStreamReqResp) error {
if !s.serviceAvailable() {
- log.Println(binapiErrorMsg)
+ log.Print(binapiErrorMsg)
return errors.New("server does not support RPC calls at this time, try again later")
}
log.Debugf("BinapiRPC.CloseStream - REQ: %#v", req)
func (s *BinapiRPC) Invoke(req BinapiRequest, resp *BinapiResponse) error {
if !s.serviceAvailable() {
- log.Println(binapiErrorMsg)
+ log.Print(binapiErrorMsg)
return errors.New("server does not support 'invoke' at this time, try again later")
}
log.Debugf("BinapiRPC.Invoke - REQ: %#v", req)
func (s *BinapiRPC) Compatibility(req BinapiCompatibilityRequest, resp *BinapiCompatibilityResponse) error {
if !s.serviceAvailable() {
- log.Println(binapiErrorMsg)
+ log.Print(binapiErrorMsg)
return errors.New("server does not support 'compatibility check' at this time, try again later")
}
log.Debugf("BinapiRPC.Compatiblity - REQ: %#v", req)