in class_mappings.go [88:126]
func responseFromClassName(className string) (proto.Message, error) {
simplifiedClassName := strings.Replace(className, wireMessageResponsePrefix, "", 1)
switch simplifiedClassName {
case "CloseConnectionResponse":
return &avaticaMessage.CloseConnectionResponse{}, nil
case "CloseStatementResponse":
return &avaticaMessage.CloseStatementResponse{}, nil
case "CommitResponse":
return &avaticaMessage.CommitResponse{}, nil
case "ConnectionSyncResponse":
return &avaticaMessage.ConnectionSyncResponse{}, nil
case "CreateStatementResponse":
return &avaticaMessage.CreateStatementResponse{}, nil
case "DatabasePropertyResponse":
return &avaticaMessage.DatabasePropertyResponse{}, nil
case "ErrorResponse":
return &avaticaMessage.ErrorResponse{}, nil
case "ExecuteResponse":
return &avaticaMessage.ExecuteResponse{}, nil
case "ExecuteBatchResponse":
return &avaticaMessage.ExecuteBatchResponse{}, nil
case "FetchResponse":
return &avaticaMessage.FetchResponse{}, nil
case "OpenConnectionResponse":
return &avaticaMessage.OpenConnectionResponse{}, nil
case "PrepareResponse":
return &avaticaMessage.PrepareResponse{}, nil
case "ResultSetResponse":
return &avaticaMessage.ResultSetResponse{}, nil
case "RollbackResponse":
return &avaticaMessage.RollbackResponse{}, nil
case "SyncResultsResponse":
return &avaticaMessage.SyncResultsResponse{}, nil
default:
return nil, fmt.Errorf("unable to create response from the string: %s", className)
}
}